This is an automated email from the ASF dual-hosted git repository. yuchenhe pushed a commit to branch v2.1.2 in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
commit e1637da85666d954e47720912904d73069f51a42 Author: zhao liwei <[email protected]> AuthorDate: Tue Dec 8 15:18:43 2020 +0800 fix: fix log bug in multi_get (#652) --- src/server/pegasus_server_impl.cpp | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/server/pegasus_server_impl.cpp b/src/server/pegasus_server_impl.cpp index 6c4cf39..456d964 100644 --- a/src/server/pegasus_server_impl.cpp +++ b/src/server/pegasus_server_impl.cpp @@ -485,7 +485,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 @@ -548,7 +550,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 --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
