Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for globalIsDistErasure (0.1 sec)

  1. cmd/utils_test.go

    		if mode := getMinioMode(); mode != expected {
    			t.Fatalf("Expected %s got %s", expected, mode)
    		}
    	}
    	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/server-startup-msg.go

    	return "%" + formatStr
    }
    
    // Prints the formatted startup message.
    func printStartupMessage(apiEndpoints []string, err error) {
    	banner := strings.Repeat("-", len(MinioBannerName))
    	if globalIsDistErasure {
    		logger.Startup(color.Bold(banner))
    	}
    	logger.Startup(color.Bold(MinioBannerName))
    	if err != nil {
    		if globalConsoleSys != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    	if err != nil {
    		adminLogIf(ctx, fmt.Errorf("server update failed with %w", err))
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	if globalIsDistErasure {
    		// Push binary to other servers
    		for idx, nerr := range globalNotificationSys.VerifyBinary(ctx, u, sha256Sum, releaseInfo, binC) {
    			if nerr.Err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    			}
    
    			disk.SetDiskID(format.Erasure.This)
    			s.erasureDisks[setIndex][diskIndex] = disk
    
    			if disk.IsLocal() {
    				globalLocalDrivesMu.Lock()
    				if globalIsDistErasure {
    					globalLocalSetDrives[s.poolIndex][setIndex][diskIndex] = disk
    				}
    				globalLocalDrivesMap[disk.Endpoint().String()] = disk
    				globalLocalDrivesMu.Unlock()
    			}
    			s.erasureDisksMu.Unlock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  5. 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
    		}
    	}
    	updatedAt = UTCNow()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  6. cmd/consolelogger.go

    	return true
    }
    
    // SetNodeName - sets the node name if any after distributed setup has initialized
    func (sys *HTTPConsoleLoggerSys) SetNodeName(nodeName string) {
    	if !globalIsDistErasure {
    		sys.nodeName = ""
    		return
    	}
    
    	host, err := xnet.ParseHost(globalLocalNodeName)
    	if err != nil {
    		logger.FatalIf(err, "Unable to start console logging subsystem")
    	}
    
    	sys.nodeName = host.Name
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  7. cmd/tier.go

    	return cfg, nil
    }
    
    // Init initializes tier configuration reading from objAPI
    func (config *TierConfigMgr) Init(ctx context.Context, objAPI ObjectLayer) error {
    	err := config.Reload(ctx, objAPI)
    	if globalIsDistErasure {
    		go config.refreshTierConfig(ctx, objAPI)
    	}
    	return err
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  8. cmd/handler-utils.go

    				r.Method, r.URL.Path),
    			HTTPStatusCode: http.StatusBadRequest,
    		}, r.URL)
    	}
    }
    
    // gets host name for current node
    func getHostName(r *http.Request) (hostName string) {
    	if globalIsDistErasure {
    		hostName = globalLocalNodeName
    	} else {
    		hostName = r.Host
    	}
    	return
    }
    
    // Proxy any request to an endpoint.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  9. cmd/admin-heal-ops.go

    	he, exists := ahs.getHealSequence(path)
    	if !exists {
    		hsp = madmin.HealStopSuccess{
    			ClientToken: "unknown",
    			StartTime:   UTCNow(),
    		}
    	} else {
    		clientToken := he.clientToken
    		if globalIsDistErasure {
    			clientToken = fmt.Sprintf("%s%s%d", he.clientToken, getKeySeparator(), GetProxyEndpointLocalIndex(globalProxyEndpoints))
    		}
    
    		hsp = madmin.HealStopSuccess{
    			ClientToken:   clientToken,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  10. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
Back to top