fix: fix log bug in multi_get (#652)

apache · Dec 8, 2020 · 6a47a3b · 6a47a3b
1 parent 8da45c6
commit 6a47a3b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/rdsn b/rdsn
diff --git a/src/server/pegasus_server_impl.cpp b/src/server/pegasus_server_impl.cpp
@@ -492,7 +492,9 @@ void pegasus_server_impl::on_multi_get(multi_get_rpc rpc)
                 if (r == 1) {
                     count++;
                     auto &kv = resp.kvs.back();
-                    limiter->add_size(kv.key.length() + kv.value.length());
+                    uint64_t kv_size = kv.key.length() + kv.value.length();
+                    size += kv_size;
+                    limiter->add_size(kv_size);
                 } else if (r == 2) {
                     expire_count++;
                 } else { // r == 3
@@ -555,7 +557,9 @@ void pegasus_server_impl::on_multi_get(multi_get_rpc rpc)
                 if (r == 1) {
                     count++;
                     auto &kv = reverse_kvs.back();
-                    limiter->add_size(kv.key.length() + kv.value.length());
+                    uint64_t kv_size = kv.key.length() + kv.value.length();
+                    size += kv_size;
+                    limiter->add_size(kv_size);
                 } else if (r == 2) {
                     expire_count++;
                 } else { // r == 3
+14 −2		include/dsn/dist/replication/replication_types.h
+2,695 −2,666		src/common/replication_types.cpp
+8 −0		src/replica/replica_check.cpp
+13 −1		src/replica/split/replica_split_manager.cpp
+11 −0		src/replica/split/replica_split_manager.h
+2 −0		src/replica/split/test/replica_split_test.cpp
+6 −2		src/replication.thrift