- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for globalIsDistErasure (0.11 sec)
-
cmd/server-startup-msg.go
return "%" + formatStr } // Prints the formatted startup message. func printStartupMessage(apiEndpoints []string, err error) { banner := strings.Repeat("-", len(MinioBannerName)) if globalIsDistErasure { logger.Startup(color.Bold(banner)) } logger.Startup(color.Bold(MinioBannerName)) if err != nil { if globalConsoleSys != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 23 14:11:35 UTC 2024 - 6.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 Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.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 Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jun 20 17:55:03 UTC 2024 - 6.5K bytes - Viewed (0) -
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.9K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (1) -
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 Nov 03 19:28:11 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/http-tracer.go
} inputBytes := reqRecorder.Size() for k, v := range reqHeaders { inputBytes += len(k) + len(v) } // Calculate node name nodeName := r.Host if globalIsDistErasure { nodeName = globalLocalNodeName } if host, port, err := net.SplitHostPort(nodeName); err == nil { if port == "443" || port == "80" { nodeName = host } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 6K bytes - Viewed (0)