Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 22 for waitRead (0.26 sec)

  1. src/sync/mutex.go

    	// the tail of the wait queue.
    	//
    	// If a waiter receives ownership of the mutex and sees that either
    	// (1) it is the last waiter in the queue, or (2) it waited for less than 1 ms,
    	// it switches mutex back to normal operation mode.
    	//
    	// Normal mode has considerably better performance as a goroutine can acquire
    	// a mutex several times in a row even if there are blocked waiters.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cni/test/install_cni.go

    	if chainedCNIPlugin && delayedConfFile != "" {
    		retry.UntilSuccessOrFail(t, func() error {
    			if err := checkResult(resultFile, expectedOutputFile); err == nil {
    				// We should have waited for the delayed conf
    				return fmt.Errorf("did not wait for valid config file")
    			}
    			return nil
    		}, retry.Delay(time.Millisecond), retry.Timeout(time.Millisecond*250))
    		var destFilenm string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after
        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
        // waited and assert based on that time. Empirically, the race where the thread ends up waiting
        // for 5.5 seconds happens about 2% of the time.
        boolean longWait = TimeUnit.NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after
        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
        // waited and assert based on that time. Empirically, the race where the thread ends up waiting
        // for 5.5 seconds happens about 2% of the time.
        boolean longWait = TimeUnit.NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        final String unitString = unit.toString().toLowerCase(Locale.ROOT);
        String message = "Waited " + timeout + " " + unit.toString().toLowerCase(Locale.ROOT);
        // Only report scheduling delay if larger than our spin threshold - otherwise it's just noise
        if (remainingNanos + SPIN_THRESHOLD_NANOS < 0) {
          // We over-waited for our timeout.
          message += " (plus ";
          long overWaitNanos = -remainingNanos;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  6. guava/src/com/google/common/util/concurrent/AbstractFuture.java

        final String unitString = unit.toString().toLowerCase(Locale.ROOT);
        String message = "Waited " + timeout + " " + unit.toString().toLowerCase(Locale.ROOT);
        // Only report scheduling delay if larger than our spin threshold - otherwise it's just noise
        if (remainingNanos + SPIN_THRESHOLD_NANOS < 0) {
          // We over-waited for our timeout.
          message += " (plus ";
          long overWaitNanos = -remainingNanos;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  7. src/crypto/tls/handshake_server_tls13.go

    			return errors.New("tls: invalid signature by the client certificate: " + err.Error())
    		}
    
    		if err := transcriptMsg(certVerify, hs.transcript); err != nil {
    			return err
    		}
    	}
    
    	// If we waited until the client certificates to send session tickets, we
    	// are ready to do it now.
    	if err := hs.sendSessionTickets(); err != nil {
    		return err
    	}
    
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 17:23:54 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  8. src/database/sql/sql.go

    // [Tx.Rollback] is called on the transaction, that transaction's
    // connection is returned to [DB]'s idle connection pool. The pool size
    // can be controlled with [DB.SetMaxIdleConns].
    type DB struct {
    	// Total time waited for new connections.
    	waitDuration atomic.Int64
    
    	connector driver.Connector
    	// numClosed is an atomic counter which represents a total number of
    	// closed connections. Stmt.openStmt checks it before cleaning closed
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 103.6K bytes
    - Viewed (0)
  9. src/runtime/signal_unix.go

    	setg(nil)
    	needm(true)
    	if st.ss_flags&_SS_DISABLE != 0 {
    		noSignalStack(sig)
    	} else {
    		sigNotOnStack(sig, sp, mp)
    	}
    	dropm()
    	return false
    }
    
    // crashing is the number of m's we have waited for when implementing
    // GOTRACEBACK=crash when a signal is received.
    var crashing atomic.Int32
    
    // testSigtrap and testSigusr1 are used by the runtime tests. If
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 16:04:54 UTC 2024
    - 45K bytes
    - Viewed (0)
  10. pkg/kubelet/kuberuntime/kuberuntime_container.go

    	}
    
    	// if we care about termination ordering, then wait for this container's turn to exit if there is
    	// time remaining
    	if ordering != nil && gracePeriod > 0 {
    		// grace period is only in seconds, so the time we've waited gets truncated downward
    		gracePeriod -= int64(ordering.waitForTurn(containerName, gracePeriod))
    	}
    
    	// always give containers a minimal shutdown window to avoid unnecessary SIGKILLs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
Back to top