- Sort Score
- Num 10 results
- Language All
Results 221 - 230 of 239 for reached (0.05 seconds)
-
cmd/storage-rest-server.go
return false } storage := newXLStorageDiskIDCheck(xl, true) storage.SetDiskID(xl.diskID) // We do not have to do SetFormatData() since 'xl' // already captures formatData cached. globalLocalDrivesMu.Lock() defer globalLocalDrivesMu.Unlock() globalLocalDrivesMap[endpoint.String()] = storage
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
cmd/batch-handlers.go
"gopkg.in/yaml.v3" ) var globalBatchConfig batch.Config const ( // Keep the completed/failed job stats 3 days before removing it oldJobsExpiration = 3 * 24 * time.Hour redactedText = "**REDACTED**" ) // BatchJobRequest this is an internal data structure not for external consumption. type BatchJobRequest struct { ID string `yaml:"-" json:"name"`
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
cmd/server_test.go
var buffer2 bytes.Buffer // retrieve the contents of response body. n, err := io.Copy(&buffer2, response.Body) c.Assert(err, nil) c.Assert(n, int64(len([]byte("hello world")))) // asserted the contents of the fetched object with the expected result. c.Assert(true, bytes.Equal(buffer2.Bytes(), []byte("hello world"))) // Test the response when object name ends with a slash.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 118.1K bytes - Click Count (0) -
cmd/erasure-multipart.go
} // Fetch buffer for I/O, returns from the pool if not allocates a new one and returns. var buffer []byte switch size := data.Size(); { case size == 0: buffer = make([]byte, 1) // Allocate at least a byte to reach EOF case size >= fi.Erasure.BlockSize || size == -1: if int64(globalBytePoolCap.Load().Width()) < fi.Erasure.BlockSize { buffer = make([]byte, fi.Erasure.BlockSize, 2*fi.Erasure.BlockSize) } else {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 47.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
if (!closed) { put(closeable, executor); return; } } closeQuietly(closeable, executor); } /** * Returns a latch that reaches zero when this objects' deferred closeables have been closed. */ CountDownLatch whenClosedCountDown() { if (closed) { return new CountDownLatch(0); } synchronized (this) {
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) -
android/guava/src/com/google/common/collect/ImmutableSortedMap.java
throw new UnsupportedOperationException(); } @Override public ImmutableSortedMap<K, V> descendingMap() { // TODO(kevinb): The descendingMap is never actually cached at all. Either: // // - Cache it, and annotate the field with @LazyInit. // - Simplify the code below, and consider eliminating the field (b/287198172), which is also // set by one of the constructors.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 21:07:18 GMT 2025 - 52.9K bytes - Click Count (0) -
cmd/iam.go
lookupRes, actualGroups, _ := sys.LDAPConfig.GetValidatedDNWithGroups(user) if lookupRes != nil { groupSet := set.CreateStringSet(actualGroups...) // duplicates can be overwritten, fetched groups should be identical. cleanQ.Users[lookupRes.NormDN] = groupSet } // Search for non-normalized DN as well for backward compatibility. if _, ok := cleanQ.Users[user]; !ok { cleanQ.Users[user] = nil
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt
* q: cute #puppies * f: images * ``` * * In addition to composing URLs from their component parts and decomposing URLs into their * component parts, this class implements relative URL resolution: what address you'd reach by * clicking a relative link on a specified page. For example: * * ```java * HttpUrl base = HttpUrl.parse("https://www.youtube.com/user/WatchTheDaily/videos"); * HttpUrl link = base.resolve("../../watch?v=cbP2N1BQdYc");
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon May 05 16:01:00 GMT 2025 - 63.5K bytes - Click Count (0) -
okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list
is-a-painter.com is-a-patsfan.org is-a-personaltrainer.com is-a-photographer.com is-a-player.com is-a-republican.com is-a-rockstar.com is-a-socialist.com is-a-soxfan.org is-a-student.com is-a-teacher.com is-a-techie.com is-a-therapist.com is-a.dev is-an-accountant.com is-an-actor.com is-an-actress.com is-an-anarchist.com is-an-artist.com is-an-engineer.com is-an-entertainer.com
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 22:00:49 GMT 2025 - 129.6K bytes - Click Count (3) -
cmd/admin-handlers-users.go
}) } sort.Slice(buckets, func(i, j int) bool { return buckets[i].Name < buckets[j].Name }) } else { buckets, err = objectAPI.ListBuckets(ctx, BucketOptions{Cached: true}) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } accountName := cred.AccessKey if cred.IsTemp() || cred.IsServiceAccount() {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 90.6K bytes - Click Count (0)