YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

Coverage Report

Created: 2022-03-09 17:30

/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/remote_bootstrap.proxy.cc
Line
Count
Source (jump to first uncovered line)
1
// THIS FILE IS AUTOGENERATED FROM yb/tserver/remote_bootstrap.proto
2
3
#include "yb/tserver/remote_bootstrap.proxy.h"
4
5
#include "yb/tserver/remote_bootstrap.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_RemoteBootstrapService_BeginRemoteBootstrapSession,
14
  "Bytes sent by yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests",
15
  yb::MetricUnit::kBytes,
16
  "Bytes sent by yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests");
17
18
METRIC_DEFINE_counter(
19
  server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession,
20
  "Bytes received in response to yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests",
21
  yb::MetricUnit::kBytes,
22
  "Bytes received in response to yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests");
23
24
METRIC_DEFINE_counter(
25
  server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive,
26
  "Bytes sent by yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests",
27
  yb::MetricUnit::kBytes,
28
  "Bytes sent by yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests");
29
30
METRIC_DEFINE_counter(
31
  server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive,
32
  "Bytes received in response to yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests",
33
  yb::MetricUnit::kBytes,
34
  "Bytes received in response to yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests");
35
36
METRIC_DEFINE_counter(
37
  server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_FetchData,
38
  "Bytes sent by yb.tserver.RemoteBootstrapService.FetchData() RPC requests",
39
  yb::MetricUnit::kBytes,
40
  "Bytes sent by yb.tserver.RemoteBootstrapService.FetchData() RPC requests");
41
42
METRIC_DEFINE_counter(
43
  server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_FetchData,
44
  "Bytes received in response to yb.tserver.RemoteBootstrapService.FetchData() RPC requests",
45
  yb::MetricUnit::kBytes,
46
  "Bytes received in response to yb.tserver.RemoteBootstrapService.FetchData() RPC requests");
47
48
METRIC_DEFINE_counter(
49
  server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession,
50
  "Bytes sent by yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests",
51
  yb::MetricUnit::kBytes,
52
  "Bytes sent by yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests");
53
54
METRIC_DEFINE_counter(
55
  server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession,
56
  "Bytes received in response to yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests",
57
  yb::MetricUnit::kBytes,
58
  "Bytes received in response to yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests");
59
60
METRIC_DEFINE_counter(
61
  server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_RemoveSession,
62
  "Bytes sent by yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests",
63
  yb::MetricUnit::kBytes,
64
  "Bytes sent by yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests");
65
66
METRIC_DEFINE_counter(
67
  server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_RemoveSession,
68
  "Bytes received in response to yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests",
69
  yb::MetricUnit::kBytes,
70
  "Bytes received in response to yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests");
71
72
namespace yb {
73
namespace tserver {
74
75
76
namespace {
77
78
const std::string kFullRemoteBootstrapServiceName = "yb.tserver.RemoteBootstrapService";
79
80
182
::yb::rpc::ProxyMetricsPtr CreateRemoteBootstrapServiceMetrics(const scoped_refptr<MetricEntity>& entity) {
81
182
  auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<5>>();
82
182
  result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)] = {
83
182
      METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity),
84
182
      METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity)
85
182
  };
86
87
182
  result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)] = {
88
182
      METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity),
89
182
      METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity)
90
182
  };
91
92
182
  result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)] = {
93
182
      METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity),
94
182
      METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity)
95
182
  };
96
97
182
  result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)] = {
98
182
      METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity),
99
182
      METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity)
100
182
  };
101
102
182
  result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)] = {
103
182
      METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity),
104
182
      METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity)
105
182
  };
106
107
182
  return result;
108
182
}
109
110
111
} // namespace
112
113
RemoteBootstrapServiceProxy::RemoteBootstrapServiceProxy(
114
    ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote,
115
    const ::yb::rpc::Protocol* protocol,
116
    const ::yb::MonoDelta& resolve_cache_timeout)
117
    : ProxyBase(kFullRemoteBootstrapServiceName, &CreateRemoteBootstrapServiceMetrics,
118
1.45k
                cache, remote, protocol, resolve_cache_timeout) {}
