BOSWatch/BW3-Core
1
0
Fork 0
mirror of https://github.com/BOSWatch/BW3-Core.git synced 2025-12-06 07:12:04 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix some pep8 in bw_client

Browse source
This commit is contained in:
Bastian Schroll 2019-10-22 17:31:01 +02:00
parent 0d338dc10d
commit 3cdd0297dd
No known key found for this signature in database
GPG key ID: 0AE96912A20E9F5F
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
bw_client.py
View file

@ -137,7 +137,8 @@ try:
# ========== INPUT CODE ========== # ========== INPUT CODE ==========
mmThread = threading.Thread(target=handleSDRInput, name="mmReader", args=(inputQueue, bwConfig.get("inputSource", "sdr"), bwConfig.get("decoder"))) mmThread = threading.Thread(target=handleSDRInput, name="mmReader",
args=(inputQueue, bwConfig.get("inputSource", "sdr"), bwConfig.get("decoder")))
mmThread.daemon = True mmThread.daemon = True
mmThread.start() mmThread.start()
@ -146,8 +147,9 @@ try:
while 1: while 1:
if not bwClient.isConnected: if not bwClient.isConnected:
logging.warning("connection to server lost - sleep %d seconds", bwConfig.get("client", "reconnectDelay", default="3")) reconnectDelay = bwConfig.get("client", "reconnectDelay", default="3")
time.sleep(bwConfig.get("client", "reconnectDelay", default="3")) logging.warning("connection to server lost - sleep %d seconds", reconnectDelay)
time.sleep(reconnectDelay)
bwClient.connect(ip, port) bwClient.connect(ip, port)
elif not inputQueue.empty(): elif not inputQueue.empty():
@ -169,8 +171,9 @@ try:
if bwClient.receive() == "[ack-]": if bwClient.receive() == "[ack-]":
logging.debug("ack ok") logging.debug("ack ok")
break break
logging.warning("cannot send packet - sleep %d seconds", bwConfig.get("client", "sendDelay", default="3")) sendDelay = bwConfig.get("client", "sendDelay", default="3")
time.sleep(bwConfig.get("client", "sendDelay", default="3")) logging.warning("cannot send packet - sleep %d seconds", sendDelay)
time.sleep(sendDelay)
else: else:
time.sleep(0.1) # reduce cpu load (wait 100ms) time.sleep(0.1) # reduce cpu load (wait 100ms)