import queue
from errors import *
+from events import *
def getAllInterfaces():
filters = ("lo", "any")
for key, val in p.items():
self.log.debug(" %s: %s" % (key, val))
+ self._handlePacket(p)
+
def run(self):
self.log.info("Starting interface %s" % self.dev)
def addEvent(self, event):
return self.cappie.queue.add(event)
+
+ def _handlePacket(self, packet):
+ if packet.operation == OPERATION_RESPONSE:
+ self.addEvent(EventResponseTrigger(self, packet))
+ #self.addEvent(EventCheckDuplicate(self, packet))
+
+ elif packet.operation == OPERATION_REQUEST:
+ self.addEvent(EventRequestTrigger(self, packet))