Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for ri (0.03 seconds)

  1. cmd/bucket-replication-utils.go

    }
    
    // ToMRFEntry returns the relevant info needed by MRF
    func (ri ReplicateObjectInfo) ToMRFEntry() MRFReplicateEntry {
    	return MRFReplicateEntry{
    		Bucket:     ri.Bucket,
    		Object:     ri.Name,
    		versionID:  ri.VersionID,
    		sz:         ri.Size,
    		RetryCount: int(ri.RetryCount),
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  2. cmd/bucket-replication.go

    			}
    		}
    		return
    	}
    
    	var ch, healCh chan<- ReplicationWorkerOperation
    	switch ri.OpType {
    	case replication.HealReplicationType, replication.ExistingObjectReplicationType:
    		ch = p.mrfReplicaCh
    		healCh = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size)
    	default:
    		ch = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size)
    	}
    	if ch == nil && healCh == nil {
    		return
    	}
    
    	select {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  3. cmd/erasure-server-pool.go

    		}
    
    		if loi.NextMarker != "" {
    			loi.NextMarker = opts.encodeMarker(loi.NextMarker)
    		}
    		return loi, nil
    	}
    	ri := logger.GetReqInfo(ctx)
    	hadoop := ri != nil && strings.Contains(ri.UserAgent, "Hadoop ") && strings.Contains(ri.UserAgent, "scala/")
    	matches := func() bool {
    		if prefix == "" {
    			return false
    		}
    		// List of standard files supported by s3a
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  4. cmd/erasure-object.go

    		} else {
    			errStr = "<nil>"
    		}
    		tags[fmt.Sprintf("ddisk-%d", index)] = errStr
    	}
    
    	return m, nil
    }
    
    func fileInfoFromRaw(ri RawFileInfo, bucket, object string, readData, inclFreeVers bool) (FileInfo, error) {
    	return getFileInfo(ri.Buf, bucket, object, "", fileInfoOpts{
    		Data:             readData,
    		InclFreeVersions: inclFreeVers,
    	})
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
Back to Top