memandra metrics : add L2 C* batch metrics

BarthV · Mar 12, 2018 · 7678326 · 7678326
1 parent 03c2364
commit 7678326
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/handlers/cassandra/cassandra.go b/handlers/cassandra/cassandra.go
@@ -54,7 +54,6 @@ func bufferSizeCheckLoop() {
 }
 
 func flushBuffer() {
-	metrics.IncCounter(MetricCmdSetL2Batch)
 	/* if singleton.isFlushing {
 		return
 	}
@@ -66,6 +65,8 @@ func flushBuffer() {
 	chanLen := len(singleton.setbuffer)
 
 	if chanLen > 0 {
+		metrics.IncCounter(MetricCmdSetL2Batch)
+
 		// fmt.Println(chanLen)
 		if chanLen >= viper.GetInt("CassandraBatchMaxItemSize") {
 			chanLen = viper.GetInt("CassandraBatchMaxItemSize")