34556e97a90ed3416424fa8c506962b22b5dd806,lazyflow/request/request_rewrite.py,RequestLock,acquire,#RequestLock#Any#,663

Before Change

        :param blocking: Same as in threading.Lock 
        
        current_request = Request.current_request()
        if current_request is None:
            if blocking:
                with self._selfProtectLock:
                    // Append "None" to indicate that a real thread is waiting (not a request)
                    self._pendingRequests.append(None)

            // Wait for the internal lock to become free
            got_it = self._modelLock.acquire(blocking)
            
            if blocking:
                with self._selfProtectLock:
                    // Search for a "None" to pull off the list of pendingRequests.
                    // Don"t take real requests from the queue
                    r = self._pendingRequests.popleft()
                    while r is not None:
                        self._pendingRequests.append(r)
                        r = self._pendingRequests.popleft()
            return got_it
        
        else: // Running in a Request
            with self._selfProtectLock:
                // Try to get it now.
                got_it = self._modelLock.acquire(False)
                if not blocking:
                    return got_it
                if not got_it:
                    self._pendingRequests.append(current_request)

            if not got_it:
                // Suspend the current request.  When it is woken, it owns the _modelLock.
                current_request._suspend()

            // Guaranteed to own _modelLock now.
            return True

    def release(self):
        assert self._modelLock.locked(), "Can"t release a RequestLock that isn"t already acquired!"
        with self._selfProtectLock:
            if len(self._pendingRequests) > 0:

After Change

        if current_request is None:
            return self._acquire_from_within_thread(blocking)
        else:
            return self._acquire_from_within_request(current_request, blocking)

    def _acquire_from_within_request(self, current_request, blocking):
            with self._selfProtectLock:
                // Try to get it immediately.

Instances