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

Relay: Tweak for zmq changes

Browse Source
This commit is contained in:
Athanasius 2022-03-12 11:59:04 +00:00
parent f34bc9559c
commit 652275159d
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/eddn/Relay.py
View File

@ -27,6 +27,10 @@ import simplejson
import zmq.green as zmq
from bottle import Bottle, response
from gevent import monkey
from zmq import PUB as ZMQ_PUB
from zmq import SUB as ZMQ_SUB
from zmq import SNDHWM as ZMQ_SNDHWM
from zmq import SUBSCRIBE as ZMQ_SUBSCRIBE
from eddn.conf.Settings import Settings, load_config
@ -113,15 +117,15 @@ class Relay(Thread):
# These form the connection to the Gateway daemon(s) upstream.
context = zmq.Context()
receiver = context.socket(zmq.SUB)
receiver.setsockopt_string(zmq.SUBSCRIBE, '')
receiver = context.socket(ZMQ_SUB)
receiver.setsockopt_string(ZMQ_SUBSCRIBE, '')
for binding in Settings.RELAY_RECEIVER_BINDINGS:
# Relays bind upstream to an Announcer, or another Relay.
receiver.connect(binding)
sender = context.socket(zmq.PUB)
sender.setsockopt(zmq.SNDHWM, 500)
sender = context.socket(ZMQ_PUB)
sender.setsockopt(ZMQ_SNDHWM, 500)
for binding in Settings.RELAY_SENDER_BINDINGS:
# End users, or other relays, may attach here.