Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 228 for rlocked (0.2 sec)

  1. pkg/kubelet/cm/dra/claiminfo_test.go

    		wantErr     bool
    	}{
    		{
    			description: "RLock-ed cache allows another RLock",
    			funcGen: func(cache *claimInfoCache) func() error {
    				return func() error {
    					if !cache.RWMutex.TryRLock() {
    						return errors.New("RLock failed")
    					}
    					return nil
    				}
    			},
    		},
    		{
    			description: "cache is locked inside a function",
    			funcGen: func(cache *claimInfoCache) func() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 21K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    	}
    	return lockCopy
    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. src/runtime/time.go

    	t.unlockAndRun(now)
    	assertLockHeld(&ts.mu) // t is unlocked now, but not ts
    	return 0
    }
    
    // unlockAndRun unlocks and runs the timer t (which must be locked).
    // If t is in a timer set (t.ts != nil), the caller must also have locked the timer set,
    // and this call will temporarily unlock the timer set while running the timer function.
    // unlockAndRun returns with t unlocked and t.ts (re-)locked.
    //
    //go:systemstack
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 29 14:36:24 UTC 2024
    - 37.5K bytes
    - Viewed (0)
  4. src/crypto/tls/quic.go

    	defer c.handshakeMutex.Lock()
    	// Send on blockedc to notify the QUICConn that the handshake is blocked.
    	// Exported methods of QUICConn wait for the handshake to become blocked
    	// before returning to the user.
    	select {
    	case c.quic.blockedc <- struct{}{}:
    	case <-c.quic.cancelc:
    		return c.sendAlertLocked(alertCloseNotify)
    	}
    	// The QUICConn reads from signalc to notify us that the handshake may
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 17:23:54 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  7. platforms/documentation/docs/src/docs/userguide/dep-man/02-declaring-dependency-versions/dependency_locking.adoc

    You can also disable locking on a specific configuration.
    This can be useful if a plugin configured locking on all configurations but you happen to add one that should not be locked.
    
    .Unlocking a specific configuration
    ====
    include::sample[dir="snippets/dependencyManagement/dependencyLocking-unlockingSingleConfiguration/kotlin",files="build.gradle.kts[tags=locking-one]"]
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 16:55:22 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. src/runtime/preempt.go

    // Goroutine preemption
    //
    // A goroutine can be preempted at any safe-point. Currently, there
    // are a few categories of safe-points:
    //
    // 1. A blocked safe-point occurs for the duration that a goroutine is
    //    descheduled, blocked on synchronization, or in a system call.
    //
    // 2. Synchronous safe-points occur when a running goroutine checks
    //    for a preemption request.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  9. src/syscall/exec_linux.go

    	// Set up and fork. This returns immediately in the parent or
    	// if there's an error.
    	upid, pidfd, err, mapPipe, locked := forkAndExecInChild1(argv0, argv, envv, chroot, dir, attr, sys, pipe)
    	if locked {
    		runtime_AfterFork()
    	}
    	if err != 0 {
    		return 0, err
    	}
    
    	// parent; return PID
    	pid = int(upid)
    	if sys.PidFD != nil {
    		*sys.PidFD = int(pidfd)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 07:45:37 UTC 2024
    - 23K bytes
    - Viewed (0)
  10. src/cmd/trace/gstate.go

    // and orthogonal to syscallEnd; both must be called if the syscall blocked. This sets up an instant
    // to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system.
    func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) {
    	name := "exit blocked syscall"
    	gs.setStartCause(ts, name, trace.SyscallP, stack)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.9K bytes
    - Viewed (0)
Back to top