/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_heartbeat.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_heartbeat.proto |
2 | | |
3 | | #include "yb/master/master_heartbeat.proxy.h" |
4 | | |
5 | | #include "yb/master/master_heartbeat.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_master_MasterHeartbeat_TSHeartbeat, |
14 | | "Bytes sent by yb.master.MasterHeartbeat.TSHeartbeat() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.master.MasterHeartbeat.TSHeartbeat() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_master_MasterHeartbeat_TSHeartbeat, |
20 | | "Bytes received in response to yb.master.MasterHeartbeat.TSHeartbeat() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.master.MasterHeartbeat.TSHeartbeat() RPC requests"); |
23 | | |
24 | | namespace yb { |
25 | | namespace master { |
26 | | |
27 | | |
28 | | namespace { |
29 | | |
30 | | const std::string kFullMasterHeartbeatName = "yb.master.MasterHeartbeat"; |
31 | | |
32 | 5.46k | ::yb::rpc::ProxyMetricsPtr CreateMasterHeartbeatMetrics(const scoped_refptr<MetricEntity>& entity) { |
33 | 5.46k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<1>>(); |
34 | 5.46k | result->value[to_underlying(MasterHeartbeatRpcMethodIndexes::kTSHeartbeat)] = { |
35 | 5.46k | METRIC_proxy_request_bytes_yb_master_MasterHeartbeat_TSHeartbeat.Instantiate(entity), |
36 | 5.46k | METRIC_proxy_response_bytes_yb_master_MasterHeartbeat_TSHeartbeat.Instantiate(entity) |
37 | 5.46k | }; |
38 | | |
39 | 5.46k | return result; |
40 | 5.46k | } |
41 | | |
42 | | |
43 | | } // namespace |
44 | | |
45 | | MasterHeartbeatProxy::MasterHeartbeatProxy( |
46 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
47 | | const ::yb::rpc::Protocol* protocol, |
48 | | const ::yb::MonoDelta& resolve_cache_timeout) |
49 | | : ProxyBase(kFullMasterHeartbeatName, &CreateMasterHeartbeatMetrics, |
50 | 6.25k | cache, remote, protocol, resolve_cache_timeout) {} |
51 | | |
52 | | ::yb::Status MasterHeartbeatProxy::TSHeartbeat( |
53 | 403k | const ::yb::master::TSHeartbeatRequestPB &req, ::yb::master::TSHeartbeatResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
54 | 403k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "TSHeartbeat"); |
55 | 403k | return proxy().SyncRequest( |
56 | 403k | &method, metrics<1>(static_cast<size_t>(MasterHeartbeatRpcMethodIndexes::kTSHeartbeat)), req, resp, controller); |
57 | 403k | } |
58 | | |
59 | | void MasterHeartbeatProxy::TSHeartbeatAsync( |
60 | | const ::yb::master::TSHeartbeatRequestPB &req, ::yb::master::TSHeartbeatResponsePB *resp, ::yb::rpc::RpcController *controller, |
61 | 0 | ::yb::rpc::ResponseCallback callback) const { |
62 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "TSHeartbeat"); |
63 | 0 | proxy().AsyncRequest( |
64 | 0 | &method, metrics<1>(static_cast<size_t>(MasterHeartbeatRpcMethodIndexes::kTSHeartbeat)), req, resp, controller, std::move(callback)); |
65 | 0 | } |
66 | | |
67 | | } // namespace master |
68 | | } // namespace yb |