def run()

in zktraffic/stats/loaders.py [0:0]

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

  def run(self):
    """ compute stats from queued requests """
    log.info("Starting queue stats loader ...")
    self._stopped = False

    self._timer.reset()
    while not self._stopped:
      # update stats for available requests/replies/events

      self._process_queue(self._requests, self._request_handlers)
      self._process_queue(self._replies, self._reply_handlers)
      self._process_queue(self._events, self._event_handlers)

      if self._timer.after(60):
        for accumulator in self._accumulators.values():
          accumulator.accumulate_stats()
        self._timer.reset()

      # no need to wake up immediately to process the new packets
      time.sleep(1)