119
120
::yb::Status RemoteBootstrapServiceProxy::BeginRemoteBootstrapSession(
121
1.45k
    const ::yb::tserver::BeginRemoteBootstrapSessionRequestPB &req, ::yb::tserver::BeginRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
122
1.45k
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "BeginRemoteBootstrapSession");
123
1.45k
  return proxy().SyncRequest(
124
1.45k
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)), req, resp, controller);
125
1.45k
}
126
127
void RemoteBootstrapServiceProxy::BeginRemoteBootstrapSessionAsync(
128
    const ::yb::tserver::BeginRemoteBootstrapSessionRequestPB &req, ::yb::tserver::BeginRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller,
129
0
    ::yb::rpc::ResponseCallback callback) const {
130
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "BeginRemoteBootstrapSession");
131
0
  proxy().AsyncRequest(
132
0
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)), req, resp, controller, std::move(callback));
133
0
}
134
135
::yb::Status RemoteBootstrapServiceProxy::CheckSessionActive(
136
2
    const ::yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB &req, ::yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB *resp, ::yb::rpc::RpcController *controller) const {
137
2
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "CheckSessionActive");
138
2
  return proxy().SyncRequest(
139
2
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)), req, resp, controller);
140
2
}
141
142
void RemoteBootstrapServiceProxy::CheckSessionActiveAsync(
143
    const ::yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB &req, ::yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB *resp, ::yb::rpc::RpcController *controller,
144
0
    ::yb::rpc::ResponseCallback callback) const {
145
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "CheckSessionActive");
146
0
  proxy().AsyncRequest(
147
0
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)), req, resp, controller, std::move(callback));
148
0
}
149
150
::yb::Status RemoteBootstrapServiceProxy::FetchData(
151
5.83k
    const ::yb::tserver::FetchDataRequestPB &req, ::yb::tserver::FetchDataResponsePB *resp, ::yb::rpc::RpcController *controller) const {
152
5.83k
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "FetchData");
153
5.83k
  return proxy().SyncRequest(
154
5.83k
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)), req, resp, controller);
155
5.83k
}
156
157
void RemoteBootstrapServiceProxy::FetchDataAsync(
158
    const ::yb::tserver::FetchDataRequestPB &req, ::yb::tserver::FetchDataResponsePB *resp, ::yb::rpc::RpcController *controller,
159
0
    ::yb::rpc::ResponseCallback callback) const {
160
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "FetchData");
161
0
  proxy().AsyncRequest(
162
0
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)), req, resp, controller, std::move(callback));
163
0
}
164
165
::yb::Status RemoteBootstrapServiceProxy::EndRemoteBootstrapSession(
166
1.00k
    const ::yb::tserver::EndRemoteBootstrapSessionRequestPB &req, ::yb::tserver::EndRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
167
1.00k
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "EndRemoteBootstrapSession");
168
1.00k
  return proxy().SyncRequest(
169
1.00k
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)), req, resp, controller);
170
1.00k
}
171
172
void RemoteBootstrapServiceProxy::EndRemoteBootstrapSessionAsync(
173
    const ::yb::tserver::EndRemoteBootstrapSessionRequestPB &req, ::yb::tserver::EndRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller,
174
0
    ::yb::rpc::ResponseCallback callback) const {
175
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "EndRemoteBootstrapSession");
176
0
  proxy().AsyncRequest(
177
0
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)), req, resp, controller, std::move(callback));
178
0
}
179
180
::yb::Status RemoteBootstrapServiceProxy::RemoveSession(
181
941
    const ::yb::tserver::RemoveSessionRequestPB &req, ::yb::tserver::RemoveSessionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
182
941
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "RemoveSession");
183
941
  return proxy().SyncRequest(
184
941
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)), req, resp, controller);
185
941
}
186
187
void RemoteBootstrapServiceProxy::RemoveSessionAsync(
188
    const ::yb::tserver::RemoveSessionRequestPB &req, ::yb::tserver::RemoveSessionResponsePB *resp, ::yb::rpc::RpcController *controller,
189
0
    ::yb::rpc::ResponseCallback callback) const {
190
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "RemoveSession");
191
0
  proxy().AsyncRequest(
192
0
      &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)), req, resp, controller, std::move(callback));
193
0
}
194
195
} // namespace tserver
196
} // namespace yb