- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 430 for succeed (0.04 seconds)
-
guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java
* is permitted and similarly for decrease/remove(). We assume that a * setCount() no-op is permitted if either add() or remove() is permitted, * though we also allow it to "succeed" if neither is permitted. */ private void assertSetCount(E element, int count) { setCountCheckReturnValue(element, count); assertEquals(
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
return whenAllComplete(asList(future1, moreFutures)); } /** * Starts specifying how to combine {@link ClosingFuture}s into a single pipeline, assuming they * all succeed. If any fail, the resulting pipeline will fail. * * @throws IllegalStateException if a {@code ClosingFuture} has already been derived from any of
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 13:51:27 GMT 2025 - 96.9K bytes - Click Count (0) -
internal/dsync/dsync_test.go
t.Errorf("expected at least %v time have passed, however %v passed", expect, elapsed) } t.Logf("expected at least %v time have passed, %v passed", expect, elapsed) } // Test two locks for different resources, both succeed func TestTwoSimultaneousLocksForDifferentResources(t *testing.T) { dm1 := NewDRWMutex(ds, "aap") dm2 := NewDRWMutex(ds, "noot") dm1.Lock(id, source) dm2.Lock(id, source) dm1.Unlock(t.Context())
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.8K bytes - Click Count (0) -
internal/dsync/drwmutex_test.go
cunlock := make(chan bool) cdone := make(chan bool) for range numReaders { go parallelReader(context.Background(), m, clocked, cunlock, cdone) } // Wait for all parallel RLock()s to succeed. for range numReaders { <-clocked } for range numReaders { cunlock <- true } // Wait for the goroutines to finish. for range numReaders { <-cdone } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 16.2K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AtomicLongMap.java
* expectedOldValue} with {@code newValue} and returns true; otherwise, this method returns false. * * <p>If {@code expectedOldValue} is zero, this method will succeed if {@code (key, zero)} is * currently in the map, or if {@code key} is not in the map at all. */ boolean replace(K key, long expectedOldValue, long newValue) { if (expectedOldValue == 0L) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 10 23:13:45 GMT 2025 - 11.7K bytes - Click Count (0) -
src/archive/tar/strconv.go
switch c := sn[i]; { case c < '0' || c > '9': return time.Time{}, ErrHeader case i < len(nanoDigits): nanoDigits[i] = c } } nsecs, _ := strconv.ParseInt(string(nanoDigits[:]), 10, 64) // Must succeed after validation if len(ss) > 0 && ss[0] == '-' { return time.Unix(secs, -1*nsecs), nil // Negative correction } return time.Unix(secs, nsecs), nil }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Sep 08 17:08:20 GMT 2025 - 9.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
public static <V extends @Nullable Object> V getDone(Future<V> future) throws ExecutionException { /* * We throw IllegalStateException, since the call could succeed later. Perhaps we "should" throw * IllegalArgumentException, since the call could succeed with a different argument. Those * exceptions' docs suggest that either is acceptable. Google's Java Practices page recommends
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 64.3K bytes - Click Count (0) -
.teamcity/src/main/kotlin/common/CommonExtensions.kt
onDependencyCancel = FailureAction.FAIL_TO_START } } } fun Dependencies.compileAllDependency(compileAllId: String) { // Compile All has to succeed before anything else is started dependsOn(RelativeId(compileAllId)) // Get the build receipt from sanity check to reuse the timestamp artifacts(RelativeId(compileAllId)) {Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Dec 22 07:15:16 GMT 2025 - 15.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
var success = false // Tell the call about the connecting call so async cancels work. call.plansToCancel += this try { call.eventListener.connectStart(call, route.socketAddress, route.proxy) connectionPool.connectionListener.connectStart(route, call) connectSocket() success = true return ConnectResult(plan = this)Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 19.3K bytes - Click Count (2)