Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for globalIsDistErasure (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top