- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for globalIsDistErasure (0.14 sec)
-
cmd/utils_test.go
if mode := getMinioMode(); mode != expected { t.Fatalf("Expected %s got %s", expected, mode) } } globalIsDistErasure = true testMinioMode(globalMinioModeDistErasure) globalIsDistErasure = false globalIsErasure = true testMinioMode(globalMinioModeErasure) globalIsDistErasure, globalIsErasure = false, false testMinioMode(globalMinioModeFS)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Feb 23 21:28:14 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/server-main.go
globalNodes = globalEndpoints.GetNodes() globalIsErasure = (setupType == ErasureSetupType) globalIsDistErasure = (setupType == DistErasureSetupType) if globalIsDistErasure { globalIsErasure = true } globalIsErasureSD = (setupType == ErasureSDSetupType) if globalDynamicAPIPort && globalIsDistErasure {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (1) -
cmd/bucket-metadata-sys.go
} if isMinioMetaBucketName(bucket) { return updatedAt, errInvalidArgument } meta, err := loadBucketMetadataParse(ctx, objAPI, bucket, parse) if err != nil { if !globalIsErasure && !globalIsDistErasure && errors.Is(err, errVolumeNotFound) { // Only single drive mode needs this fallback. meta = newBucketMetadata(bucket) } else { return updatedAt, err } } updatedAt = UTCNow()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/erasure-sets.go
} disk.SetDiskID(format.Erasure.This) s.erasureDisks[setIndex][diskIndex] = disk if disk.IsLocal() { globalLocalDrivesMu.Lock() if globalIsDistErasure { globalLocalSetDrives[s.poolIndex][setIndex][diskIndex] = disk } globalLocalDrivesMap[disk.Endpoint().String()] = disk globalLocalDrivesMu.Unlock() } s.erasureDisksMu.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
cmd/globals.go
// The layout of disks as interpreted Layout disksLayout } var ( // Global user opts context globalServerCtxt serverCtxt // Indicates if the running minio server is distributed setup. globalIsDistErasure = false // Indicates if the running minio server is an erasure-code backend. globalIsErasure = false // Indicates if the running minio server is in single drive XL mode. globalIsErasureSD = false
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/admin-router.go
// Metrics operation adminRouter.Methods(http.MethodGet).Path(adminVersion + "/metrics").HandlerFunc(adminMiddleware(adminAPI.MetricsHandler, traceHdrsS3HFlag)) if globalIsDistErasure || globalIsErasure { // Heal operations // Heal processing endpoint. adminRouter.Methods(http.MethodPost).Path(adminVersion + "/heal/").HandlerFunc(adminMiddleware(adminAPI.HealHandler, traceAllFlag))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 21 11:35:40 UTC 2024 - 26.2K bytes - Viewed (0) -
cmd/handler-api.go
} } else { apiRequestsMaxPerNode = cfg.RequestsMax if n := totalNodeCount(); n > 0 { apiRequestsMaxPerNode /= n } } if globalIsDistErasure { logger.Info("Configured max API requests per node based on available memory: %d", apiRequestsMaxPerNode) } if cap(t.requestsPool) != apiRequestsMaxPerNode { // Only replace if needed.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
he, exists := ahs.getHealSequence(path) if !exists { hsp = madmin.HealStopSuccess{ ClientToken: "unknown", StartTime: UTCNow(), } } else { clientToken := he.clientToken if globalIsDistErasure { clientToken = fmt.Sprintf("%s:%d", he.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints)) } hsp = madmin.HealStopSuccess{ ClientToken: clientToken, ClientAddress: he.clientAddress,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/handler-utils.go
r.Method, r.URL.Path), HTTPStatusCode: http.StatusBadRequest, }, r.URL) } } // gets host name for current node func getHostName(r *http.Request) (hostName string) { if globalIsDistErasure { hostName = globalLocalNodeName } else { hostName = r.Host } return } // Proxy any request to an endpoint.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/tier.go
return cfg, nil } // Init initializes tier configuration reading from objAPI func (config *TierConfigMgr) Init(ctx context.Context, objAPI ObjectLayer) error { err := config.Reload(ctx, objAPI) if globalIsDistErasure { go config.refreshTierConfig(ctx, objAPI) } return err
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 15.7K bytes - Viewed (0)