Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for configRetriableErrors (0.22 sec)

  1. cmd/server-main.go

    	globalTierConfigMgr = NewTierConfigMgr()
    
    	globalTransitionState = newTransitionState(GlobalContext)
    	globalSiteResyncMetrics = newSiteResyncMetrics(GlobalContext)
    }
    
    func configRetriableErrors(err error) bool {
    	if err == nil {
    		return false
    	}
    
    	notInitialized := strings.Contains(err.Error(), "Server not initialized, please try again") ||
    		errors.Is(err, errServerNotInitialized)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 33K bytes
    - Viewed (1)
  2. cmd/erasure-server-pool-decom.go

    						// A previous decommission running found restart it.
    						for _, idx := range poolIndices {
    							z.doDecommissionInRoutine(ctx, idx)
    						}
    						return
    					}
    					if configRetriableErrors(err) {
    						decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pools %v: %w: retrying..", pools, err))
    						time.Sleep(time.Second + time.Duration(r.Float64()*float64(5*time.Second)))
    						continue
    					}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  3. cmd/iam.go

    	// Migrate storage format if needed.
    	for {
    		// Migrate IAM configuration, if necessary.
    		if err := saveIAMFormat(retryCtx, sys.store); err != nil {
    			if configRetriableErrors(err) {
    				logger.Info("Waiting for all MinIO IAM sub-system to be initialized.. possible cause (%v)", err)
    				time.Sleep(time.Duration(r.Float64() * float64(time.Second)))
    				continue
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. cmd/erasure-server-pool.go

    	for {
    		var err error
    		bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() {
    			err = z.Init(ctx) // Initializes all pools.
    		})
    		if err != nil {
    			if !configRetriableErrors(err) {
    				logger.Fatal(err, "Unable to initialize backend")
    			}
    			retry := time.Duration(r.Float64() * float64(5*time.Second))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
Back to top