mirror of
https://github.com/craigerl/aprsd.git
synced 2024-09-27 07:36:40 -04:00
Cleaned out old ack_dict
This patch removes remnants of ack_dict from the code. The new mechanism is the MsgTrack object queue.
This commit is contained in:
parent
1697395e84
commit
dbc891f738
@ -13,11 +13,6 @@ from aprsd import client, threads, utils
|
|||||||
|
|
||||||
LOG = logging.getLogger("APRSD")
|
LOG = logging.getLogger("APRSD")
|
||||||
|
|
||||||
# message_nubmer:ack combos so we stop sending a message after an
|
|
||||||
# ack from radio {int:int}
|
|
||||||
# FIXME
|
|
||||||
ack_dict = {}
|
|
||||||
|
|
||||||
# What to return from a plugin if we have processed the message
|
# What to return from a plugin if we have processed the message
|
||||||
# and it's ok, but don't send a usage string back
|
# and it's ok, but don't send a usage string back
|
||||||
NULL_MESSAGE = -1
|
NULL_MESSAGE = -1
|
||||||
@ -240,8 +235,6 @@ class TextMessage(Message):
|
|||||||
return re.sub("fuck|shit|cunt|piss|cock|bitch", "****", message)
|
return re.sub("fuck|shit|cunt|piss|cock|bitch", "****", message)
|
||||||
|
|
||||||
def send(self):
|
def send(self):
|
||||||
global ack_dict
|
|
||||||
|
|
||||||
tracker = MsgTrack()
|
tracker = MsgTrack()
|
||||||
tracker.add(self)
|
tracker.add(self)
|
||||||
LOG.debug("Length of MsgTrack is {}".format(len(tracker)))
|
LOG.debug("Length of MsgTrack is {}".format(len(tracker)))
|
||||||
|
@ -116,7 +116,6 @@ class APRSDRXThread(APRSDThread):
|
|||||||
tracker = messaging.MsgTrack()
|
tracker = messaging.MsgTrack()
|
||||||
tracker.remove(ack_num)
|
tracker.remove(ack_num)
|
||||||
LOG.debug("Length of MsgTrack is {}".format(len(tracker)))
|
LOG.debug("Length of MsgTrack is {}".format(len(tracker)))
|
||||||
# messaging.ack_dict.update({int(ack_num): 1})
|
|
||||||
return
|
return
|
||||||
|
|
||||||
def process_mic_e_packet(self, packet):
|
def process_mic_e_packet(self, packet):
|
||||||
|
Loading…
Reference in New Issue
Block a user