self.promisc = promisc
self.queue = self.cappie.queue
- self.db = Database(self)
-
self.log.debug("Created new interface %s" % self.dev)
self.__running = True
for key, val in p.items():
self.log.debug(" %s: %s" % (key, val))
- if not self.db.has(p["source_address"]):
- self.db.put(p["source_address"], "SOURCE_IP_ADDRESS", p["source_ip_address"])
-
def run(self):
self.log.info("Starting interface %s" % self.dev)
- self.db.open()
-
p = pcapy.open_live(self.dev, self.mtu, self.promisc, 0)
p.setfilter(self.filter)
#p.loop(0, self._callback)
p.setnonblock(1)
while True:
if not self.__running:
- self.db.close()
return
if p.dispatch(1, self._callback):