- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 812 for pcancel (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/decorated_watcher.go
w watch.Interface decorator func(runtime.Object) cancel context.CancelFunc resultCh chan watch.Event } func newDecoratedWatcher(ctx context.Context, w watch.Interface, decorator func(runtime.Object)) *decoratedWatcher { ctx, cancel := context.WithCancel(ctx) d := &decoratedWatcher{ w: w, decorator: decorator, cancel: cancel, resultCh: make(chan watch.Event), } go d.run(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 02 19:25:31 UTC 2021 - 2.3K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/promise_test.go
} goGetAndExpect(t, wr, gots, aval) cancel() time.Sleep(time.Second) // give it a chance to misbehave goGetAndExpect(t, wr, gots, aval) } func TestWriteOnceCancel(t *testing.T) { oldTime := time.Now() cval := &oldTime ctx, cancel := context.WithCancel(context.Background()) wr := NewWriteOnce(nil, ctx, cval) gots := make(chan interface{}) goGetExpectNotYet(t, wr, gots, "cancel") cancel() expectGotValue(t, gots, cval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 19:19:31 UTC 2023 - 3K bytes - Viewed (0) -
src/cmd/vet/testdata/lostcancel/lostcancel.go
package lostcancel import "context" func _() { var _, cancel = context.WithCancel(context.Background()) // ERROR "the cancel function is not used on all paths \(possible context leak\)" if false { _ = cancel }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 20 15:46:42 UTC 2019 - 475 bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r48/CancellationCrossVersionSpec.groovy
def build = action.build() build.withCancellationToken(cancel.token()) collectOutputs(build) build.run(resultHandler) sync.waitForAllPendingCalls(resultHandler) cancel.cancel() sync.releaseAll() resultHandler.finished() } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/ContinuousBuildCancellationCrossVersionSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertFailed(future, cause); } public void testCanceled() throws Exception { assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, false); } public void testInterrupted() throws Exception { assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, true); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/etcd.go
timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() _, err := client.Delete(timeoutCtx, key) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() resp, err := client.Get(timeoutCtx, key)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r26/TestLauncherCancellationCrossVersionSpec.groovy
def build = connection.newTestLauncher() build.withJvmTestClasses("Broken") build.withCancellationToken(cancel.token()) build.run(resultHandler) sync.waitForAllPendingCalls(resultHandler) cancel.cancel() sync.releaseAll() resultHandler.finished() } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertFailed(future, cause); } public void testCanceled() throws Exception { assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, false); } public void testInterrupted() throws Exception { assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, true); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 15.5K bytes - Viewed (0) -
pkg/kubelet/config/mux_test.go
limitations under the License. */ package config import ( "context" "reflect" "testing" ) func TestConfigurationChannels(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() mux := newMux(nil) channelOne := mux.ChannelWithContext(ctx, "one") if channelOne != mux.ChannelWithContext(ctx, "one") {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.5K bytes - Viewed (0)