This is an automated email from the ASF dual-hosted git repository.
yuchenhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new 6a47a3b fix: fix log bug in multi_get (#652)
6a47a3b is described below
commit 6a47a3bf097b082d3c7dfd4402add411378df092
Author: zhao liwei <[email protected]>
AuthorDate: Tue Dec 8 15:18:43 2020 +0800
fix: fix log bug in multi_get (#652)
---
rdsn | 2 +-
src/server/pegasus_server_impl.cpp | 8 ++++++--
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/rdsn b/rdsn
index 64b9e11..65edf61 160000
--- a/rdsn
+++ b/rdsn
@@ -1 +1 @@
-Subproject commit 64b9e11703aea7acfa771037cbc3ad8b363abfaa
+Subproject commit 65edf61e376b692f41845ab3deb71cb686ea5575
diff --git a/src/server/pegasus_server_impl.cpp
b/src/server/pegasus_server_impl.cpp
index 5e65df0..ad8b4e0 100644
--- 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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
