rt/Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2026-10-26 10:51:49 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Killed a couple of allocs, canonical HDLC frame method

Browse source
This commit is contained in:
Mark Qvist 2026-09-01 14:45:54 +02:00
parent ea98db4f53
commit eb8414bee9
No known key found for this signature in database
3 changed files with 12 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
RNS/Interfaces/BackboneInterface.py
View file

@ -1031,7 +1031,7 @@ class BackboneClientInterface(Interface):
def process_outgoing(self, data):
if self.online and not self.detached:
try:
frame = bytes([HDLC.FLAG])+HDLC.escape(data)+bytes([HDLC.FLAG])
frame = HDLC.frame(data)
if self.tx_stalled or not self.transmit_buffer.append(frame, self.tx_hwm):
self.tx_drops += 1
self.tx_dropped_bytes += len(frame)

4
RNS/Interfaces/LocalInterface.py
View file

@ -218,7 +218,7 @@ class LocalClientInterface(Interface):
if self.online:
try:
if self.epoll_backend:
frame = bytes([HDLC.FLAG])+HDLC.escape(data)+bytes([HDLC.FLAG])
frame = HDLC.frame(data)
if self.tx_stalled or not self.transmit_buffer.append(frame, self.tx_hwm):
self.tx_drops += 1
self.tx_dropped_bytes += len(frame)
@ -235,7 +235,7 @@ class LocalClientInterface(Interface):
s = len(data) / self.bitrate * 8
time.sleep(s)
data = bytes([HDLC.FLAG])+HDLC.escape(data)+bytes([HDLC.FLAG])
data = HDLC.frame(data)
self.socket.sendall(data)
self.writing = False
self.txb += len(data)

9
RNS/Interfaces/util/HDLC.py
View file

@ -50,6 +50,15 @@ class HDLC():
frame = frame.replace(HDLC.ESCPD_ESC, HDLC.ESC_B)
return frame
@staticmethod
def frame(data):
esc = HDLC.escape(data)
frame = bytearray(len(esc)+2)
frame[0] = HDLC.FLAG
frame[1:-1] = esc
frame[-1] = HDLC.FLAG
return frame
class ReceiveBuffer():
def __init__(self, mtu, min_frame_len, max_frame_len=None, on_frame=None, on_invalid=None):
self._mtu = mtu