Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for globalIsDistErasure (0.14 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 23 21:28:14 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. cmd/server-main.go

    	globalNodes = globalEndpoints.GetNodes()
    
    	globalIsErasure = (setupType == ErasureSetupType)
    	globalIsDistErasure = (setupType == DistErasureSetupType)
    	if globalIsDistErasure {
    		globalIsErasure = true
    	}
    	globalIsErasureSD = (setupType == ErasureSDSetupType)
    	if globalDynamicAPIPort && globalIsDistErasure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. cmd/globals.go

    	// The layout of disks as interpreted
    	Layout disksLayout
    }
    
    var (
    	// Global user opts context
    	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
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  7. cmd/handler-api.go

    		}
    	} else {
    		apiRequestsMaxPerNode = cfg.RequestsMax
    		if n := totalNodeCount(); n > 0 {
    			apiRequestsMaxPerNode /= n
    		}
    	}
    
    	if globalIsDistErasure {
    		logger.Info("Configured max API requests per node based on available memory: %d", apiRequestsMaxPerNode)
    	}
    
    	if cap(t.requestsPool) != apiRequestsMaxPerNode {
    		// Only replace if needed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. 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:%d", he.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints))
    		}
    
    		hsp = madmin.HealStopSuccess{
    			ClientToken:   clientToken,
    			ClientAddress: he.clientAddress,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top