For all proto

3 years ago · f2494aec61
parent 2f322c7fe7
commit f2494aec61
1 changed files with 6 additions and 2 deletions
--- a/hblink.py
+++ b/hblink.py
@ -418,7 +418,9 @@ class OPENBRIDGE(DatagramProtocol):
                if compare_digest(_hash, _ckhs) and (_sockaddr == self._config['TARGET_SOCK'] or self._config['RELAX_CHECKS']):
                    _peer_id = _data[11:15]
                    if self._config['NETWORK_ID'] != _peer_id:
-                        logger.error('(%s) OpenBridge packet discarded because NETWORK_ID: %s Does not match sent Peer ID: %s', self._system, int_id(self._config['NETWORK_ID']), int_id(_peer_id))
+                        if _stream_id not in self._laststrid:
+                            logger.error('(%s) OpenBridge packet discarded because NETWORK_ID: %s Does not match sent Peer ID: %s', self._system, int_id(self._config['NETWORK_ID']), int_id(_peer_id))
+                            self._laststrid.append(_stream_id)
                        return
                    _seq = _data[4]
                    _rf_src = _data[5:8]
@ -550,7 +552,9 @@ class OPENBRIDGE(DatagramProtocol):
                if compare_digest(_hash, _ckhs) and (_sockaddr == self._config['TARGET_SOCK'] or self._config['RELAX_CHECKS']):
                    _peer_id = _data[11:15]
                    if self._config['NETWORK_ID'] != _peer_id:
-                        logger.error('(%s) OpenBridge packet discarded because NETWORK_ID: %s Does not match sent Peer ID: %s', self._system, int_id(self._config['NETWORK_ID']), int_id(_peer_id))
+                        if _stream_id not in self._laststrid:
+                            logger.error('(%s) OpenBridge packet discarded because NETWORK_ID: %s Does not match sent Peer ID: %s', self._system, int_id(self._config['NETWORK_ID']), int_id(_peer_id))
+                            self._laststrid.append(_stream_id)
                        return
                    _seq = _data[4]
                    _rf_src = _data[5:8]