Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 38 for system (0.16 sec)

  1. cmd/xl-storage.go

    	uuid := mustGetUUID()
    	filePath := pathJoin(s.drivePath, minioMetaTmpDeletedBucket, ".writable-check-"+uuid+".tmp")
    
    	// Create top level directories if they don't exist.
    	// with mode 0o777 mkdir honors system umask.
    	mkdirAll(pathutil.Dir(filePath), 0o777, s.drivePath) // don't need to fail here
    
    	w, err := s.openFileDirect(filePath, os.O_CREATE|os.O_WRONLY|os.O_EXCL)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    	"github.com/minio/minio/internal/hash/sha256"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/pkg/v2/sync/errgroup"
    )
    
    // Object was stored with additional erasure codes due to degraded system at upload time
    const minIOErasureUpgraded = "x-minio-internal-erasure-upgraded"
    
    const erasureAlgorithm = "rs-vandermonde"
    
    // GetChecksumInfo - get checksum of a part.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  3. cmd/test-utils_test.go

    	logger.DisableErrorLog = true
    
    	// Uncomment the following line to see trace logs during unit tests.
    	// logger.AddTarget(console.New())
    
    	// Set system resources to maximum.
    	setMaxResources(nil)
    
    	// Initialize globalConsoleSys system
    	globalConsoleSys = NewConsoleLogger(context.Background(), io.Discard)
    
    	globalInternodeTransport = NewInternodeHTTPTransport(0)()
    
    	initHelp()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    	return nil
    }
    
    // IAMStoreSys contains IAMStorageAPI to add higher-level methods on the storage
    // layer.
    type IAMStoreSys struct {
    	IAMStorageAPI
    }
    
    // HasWatcher - returns if the storage system has a watcher.
    func (store *IAMStoreSys) HasWatcher() bool {
    	_, ok := store.IAMStorageAPI.(iamStorageWatcher)
    	return ok
    }
    
    // GetUser - fetches credential from memory.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  5. cmd/site-replication.go

    	for {
    		select {
    		case <-healTimer.C:
    			c.RLock()
    			enabled := c.enabled
    			c.RUnlock()
    			if enabled {
    				refreshStart := time.Now()
    				c.healIAMSystem(ctx, objAPI) // heal IAM system first
    				c.healBuckets(ctx, objAPI)   // heal buckets subsequently
    
    				took := time.Since(refreshStart).Seconds()
    				if took > maxRefreshDurationSecondsForLog {
    					// Log if we took a lot of time.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  6. cmd/bucket-replication.go

    		}
    		uploadedParts = append(uploadedParts, minio.CompletePart{
    			PartNumber: pInfo.PartNumber,
    			ETag:       pInfo.ETag,
    		})
    	}
    
    	// really big value but its okay on heavily loaded systems. This is just tail end timeout.
    	cctx, ccancel := context.WithTimeout(ctx, 10*time.Minute)
    	defer ccancel()
    	_, err = c.CompleteMultipartUpload(cctx, bucket, object, uploadID, uploadedParts, minio.PutObjectOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  7. cmd/server-main.go

    	globalBucketMonitor = bandwidth.NewMonitor(ctx, uint64(totalNodeCount()))
    
    	// Create a new config system.
    	globalConfigSys = NewConfigSys()
    
    	// Create new IAM system.
    	globalIAMSys = NewIAMSys()
    
    	// Create new policy system.
    	globalPolicySys = NewPolicySys()
    
    	// Create new lifecycle system.
    	globalLifecycleSys = NewLifecycleSys()
    
    	// Create new bucket encryption subsystem
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  8. cmd/metrics-v3.go

    	systemNetworkInternodeCollectorPath collectorPath = "/system/network/internode"
    	systemDriveCollectorPath            collectorPath = "/system/drive"
    	systemMemoryCollectorPath           collectorPath = "/system/memory"
    	systemCPUCollectorPath              collectorPath = "/system/cpu"
    	systemProcessCollectorPath          collectorPath = "/system/process"
    	systemGoCollectorPath               collectorPath = "/system/go"
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  9. cmd/metrics-v3-types.go

    			if err := loader(ctx, m, c); err != nil {
    				return err
    			}
    		}
    		return nil
    	}
    }
    
    // BucketMetricsLoaderFn - represents a function to load metrics from the
    // metricsCache and the system for a given list of buckets.
    //
    // Note that returning an error here will cause the Metrics handler to return a
    // 500 Internal Server Error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:05:22 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  10. .github/workflows/multipart/migrate.sh

    	docker-compose -f docker-compose-site2.yaml rm -s -f || true
    	for volume in $(docker volume ls -q | grep minio); do
    		docker volume rm ${volume} || true
    	done
    
    	docker system prune -f || true
    	docker volume prune -f || true
    	docker volume rm $(docker volume ls -q -f dangling=true) || true
    }
    
    cleanup
    
    if [ ! -f ./mc ]; then
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 15:54:24 GMT 2024
    - 4.4K bytes
    - Viewed (0)
Back to top