/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/tserver_forward_service.proxy.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.proxy.h" |
4 | | |
5 | | #include "yb/tserver/tserver_forward_service.service.h" |
6 | | |
7 | | #include "yb/rpc/proxy.h" |
8 | | #include "yb/rpc/outbound_call.h" |
9 | | #include "yb/util/metrics.h" |
10 | | #include "yb/util/net/sockaddr.h" |
11 | | |
12 | | METRIC_DEFINE_counter( |
13 | | server, proxy_request_bytes_yb_tserver_TabletServerForwardService_Write, |
14 | | "Bytes sent by yb.tserver.TabletServerForwardService.Write() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.tserver.TabletServerForwardService.Write() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_tserver_TabletServerForwardService_Write, |
20 | | "Bytes received in response to yb.tserver.TabletServerForwardService.Write() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.tserver.TabletServerForwardService.Write() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_tserver_TabletServerForwardService_Read, |
26 | | "Bytes sent by yb.tserver.TabletServerForwardService.Read() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.tserver.TabletServerForwardService.Read() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_tserver_TabletServerForwardService_Read, |
32 | | "Bytes received in response to yb.tserver.TabletServerForwardService.Read() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.tserver.TabletServerForwardService.Read() RPC requests"); |
35 | | |
36 | | namespace yb { |
37 | | namespace tserver { |
38 | | |
39 | | |
40 | | namespace { |
41 | | |
42 | | const std::string kFullTabletServerForwardServiceName = "yb.tserver.TabletServerForwardService"; |
43 | | |
44 | 0 | ::yb::rpc::ProxyMetricsPtr CreateTabletServerForwardServiceMetrics(const scoped_refptr<MetricEntity>& entity) { |
45 | 0 | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<2>>(); |
46 | 0 | result->value[to_underlying(TabletServerForwardServiceRpcMethodIndexes::kWrite)] = { |
47 | 0 | METRIC_proxy_request_bytes_yb_tserver_TabletServerForwardService_Write.Instantiate(entity), |
48 | 0 | METRIC_proxy_response_bytes_yb_tserver_TabletServerForwardService_Write.Instantiate(entity) |
49 | 0 | }; |
50 | |
|
51 | 0 | result->value[to_underlying(TabletServerForwardServiceRpcMethodIndexes::kRead)] = { |
52 | 0 | METRIC_proxy_request_bytes_yb_tserver_TabletServerForwardService_Read.Instantiate(entity), |
53 | 0 | METRIC_proxy_response_bytes_yb_tserver_TabletServerForwardService_Read.Instantiate(entity) |
54 | 0 | }; |
55 | |
|
56 | 0 | return result; |
57 | 0 | } |
58 | | |
59 | | |
60 | | } // namespace |
61 | | |
62 | | TabletServerForwardServiceProxy::TabletServerForwardServiceProxy( |
63 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
64 | | const ::yb::rpc::Protocol* protocol, |
65 | | const ::yb::MonoDelta& resolve_cache_timeout) |
66 | | : ProxyBase(kFullTabletServerForwardServiceName, &CreateTabletServerForwardServiceMetrics, |
67 | 0 | cache, remote, protocol, resolve_cache_timeout) {} |
68 | | |
69 | | ::yb::Status TabletServerForwardServiceProxy::Write( |
70 | 0 | const ::yb::tserver::WriteRequestPB &req, ::yb::tserver::WriteResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
71 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerForwardService", "Write"); |
72 | 0 | return proxy().SyncRequest( |
73 | 0 | &method, metrics<2>(static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kWrite)), req, resp, controller); |
74 | 0 | } |
75 | | |
76 | | void TabletServerForwardServiceProxy::WriteAsync( |
77 | | const ::yb::tserver::WriteRequestPB &req, ::yb::tserver::WriteResponsePB *resp, ::yb::rpc::RpcController *controller, |
78 | 0 | ::yb::rpc::ResponseCallback callback) const { |
79 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerForwardService", "Write"); |
80 | 0 | proxy().AsyncRequest( |
81 | 0 | &method, metrics<2>(static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kWrite)), req, resp, controller, std::move(callback)); |
82 | 0 | } |
83 | | |
84 | | ::yb::Status TabletServerForwardServiceProxy::Read( |
85 | 0 | const ::yb::tserver::ReadRequestPB &req, ::yb::tserver::ReadResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
86 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerForwardService", "Read"); |
87 | 0 | return proxy().SyncRequest( |
88 | 0 | &method, metrics<2>(static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kRead)), req, resp, controller); |
89 | 0 | } |
90 | | |
91 | | void TabletServerForwardServiceProxy::ReadAsync( |
92 | | const ::yb::tserver::ReadRequestPB &req, ::yb::tserver::ReadResponsePB *resp, ::yb::rpc::RpcController *controller, |
93 | 0 | ::yb::rpc::ResponseCallback callback) const { |
94 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerForwardService", "Read"); |
95 | 0 | proxy().AsyncRequest( |
96 | 0 | &method, metrics<2>(static_cast<size_t>(TabletServerForwardServiceRpcMethodIndexes::kRead)), req, resp, controller, std::move(callback)); |
97 | 0 | } |
98 | | |
99 | | } // namespace tserver |
100 | | } // namespace yb |