(self)
Main method run by the polling thread of the thread pool.
        Check whether inactive clients have become active
Main method run by the polling thread of the thread pool.
        Check whether inactive clients have become active
Main method run by the polling thread of the thread pool . Check whether inactive clients have become active
def _poll_inactive_clients(self):
        '''Main method run by the polling thread of the thread pool.
        Check whether inactive clients have become active'''
        while self.active:
            try:
                # the actual poll, with a timeout of 1s so that we can exit in case
                # we re not active anymore
                active_clients = self.poll_object.poll(1)
                # for each client that became active, put them in the active queue
                self._handle_poll_result(active_clients)
            except Exception:
                ex = sys.exc_info()[1]
                # "Caught exception in Worker thread" message
                self.logger.warning("failed to poll clients, caught exception : %s", str(ex))
                # wait a bit so that we do not loop too fast in case of error
                time.sleep(0.2)
def _poll_inactive_clients ( self ) : while self . active : try : # the actual poll, with a timeout of 1s so that we can exit in case # we re not active anymore active_clients = self . poll_object . poll ( 1 ) # for each client that became active, put them in the active queue self . _handle_poll_result ( active_clients ) except Exception : ex = sys . exc_info ( ) [ 1 ] # "Caught exception in Worker thread" message self . logger . warning ( "failed to poll clients, caught exception : %s" , str ( ex ) ) # wait a bit so that we do not loop too fast in case of error time . sleep ( 0.2 )