- Sort Score
- Num 10 results
- Language All
Results 1 - 4 of 4 for ri (0.03 seconds)
-
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) -
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) -
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 s3aCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
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)