Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for configRetriableErrors (0.31 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)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  2. 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) {
    				retryInterval := time.Duration(r.Float64() * float64(time.Second))
    				logger.Info("Waiting for all MinIO IAM sub-system to be initialized.. possible cause (%v) (retrying in %s)", err, retryInterval)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  3. 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
    					}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  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))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top