From 3adc3a04555cd10694780b3a6c359f3c90a24390 Mon Sep 17 00:00:00 2001 From: Wei Han Date: Wed, 19 Jul 2017 10:37:12 -0700 Subject: [PATCH] replicator:only update per dest counters if the msg type is MESSAGE --- services/replicator/inconn.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/services/replicator/inconn.go b/services/replicator/inconn.go index f5374ef4..2131cdfa 100644 --- a/services/replicator/inconn.go +++ b/services/replicator/inconn.go @@ -175,7 +175,7 @@ func (conn *inConnection) writeMsgsStream() { // Update per destination metrics after msg is sent to local store (call is OpenReplicationRemoteRead) // so they're most accurate. - if conn.metricsScope == metrics.OpenReplicationRemoteReadScope { + if conn.metricsScope == metrics.OpenReplicationRemoteReadScope && msg.GetType() == store.ReadMessageContentType_MESSAGE { conn.destM3Client.IncCounter(conn.perDestMetricsScope, metrics.ReplicatorInConnPerDestMsgWritten) latency := time.Duration(time.Now().UnixNano() - msg.GetMessage().Message.GetEnqueueTimeUtc()) conn.destM3Client.RecordTimer(conn.perDestMetricsScope, metrics.ReplicatorInConnPerDestMsgLatency, latency)