Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Loaded (0.19 sec)

  1. cmd/erasure-server-pool.go

    		globalLocalDrivesMu.Unlock()
    	}
    
    	z.decommissionCancelers = make([]context.CancelFunc, len(z.serverPools))
    
    	// Initialize the pool meta, but set it to not save.
    	// When z.Init below has loaded the poolmeta will be initialized,
    	// and allowed to save.
    	z.poolMeta = newPoolMeta(z, poolMeta{})
    	z.poolMeta.dontSave = true
    
    	bootstrapTrace("newSharedLock", func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/config-current.go

    	return readServerConfig(GlobalContext, objAPI, nil)
    }
    
    // loadConfig - loads a new config from disk, overrides params
    // from env if found and valid
    // data is optional. If nil it will be loaded from backend.
    func loadConfig(objAPI ObjectLayer, data []byte) error {
    	bootstrapTraceMsg("load the configuration")
    	srvCfg, err := readServerConfig(GlobalContext, objAPI, data)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    	globalEndpoints = EndpointServerPools{}
    }
    
    func resetGlobalIsErasure() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/format-erasure.go

    	if err := saveFormatErasureAll(ctx, storageDisks, formats); err != nil {
    		return nil, err
    	}
    
    	return getFormatErasureInQuorum(formats)
    }
    
    // ecDrivesNoConfig returns the erasure coded drives in a set if no config has been set.
    // It will attempt to read it from env variable and fall back to drives/2.
    func ecDrivesNoConfig(setDriveCount int) (int, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    	healDeleteDangling   = true
    	healObjectSelectProb = 1024 // Overall probability of a file being scanned; one in n.
    )
    
    var (
    	globalHealConfig heal.Config
    
    	// Sleeper values are updated when config is loaded.
    	scannerSleeper                       = newDynamicSleeper(2, time.Second, true) // Keep defaults same as config defaults
    	scannerCycle                         = uatomic.NewDuration(dataScannerStartDelay)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    		return -1
    	}
    }
    
    // Returns always a same erasure coded set for a given input.
    func (s *erasureSets) getHashedSetIndex(input string) int {
    	return hashKey(s.distributionAlgo, input, len(s.sets), s.deploymentID)
    }
    
    // Returns always a same erasure coded set for a given input.
    func (s *erasureSets) getHashedSet(input string) (set *erasureObjects) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  7. cmd/metrics-v3.go

    		clusterAuditMG,
    		clusterNotificationMG,
    		clusterIAMMG,
    	}
    
    	// Bucket metrics are special, they always include the bucket label. These
    	// metrics required a list of buckets to be passed to the loader, and the list
    	// of buckets is not known until the request is made. So we keep a separate
    	// map for bucket metrics and handle them specially.
    
    	// Add the serverName and poolIndex labels to all non-cluster metrics.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	}
    	globalIsErasureSD = (setupType == ErasureSDSetupType)
    	if globalDynamicAPIPort && globalIsDistErasure {
    		logger.FatalIf(errInvalidArgument, "Invalid --address=\"%s\", port '0' is not allowed in a distributed erasure coded setup", ctxt.Addr)
    	}
    
    	globalLocalNodeName = GetLocalPeer(globalEndpoints, globalMinioHost, globalMinioPort)
    	nodeNameSum := sha256.Sum256([]byte(globalLocalNodeName))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
Back to top