Simon 3 years ago
parent d01019fa61
commit c9cb71accd

@ -563,7 +563,6 @@ def topoTrimmer():
_toprem.append(_src) _toprem.append(_src)
for _remove in _toprem: for _remove in _toprem:
TOPO.pop(_remove) TOPO.pop(_remove)
print(TOPO)
topoWrite() topoWrite()

@ -758,11 +758,11 @@ class OPENBRIDGE(DatagramProtocol):
_ver = _packet[12:13] _ver = _packet[12:13]
_hops = _packet[13:14] _hops = _packet[13:14]
if _hash == _hash2: if _hash == _hash2:
logger.trace('(%s) *ProtoControl* BCTO received: %s connected to %s with proto ver. %s',self._system, int_id(_src), int_id(_dst), int.from_bytes(_ver,'big')) logger.trace('(%s) *ProtoControl* BCTO received: %s connected to %s with proto ver. %s. HOPS: ',self._system, int_id(_src), int_id(_dst), int.from_bytes(_ver,'big'), int.from_bytes(_hops,'big')
if (int.from_bytes(_hops,'big') < 10 and _src != self._CONFIG['GLOBAL']['SERVER_ID']): if (int.from_bytes(_hops,'big') < 10 and _src != self._CONFIG['GLOBAL']['SERVER_ID']):
self.retransmit_bcto(_packet[4:13],int.from_bytes(_hops,'big')) self.retransmit_bcto(_packet[4:13],int.from_bytes(_hops,'big'))
else: else:
logger.trace('(%s) *BridgeControl* not retransmitting BCTO - hop count exceeded',self._system) logger.trace('(%s) *BridgeControl* not retransmitting BCTO - hop count exceeded or my packet',self._system)
self.process_bcto(_src,_dst,_ver) self.process_bcto(_src,_dst,_ver)
else: else:
h,p = _sockaddr h,p = _sockaddr

Loading…
Cancel
Save

Powered by TurnKey Linux.