Probe I/Q server to see if it has started.
This commit is contained in:
parent
e11ccbfb1f
commit
c6b50e81f9
11
openwebrx.py
11
openwebrx.py
@ -135,7 +135,16 @@ def main():
|
||||
rtl_thread=threading.Thread(target = lambda:subprocess.Popen(cfg.start_rtl_command, shell=True), args=())
|
||||
rtl_thread.start()
|
||||
print "[openwebrx-main] Started rtl_thread: "+cfg.start_rtl_command
|
||||
time.sleep(1) #wait until it really starts
|
||||
print "[openwebrx-main] Waiting for I/Q server to start..."
|
||||
while True:
|
||||
testsock=socket.socket()
|
||||
try: testsock.connect(("127.0.0.1", cfg.iq_server_port))
|
||||
except:
|
||||
time.sleep(0.1)
|
||||
continue
|
||||
testsock.close()
|
||||
break
|
||||
print "[openwebrx-main] I/Q server started."
|
||||
|
||||
#Initialize clients
|
||||
clients=[]
|
||||
|
@ -56,7 +56,7 @@ class dsp_plugin:
|
||||
if self.csdr_through: any_chain_base+="csdr through | "
|
||||
any_chain_base+=self.format_conversion+(" | " if self.format_conversion!="" else "") ##"csdr flowcontrol {flowcontrol} auto 1.5 10 | "
|
||||
if which == "fft":
|
||||
fft_chain_base = "sleep 1; "+any_chain_base+"csdr fft_cc {fft_size} {fft_block_size} | csdr logpower_cf -70 | csdr fft_exchange_sides_ff {fft_size}"
|
||||
fft_chain_base = any_chain_base+"csdr fft_cc {fft_size} {fft_block_size} | csdr logpower_cf -70 | csdr fft_exchange_sides_ff {fft_size}"
|
||||
if self.fft_compression=="adpcm":
|
||||
return fft_chain_base+" | csdr compress_fft_adpcm_f_u8 {fft_size}"
|
||||
else:
|
||||
|
Loading…
Reference in New Issue
Block a user