- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for globalIsDistErasure (0.48 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 23 21:28:14 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/metrics-v3-system-network.go
// // This is a `MetricsLoaderFn`. func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error { connStats := globalConnStats.toServerConnStats() rpcStats := rest.GetRPCStats() if globalIsDistErasure { m.Set(internodeErrorsTotal, float64(rpcStats.Errs)) m.Set(internodeDialErrorsTotal, float64(rpcStats.DialErrs)) m.Set(internodeDialAvgTimeNanos, float64(rpcStats.DialAvgDuration))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.4K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (3) -
cmd/routers.go
// Initialize router. `SkipClean(true)` stops minio/mux from // normalizing URL path minio/minio#3256 router := mux.NewRouter().SkipClean(true).UseEncodedPath() // Initialize distributed NS lock. if globalIsDistErasure { registerDistErasureRouters(router, endpointServerPools) } // Add Admin router, all APIs are enabled in server mode. registerAdminRouter(router, true) // Add healthCheck router
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Mar 08 19:08:18 UTC 2024 - 3.6K bytes - Viewed (0) -
cmd/admin-server-info.go
func getLocalServerProperty(endpointServerPools EndpointServerPools, r *http.Request, metrics bool) madmin.ServerProperties { addr := globalLocalNodeName if r != nil { addr = r.Host } if globalIsDistErasure { addr = globalLocalNodeName } poolNumbers := make(map[int]struct{}) network := make(map[string]string) for _, ep := range endpointServerPools { for _, endpoint := range ep.Endpoints {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
m.Set(processUptimeSeconds, time.Since(globalBootTime).Seconds()) } p, err := procfs.Self() if err != nil { metricsLogIf(ctx, err) } else { loadProcFSMetrics(ctx, p, m) } if globalIsDistErasure && globalLockServer != nil { st := globalLockServer.stats() m.Set(processLocksReadTotal, float64(st.Reads)) m.Set(processLocksWriteTotal, float64(st.Writes)) } return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 26 16:07:23 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/metrics-realtime.go
} } metrics[d.Endpoint] = dm } return metrics } func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if !globalIsDistErasure { return } all := globalNotificationSys.GetMetrics(ctx, types, opts) for _, remote := range all { m.Merge(&remote) } return m
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/consolelogger.go
return true } // SetNodeName - sets the node name if any after distributed setup has initialized func (sys *HTTPConsoleLoggerSys) SetNodeName(nodeName string) { if !globalIsDistErasure { sys.nodeName = "" return } host, err := xnet.ParseHost(globalLocalNodeName) if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
cmd/lock-rest-server.go
lockValidityDuration = 1 * time.Minute ) // lockMaintenance loops over all locks and discards locks // that have not been refreshed for some time. func lockMaintenance(ctx context.Context) { if !globalIsDistErasure { return } // Initialize a new ticker with 1 minute between each ticks. lkTimer := time.NewTimer(lockMaintenanceInterval) // Stop the timer upon returning. defer lkTimer.Stop() for {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 5.9K bytes - Viewed (0) -
cmd/admin-handlers.go
peerResults := make(map[string]madmin.ServerPeerUpdateStatus) local := globalLocalNodeName if local == "" { local = "127.0.0.1" } failedClients := make(map[int]struct{}) if globalIsDistErasure { // Push binary to other servers for idx, nerr := range globalNotificationSys.VerifyBinary(ctx, u, sha256Sum, releaseInfo, binC) { if nerr.Err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0)