mirror of
https://github.com/minio/minio.git
synced 2025-01-24 13:13:16 -05:00
replication: remove check for empty version id (#17964)
This commit is contained in:
parent
18b3655c99
commit
d665e855de
@ -2960,8 +2960,8 @@ func getReplicationDiff(ctx context.Context, objAPI ObjectLayer, bucket string,
|
|||||||
|
|
||||||
// QueueReplicationHeal is a wrapper for queueReplicationHeal
|
// QueueReplicationHeal is a wrapper for queueReplicationHeal
|
||||||
func QueueReplicationHeal(ctx context.Context, bucket string, oi ObjectInfo, retryCount int) {
|
func QueueReplicationHeal(ctx context.Context, bucket string, oi ObjectInfo, retryCount int) {
|
||||||
// un-versioned or a prefix
|
// ignore modtime zero objects
|
||||||
if oi.VersionID == "" || oi.ModTime.IsZero() {
|
if oi.ModTime.IsZero() {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
rcfg, _ := getReplicationConfig(ctx, bucket)
|
rcfg, _ := getReplicationConfig(ctx, bucket)
|
||||||
@ -2975,8 +2975,8 @@ func QueueReplicationHeal(ctx context.Context, bucket string, oi ObjectInfo, ret
|
|||||||
// queueReplicationHeal enqueues objects that failed replication OR eligible for resyncing through
|
// queueReplicationHeal enqueues objects that failed replication OR eligible for resyncing through
|
||||||
// an ongoing resync operation or via existing objects replication configuration setting.
|
// an ongoing resync operation or via existing objects replication configuration setting.
|
||||||
func queueReplicationHeal(ctx context.Context, bucket string, oi ObjectInfo, rcfg replicationConfig, retryCount int) (roi ReplicateObjectInfo) {
|
func queueReplicationHeal(ctx context.Context, bucket string, oi ObjectInfo, rcfg replicationConfig, retryCount int) (roi ReplicateObjectInfo) {
|
||||||
// un-versioned or a prefix
|
// ignore modtime zero objects
|
||||||
if oi.VersionID == "" || oi.ModTime.IsZero() {
|
if oi.ModTime.IsZero() {
|
||||||
return roi
|
return roi
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user