- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for Graves (0.14 sec)
-
cmd/erasure-object_test.go
if err != nil { t.Fatal(err) } // Object was uploaded with 4 known bad drives, so we should still be able to lose 3 drives and still write to the object. erasureDisks = xl.getDisks() z.serverPools[0].erasureDisksMu.Lock() xl.getDisks = func() []StorageAPI { erasureDisks[7] = nil erasureDisks[8] = nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-heal_test.go
func TestErasureHeal(t *testing.T) { for i, test := range erasureHealTests { if test.offDisks < test.badStaleDisks { // test case sanity check t.Fatalf("Test %d: Bad test case - number of stale drives cannot be less than number of badstale drives", i) } // create some test data setup, err := newErasureTestSetup(t, test.dataBlocks, test.disks-test.dataBlocks, test.blocksize) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/config/heal/help.go
return config.DefaultHelpPostfix(DefaultKVS, key) } // Help provides help for config values Help = config.HelpKVS{ config.HelpKV{ Key: Bitrot, Description: `perform bitrot scan on drives when checking objects during scanner` + defaultHelpPostfix(Bitrot), Optional: true, Type: "on|off", }, config.HelpKV{ Key: Sleep,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 1.8K bytes - Viewed (0) -
cmd/metrics.go
"Total number of offline drives in current MinIO server instance", nil, nil), prometheus.GaugeValue, float64(offlineDisks.Sum()), ) // MinIO Total Disks per node ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(minioNamespace, "drives", "total"), "Total number of drives for current MinIO server instance", nil, nil),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/grid/trace.go
if t == nil || t.Publisher.NumSubscribers(t.TraceType) == 0 { return c.roundtrip(h, req) } // Following trimming is needed for consistency between outputs with other internode traces. local := strings.TrimPrefix(strings.TrimPrefix(t.Local, httpsScheme), httpScheme) remote := strings.TrimPrefix(strings.TrimPrefix(t.Remote, httpsScheme), httpScheme) start := time.Now() body := bytesOrLength(req)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
cmd/metrics-v2.go
Subsystem: "health", Name: "erasure_set_online_drives", Help: "Get the count of the online drives in this erasure set", Type: gaugeMetric, } } func getClusterErasureSetHealingDrivesMD() MetricDescription { return MetricDescription{ Namespace: clusterMetricNamespace, Subsystem: "health", Name: "erasure_set_healing_drives",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/globals.go
globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners globalConsoleSys *HTTPConsoleLoggerSys // All unique drives for this deployment globalEndpoints EndpointServerPools // All unique nodes for this deployment globalNodes []Node // The name of this local node, fetched from arguments globalLocalNodeName string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/object-api-errors.go
func (e SlowDown) Error() string { return "Please reduce your request rate" } // RQErrType reason for read quorum error. type RQErrType int const ( // RQInsufficientOnlineDrives - not enough online drives. RQInsufficientOnlineDrives RQErrType = 1 << iota // RQInconsistentMeta - inconsistent metadata. RQInconsistentMeta ) func (t RQErrType) String() string { switch t { case RQInsufficientOnlineDrives:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0)