third-party-mirrors/EDDN
1
0
Fork 0
mirror of https://github.com/EDCD/EDDN.git synced 2025-04-25 04:40:53 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Monitor: python3 tweaks

Browse Source 
* setsockopt_string()
* Trying to see what's up with:

Traceback (most recent call last):
  File "src/gevent/greenlet.py", line 906, in gevent._gevent_cgreenlet.Greenlet.run
  File "/home/eddn/dev/python3.9-venv/lib/python3.9/site-packages/eddn-2.0a0.dev0-py3.9.egg/eddn/Monitor.py", line 203, in monitor_worker
    message_text = zlib.decompress(message)
zlib.error: Error -3 while decompressing data: incorrect header check
2021-11-04T18:25:03Z <Greenlet at 0x7f71dbecf150: monitor_worker(b'\'https://eddn.edcd.io/schemas/journal/1\' |-| b)> failed with error
This commit is contained in:
Athanasius 2021-11-04 18:26:44 +00:00
parent f7370a2f0b
commit cc19d390ce
No known key found for this signature in database
GPG Key ID: 8C392035DD80FD62
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/eddn/Monitor.py
View File

@ -198,7 +198,7 @@ class Monitor(Thread):
context = zmq.Context() context = zmq.Context()
receiver = context.socket(zmq.SUB) receiver = context.socket(zmq.SUB)
receiver.setsockopt(zmq.SUBSCRIBE, '') receiver.setsockopt_string(zmq.SUBSCRIBE, '')
for binding in Settings.MONITOR_RECEIVER_BINDINGS: for binding in Settings.MONITOR_RECEIVER_BINDINGS:
receiver.connect(binding) receiver.connect(binding)
@ -219,6 +219,7 @@ class Monitor(Thread):
else: else:
message = message_split[0] message = message_split[0]
print(f'message: {message}')
message_text = zlib.decompress(message) message_text = zlib.decompress(message)
json = simplejson.loads(message_text) json = simplejson.loads(message_text)