- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 438 for readlink (0.08 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
if (this.errorCode == null) { this.errorCode = errorCode condition.signalAll() } } } /** * Returns true if read timeouts should be enforced while reading response headers or body bytes. * We always do timeouts in the HTTP server role. For clients, we only do timeouts after the * request is transmitted. This is only interesting for duplex calls where the request and
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/NullPointerTester.java
} } return map.values(); } private ImmutableList<Method> getVisibleMethods(Class<?> cls) { // Don't use cls.getPackage() because it does nasty things like reading // a file. String visiblePackage = Reflection.getPackageName(cls); ImmutableList.Builder<Method> builder = ImmutableList.builder(); for (Class<?> type : TypeToken.of(cls).getTypes().rawTypes()) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 22.6K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
// block -> data combineSharedBlocks := make(map[int][]byte) combineFilledBlocks := make(map[int][]byte) nextFile: for key, file := range files[partIdx] { fmt.Println("Reading base version", file[0], "part", part) var combined []byte var missingAll int var lastValidAll int attempt := 0 for block := 0; ; block++ { combineFilled := combineFilledBlocks[block]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 05 11:57:44 UTC 2024 - 40.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* Future} is "completed" even if it is cancelled while its underlying work continues on a * thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for * example, if the deadline expires on a {@code Future} returned from {@link * Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// quorum + 1 when tolerance is exactly half of the // total locker clients. if quorum == tolerance { quorum++ } } log("lockBlocking %s/%s for %#v: lockType readLock(%t), additional opts: %#v, quorum: %d, tolerance: %d, lockClients: %d\n", id, source, dm.Names, isReadLock, opts, quorum, tolerance, len(restClnts)) tolerance = len(restClnts) - quorum attempt := uint(0) for {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/test-utils_test.go
} // httptest Recorder to capture all the response by the http handler. rec := httptest.NewRecorder() // reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request. // If the body is read in the handler the same request cannot be made use of. buf, err := io.ReadAll(anonReq.Body)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
stream.writeObject(factory); stream.writeObject(backingMap()); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible @SuppressWarnings("unchecked") // reading data stored by writeObject private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 16 21:21:17 UTC 2024 - 86.3K bytes - Viewed (0) -
cmd/data-usage-cache_gen.go
return } case "nv": za0002.NumVersions, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Tiers", za0001, "NumVersions") return } case "no": za0002.NumObjects, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Tiers", za0001, "NumObjects") return } default:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 75K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Range.java
* property <i>P</i>. See, for example, the definition of {@link #intersection intersection}. * <li>A {@code Range} is serializable if it has no bounds, or if each bound is serializable. * </ul> * * <h3>Further reading</h3> * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/RangesExplained">{@code Range}</a>. * * @author Kevin Bourrillion * @author Gregory Kick * @since 10.0
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 16 17:21:56 UTC 2024 - 27.8K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hashing.java
} /** * Used to randomize {@link #goodFastHash} instances, so that programs which persist anything * dependent on the hash codes they produce will fail sooner. */ @SuppressWarnings("GoodTime") // reading system time without TimeSource static final int GOOD_FAST_HASH_SEED = (int) System.currentTimeMillis(); /** * Returns a hash function implementing the <a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jul 19 16:02:36 UTC 2024 - 29.3K bytes - Viewed (0)