diff --git a/rdsn b/rdsn index 64b9e11703..65edf61e37 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 5e65df0aff..ad8b4e0fc5 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