Conflicts:
cappie/__init__.py
cappie/queue.py
import protocol
import queue
+import util
from errors import *
+ from events import *
def getAllInterfaces():
filters = ("lo", "any")
def run(self):
self.log.info("Starting interface %s" % self.dev)
- self.db.open()
-
+ util.setprocname("interface %s" % self.dev)
+
p = pcapy.open_live(self.dev, self.mtu, self.promisc, 0)
p.setfilter(self.filter)
#p.loop(0, self._callback)
from threading import Thread
+import util
+
+ from database import Database
from errors import *
+ from events import *
class Queue(Thread):
heartbeat = 1.0
def run(self):
self.log.debug("Started event queue")
+ util.setprocname("queue")
+
+ self.db.open()
+
while self.__running or self.__queue:
if not self.__queue:
#self.log.debug("Queue sleeping for %s seconds" % self.heartbeat)