Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for addPartialOp (0.28 sec)

  1. cmd/mrf.go

    // related to the global background MRF.
    type mrfState struct {
    	opCh chan partialOperation
    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    func (m *mrfState) addPartialOp(op partialOperation) {
    	if m == nil {
    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    	}
    }
    
    var healSleeper = newDynamicSleeper(5, time.Second, false)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    		// buckets only and not the quourum lost ones like this, so
    		// explicit call
    		for bktName, count := range bucketsMap {
    			if count < quorum {
    				// Queue a bucket heal task
    				globalMRFState.addPartialOp(partialOperation{
    					bucket: bktName,
    					queued: time.Now(),
    				})
    			}
    		}
    	}
    
    	result := make([]BucketInfo, 0, len(resultMap))
    	for _, bi := range resultMap {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    				case errors.Is(err, errFileCorrupt):
    					scan = madmin.HealDeepScan
    				}
    				switch scan {
    				case madmin.HealNormalScan, madmin.HealDeepScan:
    					healOnce.Do(func() {
    						globalMRFState.addPartialOp(partialOperation{
    							bucket:    bucket,
    							object:    object,
    							versionID: fi.VersionID,
    							queued:    time.Now(),
    							setIndex:  er.setIndex,
    							poolIndex: er.poolIndex,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  4. cmd/erasure-multipart.go

    		return ObjectInfo{}, toObjectErr(err, bucket, object, uploadID)
    	}
    
    	if !opts.Speedtest && len(versions) > 0 {
    		globalMRFState.addPartialOp(partialOperation{
    			bucket:    bucket,
    			object:    object,
    			queued:    time.Now(),
    			versions:  versions,
    			setIndex:  er.setIndex,
    			poolIndex: er.poolIndex,
    		})
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
Back to top