def run()

in zktraffic/network/sniffer.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

  def run(self, *args, **kwargs):
    pfilter = "port %d" % self._port
    try:
      sniff_kwargs = {"filter": pfilter, "store": 0, "prn": self.handle_packet}
      if self._iface != "any":
        sniff_kwargs["iface"] = self._iface

      if "offline" in kwargs:
        sniff_kwargs["offline"] = kwargs["offline"]

      sniff(**sniff_kwargs)
    except socket.error as ex:
      sys.stderr.write("Error: %s, device: %s\n" % (ex, self._iface))
    finally:
      if "offline" not in kwargs:
        os.kill(os.getpid(), signal.SIGINT)