- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 30 for Yet (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
if (super.cancel(interruptIfRunning)) { /* * requireNonNull is generally safe: If cancel succeeded, then this Future was still * pending, so its `state` field hasn't been nulled out yet. * * OK, it's technically possible for this to fail in the presence of unsafe publishing, as * discussed in the comments in TimeoutFuture. TODO(cpovirk): Maybe check for null before
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMap.java
@Deprecated @Override public final ImmutableSortedMap<K, V> buildKeepingLast() { // TODO(emcmanus): implement throw new UnsupportedOperationException( "ImmutableSortedMap.Builder does not yet implement buildKeepingLast()"); } } private final transient RegularImmutableSortedSet<K> keySet; private final transient ImmutableList<V> valueList;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 53.2K bytes - Viewed (0) -
cmd/bucket-handlers.go
// ------------------------- // This operation lists in-progress multipart uploads. An in-progress // multipart upload is a multipart upload that has been initiated, // using the Initiate Multipart Upload request, but has not yet been // completed or aborted. This operation returns at most 1,000 multipart // uploads in the response. func (api objectAPIHandlers) ListMultipartUploadsHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// Note that although we have two routes available, we only use one. The retry is permitted // because there are routes available, but it chooses the existing connection since it isn't // yet considered unhealthy. assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) } @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun noRecoveryWhenRoutesExhausted(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
cmd/test-utils_test.go
letterIdxMax = 63 / letterIdxBits // # of letter indices fitting in 63 bits ) // Random number state. // We generate random temporary file names so that there's a good // chance the file doesn't exist yet. var ( randN uint32 randmu sync.Mutex ) // Temp files created in default Tmp dir var globalTestTmpDir = os.TempDir() // reseed - returns a new seed every time the function is called.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
.bazelrc
# rbe_linux_cuda_nvcc: RBE options to build with GPU support using nvcc. # # Embedded Linux options (experimental and only tested with TFLite build yet) # elinux: General Embedded Linux options shared by all flavors. # elinux_aarch64: Embedded Linux options for aarch64 (ARM64) CPU support. # elinux_armhf: Embedded Linux options for armhf (ARMv7) CPU support.
Plain Text - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Thu May 02 19:34:20 GMT 2024 - 52.8K bytes - Viewed (2) -
cmd/erasure-object.go
}() validResp := 0 totalResp := 0 // minDisks value is only to reduce the number of calls // to the disks; this value is not accurate because we do // not know the storage class of the object yet minDisks := 0 if p := globalStorageClass.GetParityForSC(""); p > -1 { minDisks = er.setDriveCount - p } else { minDisks = er.setDriveCount - er.defaultParityCount }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
mu.Lock() defer mu.Unlock() allMerged = dataUsageCache{Info: dataUsageCacheInfo{Name: dataUsageRoot}} for _, info := range results { if info.Info.LastUpdate.IsZero() { // Not filled yet. return } allMerged.merge(info) } if allMerged.root() != nil && allMerged.Info.LastUpdate.After(lastUpdate) { updates <- allMerged.dui(allMerged.Info.Name, allBuckets)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/sts-handlers_test.go
err = s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled) if err != nil { c.Fatalf("Unable to set user: %v", err) } // confirm that the user is unable to access the bucket - we have not // yet set any policy uClient := s.getUserClient(c, accessKey, secretKey, "") c.mustNotListObjects(ctx, uClient, bucket) err = s.adm.UpdateGroupMembers(ctx, madmin.GroupAddRemove{ Group: "test-group",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
src/cmd/cgo/gcc.go
) if p.GccIsClang { c = append(c, "-ferror-limit=0", // Apple clang version 1.7 (tags/Apple/clang-77) (based on LLVM 2.9svn) // doesn't have -Wno-unneeded-internal-declaration, so we need yet another // flag to disable the warning. Yes, really good diagnostics, clang. "-Wno-unknown-warning-option", "-Wno-unneeded-internal-declaration", "-Wno-unused-function", "-Qunused-arguments",
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Nov 02 16:43:23 GMT 2023 - 97K bytes - Viewed (0)