- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 134 for conceal (0.16 sec)
-
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/StreamsTest.java
Stream<String> concatenated = Streams.concat(Stream.of("a"), streamB, Stream.empty(), Stream.of("c", "d")); assertThat(concatenated).containsExactly("a", "b", "c", "d").inOrder(); concatenated.close(); assertThat(closeCountB.get()).isEqualTo(1); } public void testConcat_refStream_closeIsPropagated_Stream_concat() { // Just to demonstrate behavior of Stream::concat in the standard library
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 20K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
} return testCases }() const ( EnvTestEtcdBackend = "_MINIO_ETCD_TEST_SERVER" ) func (s *TestSuiteIAM) setUpEtcd(c *check, etcdServer string) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout) defer cancel() configCmds := []string{ "etcd", "endpoints=" + etcdServer, "path_prefix=" + mustGetUUID(), } _, err := s.adm.SetConfigKV(ctx, strings.Join(configCmds, " "))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K 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); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/admin-handlers_test.go
ctx, cancel := context.WithCancel(ctx) // reset global variables to start afresh. resetTestGlobals() // Set globalIsErasure to indicate that the setup uses an erasure // code backend. globalIsErasure = true // Initializing objectLayer for HealFormatHandler. objLayer, erasureDirs, xlErr := initTestErasureObjLayer(ctx) if xlErr != nil { cancel() return nil, xlErr }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
maven-core/src/site/apt/offline-mode.apt
using file:// or not residing on a local (not shared) filesystem will be unavailable. * Implications for Mojo Execution ** Deployment mojos The concept of deployment is dependent on the availability of a some remote repository. Just as above, if that repository is not using file:// (which is highly likely to be the case), or the repository is
Plain Text - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Mar 18 00:24:53 GMT 2024 - 10.6K 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); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.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 08 22:53:08 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 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertEvents( "take plan 1", "plan 1 TCP connecting...", ) taskFaker.advanceUntil(500.ms) assertEvents( "take plan 2", "plan 0 cancel", "plan 1 cancel", ) taskFaker.advanceUntil(510.ms) assertEvents( "plan 1 TCP connect canceled", ) taskFaker.advanceUntil(520.ms) assertEvents(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0)