Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for globalIsErasure (0.11 sec)

  1. cmd/utils_test.go

    		}
    	}
    	globalIsDistErasure = true
    	testMinioMode(globalMinioModeDistErasure)
    
    	globalIsDistErasure = false
    	globalIsErasure = true
    	testMinioMode(globalMinioModeErasure)
    
    	globalIsDistErasure, globalIsErasure = false, false
    	testMinioMode(globalMinioModeFS)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers_test.go

    	ctx, cancel := context.WithCancel(ctx)
    
    	// reset global variables to start afresh.
    	resetTestGlobals()
    
    	// Set globalIsErasure to indicate that the setup uses an erasure
    	// code backend.
    	globalIsErasure = true
    
    	// Initializing objectLayer for HealFormatHandler.
    	objLayer, erasureDirs, xlErr := initTestErasureObjLayer(ctx)
    	if xlErr != nil {
    		cancel()
    		return nil, xlErr
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    		updates:               cache.Info.updates,
    		updateCurrentPath:     updatePath,
    		disks:                 disks,
    		disksQuorum:           len(disks) / 2,
    	}
    
    	var skipHeal atomic.Bool
    	if !globalIsErasure || cache.Info.SkipHealing {
    		skipHeal.Store(true)
    	}
    
    	// Check if we should do healing at all.
    	s.shouldHeal = func() bool {
    		if skipHeal.Load() {
    			return false
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  4. cmd/config-current.go

    		config.BatchSubSys:          batch.DefaultKVS,
    		config.BrowserSubSys:        browser.DefaultKVS,
    	}
    	maps.Copy(kvs, notify.DefaultNotificationKVS)
    	maps.Copy(kvs, lambda.DefaultLambdaKVS)
    	if globalIsErasure {
    		kvs[config.StorageClassSubSys] = storageclass.DefaultKVS
    		kvs[config.HealSubSys] = heal.DefaultKVS
    	}
    	config.RegisterDefaultKVS(kvs)
    
    	// Captures help for each sub-system
    	helpSubSys := config.HelpKVS{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  5. cmd/globals.go

    	globalServerCtxt serverCtxt
    
    	// Indicates if the running minio server is distributed setup.
    	globalIsDistErasure = false
    
    	// Indicates if the running minio server is an erasure-code backend.
    	globalIsErasure = false
    
    	// Indicates if the running minio server is in single drive XL mode.
    	globalIsErasureSD = false
    
    	// Indicates if server code should go through testing path.
    	globalIsTesting = false
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  6. cmd/server-main.go

    	logger.FatalIf(err, "Invalid command line arguments")
    	globalNodes = globalEndpoints.GetNodes()
    
    	globalIsErasure = (setupType == ErasureSetupType)
    	globalIsDistErasure = (setupType == DistErasureSetupType)
    	if globalIsDistErasure {
    		globalIsErasure = true
    	}
    	globalIsErasureSD = (setupType == ErasureSDSetupType)
    	if globalDynamicAPIPort && globalIsDistErasure {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  7. cmd/bucket-metadata-sys.go

    	}
    
    	if isMinioMetaBucketName(bucket) {
    		return updatedAt, errInvalidArgument
    	}
    
    	meta, err := loadBucketMetadataParse(ctx, objAPI, bucket, parse)
    	if err != nil {
    		if !globalIsErasure && !globalIsDistErasure && errors.Is(err, errVolumeNotFound) {
    			// Only single drive mode needs this fallback.
    			meta = newBucketMetadata(bucket)
    		} else {
    			return updatedAt, err
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  8. cmd/admin-router.go

    		// Metrics operation
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/metrics").HandlerFunc(adminMiddleware(adminAPI.MetricsHandler, traceHdrsS3HFlag))
    
    		if globalIsDistErasure || globalIsErasure {
    			// Heal operations
    
    			// Heal processing endpoint.
    			adminRouter.Methods(http.MethodPost).Path(adminVersion + "/heal/").HandlerFunc(adminMiddleware(adminAPI.HealHandler, traceAllFlag))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  9. cmd/utils.go

    			}
    		}
    	}
    	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
    	}
    }
    
    func iamPolicyClaimNameOpenID() string {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    	globalEndpoints = EndpointServerPools{}
    }
    
    func resetGlobalIsErasure() {
    	globalIsErasure = false
    }
    
    // reset global heal state
    func resetGlobalHealState() {
    	// Init global heal state
    	if globalAllHealState == nil {
    		globalAllHealState = newHealState(GlobalContext, false)
    	} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top