Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Chan (0.17 sec)

  1. cmd/object-api-interface.go

    type ObjectLayer interface {
    	// Locking operations on object.
    	NewNSLock(bucket string, objects ...string) RWLocker
    
    	// Storage operations.
    	Shutdown(context.Context) error
    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    	BackendInfo() madmin.BackendInfo
    	Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	for i := range errs {
    		errs[i] = errDiskOngoingReq
    	}
    
    	done := make(chan bool, er.setDriveCount)
    	disks := er.getDisks()
    
    	ropts := ReadOptions{
    		ReadData:         readData,
    		InclFreeVersions: opts.InclFreeVersions,
    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    			if disk == nil || !disk.IsOnline() {
    				parityDrives++
    				offlineDrives++
    				continue
    			}
    		}
    
    		if offlineDrives >= (len(onlineDisks)+1)/2 {
    			// if offline drives are more than 50% of the drives
    			// we have no quorum, we shouldn't proceed just
    			// fail at that point.
    			return nil, toObjectErr(errErasureWriteQuorum, bucket, object)
    		}
    
    		if parityDrives >= len(onlineDisks)/2 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    			if !srcTimestamp.IsZero() {
    				ondiskTimestamp, err := time.Parse(time.RFC3339Nano, lastTaggingTimestamp)
    				// update tagging metadata only if replica  timestamp is newer than what's on disk
    				if err != nil || (err == nil && !ondiskTimestamp.After(srcTimestamp)) {
    					srcInfo.UserDefined[ReservedMetadataPrefixLower+TaggingTimestamp] = srcTimestamp.UTC().Format(time.RFC3339Nano)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top