From 53fd7d33da2e486eaa0a1d02ead61d544112ed8c Mon Sep 17 00:00:00 2001 From: Michael Tremer Date: Thu, 29 Apr 2010 16:40:12 +0200 Subject: [PATCH] Remove database instance from each interface thread. --- cappie/__init__.py | 8 -------- 1 file changed, 8 deletions(-) diff --git a/cappie/__init__.py b/cappie/__init__.py index 5e5a10a..01737d1 100644 --- a/cappie/__init__.py +++ b/cappie/__init__.py @@ -139,8 +139,6 @@ class Interface(Thread): self.promisc = promisc self.queue = self.cappie.queue - self.db = Database(self) - self.log.debug("Created new interface %s" % self.dev) self.__running = True @@ -160,14 +158,9 @@ class Interface(Thread): 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) @@ -175,7 +168,6 @@ class Interface(Thread): p.setnonblock(1) while True: if not self.__running: - self.db.close() return if p.dispatch(1, self._callback): -- 2.47.3