You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by la...@apache.org on 2021/06/03 09:48:59 UTC
[incubator-pegasus] 02/06: fix: overload dump_write_request
shouldn't auto-reply to client (#718)
This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a commit to branch v2.2
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
commit 1748ee71365f6c826649ff7e548ab216bf2c0c45
Author: Jiashuo <js...@live.com>
AuthorDate: Tue Apr 13 11:21:55 2021 +0800
fix: overload dump_write_request shouldn't auto-reply to client (#718)
---
src/server/pegasus_server_impl.cpp | 50 ++++++++++++++------------------------
1 file changed, 18 insertions(+), 32 deletions(-)
diff --git a/src/server/pegasus_server_impl.cpp b/src/server/pegasus_server_impl.cpp
index 3ea4665..f0d5f50 100644
--- a/src/server/pegasus_server_impl.cpp
+++ b/src/server/pegasus_server_impl.cpp
@@ -2783,49 +2783,35 @@ std::string pegasus_server_impl::dump_write_request(dsn::message_ex *request)
{
dsn::task_code rpc_code(request->rpc_code());
if (rpc_code == dsn::apps::RPC_RRDB_RRDB_PUT) {
- auto put = put_rpc::auto_reply(request).request();
+ auto put = put_rpc(request).request();
::dsn::blob hash_key, sort_key;
pegasus_restore_key(put.key, hash_key, sort_key);
- std::string request("put:");
- request.append("hash_key=")
- .append(pegasus::utils::c_escape_string(hash_key))
- .append(",sort_key=")
- .append(pegasus::utils::c_escape_string(sort_key));
- return request;
+ return fmt::format("put: hash_key={}, sort_key={}",
+ pegasus::utils::c_escape_string(hash_key),
+ pegasus::utils::c_escape_string(sort_key));
}
if (rpc_code == dsn::apps::RPC_RRDB_RRDB_MULTI_PUT) {
- auto multi_put = multi_put_rpc::auto_reply(request).request();
- std::string request("multi_put:");
- request.append("hash_key=")
- .append(pegasus::utils::c_escape_string((multi_put.hash_key))
- .append(",multi_put_count=")
- .append(std::to_string(multi_put.kvs.size())));
- return request;
+ auto multi_put = multi_put_rpc(request).request();
+ return fmt::format("multi_put: hash_key={}, multi_put_count={}",
+ pegasus::utils::c_escape_string(multi_put.hash_key),
+ multi_put.kvs.size());
}
if (rpc_code == dsn::apps::RPC_RRDB_RRDB_CHECK_AND_SET) {
- auto check_and_set = check_and_set_rpc::auto_reply(request).request();
- std::string request("check_and_set:");
- request.append("hash_key=")
- .append(pegasus::utils::c_escape_string(check_and_set.hash_key))
- .append(",check_sort_key=")
- .append(pegasus::utils::c_escape_string(check_and_set.check_sort_key))
- .append(",set_sort_key=")
- .append(pegasus::utils::c_escape_string(check_and_set.set_sort_key));
- return request;
+ auto check_and_set = check_and_set_rpc(request).request();
+ return fmt::format("check_and_set: hash_key={}, check_sort_key={}, set_sort_key={}",
+ pegasus::utils::c_escape_string(check_and_set.hash_key),
+ pegasus::utils::c_escape_string(check_and_set.check_sort_key),
+ pegasus::utils::c_escape_string(check_and_set.set_sort_key));
}
if (rpc_code == dsn::apps::RPC_RRDB_RRDB_CHECK_AND_MUTATE) {
- auto check_and_mutate = check_and_mutate_rpc::auto_reply(request).request();
- std::string request("check_and_mutate:");
- request.append("hash_key=")
- .append(pegasus::utils::c_escape_string(check_and_mutate.hash_key))
- .append(",check_sort_key=")
- .append(pegasus::utils::c_escape_string(check_and_mutate.check_sort_key))
- .append(",set_value_count=")
- .append(std::to_string(check_and_mutate.mutate_list.size()));
- return request;
+ auto check_and_mutate = check_and_mutate_rpc(request).request();
+ return fmt::format("check_and_mutate: hash_key={}, check_sort_key={}, set_value_count={}",
+ pegasus::utils::c_escape_string(check_and_mutate.hash_key),
+ pegasus::utils::c_escape_string(check_and_mutate.check_sort_key),
+ check_and_mutate.mutate_list.size());
}
return "default";
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org