diff --git a/handlers/cassandra/cassandra.go b/handlers/cassandra/cassandra.go index 2208d5b..7699dde 100644 --- 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")