- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for block64 (0.14 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
} /** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// activeQ is empty and waits until a new item is added to the queue. It // increments scheduling cycle when a pod is popped. func (p *PriorityQueue) Pop(logger klog.Logger) (*framework.QueuedPodInfo, error) { p.lock.Lock() defer p.lock.Unlock() for p.activeQ.Len() == 0 { // When the queue is empty, invocation of Pop() is blocked until new item is enqueued.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// This should wake up waiter1 and cause the waiter1 node to be removed. waiter1.interrupt(); waiter1.join(); waiter2.awaitWaiting(); // should still be blocked LockSupport.unpark(waiter2); // spurious wakeup waiter2.awaitWaiting(); // should eventually re-park future.set(null); waiter2.join(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
cmd/api-response.go
} // ObjectInternalInfo contains some internal information about a given // object, it will printed in listing calls with enabled metadata. type ObjectInternalInfo struct { K int // Data blocks M int // Parity blocks } // Object container for object metadata type Object struct { Key string LastModified string // time string of format "2006-01-02T15:04:05.000Z" ETag string
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.5K bytes - Viewed (0) -
src/time/tick_test.go
} t.Fatalf("never got done") } // Reset timer in heap (already reset above, but just in case). tim.Reset(10000 * Second) drainAsync() // Test stop while timer in heap (because goroutine is blocked on <-C). done := make(chan bool) notDone(done) go func() { <-C close(done) }() Sleep(sched) notDone(done) // Test reset far away while timer in heap. tim.Reset(20000 * Second)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// to tell the receiving goroutines that all data have been sent." // Block until either a request is received or a push is triggered. // We need 2 go routines because 'read' blocks in Recv(). go s.receiveDelta(con, ids) // Wait for the proxy to be fully initialized before we start serving traffic. Because // initialization doesn't have dependencies that will block, there is no need to add any timeout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/object-api-utils.go
// Number of full blocks in skipped area seqNum = uint32(compOff / SSEDAREPackageBlockSize) // Skip this many inside a decrypted block to get to compression block start decryptSkip = compOff % SSEDAREPackageBlockSize // Skip this number of full blocks. skipEnc := compOff / SSEDAREPackageBlockSize skipEnc *= sseDAREEncPackageBlockSize
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 36.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
} } // Ensure there is some budget for slowing down processing. // We use the fakeTimeBudget to prevent this test from flaking under // the following conditions: // 1) the watch w1 is blocked, so we were consuming the whole budget once // its buffer was filled in (10 items) // 2) the budget is refreshed once per second, so it basically wasn't // happening in the test at all
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
}, Result: simulation.Result{ // This request should be blocked ClusterMatched: "BlackHoleCluster", }, }, { Name: "direct request to inbound port", Call: simulation.Call{ Port: 15006, Protocol: simulation.TCP, }, Result: simulation.Result{ // This request should be blocked ClusterMatched: "BlackHoleCluster", }, }, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
// lists as we go. The heavy lifting has mostly already been done. var prevBlock *Block for _, b := range state.f.Blocks { state.mergePredecessors(b, blockLocs, prevBlock, true) // Handle any differences among predecessor blocks and previous block (perhaps not a predecessor) for _, varID := range state.changedVars.contents() { state.updateVar(VarID(varID), b, BlockStart)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0)