sv/tsun-gen3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cleanup msg_get_time handler

Browse Source
This commit is contained in:
Stefan Allius
2023-11-17 23:20:03 +01:00
parent 690c66a13a
commit 0db2c3945d
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/src/messages.py
View File

@@ -320,6 +320,7 @@ class Message(metaclass=IterRegistry):
f' proxy-time: {ts:08x}') f' proxy-time: {ts:08x}')
elif not self.ctrl.is_ind(): elif not self.ctrl.is_ind():
self.inc_counter('Unknown_Ctrl') self.inc_counter('Unknown_Ctrl')
self.forward(self._recv_buffer, self.header_len+self.data_len)
else: else:
if self.ctrl.is_ind(): if self.ctrl.is_ind():
ts = self.__timestamp() ts = self.__timestamp()
@@ -333,10 +334,8 @@ class Message(metaclass=IterRegistry):
result = struct.unpack_from('!q', self._recv_buffer, result = struct.unpack_from('!q', self._recv_buffer,
self.header_len) self.header_len)
logger.debug(f'tsun-time: {result[0]:08x}') logger.debug(f'tsun-time: {result[0]:08x}')
return # ignore received response from tsun
else: else:
self.inc_counter('Unknown_Ctrl') self.inc_counter('Unknown_Ctrl')
self.forward(self._recv_buffer, self.header_len+self.data_len)
def parse_msg_header(self): def parse_msg_header(self):
result = struct.unpack_from('!lB', self._recv_buffer, self.header_len) result = struct.unpack_from('!lB', self._recv_buffer, self.header_len)