ShaYmez/RYSEN
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

CONFIG not config

Browse Source
This commit is contained in:
Simon 2021-05-02 17:11:50 +01:00
parent 45e10a9472
commit 190e17b50e
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bridge_master.py
View File

@ -362,7 +362,7 @@ def kaReporting():
for system in systems: for system in systems:
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE': if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
if '_bcka' in CONFIG['SYSTEMS'][system] and CONFIG['SYSTEMS'][system]['_bcka'] < time() - 60: if '_bcka' in CONFIG['SYSTEMS'][system] and CONFIG['SYSTEMS'][system]['_bcka'] < time() - 60:
logger.warning('(ROUTER) not sending to system %s as last keepalive was %s ago',system, config['SYSTEMS'][system]['_bcka'] - time()) logger.warning('(ROUTER) not sending to system %s as last keepalive was %s ago',system, CONFIG['SYSTEMS'][system]['_bcka'] - time())
# run this every 10 seconds to trim orphaned stream ids # run this every 10 seconds to trim orphaned stream ids
def stream_trimmer_loop(): def stream_trimmer_loop():

2
hblink.py
View File

@ -144,7 +144,7 @@ class OPENBRIDGE(DatagramProtocol):
_packet = BCKA _packet = BCKA
_packet = b''.join([_packet[:4], (hmac_new(self._config['PASSPHRASE'],_packet,sha1).digest())]) _packet = b''.join([_packet[:4], (hmac_new(self._config['PASSPHRASE'],_packet,sha1).digest())])
self.transport.write(_packet, (self._config['TARGET_IP'], self._config['TARGET_PORT'])) self.transport.write(_packet, (self._config['TARGET_IP'], self._config['TARGET_PORT']))
logger.debug('(%s) *BridgeControl* sent Keep Alive',self._system) logger.debug('(%s) *BridgeControl* sent KeepAlive',self._system)
def send_bcsq(self,_tgid,_stream_id): def send_bcsq(self,_tgid,_stream_id):
_packet = b''.join([BCSQ, _tgid, _stream_id]) _packet = b''.join([BCSQ, _tgid, _stream_id])