Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for globalIsDistErasure (0.48 sec)

  1. cmd/peer-rest-client.go

    // but 'all' will contain nil entry for local client.
    // The 'all' slice will be in the same order across the cluster.
    func newPeerRestClients(endpoints EndpointServerPools) (remote, all []*peerRESTClient) {
    	if !globalIsDistErasure {
    		// Only useful in distributed setups
    		return nil, nil
    	}
    
    	hosts := endpoints.hostsSorted()
    	remote = make([]*peerRESTClient, 0, len(hosts))
    	all = make([]*peerRESTClient, len(hosts))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. cmd/utils.go

    					xfix = xfix[xi+1:]
    					break
    				}
    			}
    		}
    	}
    	return xfix
    }
    
    // Returns the mode in which MinIO is running
    func getMinioMode() string {
    	switch {
    	case globalIsDistErasure:
    		return globalMinioModeDistErasure
    	case globalIsErasure:
    		return globalMinioModeErasure
    	case globalIsErasureSD:
    		return globalMinioModeErasureSD
    	default:
    		return globalMinioModeFS
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    				}
    			}
    			if g.metricsGroupOpts.dependGlobalLockServer {
    				if globalLockServer == nil {
    					return []MetricV2{}, nil
    				}
    			}
    			if g.metricsGroupOpts.dependGlobalIsDistErasure {
    				if !globalIsDistErasure {
    					return []MetricV2{}, nil
    				}
    			}
    			if g.metricsGroupOpts.dependGlobalBackgroundHealState {
    				if globalBackgroundHealState == nil {
    					return []MetricV2{}, nil
    				}
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    		}
    	)
    
    	// Maximum number of reusable buffers per node at any given point in time.
    	n := uint64(1024) // single node single/multiple drives set this to 1024 entries
    
    	if globalIsDistErasure {
    		n = 2048
    	}
    
    	// Avoid allocating more than half of the available memory
    	if maxN := availableMemory() / (blockSizeV2 * 2); n > maxN {
    		n = maxN
    	}
    
    	if globalIsCICD || strconv.IntSize == 32 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  5. cmd/iam.go

    		if err == nil {
    			globalSiteReplicatorCred.Set(sa.Credentials.SecretKey)
    		}
    	}
    
    	if firstTime {
    		bootstrapTraceMsg(fmt.Sprintf("globalIAMSys.Load(): (duration: %s)", loadDuration))
    		if globalIsDistErasure {
    			logger.Info("IAM load(startup) finished. (duration: %s)", loadDuration)
    		}
    	}
    
    	select {
    	case <-sys.configLoaded:
    	default:
    		close(sys.configLoaded)
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    		crypto.EnvKMSAutoEncryption,
    		config.EnvAccessKey,
    		config.EnvSecretKey,
    		config.EnvRootUser,
    		config.EnvRootPassword,
    	} {
    		os.Unsetenv(env)
    	}
    
    	// Set as non-distributed.
    	globalIsDistErasure = false
    
    	// Disable printing console messages during tests.
    	color.Output = io.Discard
    	// Disable Error logging in testing.
    	logger.DisableLog = true
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top