BOSWatch/BW3-Core
1
0
Fork 0
mirror of https://github.com/BOSWatch/BW3-Core.git synced 2026-04-05 14:25:45 +00:00
Code Issues Projects Releases Packages Wiki Activity

move decoding to InputBase.addToQueue()

Browse source
This commit is contained in:
Schrolli91 2021-01-08 21:39:41 +01:00
parent a697564294
commit f3f188f93b
No known key found for this signature in database
GPG key ID: 0AE96912A20E9F5F
2 changed files with 7 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

10
boswatch/inputSource/inputBase.py
View file

@ -20,6 +20,7 @@ import threading
from abc import ABC, abstractmethod
from boswatch.utils import paths
from boswatch.processManager import ProcessManager
from boswatch.decoder.decoder import Decoder
logging.debug("- %s loaded", __name__)
@ -61,10 +62,11 @@ class InputBase(ABC):
logging.debug("input thread stopped")
def addToQueue(self, data):
"""!Adds alarm data to the queue for further processing during boswatch client"""
self._inputQueue.put_nowait((data, time.time()))
logging.debug("Add received data to queue")
print(data)
"""!Decode and add alarm data to the queue for further processing during boswatch client"""
bwPacket = Decoder.decode(data)
if bwPacket is not None:
self._inputQueue.put_nowait((bwPacket, time.time()))
logging.debug("Added received data to queue")
def getDecoderInstance(self, decoderConfig, StdIn):
mmProc = ProcessManager(str(decoderConfig.get("path", default="multimon-ng")), textMode=True)