- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 317 for Yancey (0.2 sec)
-
cmd/namespace-lock.go
type LockContext struct { ctx context.Context cancel context.CancelFunc } // Context returns lock context func (l LockContext) Context() context.Context { return l.ctx } // Cancel function calls cancel() function func (l LockContext) Cancel() { if l.cancel != nil { l.cancel() } } // newNSLock - return a new name space lock map.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* write. * * 2. visibility of the writes to an afterDone() call triggered by cancel(): * * Since these fields are non-final that means that TimeoutFuture is not being 'safely published', * thus a motivated caller may be able to expose the reference to another thread that would then * call cancel() and be unable to cancel the delegate.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/dsync/drwmutex.go
} } } } func (dm *DRWMutex) startContinuousLockRefresh(lockLossCallback func(), id, source string, quorum int) { ctx, cancel := context.WithCancel(context.Background()) dm.m.Lock() dm.cancelRefresh = cancel dm.m.Unlock() go func() { defer cancel() refreshTimer := time.NewTimer(dm.refreshInterval) defer refreshTimer.Stop() for { select { case <-ctx.Done():
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
public final void addListener(Runnable listener, Executor executor) { super.addListener(listener, executor); } @CanIgnoreReturnValue @Override public final boolean cancel(boolean mayInterruptIfRunning) { return super.cancel(mayInterruptIfRunning); } } private static final Logger log = Logger.getLogger(AbstractFuture.class.getName()); private State state; private V value;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K 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)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
var ztunnelTestCounter atomic.Uint32 func TestZtunnelSendsPodSnapshot(t *testing.T) { ztunnelKeepAliveCheckInterval = time.Second / 10 mt := monitortest.New(t) setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid m, fds := readRequest(t, ztunClient)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception { // Simple (combined.cancel -> input.cancel -> setOneValue): successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true); /* * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue), * to show that this isn't just about problems with the input future we just * cancelled:
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
cmd/jwt_test.go
return token.SignedString([]byte(secretKey)) } // Tests web request authenticator. func TestWebRequestAuthenticate(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
UID: "123", }, Spec: corev1.PodSpec{ Containers: containers, }, Status: podStatus, } } func TestServerAddPod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging() fixture := getTestFixure(ctx) netServer := fixture.netServer ztunnelServer := fixture.ztunnelServer podMeta := metav1.ObjectMeta{ Name: "foo",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"istio.io/istio/pkg/monitoring/monitortest" "istio.io/istio/pkg/test/util/assert" ) func TestExistingPodAddedWhenNsLabeled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, },
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0)