ThaiSDR/IDRB
1
0
Fork 0
mirror of https://github.com/damp11113/IDRB.git synced 2025-04-28 06:58:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
dharm pimsen 2024-01-29 18:44:28 +07:00
parent ed8ab5ef9f
commit b48c058852
1 changed files with 0 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
Client/client.py
View File

@ -241,7 +241,6 @@ class App:
if len(data) == 0: if len(data) == 0:
dpg.configure_item("serverstatus", default_value='lost connected', color=(255, 0, 0)) dpg.configure_item("serverstatus", default_value='lost connected', color=(255, 0, 0))
<<<<<<< Updated upstream
socket.close() socket.close()
if self.cprotocol == "TCP": if self.cprotocol == "TCP":
socket.close() socket.close()
@ -257,23 +256,6 @@ class App:
break # No more messages break # No more messages
else: else:
raise raise
=======
if self.cprotocol == "TCP":
socket.close()
elif self.cprotocol == "ZeroMQ":
while True:
try:
message = socket.recv(zmq.NOBLOCK)
if message is None:
break # No more messages
# Process the received message if needed
print(f"Received message: {message.decode()}")
except zmq.error.ZMQError as e:
if e.errno == zmq.EAGAIN:
break # No more messages
else:
raise
>>>>>>> Stashed changes
socket.close() socket.close()
else: else:
socket.close() socket.close()
@ -342,11 +324,7 @@ class App:
data = datadecoded["channel"][self.readchannel]["Content"] data = datadecoded["channel"][self.readchannel]["Content"]
if len(data) == 0: if len(data) == 0:
<<<<<<< Updated upstream
dpg.configure_item("serverstatus", default_value=f'connected but no audio', color=(255, 0, 0)) dpg.configure_item("serverstatus", default_value=f'connected but no audio', color=(255, 0, 0))
=======
dpg.configure_item("serverstatus", default_value=f'connected No audio', color=(255, 0, 0))
>>>>>>> Stashed changes
if self.ccisdecryptpassword and self.ccisencrypt: if self.ccisdecryptpassword and self.ccisencrypt:
try: try:
@ -400,7 +378,6 @@ class App:
bytesconunt_frame += 1 bytesconunt_frame += 1
else: else:
streamoutput.close() streamoutput.close()
<<<<<<< Updated upstream
if self.cprotocol == "TCP": if self.cprotocol == "TCP":
socket.close() socket.close()
elif self.cprotocol == "ZeroMQ": elif self.cprotocol == "ZeroMQ":
@ -415,24 +392,6 @@ class App:
break # No more messages break # No more messages
else: else:
raise raise
=======
socket.close()
if self.cprotocol == "TCP":
socket.close()
elif self.cprotocol == "ZeroMQ":
while True:
try:
message = socket.recv(zmq.NOBLOCK)
if message is None:
break # No more messages
# Process the received message if needed
print(f"Received message: {message.decode()}")
except zmq.error.ZMQError as e:
if e.errno == zmq.EAGAIN:
break # No more messages
else:
raise
>>>>>>> Stashed changes
socket.close() socket.close()
else: else:
socket.close() socket.close()
@ -447,7 +406,6 @@ class App:
streamoutput.close() streamoutput.close()
except: except:
pass pass
<<<<<<< Updated upstream
socket.close() socket.close()
if self.cprotocol == "TCP": if self.cprotocol == "TCP":
socket.close() socket.close()
@ -463,23 +421,6 @@ class App:
break # No more messages break # No more messages
else: else:
raise raise
=======
if self.cprotocol == "TCP":
socket.close()
elif self.cprotocol == "ZeroMQ":
while True:
try:
message = socket.recv(zmq.NOBLOCK)
if message is None:
break # No more messages
# Process the received message if needed
print(f"Received message: {message.decode()}")
except zmq.error.ZMQError as e:
if e.errno == zmq.EAGAIN:
break # No more messages
else:
raise
>>>>>>> Stashed changes
socket.close() socket.close()
else: else:
socket.close() socket.close()