Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 690 for rlock (0.09 sec)

  1. kotlin-js-store/yarn.lock

    Yuri Schimke <******@****.***> 1690028931 +0100
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 87.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt

        return lock.withLock(action)
      }
    
      inline fun <T> RealConnection.withLock(action: () -> T): T {
        contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) }
        return lock.withLock(action)
      }
    
      inline fun <T> RealCall.withLock(action: () -> T): T {
        contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) }
        return lock.withLock(action)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      internal inline fun Any.assertThreadHoldsLock() {
        if (assertionsEnabled && !taskRunner.lock.isHeldByCurrentThread) {
          throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
        }
      }
    
      @Suppress("NOTHING_TO_INLINE")
      internal inline fun Any.assertThreadDoesntHoldLock() {
        if (assertionsEnabled && taskRunner.lock.isHeldByCurrentThread) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    		}
    		m.addResponse(Response{Err: ErrIncorrectSequence})
    		return false
    	}
    	m.RecvSeq++
    	return true
    }
    
    // response will send handleIncoming response to client.
    // may never block.
    // Should return whether the next call would block.
    func (m *muxClient) response(seq uint32, r Response) {
    	if debugReqs {
    		fmt.Println(m.MuxID, m.parent.String(), "RESP")
    	}
    	if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. docs/site-replication/run-multi-site-oidc.sh

    	exit_1
    fi
    
    ./mc mb --with-lock minio3/newbucket-olock
    sleep 5
    
    enabled_minio2=$(./mc stat --json minio2/newbucket-olock | jq -r .ObjectLock.enabled)
    if [ $? -ne 0 ]; then
    	echo "expected bucket to be mirrored with object-lock but not present, exiting..."
    	exit_1
    fi
    
    if [ "${enabled_minio2}" != "Enabled" ]; then
    	echo "expected bucket to be mirrored with object-lock enabled, exiting..."
    	exit_1
    fi
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. cmd/grid.go

    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalLockGrid is the global lock grid manager.
    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. internal/lock/lock_nix.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lock
    
    import (
    	"os"
    	"syscall"
    )
    
    // Internal function implements support for both
    // blocking and non blocking lock type.
    func lockedOpenFile(path string, flag int, perm os.FileMode, lockType int) (*LockedFile, error) {
    	switch flag {
    	case syscall.O_RDONLY:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    		if err != nil {
    			if !xnet.IsNetworkOrHostDown(err, true) {
    				gridLogIfNot(ctx, fmt.Errorf("ws read: %w", err), net.ErrClosed, io.EOF)
    			}
    			return
    		}
    		block := c.blockMessages.Load()
    		if block != nil && *block != nil {
    			<-*block
    		}
    
    		if c.incomingBytes != nil {
    			c.incomingBytes(int64(len(msg)))
    		}
    
    		// Parse the received message
    		var m message
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top