- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Graves (0.21 sec)
-
android/guava/src/com/google/common/base/Preconditions.java
* which are <i>not the caller's fault</i>. Doing so is <b>not recommended</b> because it is * misleading to future readers of the code and of stack traces. See <a * href="https://github.com/google/guava/wiki/ConditionalFailuresExplained">Conditional failures * explained</a> in the Guava User Guide for more advice. Notably, {@link Verify} offers assertions
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 11 11:52:14 GMT 2024 - 52.9K bytes - Viewed (0) -
cmd/admin-handlers.go
// if a "restart/stop" was successful or not. Service signal now supports // a dry-run that helps skip the nodes that may have hung drives. By default // restart/stop will ignore the servers that are hung on drives. You can use // 'force' param to force restart even with hung drives if needed. func (a adminAPIHandlers) ServiceV2Handler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() vars := mux.Vars(r)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/erasure-server-pool.go
if errors.Is(err, errNoHealRequired) { countNoHeal++ } r.DiskCount += result.DiskCount r.SetCount += result.SetCount r.Before.Drives = append(r.Before.Drives, result.Before.Drives...) r.After.Drives = append(r.After.Drives, result.After.Drives...) } // No heal returned by all serverPools, return errNoHealRequired if countNoHeal == len(z.serverPools) { return r, errNoHealRequired }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(data2.streamId).isEqualTo(3) assertArrayEquals("fghi".toByteArray(), data2.data) } /** * Confirm that we account for discarded data frames. It's possible that data frames are in-flight * just prior to us canceling a stream. */ @Test fun discardedDataFramesAreCounted() { // Write the mocking script. peer.sendFrame().settings(Settings())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
writeTimeout = checkDuration("duration", duration) } /** * Sets the interval between HTTP/2 and web socket pings initiated by this client. Use this to * automatically send ping frames until either the connection fails or it is closed. This keeps * the connection alive and may detect connectivity failures. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/minio-dashboard.json
"editorMode": "builder", "expr": "minio_cluster_health_erasure_set_online_drives{job=~\"$scrape_jobs\"}", "fullMetaSearch": false, "hide": false, "includeNullMetadata": true, "instant": false, "legendFormat": "Pool {{pool}} / Set {{set}} - Online Drives", "range": true, "refId": "A", "useBackend": false },
Json - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 10:03:01 GMT 2024 - 93K bytes - Viewed (2) -
cmd/erasure-object.go
if disk == nil || !disk.IsOnline() { parityDrives++ offlineDrives++ continue } } if offlineDrives >= (len(storageDisks)+1)/2 { // if offline drives are more than 50% of the drives // we have no quorum, we shouldn't proceed just // fail at that point. return ObjectInfo{}, toObjectErr(errErasureWriteQuorum, bucket, object) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2) -
cmd/test-utils_test.go
// Special object test type for stale files situations. type objTestStaleFilesType func(obj ObjectLayer, instanceType string, dirs []string, t *testing.T) // ExecObjectLayerStaleFilesTest - executes object layer tests those leaves stale // files/directories under .minio/tmp. Creates Erasure ObjectLayer instance and runs test for Erasure layer. func ExecObjectLayerStaleFilesTest(t *testing.T, objTest objTestStaleFilesType) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
cmd/xl-storage.go
// ReadAll is a raw call, reads content at any path and returns the buffer. func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) { // Specific optimization to avoid re-read from the drives for `format.json` // in-case the caller is a network operation. if volume == minioMetaBucket && path == formatConfigFile { s.RLock() formatData := make([]byte, len(s.formatData))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirReferenceShortener.kt
return closestClassId == classId || (closestClassId != classIdOfAnother && closestClassId == classId.idWithoutCompanion()) } /** * Travels all containing classes of [innerClass] and finds the one matching ClassId with one of [candidates]. Returns the matching * ClassId. If it does not have a matching ClassId, it returns null. */
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 25 18:51:33 GMT 2024 - 69.5K bytes - Viewed (0)