- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 181 for deltaY (1.12 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
eachQueue@ for (queue in readyQueues) { val candidate = queue.futureTasks[0] val candidateDelay = maxOf(0L, candidate.nextExecuteNanoTime - now) when { // Compute the delay of the soonest-executable task. candidateDelay > 0L -> { minDelayNanos = minOf(candidateDelay, minDelayNanos) continue@eachQueue }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
shouldBeEnabled := util.PodRedirectionEnabled(ns, newPod) isTerminated := kube.CheckPodTerminal(newPod) // Check intent (labels) versus status (annotation) - is there a delta we need to fix? changeNeeded := (isAnnotated != shouldBeEnabled) && !isTerminated // nolint: lll
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
common-protos/k8s.io/api/certificates/v1/generated.proto
// expirationSeconds is the requested duration of validity of the issued // certificate. The certificate signer may issue a certificate with a different // validity duration so a client must check the delta between the notBefore and // and notAfter fields in the issued certificate to determine the actual duration. // // The v1.22+ in-tree implementations of the well-known Kubernetes signers will
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 11.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
* * This test uses [TaskFaker] to deterministically test racy code. Each function in this test has * the same structure: * * * prepare a set of plans, each with a predictable connect delay * * attempt to find a connection * * step through time, asserting that the expected side effects are performed. */ internal class FastFallbackExchangeFinderTest { private val taskFaker = TaskFaker()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K bytes - Viewed (0) -
src/net/tcpsock.go
} return nil } // SetNoDelay controls whether the operating system should delay // packet transmission in hopes of sending fewer packets (Nagle's // algorithm). The default is true (no delay), meaning that data is // sent as soon as possible after a Write. func (c *TCPConn) SetNoDelay(noDelay bool) error { if !c.ok() { return syscall.EINVAL }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0) -
src/compress/bzip2/bzip2.go
huffmanTrees := make([]huffmanTree, numHuffmanTrees) // Now we decode the arrays of code-lengths for each tree. lengths := make([]uint8, numSymbols) for i := range huffmanTrees { // The code lengths are delta encoded from a 5-bit base value. length := br.ReadBits(5) for j := range lengths { for { if length < 1 || length > 20 { return StructuralError("Huffman length out of range") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 13K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
private TestCondition(Lock lock, Condition condition) { this.lock = lock; this.condition = condition; } static TestCondition createAndSignalAfter(long delay, TimeUnit unit) { final TestCondition testCondition = create(); ScheduledExecutorService scheduledPool = Executors.newScheduledThreadPool(1);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
staging/src/k8s.io/api/certificates/v1/types.go
// expirationSeconds is the requested duration of validity of the issued // certificate. The certificate signer may issue a certificate with a different // validity duration so a client must check the delta between the notBefore and // and notAfter fields in the issued certificate to determine the actual duration. // // The v1.22+ in-tree implementations of the well-known Kubernetes signers will
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 15.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
boolean longWait = TimeUnit.NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5; // Count how long it actually took to return; we'll accept any number between the expected delay // and the approximate actual delay, to be robust to variance in thread scheduling. char overWaitNanosFirstDigit = Long.toString( thread.timeSpentBlocked - TimeUnit.MILLISECONDS.toNanos(longWait ? 5000 : 3000))
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
src/go/types/typexpr.go
if isTypeParam(typ) { return } // We don't want to call under() or complete interfaces while we are in // the middle of type-checking parameter declarations that might belong // to interface methods. Delay this check to the end of type-checking. check.later(func() { if t, _ := under(typ).(*Interface); t != nil { tset := computeInterfaceTypeSet(check, e.Pos(), t) // TODO(gri) is this the correct position?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 16.3K bytes - Viewed (0)