pypet/utils/mpwrappers.py
def _req_rep_retry(self, request):
        """Returns response and number of retries"""
        retries_left = self.RETRIES
        while retries_left:
            self._logger.log(1, 'Sending REQ `%s`', request)
            self._send_request(request)
            socks = dict(self._poll.poll(self.TIMEOUT))
            if socks.get(self._socket) == zmq.POLLIN:
                response = self._receive_response()
                self._logger.log(1, 'Received REP `%s`', response)
                return response, self.RETRIES - retries_left
            else:
                self._logger.debug('No response from server (%d retries left)' %
                                   retries_left)
                self._close_socket(confused=True)
                retries_left -= 1
                if retries_left == 0:
                    raise RuntimeError('Server seems to be offline!')
                time.sleep(self.SLEEP)
                self._start_socket()
def _req_rep_retry(self, request):
        retries_left = self.RETRIES
        while retries_left:
            self._logger.log(1, 'Sending REQ `%s`', request)
            self._send_request(request)
            socks = dict(self._poll.poll(self.TIMEOUT))
            if socks.get(self._socket) == zmq.POLLIN:
                response = self._receive_response()
                self._logger.log(1, 'Received REP `%s`', response)
                return response, self.RETRIES - retries_left
            else:
                self._logger.debug('No response from server (%d retries left)' %
                                   retries_left)
                self._close_socket(confused=True)
                retries_left -= 1
                if retries_left == 0:
                    raise RuntimeError('Server seems to be offline!')
                time.sleep(self.SLEEP)
                self._start_socket()
def _req_rep_retry ( self , request ) : retries_left = self . RETRIES while retries_left : self . _logger . log ( 1 , 'Sending REQ `%s`' , request ) self . _send_request ( request ) socks = dict ( self . _poll . poll ( self . TIMEOUT ) ) if socks . get ( self . _socket ) == zmq . POLLIN : response = self . _receive_response ( ) self . _logger . log ( 1 , 'Received REP `%s`' , response ) return response , self . RETRIES - retries_left else : self . _logger . debug ( 'No response from server (%d retries left)' % retries_left ) self . _close_socket ( confused = True ) retries_left -= 1 if retries_left == 0 : raise RuntimeError ( 'Server seems to be offline!' ) time . sleep ( self . SLEEP ) self . _start_socket ( )
Returns response and number of retries
Returns response and number of retries