mirror of
https://github.com/minio/minio.git
synced 2025-01-24 13:13:16 -05:00
replication: fix audit log reporting (#17222)
This commit is contained in:
parent
aaf1abc993
commit
2131046427
@ -1031,11 +1031,13 @@ func replicateObject(ctx context.Context, ri ReplicateObjectInfo, objectAPI Obje
|
|||||||
}(i, tgt)
|
}(i, tgt)
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
||||||
|
replicationStatus = rinfos.ReplicationStatus() // used in defer function
|
||||||
// FIXME: add support for missing replication events
|
// FIXME: add support for missing replication events
|
||||||
// - event.ObjectReplicationMissedThreshold
|
// - event.ObjectReplicationMissedThreshold
|
||||||
// - event.ObjectReplicationReplicatedAfterThreshold
|
// - event.ObjectReplicationReplicatedAfterThreshold
|
||||||
eventName := event.ObjectReplicationComplete
|
eventName := event.ObjectReplicationComplete
|
||||||
if rinfos.ReplicationStatus() == replication.Failed {
|
if replicationStatus == replication.Failed {
|
||||||
eventName = event.ObjectReplicationFailed
|
eventName = event.ObjectReplicationFailed
|
||||||
}
|
}
|
||||||
newReplStatusInternal := rinfos.ReplicationStatusInternal()
|
newReplStatusInternal := rinfos.ReplicationStatusInternal()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user