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/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