- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 253 for conceal (0.33 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/math/MathTesting.java
ImmutableList.copyOf( Iterables.concat( Iterables.transform(POSITIVE_INTEGER_CANDIDATES, NEGATE_INT), ImmutableList.of(Integer.MIN_VALUE))); NONZERO_INTEGER_CANDIDATES = ImmutableList.copyOf( Iterables.concat(POSITIVE_INTEGER_CANDIDATES, NEGATIVE_INTEGER_CANDIDATES)); ALL_INTEGER_CANDIDATES = Iterables.concat(NONZERO_INTEGER_CANDIDATES, ImmutableList.of(0)); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 11.2K 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) -
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) -
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 Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K 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) -
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K 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 Apr 21 19:28:08 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) -
cni/pkg/nodeagent/net_test.go
Status: corev1.PodStatus{ PodIP: "2.2.2.2", PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}}, }, } } 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 Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 14.3K bytes - Viewed (0)