/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/backup.service.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/tserver/backup.proto |
2 | | |
3 | | #include "yb/tserver/backup.pb.h" |
4 | | #include "yb/tserver/backup.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_TabletServerBackupService_TabletSnapshotOp, |
18 | | "Bytes received by yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp, |
24 | | "Bytes sent in response to yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_tserver_TabletServerBackupService_TabletSnapshotOp, |
30 | | "Microseconds spent handling yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | namespace yb { |
36 | | namespace tserver { |
37 | | |
38 | 8.74k | TabletServerBackupServiceIf::TabletServerBackupServiceIf(const scoped_refptr<MetricEntity>& entity) { |
39 | 8.74k | InitMethods(entity); |
40 | 8.74k | } |
41 | | |
42 | 92 | TabletServerBackupServiceIf::~TabletServerBackupServiceIf() { |
43 | 92 | } |
44 | | |
45 | 8.65k | void TabletServerBackupServiceIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
46 | 8.65k | map->emplace(methods_[static_cast<size_t>(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp))); |
47 | 8.65k | } |
48 | | |
49 | 55 | void TabletServerBackupServiceIf::Handle(::yb::rpc::InboundCallPtr call) { |
50 | 55 | auto index = call->method_index(); |
51 | 55 | methods_[index].handler(std::move(call)); |
52 | 55 | } |
53 | | |
54 | 26.2k | std::string TabletServerBackupServiceIf::service_name() const { |
55 | 26.2k | return "yb.tserver.TabletServerBackupService"; |
56 | 26.2k | } |
57 | 0 | std::string TabletServerBackupServiceIf::static_service_name() { |
58 | 0 | return "yb.tserver.TabletServerBackupService"; |
59 | 0 | } |
60 | | |
61 | 8.74k | void TabletServerBackupServiceIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
62 | 8.74k | methods_[static_cast<size_t>(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp)] = { |
63 | 8.74k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerBackupService", "TabletSnapshotOp"), |
64 | 8.74k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
65 | 55 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp)].metrics); |
66 | 55 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::TabletSnapshotOpRequestPB, ::yb::tserver::TabletSnapshotOpResponsePB>>( |
67 | 55 | std::move(call), [this](const ::yb::tserver::TabletSnapshotOpRequestPB* req, ::yb::tserver::TabletSnapshotOpResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
68 | 55 | TabletSnapshotOp(req, resp, std::move(rpc_context)); |
69 | 55 | }); |
70 | 55 | }, |
71 | 8.74k | .metrics = ::yb::rpc::RpcMethodMetrics( |
72 | 8.74k | METRIC_service_request_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp.Instantiate(entity), |
73 | 8.74k | METRIC_service_response_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp.Instantiate(entity), |
74 | 8.74k | METRIC_handler_latency_yb_tserver_TabletServerBackupService_TabletSnapshotOp.Instantiate(entity)) |
75 | 8.74k | }; |
76 | | |
77 | 8.74k | } |
78 | | |
79 | | } // namespace tserver |
80 | | } // namespace yb |