|
|
|
|
@ -21,7 +21,6 @@ server_port_2 = os.getenv('SERVER_PORT_2')
|
|
|
|
|
PARAMS = {'split_size': 400_000, 'point_amount': 100_000}
|
|
|
|
|
PARAMS['show_amount'] = 0.8 * PARAMS['point_amount']
|
|
|
|
|
token = 0
|
|
|
|
|
channel = 1
|
|
|
|
|
flag = 0
|
|
|
|
|
|
|
|
|
|
##############################
|
|
|
|
|
@ -30,6 +29,7 @@ flag = 0
|
|
|
|
|
f_base = 1.1e9
|
|
|
|
|
f_step = 20e6
|
|
|
|
|
f_roof = 1.3e9
|
|
|
|
|
channel = f_base
|
|
|
|
|
##############################
|
|
|
|
|
# Variables
|
|
|
|
|
##############################
|
|
|
|
|
@ -96,7 +96,7 @@ def work(lvl):
|
|
|
|
|
if f >= f_roof:
|
|
|
|
|
f = f_base
|
|
|
|
|
signal_arr = []
|
|
|
|
|
channel = 1
|
|
|
|
|
channel = f
|
|
|
|
|
return f, EOCF
|
|
|
|
|
else:
|
|
|
|
|
if flag == 0 and len(signal_arr) >= PARAMS['point_amount']:
|
|
|
|
|
@ -104,11 +104,11 @@ def work(lvl):
|
|
|
|
|
signal_arr = []
|
|
|
|
|
if flag == 0:
|
|
|
|
|
f += f_step
|
|
|
|
|
channel += 1
|
|
|
|
|
channel = f
|
|
|
|
|
if len(signal_arr) >= PARAMS['split_size']:
|
|
|
|
|
send_data(signal_arr[:PARAMS['split_size']])
|
|
|
|
|
flag = 0
|
|
|
|
|
signal_arr = []
|
|
|
|
|
channel += 1
|
|
|
|
|
f += f_step
|
|
|
|
|
channel = f
|
|
|
|
|
return f, EOCF
|
|
|
|
|
|