- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for waitDone (0.19 sec)
-
src/time/tick_test.go
select { case <-C: done <- true case <-stop: } close(done2) }() Sleep(sched) notDone(done) tim.Reset(sched / 2) Sleep(sched) waitDone(done) tim.Stop() close(stop) waitDone(done1) waitDone(done2) if isTicker { // extra send might have sent done again // (handled by buffering done above). select { default: case <-done: }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/cmd/cgo/internal/test/test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:50:06 UTC 2024 - 48.5K bytes - Viewed (0) -
src/net/http/h2_bundle.go
// auto-decoding a portion of a gzipped document will just fail // anyway. See https://golang.org/issue/8923 cs.requestedGzip = true } go cs.doRequest(req, streamf) waitDone := func() error { select { case <-cs.donec: return nil case <-ctx.Done(): return ctx.Err() case <-cs.reqCancel: return http2errRequestCanceled } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
dt := newTransportDialTester(t, http1Mode) // First request creates a new connection. rt1 := dt.roundTrip() c1 := dt.wantDial() c1.finish(nil) rt1.wantDone(c1) rt1.finish() // Second request reuses the first connection. rt2 := dt.roundTrip() rt2.wantDone(c1) rt2.finish() } func TestTransportPoolConnCannotReuseConnectionInUse(t *testing.T) { dt := newTransportDialTester(t, http1Mode)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
new Object() { @Override protected void finalize() { future.set(null); } }; x = null; // Hint to the JIT that x is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 7.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
* * <pre>{@code * awaitDone(new FinalizationPredicate() { * public boolean isDone() { * return ref.get() == null; * } * }); * }</pre> * * @throws RuntimeException if timed out or interrupted while waiting */ public static void awaitClear(WeakReference<?> ref) { awaitDone( new FinalizationPredicate() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
* * <pre>{@code * awaitDone(new FinalizationPredicate() { * public boolean isDone() { * return ref.get() == null; * } * }); * }</pre> * * @throws RuntimeException if timed out or interrupted while waiting */ public static void awaitClear(WeakReference<?> ref) { awaitDone( new FinalizationPredicate() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
frq = null; } public void testFinalizeReferentCalled() { final MockReference reference = new MockReference(frq = new FinalizableReferenceQueue()); GcFinalization.awaitDone( new GcFinalization.FinalizationPredicate() { @Override public boolean isDone() { return reference.finalizeReferentCalled; } }); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0) -
src/database/sql/sql.go
cancel func() // ctx lives for the life of the transaction. ctx context.Context } // awaitDone blocks until the context in Tx is canceled and rolls back // the transaction if it's not already done. func (tx *Tx) awaitDone() { // Wait for either the transaction to be committed or rolled // back, or for the associated context to be closed. <-tx.ctx.Done()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
os.Exit(1) } } // Add storageclasses waitMode := storagev1.VolumeBindingWaitForFirstConsumer immediateMode := storagev1.VolumeBindingImmediate classes := []*storagev1.StorageClass{ { ObjectMeta: metav1.ObjectMeta{ Name: waitClassWithProvisioner, }, VolumeBindingMode: &waitMode, Provisioner: provisioner, AllowedTopologies: []v1.TopologySelectorTerm{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0)