diff --git a/bridge_master.py b/bridge_master.py index c6c8a08..c8bc149 100644 --- a/bridge_master.py +++ b/bridge_master.py @@ -550,7 +550,9 @@ def sendVoicePacket(self,pkt,_source_id,_dest_id,_slot): 'CONTENTION':False, 'RFS': _source_id, 'TGID': _dest_id, - 'LAST': _pkt_time + 'LAST': _pkt_time, + 'source_server': False, + 'source_rptr': False } _slot['TX_TGID'] = _dest_id else: @@ -1547,8 +1549,8 @@ class routerOBP(OPENBRIDGE): 'RX_PEER': _peer_id, 'packets': 0, 'crcs': set(), - '_source_server' : _source_server, - '_source_rptr' : _source_rptr + 'source_server' : _source_server, + 'source_rptr' : _source_rptr } @@ -1696,8 +1698,8 @@ class routerOBP(OPENBRIDGE): 'packets': 0, 'loss': 0, 'crcs': set(), - '_source_server' : _source_server, - '_source_rptr' : _source_rptr + 'source_server' : _source_server, + 'source_rptr' : _source_rptr } @@ -1978,8 +1980,8 @@ class routerHBP(HBSYSTEM): 'RFS': _rf_src, 'TGID': _dst_id, 'RX_PEER': _peer_id, - '_source_server' : _source_server, - '_source_rptr' : _source_rptr + 'source_server' : _source_server, + 'source_rptr' : _source_rptr } # Generate LCs (full and EMB) for the TX stream dst_lc = b''.join([self.STATUS[_slot]['RX_LC'][0:3], _target['TGID'], _rf_src]) @@ -2139,8 +2141,8 @@ class routerHBP(HBSYSTEM): 'RFS': _rf_src, 'TGID': _dst_id, 'RX_PEER': _peer_id, - '_source_server' : _source_server, - '_source_rptr' : _source_rptr + 'source_server' : _source_server, + 'source_rptr' : _source_rptr } # Record the time of this packet so we can later identify a stale stream