grr/server/grr_response_server/databases/mysql_flows.py
def _FlowProcessingRequestHandlerLoop(self, handler):
    """The main loop for the flow processing request queue."""
    while not self.flow_processing_request_handler_stop:
      try:
        msgs = self._LeaseFlowProcessingReqests()
        if msgs:
          for m in msgs:
            self.flow_processing_request_handler_pool.AddTask(
                target=handler, args=(m,))
        else:
          time.sleep(5)

      except Exception as e:  # pylint: disable=broad-except
        logging.exception("_FlowProcessingRequestHandlerLoop raised %s.", e)
        break
The main loop for the flow processing request queue.
The main loop for the flow processing request queue.
The main loop for the flow processing request queue .
def _FlowProcessingRequestHandlerLoop(self, handler):
    while not self.flow_processing_request_handler_stop:
      try:
        msgs = self._LeaseFlowProcessingReqests()
        if msgs:
          for m in msgs:
            self.flow_processing_request_handler_pool.AddTask(
                target=handler, args=(m,))
        else:
          time.sleep(5)
      except Exception as e:  
        logging.exception("_FlowProcessingRequestHandlerLoop raised %s.", e)
        break
def _FlowProcessingRequestHandlerLoop ( self , handler ) : while not self . flow_processing_request_handler_stop : try : msgs = self . _LeaseFlowProcessingReqests ( ) if msgs : for m in msgs : self . flow_processing_request_handler_pool . AddTask ( target = handler , args = ( m , ) ) else : time . sleep ( 5 ) except Exception as e : logging . exception ( "_FlowProcessingRequestHandlerLoop raised %s." , e ) break
The main loop for the flow processing request queue.
The main loop for the flow processing request queue .
"""The main loop for the flow processing request queue.""" # pylint: disable=broad-except
self
handler