pypet/utils/mpwrappers.py
def acquire(self):
        """Acquires lock and returns `True`

        Blocks until lock is available.

        """
        self.start(test_connection=False)
        while True:
            str_response, retries = self._req_rep_retry(LockerServer.LOCK)
            response = str_response.split(LockerServer.DELIMITER)
            if response[0] == LockerServer.GO:
                return True
            elif response[0] == LockerServer.LOCK_ERROR and retries > 0:
                # Message was sent but Server response was lost and we tried again
                self._logger.error(str_response + '; Probably due to retry')
                return True
            elif response[0] == LockerServer.WAIT:
                time.sleep(self.SLEEP)
            else:
                raise RuntimeError('Response `%s` not understood' % response)
def acquire(self):
        """Acquires lock and returns `True`

        Blocks until lock is available.

        """
        self.start(test_connection=False)
        while True:
            str_response, retries = self._req_rep_retry(LockerServer.LOCK)
            response = str_response.split(LockerServer.DELIMITER)
            if response[0] == LockerServer.GO:
                return True
            elif response[0] == LockerServer.LOCK_ERROR and retries > 0:
                # Message was sent but Server response was lost and we tried again
                self._logger.error(str_response + '; Probably due to retry')
                return True
            elif response[0] == LockerServer.WAIT:
                time.sleep(self.SLEEP)
            else:
                raise RuntimeError('Response `%s` not understood' % response)
def acquire ( self ) : self . start ( test_connection = False ) while True : str_response , retries = self . _req_rep_retry ( LockerServer . LOCK ) response = str_response . split ( LockerServer . DELIMITER ) if response [ 0 ] == LockerServer . GO : return True elif response [ 0 ] == LockerServer . LOCK_ERROR and retries > 0 : # Message was sent but Server response was lost and we tried again self . _logger . error ( str_response + '; Probably due to retry' ) return True elif response [ 0 ] == LockerServer . WAIT : time . sleep ( self . SLEEP ) else : raise RuntimeError ( 'Response `%s` not understood' % response )
Acquires lock and returns `True`

        Blocks until lock is available.
Acquires lock and returns True