Merge branch 'master' of git.wrede.ca:andreas/heartbeat
This commit is contained in:
@@ -331,7 +331,12 @@ def process():
|
|||||||
conn = conIds[rfh]
|
conn = conIds[rfh]
|
||||||
data, addr = ifiles[rfh].recvfrom(MAXRECV)
|
data, addr = ifiles[rfh].recvfrom(MAXRECV)
|
||||||
# if verbose: print("sock.recvfrom: %s (%s) %s" % (addr, len(data), data[:4]))
|
# if verbose: print("sock.recvfrom: %s (%s) %s" % (addr, len(data), data[:4]))
|
||||||
msgDict = stodict(data)
|
try:
|
||||||
|
msgDict = stodict(data)
|
||||||
|
except Exception as e:
|
||||||
|
print("failed to parse incoming data from %s: " % (addr, data))
|
||||||
|
continue
|
||||||
|
|
||||||
if verbose: print("sock.recvfrom: %s (%s) %s" % (addr, len(data), str(msgDict)[:80]))
|
if verbose: print("sock.recvfrom: %s (%s) %s" % (addr, len(data), str(msgDict)[:80]))
|
||||||
if msgDict == None:
|
if msgDict == None:
|
||||||
print("bad backet from %s (%s) %s" % (addr, len(data), data))
|
print("bad backet from %s (%s) %s" % (addr, len(data), data))
|
||||||
|
|||||||
Reference in New Issue
Block a user