Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 42 for waitRead (0.16 sec)

  1. 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)
  2. pkg/kubelet/prober/worker_test.go

    		laterStatus.ContainerStatuses[0].State.Running.StartedAt.Time =
    			time.Now().Add(-100 * time.Second)
    		m.statusManager.SetPodStatus(w.pod, laterStatus)
    
    		// Second call should succeed (already waited).
    		expectContinue(t, w, w.doProbe(ctx), "after initial delay")
    		expectResult(t, w, results.Success, "after initial delay")
    	}
    }
    
    func TestFailureThreshold(t *testing.T) {
    	ctx := context.Background()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 23:48:10 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  3. 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/io/testdata/alice_in_wonderland.txt

    narrow, to be sure; but I THINK I can kick a little!'
    
      She drew her foot as far down the chimney as she could, and
    waited till she heard a little animal (she couldn't guess of what
    sort it was) scratching and scrambling about in the chimney close
    above her:  then, saying to herself `This is Bill,' she gave one
    sharp kick, and waited to see what would happen next.
    
      The first thing she heard was a general chorus of `There goes
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Oct 29 21:35:03 UTC 2012
    - 145.2K 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