Skip to content

Commit

Permalink
MB-41694 - log default or non-default replication update msg correctly
Browse files Browse the repository at this point in the history
Change-Id: I8a3ad296fb7d1471cf6909d355f88beef4d44ec6
Reviewed-on: http://review.couchbase.org/c/goxdcr/+/136977
Reviewed-by: Lilei Chen <lilei.chen@couchbase.com>
Reviewed-by: Neil Huang <neil.huang@couchbase.com>
Tested-by: Neil Huang <neil.huang@couchbase.com>
  • Loading branch information
nelio2k committed Sep 28, 2020
1 parent b1d0464 commit 400e7a3
Showing 1 changed file with 9 additions and 5 deletions.
14 changes: 9 additions & 5 deletions replication_manager/replication_manager.go
Expand Up @@ -1128,7 +1128,7 @@ func writeCreateReplicationEvent(spec *metadata.ReplicationSpecification, realUs
}

func writeUpdateDefaultReplicationSettingsEvent(changedSettingsMap *metadata.ReplicationSettingsMap, realUserId *service_def.RealUserId, localRemoteIPs *service_def.LocalRemoteIPs) {
event, err := constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap, realUserId, localRemoteIPs)
event, err := constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap, realUserId, localRemoteIPs, true)
if err == nil {
err = AuditService().Write(service_def.UpdateDefaultReplicationSettingsEventId, event)
}
Expand All @@ -1139,7 +1139,7 @@ func writeUpdateReplicationSettingsEvent(spec *metadata.ReplicationSpecification
replicationSpecificFields, err := constructReplicationSpecificFieldsFromSpec(spec)
if err == nil {
var updateDefaultReplicationSettingsEvent *service_def.UpdateDefaultReplicationSettingsEvent
updateDefaultReplicationSettingsEvent, err = constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap, realUserId, localRemoteIPs)
updateDefaultReplicationSettingsEvent, err = constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap, realUserId, localRemoteIPs, false)
if err == nil {
updateReplicationSettingsEvent := &service_def.UpdateReplicationSettingsEvent{
ReplicationSpecificFields: *replicationSpecificFields,
Expand Down Expand Up @@ -1192,8 +1192,12 @@ func constructGenericReplicationEvent(spec *metadata.ReplicationSpecification, r
ReplicationSpecificFields: *replicationSpecificFields}, nil
}

func constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap *metadata.ReplicationSettingsMap, realUserId *service_def.RealUserId, localRemoteIPs *service_def.LocalRemoteIPs) (*service_def.UpdateDefaultReplicationSettingsEvent, error) {
logger_rm.Info("Start constructUpdateDefaultReplicationSettingsEvent....")
func constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap *metadata.ReplicationSettingsMap, realUserId *service_def.RealUserId, localRemoteIPs *service_def.LocalRemoteIPs, forDefaultReplication bool) (*service_def.UpdateDefaultReplicationSettingsEvent, error) {
var eventName = "constructUpdateDefaultReplicationSettingsEvent"
if !forDefaultReplication {
eventName = "constructUpdateReplicationSettingsEvent"
}
logger_rm.Infof("Start %v....", eventName)
genericReplicationFields, err := constructGenericReplicationFields(realUserId, localRemoteIPs)
if err != nil {
return nil, err
Expand All @@ -1208,7 +1212,7 @@ func constructUpdateDefaultReplicationSettingsEvent(changedSettingsMap *metadata
convertedSettingsMap[SettingsKeyToRestKeyMap[key]] = value
}
}
logger_rm.Info("Done constructUpdateDefaultReplicationSettingsEvent....")
logger_rm.Infof("Done %v....", eventName)

return &service_def.UpdateDefaultReplicationSettingsEvent{
GenericReplicationFields: *genericReplicationFields,
Expand Down

0 comments on commit 400e7a3

Please sign in to comment.