/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/tserver_forward_service.service.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/tserver/tserver_forward_service.proto |
2 | | |
3 | | #include "yb/tserver/tserver_forward_service.pb.h" |
4 | | #include "yb/tserver/tserver_forward_service.service.h" |
5 | | |
6 | | #include <glog/logging.h> |
7 | | |
8 | | #include "yb/rpc/inbound_call.h" |
9 | | #include "yb/rpc/local_call.h" |
10 | | #include "yb/rpc/remote_method.h" |
11 | | #include "yb/rpc/rpc_context.h" |
12 | | #include "yb/rpc/rpc_service.h" |
13 | | #include "yb/rpc/service_if.h" |
14 | | #include "yb/util/metrics.h" |
15 | | |
16 | | METRIC_DEFINE_counter( |
17 | | server, service_request_bytes_yb_tserver_TabletServerForwardService_Write, |
18 | | "Bytes received by yb.tserver.TabletServerForwardService.Write() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.tserver.TabletServerForwardService.Write() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_tserver_TabletServerForwardService_Write, |
24 | | "Bytes sent in response to yb.tserver.TabletServerForwardService.Write() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.tserver.TabletServerForwardService.Write() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_tserver_TabletServerForwardService_Write, |
30 | | "Microseconds spent handling yb.tserver.TabletServerForwardService.Write() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.tserver.TabletServerForwardService.Write() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | METRIC_DEFINE_counter( |
36 | | server, service_request_bytes_yb_tserver_TabletServerForwardService_Read, |
37 | | "Bytes received by yb.tserver.TabletServerForwardService.Read() RPC requests", |
38 | | yb::MetricUnit::kBytes, |
39 | | "Bytes received by yb.tserver.TabletServerForwardService.Read() RPC requests"); |
40 | | |
41 | | METRIC_DEFINE_counter( |
42 | | server, service_response_bytes_yb_tserver_TabletServerForwardService_Read, |
43 | | "Bytes sent in response to yb.tserver.TabletServerForwardService.Read() RPC requests", |
44 | | yb::MetricUnit::kBytes, |
45 | | "Bytes sent in response to yb.tserver.TabletServerForwardService.Read() RPC requests"); |
46 | | |
47 | | METRIC_DEFINE_histogram_with_percentiles( |
48 | | server, handler_latency_yb_tserver_TabletServerForwardService_Read, |
49 | | "Microseconds spent handling yb.tserver.TabletServerForwardService.Read() RPC requests", |
50 | | yb::MetricUnit::kMicroseconds, |
51 | | "Microseconds spent handling yb.tserver.TabletServerForwardService.Read() RPC requests", |
52 | | 60000000LU, 2); |
53 | | |
54 | | namespace yb { |
55 | | namespace tserver { |
56 | | |
57 | 5.81k | TabletServerForwardServiceIf::TabletServerForwardServiceIf(const scoped_refptr<MetricEntity>& entity) { |
58 | 5.81k | InitMethods(entity); |
59 | 5.81k | } |
60 | | |
61 | 73 | TabletServerForwardServiceIf::~TabletServerForwardServiceIf() { |
62 | 73 | } |
63 | | |
64 | 5.80k | void TabletServerForwardServiceIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
65 | 5.80k | map->emplace(methods_[static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kWrite)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kWrite))); |
66 | 5.80k | map->emplace(methods_[static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kRead)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kRead))); |
67 | 5.80k | } |
68 | | |
69 | 0 | void TabletServerForwardServiceIf::Handle(::yb::rpc::InboundCallPtr call) { |
70 | 0 | auto index = call->method_index(); |
71 | 0 | methods_[index].handler(std::move(call)); |
72 | 0 | } |
73 | | |
74 | 17.4k | std::string TabletServerForwardServiceIf::service_name() const { |
75 | 17.4k | return "yb.tserver.TabletServerForwardService"; |
76 | 17.4k | } |
77 | 0 | std::string TabletServerForwardServiceIf::static_service_name() { |
78 | 0 | return "yb.tserver.TabletServerForwardService"; |
79 | 0 | } |
80 | | |
81 | 5.81k | void TabletServerForwardServiceIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
82 | 5.81k | methods_[static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kWrite)] = { |
83 | 5.81k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerForwardService", "Write"), |
84 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
85 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kWrite)].metrics); |
86 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::WriteRequestPB, ::yb::tserver::WriteResponsePB>>( |
87 | 0 | std::move(call), [this](const ::yb::tserver::WriteRequestPB* req, ::yb::tserver::WriteResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
88 | 0 | Write(req, resp, std::move(rpc_context)); |
89 | 0 | }); |
90 | 0 | }, |
91 | 5.81k | .metrics = ::yb::rpc::RpcMethodMetrics( |
92 | 5.81k | METRIC_service_request_bytes_yb_tserver_TabletServerForwardService_Write.Instantiate(entity), |
93 | 5.81k | METRIC_service_response_bytes_yb_tserver_TabletServerForwardService_Write.Instantiate(entity), |
94 | 5.81k | METRIC_handler_latency_yb_tserver_TabletServerForwardService_Write.Instantiate(entity)) |
95 | 5.81k | }; |
96 | | |
97 | 5.81k | methods_[static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kRead)] = { |
98 | 5.81k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerForwardService", "Read"), |
99 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
100 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kRead)].metrics); |
101 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::ReadRequestPB, ::yb::tserver::ReadResponsePB>>( |
102 | 0 | std::move(call), [this](const ::yb::tserver::ReadRequestPB* req, ::yb::tserver::ReadResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
103 | 0 | Read(req, resp, std::move(rpc_context)); |
104 | 0 | }); |
105 | 0 | }, |
106 | 5.81k | .metrics = ::yb::rpc::RpcMethodMetrics( |
107 | 5.81k | METRIC_service_request_bytes_yb_tserver_TabletServerForwardService_Read.Instantiate(entity), |
108 | 5.81k | METRIC_service_response_bytes_yb_tserver_TabletServerForwardService_Read.Instantiate(entity), |
109 | 5.81k | METRIC_handler_latency_yb_tserver_TabletServerForwardService_Read.Instantiate(entity)) |
110 | 5.81k | }; |
111 | | |
112 | 5.81k | } |
113 | | |
114 | | } // namespace tserver |
115 | | } // namespace yb |