/Users/deen/code/yugabyte-db/src/yb/rpc/rpc_context.h
Line | Count | Source (jump to first uncovered line) |
1 | | // Licensed to the Apache Software Foundation (ASF) under one |
2 | | // or more contributor license agreements. See the NOTICE file |
3 | | // distributed with this work for additional information |
4 | | // regarding copyright ownership. The ASF licenses this file |
5 | | // to you under the Apache License, Version 2.0 (the |
6 | | // "License"); you may not use this file except in compliance |
7 | | // with the License. You may obtain a copy of the License at |
8 | | // |
9 | | // http://www.apache.org/licenses/LICENSE-2.0 |
10 | | // |
11 | | // Unless required by applicable law or agreed to in writing, |
12 | | // software distributed under the License is distributed on an |
13 | | // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
14 | | // KIND, either express or implied. See the License for the |
15 | | // specific language governing permissions and limitations |
16 | | // under the License. |
17 | | // |
18 | | // The following only applies to changes made to this file as part of YugaByte development. |
19 | | // |
20 | | // Portions Copyright (c) YugaByte, Inc. |
21 | | // |
22 | | // Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except |
23 | | // in compliance with the License. You may obtain a copy of the License at |
24 | | // |
25 | | // http://www.apache.org/licenses/LICENSE-2.0 |
26 | | // |
27 | | // Unless required by applicable law or agreed to in writing, software distributed under the License |
28 | | // is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express |
29 | | // or implied. See the License for the specific language governing permissions and limitations |
30 | | // under the License. |
31 | | // |
32 | | #ifndef YB_RPC_RPC_CONTEXT_H |
33 | | #define YB_RPC_RPC_CONTEXT_H |
34 | | |
35 | | #include <string> |
36 | | |
37 | | #include <boost/type_traits/is_detected.hpp> |
38 | | |
39 | | #include "yb/rpc/rpc_header.pb.h" |
40 | | #include "yb/rpc/serialization.h" |
41 | | #include "yb/rpc/service_if.h" |
42 | | |
43 | | #include "yb/util/memory/arena.h" |
44 | | #include "yb/util/ref_cnt_buffer.h" |
45 | | #include "yb/util/status.h" |
46 | | |
47 | | #include "yb/util/status_fwd.h" |
48 | | #include "yb/util/monotime.h" |
49 | | #include "yb/util/net/sockaddr.h" |
50 | | |
51 | | namespace google { |
52 | | namespace protobuf { |
53 | | class Message; |
54 | | } // namespace protobuf |
55 | | } // namespace google |
56 | | |
57 | | namespace yb { |
58 | | |
59 | | class Trace; |
60 | | |
61 | | namespace util { |
62 | | |
63 | | class RefCntBuffer; |
64 | | |
65 | | } |
66 | | |
67 | | namespace rpc { |
68 | | |
69 | | class YBInboundCall; |
70 | | |
71 | | class RpcCallParams { |
72 | | public: |
73 | 81.1M | virtual ~RpcCallParams() = default; |
74 | | |
75 | | virtual Result<size_t> ParseRequest(Slice param) = 0; |
76 | | virtual AnyMessageConstPtr SerializableResponse() = 0; |
77 | | }; |
78 | | |
79 | | class RpcCallPBParams : public RpcCallParams { |
80 | | public: |
81 | | Result<size_t> ParseRequest(Slice param) override; |
82 | | |
83 | | AnyMessageConstPtr SerializableResponse() override; |
84 | | |
85 | | virtual google::protobuf::Message& request() = 0; |
86 | | virtual google::protobuf::Message& response() = 0; |
87 | | |
88 | | static google::protobuf::Message* CastMessage(const AnyMessagePtr& msg); |
89 | | |
90 | | static const google::protobuf::Message* CastMessage(const AnyMessageConstPtr& msg); |
91 | | }; |
92 | | |
93 | | template <class Req, class Resp> |
94 | | class RpcCallPBParamsImpl : public RpcCallPBParams { |
95 | | public: |
96 | | using RequestType = Req; |
97 | | using ResponseType = Resp; |
98 | | |
99 | 70.2M | RpcCallPBParamsImpl() = default; yb::rpc::RpcCallPBParamsImpl<yb::tserver::BeginRemoteBootstrapSessionRequestPB, yb::tserver::BeginRemoteBootstrapSessionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.03k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB, yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::FetchDataRequestPB, yb::tserver::FetchDataResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 11.3k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::EndRemoteBootstrapSessionRequestPB, yb::tserver::EndRemoteBootstrapSessionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.02k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::RemoveSessionRequestPB, yb::tserver::RemoveSessionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.93k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::CreateTabletRequestPB, yb::tserver::CreateTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 139k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::DeleteTabletRequestPB, yb::tserver::DeleteTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 77.5k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tablet::ChangeMetadataRequestPB, yb::tserver::ChangeMetadataResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 32.3k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSafeTimeRequestPB, yb::tserver::GetSafeTimeResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4.39k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::BackfillIndexRequestPB, yb::tserver::BackfillIndexResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4.51k | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::CopartitionTableRequestPB, yb::tserver::CopartitionTableResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::FlushTabletsRequestPB, yb::tserver::FlushTabletsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 43 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::CountIntentsRequestPB, yb::tserver::CountIntentsResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::AddTableToTabletRequestPB, yb::tserver::AddTableToTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 126 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::RemoveTableFromTabletRequestPB, yb::tserver::RemoveTableFromTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 81 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tablet::SplitTabletRequestPB, yb::tserver::SplitTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 141 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::UpgradeYsqlRequestPB, yb::tserver::UpgradeYsqlResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::CreateCDCStreamRequestPB, yb::cdc::CreateCDCStreamResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 307 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::DeleteCDCStreamRequestPB, yb::cdc::DeleteCDCStreamResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::ListTabletsRequestPB, yb::cdc::ListTabletsResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetChangesRequestPB, yb::cdc::GetChangesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 642 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetCheckpointRequestPB, yb::cdc::GetCheckpointResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 14 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::UpdateCdcReplicatedIndexRequestPB, yb::cdc::UpdateCdcReplicatedIndexResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 219 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::BootstrapProducerRequestPB, yb::cdc::BootstrapProducerResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetLatestEntryOpIdRequestPB, yb::cdc::GetLatestEntryOpIdResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetCDCDBStreamInfoRequestPB, yb::cdc::GetCDCDBStreamInfoResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::cdc::SetCDCCheckpointRequestPB, yb::cdc::SetCDCCheckpointResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 6 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::TabletSnapshotOpRequestPB, yb::tserver::TabletSnapshotOpResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 55 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateSnapshotRequestPB, yb::master::CreateSnapshotResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotsRequestPB, yb::master::ListSnapshotsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 9 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotRestorationsRequestPB, yb::master::ListSnapshotRestorationsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 6 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::RestoreSnapshotRequestPB, yb::master::RestoreSnapshotResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteSnapshotRequestPB, yb::master::DeleteSnapshotResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ImportSnapshotMetaRequestPB, yb::master::ImportSnapshotMetaResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::CreateSnapshotScheduleRequestPB, yb::master::CreateSnapshotScheduleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 8 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotSchedulesRequestPB, yb::master::ListSnapshotSchedulesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 11 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteSnapshotScheduleRequestPB, yb::master::DeleteSnapshotScheduleResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgHeartbeatRequestPB, yb::tserver::PgHeartbeatResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 10.7k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgAlterDatabaseRequestPB, yb::tserver::PgAlterDatabaseResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgAlterTableRequestPB, yb::tserver::PgAlterTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 522 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgBackfillIndexRequestPB, yb::tserver::PgBackfillIndexResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 540 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateDatabaseRequestPB, yb::tserver::PgCreateDatabaseResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 134 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateSequencesDataTableRequestPB, yb::tserver::PgCreateSequencesDataTableResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateTableRequestPB, yb::tserver::PgCreateTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.05k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateTablegroupRequestPB, yb::tserver::PgCreateTablegroupResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 54 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropDatabaseRequestPB, yb::tserver::PgDropDatabaseResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 72 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropTableRequestPB, yb::tserver::PgDropTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4.14k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropTablegroupRequestPB, yb::tserver::PgDropTablegroupResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 39 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgFinishTransactionRequestPB, yb::tserver::PgFinishTransactionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 218k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgGetCatalogMasterVersionRequestPB, yb::tserver::PgGetCatalogMasterVersionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 22 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgGetDatabaseInfoRequestPB, yb::tserver::PgGetDatabaseInfoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.72k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgIsInitDbDoneRequestPB, yb::tserver::PgIsInitDbDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgListLiveTabletServersRequestPB, yb::tserver::PgListLiveTabletServersResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgOpenTableRequestPB, yb::tserver::PgOpenTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 191k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgPerformRequestPB, yb::tserver::PgPerformResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.17M | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgReserveOidsRequestPB, yb::tserver::PgReserveOidsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 805 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgRollbackSubTransactionRequestPB, yb::tserver::PgRollbackSubTransactionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 13.5k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgSetActiveSubTransactionRequestPB, yb::tserver::PgSetActiveSubTransactionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 61.7k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgTabletServerCountRequestPB, yb::tserver::PgTabletServerCountResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 148 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgTruncateTableRequestPB, yb::tserver::PgTruncateTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 624 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgValidatePlacementRequestPB, yb::tserver::PgValidatePlacementResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgInsertSequenceTupleRequestPB, yb::tserver::PgInsertSequenceTupleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 295 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgUpdateSequenceTupleRequestPB, yb::tserver::PgUpdateSequenceTupleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.97k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgReadSequenceTupleRequestPB, yb::tserver::PgReadSequenceTupleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3.23k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDeleteSequenceTupleRequestPB, yb::tserver::PgDeleteSequenceTupleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 282 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDeleteDBSequencesRequestPB, yb::tserver::PgDeleteDBSequencesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 71 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::WriteRequestPB, yb::tserver::WriteResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 796k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::ReadRequestPB, yb::tserver::ReadResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.12M | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::VerifyTableRowRangeRequestPB, yb::tserver::VerifyTableRowRangeResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::NoOpRequestPB, yb::tserver::NoOpResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::ListTabletsRequestPB, yb::tserver::ListTabletsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 217 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetLogLocationRequestPB, yb::tserver::GetLogLocationResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::ChecksumRequestPB, yb::tserver::ChecksumResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3.30k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::ListTabletsForTabletServerRequestPB, yb::tserver::ListTabletsForTabletServerResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 881 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::ImportDataRequestPB, yb::tserver::ImportDataResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::UpdateTransactionRequestPB, yb::tserver::UpdateTransactionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.22M | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTransactionStatusRequestPB, yb::tserver::GetTransactionStatusResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 209k | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTransactionStatusAtParticipantRequestPB, yb::tserver::GetTransactionStatusAtParticipantResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::AbortTransactionRequestPB, yb::tserver::AbortTransactionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 34.8k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::TruncateRequestPB, yb::tserver::TruncateResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 57.1k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTabletStatusRequestPB, yb::tserver::GetTabletStatusResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetMasterAddressesRequestPB, yb::tserver::GetMasterAddressesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 9 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PublishRequestPB, yb::tserver::PublishResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 684 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::IsTabletServerReadyRequestPB, yb::tserver::IsTabletServerReadyResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 18 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::TakeTransactionRequestPB, yb::tserver::TakeTransactionResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSplitKeyRequestPB, yb::tserver::GetSplitKeyResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 144 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSharedDataRequestPB, yb::tserver::GetSharedDataResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 8 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::AddRequestPB, yb::rpc_test::AddResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 643 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::SleepRequestPB, yb::rpc_test::SleepResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 39 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::EchoRequestPB, yb::rpc_test::EchoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 13.6k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::WhoAmIRequestPB, yb::rpc_test::WhoAmIResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::rpc_test_diff_package::ReqDiffPackagePB, yb::rpc_test_diff_package::RespDiffPackagePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::PanicRequestPB, yb::rpc_test::PanicResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::PingRequestPB, yb::rpc_test::PingResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 49.9k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::DisconnectRequestPB, yb::rpc_test::DisconnectResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.26k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::ForwardRequestPB, yb::rpc_test::ForwardResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 12 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::TrivialRequestPB, yb::rpc_test::TrivialResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::ConcatRequestPB, yb::rpc_test::ConcatResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::FlushTablesRequestPB, yb::master::FlushTablesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 10 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsFlushTablesDoneRequestPB, yb::master::IsFlushTablesDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 21 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::FlushSysCatalogRequestPB, yb::master::FlushSysCatalogResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::CompactSysCatalogRequestPB, yb::master::CompactSysCatalogResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::IsInitDbDoneRequestPB, yb::master::IsInitDbDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.10k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::SplitTabletRequestPB, yb::master::SplitTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 66 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTransactionStatusTableRequestPB, yb::master::CreateTransactionStatusTableResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteNotServingTabletRequestPB, yb::master::DeleteNotServingTabletResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 6 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DisableTabletSplittingRequestPB, yb::master::DisableTabletSplittingResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::IsTabletSplittingCompleteRequestPB, yb::master::IsTabletSplittingCompleteResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::DdlLogRequestPB, yb::master::DdlLogResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTabletLocationsRequestPB, yb::master::GetTabletLocationsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 15.2k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTableLocationsRequestPB, yb::master::GetTableLocationsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 228k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTransactionStatusTabletsRequestPB, yb::master::GetTransactionStatusTabletsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3.32k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ReservePgsqlOidsRequestPB, yb::master::ReservePgsqlOidsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 805 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetYsqlCatalogConfigRequestPB, yb::master::GetYsqlCatalogConfigResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 22 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::RedisConfigSetRequestPB, yb::master::RedisConfigSetResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 182 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::RedisConfigGetRequestPB, yb::master::RedisConfigGetResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.17k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTabletServersRequestPB, yb::master::ListTabletServersResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 26.8k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListLiveTabletServersRequestPB, yb::master::ListLiveTabletServersResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListMastersRequestPB, yb::master::ListMastersResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 67 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ListMasterRaftPeersRequestPB, yb::master::ListMasterRaftPeersResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::GetMasterRegistrationRequestPB, yb::master::GetMasterRegistrationResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 29.3M | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsMasterLeaderReadyRequestPB, yb::master::IsMasterLeaderReadyResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 172 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DumpMasterStateRequestPB, yb::master::DumpMasterStateResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeLoadBalancerStateRequestPB, yb::master::ChangeLoadBalancerStateResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetLoadBalancerStateRequestPB, yb::master::GetLoadBalancerStateResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::RemovedMasterUpdateRequestPB, yb::master::RemovedMasterUpdateResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 38 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::SetPreferredZonesRequestPB, yb::master::SetPreferredZonesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetMasterClusterConfigRequestPB, yb::master::GetMasterClusterConfigResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 334 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeMasterClusterConfigRequestPB, yb::master::ChangeMasterClusterConfigResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 170 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetLoadMovePercentRequestPB, yb::master::GetLoadMovePercentResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.06k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetLeaderBlacklistPercentRequestPB, yb::master::GetLoadMovePercentResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 388 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsLoadBalancedRequestPB, yb::master::IsLoadBalancedResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 238 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsLoadBalancerIdleRequestPB, yb::master::IsLoadBalancerIdleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.48k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::AreLeadersOnPreferredOnlyRequestPB, yb::master::AreLeadersOnPreferredOnlyResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 147 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateRoleRequestPB, yb::master::CreateRoleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 757 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterRoleRequestPB, yb::master::AlterRoleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 58 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteRoleRequestPB, yb::master::DeleteRoleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 730 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GrantRevokeRoleRequestPB, yb::master::GrantRevokeRoleResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 52 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GrantRevokePermissionRequestPB, yb::master::GrantRevokePermissionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 721 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetPermissionsRequestPB, yb::master::GetPermissionsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 115k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTableRequestPB, yb::master::CreateTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 7.48k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsCreateTableDoneRequestPB, yb::master::IsCreateTableDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 29.6k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTablesRequestPB, yb::master::ListTablesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.93k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTableSchemaRequestPB, yb::master::GetTableSchemaResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 171k | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetTablegroupSchemaRequestPB, yb::master::GetTablegroupSchemaResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetColocatedTabletSchemaRequestPB, yb::master::GetColocatedTabletSchemaResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::TruncateTableRequestPB, yb::master::TruncateTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 12.6k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsTruncateTableDoneRequestPB, yb::master::IsTruncateTableDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 10.5k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::BackfillIndexRequestPB, yb::master::BackfillIndexResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 540 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::LaunchBackfillIndexForTableRequestPB, yb::master::LaunchBackfillIndexForTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetBackfillJobsRequestPB, yb::master::GetBackfillJobsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 697 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteTableRequestPB, yb::master::DeleteTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.50k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsDeleteTableDoneRequestPB, yb::master::IsDeleteTableDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 11.7k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterTableRequestPB, yb::master::AlterTableResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 704 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsAlterTableDoneRequestPB, yb::master::IsAlterTableDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.39k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateNamespaceRequestPB, yb::master::CreateNamespaceResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2.64k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsCreateNamespaceDoneRequestPB, yb::master::IsCreateNamespaceDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 3.56k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteNamespaceRequestPB, yb::master::DeleteNamespaceResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.64k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsDeleteNamespaceDoneRequestPB, yb::master::IsDeleteNamespaceDoneResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.74k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterNamespaceRequestPB, yb::master::AlterNamespaceResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 7 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListNamespacesRequestPB, yb::master::ListNamespacesResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.12k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetNamespaceInfoRequestPB, yb::master::GetNamespaceInfoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 6.03k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTablegroupRequestPB, yb::master::CreateTablegroupResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 56 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteTablegroupRequestPB, yb::master::DeleteTablegroupResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 40 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTablegroupsRequestPB, yb::master::ListTablegroupsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 7 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateUDTypeRequestPB, yb::master::CreateUDTypeResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 47 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteUDTypeRequestPB, yb::master::DeleteUDTypeResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 54 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ListUDTypesRequestPB, yb::master::ListUDTypesResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::GetUDTypeInfoRequestPB, yb::master::GetUDTypeInfoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 56 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeEncryptionInfoRequestPB, yb::master::ChangeEncryptionInfoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 17 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsEncryptionEnabledRequestPB, yb::master::IsEncryptionEnabledResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 17 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::AddUniverseKeysRequestPB, yb::master::AddUniverseKeysResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 51 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetUniverseKeyRegistryRequestPB, yb::master::GetUniverseKeyRegistryResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 12.7k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::HasUniverseKeyInMemoryRequestPB, yb::master::HasUniverseKeyInMemoryResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 69 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::TSHeartbeatRequestPB, yb::master::TSHeartbeatResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.17M | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ValidateReplicationInfoRequestPB, yb::master::ValidateReplicationInfoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateCDCStreamRequestPB, yb::master::CreateCDCStreamResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.50k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteCDCStreamRequestPB, yb::master::DeleteCDCStreamResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListCDCStreamsRequestPB, yb::master::ListCDCStreamsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetCDCStreamRequestPB, yb::master::GetCDCStreamResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 6 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetCDCDBStreamInfoRequestPB, yb::master::GetCDCDBStreamInfoResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 22 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::UpdateCDCStreamRequestPB, yb::master::UpdateCDCStreamResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::master::SetupUniverseReplicationRequestPB, yb::master::SetupUniverseReplicationResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteUniverseReplicationRequestPB, yb::master::DeleteUniverseReplicationResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::AlterUniverseReplicationRequestPB, yb::master::AlterUniverseReplicationResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::SetUniverseReplicationEnabledRequestPB, yb::master::SetUniverseReplicationEnabledResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetUniverseReplicationRequestPB, yb::master::GetUniverseReplicationResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::IsSetupUniverseReplicationDoneRequestPB, yb::master::IsSetupUniverseReplicationDoneResponsePB>::RpcCallPBParamsImpl() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::UpdateConsumerOnProducerSplitRequestPB, yb::master::UpdateConsumerOnProducerSplitResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::consensus::ConsensusRequestPB, yb::consensus::ConsensusResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 25.5M | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::consensus::MultiRaftConsensusRequestPB, yb::consensus::MultiRaftConsensusResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::consensus::VoteRequestPB, yb::consensus::VoteResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1.39M | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::ChangeConfigRequestPB, yb::consensus::ChangeConfigResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 5.29k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::UnsafeChangeConfigRequestPB, yb::consensus::UnsafeChangeConfigResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 6 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetNodeInstanceRequestPB, yb::consensus::GetNodeInstanceResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 20.9k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::RunLeaderElectionRequestPB, yb::consensus::RunLeaderElectionResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 96.2k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::LeaderElectionLostRequestPB, yb::consensus::LeaderElectionLostResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 77 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::LeaderStepDownRequestPB, yb::consensus::LeaderStepDownResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 54.1k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetLastOpIdRequestPB, yb::consensus::GetLastOpIdResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 575 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetConsensusStateRequestPB, yb::consensus::GetConsensusStateResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 4.06k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::StartRemoteBootstrapRequestPB, yb::consensus::StartRemoteBootstrapResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 10.6k | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::server::SetFlagRequestPB, yb::server::SetFlagResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 352 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::server::GetFlagRequestPB, yb::server::GetFlagResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 29 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::server::RefreshFlagsRequestPB, yb::server::RefreshFlagsResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 2 | RpcCallPBParamsImpl() = default; |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::server::FlushCoverageRequestPB, yb::server::FlushCoverageResponsePB>::RpcCallPBParamsImpl() yb::rpc::RpcCallPBParamsImpl<yb::server::ServerClockRequestPB, yb::server::ServerClockResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 1 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::server::GetStatusRequestPB, yb::server::GetStatusResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 7 | RpcCallPBParamsImpl() = default; |
yb::rpc::RpcCallPBParamsImpl<yb::server::PingRequestPB, yb::server::PingResponsePB>::RpcCallPBParamsImpl() Line | Count | Source | 99 | 380k | RpcCallPBParamsImpl() = default; |
|
100 | | |
101 | 140M | Req& request() override { |
102 | 140M | return req_; |
103 | 140M | } yb::rpc::RpcCallPBParamsImpl<yb::tserver::BeginRemoteBootstrapSessionRequestPB, yb::tserver::BeginRemoteBootstrapSessionResponsePB>::request() Line | Count | Source | 101 | 4.07k | Req& request() override { | 102 | 4.07k | return req_; | 103 | 4.07k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB, yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB>::request() Line | Count | Source | 101 | 10 | Req& request() override { | 102 | 10 | return req_; | 103 | 10 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::FetchDataRequestPB, yb::tserver::FetchDataResponsePB>::request() Line | Count | Source | 101 | 22.6k | Req& request() override { | 102 | 22.6k | return req_; | 103 | 22.6k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::EndRemoteBootstrapSessionRequestPB, yb::tserver::EndRemoteBootstrapSessionResponsePB>::request() Line | Count | Source | 101 | 4.04k | Req& request() override { | 102 | 4.04k | return req_; | 103 | 4.04k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::RemoveSessionRequestPB, yb::tserver::RemoveSessionResponsePB>::request() Line | Count | Source | 101 | 3.87k | Req& request() override { | 102 | 3.87k | return req_; | 103 | 3.87k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::CreateTabletRequestPB, yb::tserver::CreateTabletResponsePB>::request() Line | Count | Source | 101 | 279k | Req& request() override { | 102 | 279k | return req_; | 103 | 279k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::DeleteTabletRequestPB, yb::tserver::DeleteTabletResponsePB>::request() Line | Count | Source | 101 | 155k | Req& request() override { | 102 | 155k | return req_; | 103 | 155k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tablet::ChangeMetadataRequestPB, yb::tserver::ChangeMetadataResponsePB>::request() Line | Count | Source | 101 | 64.7k | Req& request() override { | 102 | 64.7k | return req_; | 103 | 64.7k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSafeTimeRequestPB, yb::tserver::GetSafeTimeResponsePB>::request() Line | Count | Source | 101 | 8.80k | Req& request() override { | 102 | 8.80k | return req_; | 103 | 8.80k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::BackfillIndexRequestPB, yb::tserver::BackfillIndexResponsePB>::request() Line | Count | Source | 101 | 9.04k | Req& request() override { | 102 | 9.04k | return req_; | 103 | 9.04k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::CopartitionTableRequestPB, yb::tserver::CopartitionTableResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::FlushTabletsRequestPB, yb::tserver::FlushTabletsResponsePB>::request() Line | Count | Source | 101 | 86 | Req& request() override { | 102 | 86 | return req_; | 103 | 86 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::CountIntentsRequestPB, yb::tserver::CountIntentsResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::AddTableToTabletRequestPB, yb::tserver::AddTableToTabletResponsePB>::request() Line | Count | Source | 101 | 252 | Req& request() override { | 102 | 252 | return req_; | 103 | 252 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::RemoveTableFromTabletRequestPB, yb::tserver::RemoveTableFromTabletResponsePB>::request() Line | Count | Source | 101 | 162 | Req& request() override { | 102 | 162 | return req_; | 103 | 162 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tablet::SplitTabletRequestPB, yb::tserver::SplitTabletResponsePB>::request() Line | Count | Source | 101 | 282 | Req& request() override { | 102 | 282 | return req_; | 103 | 282 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::UpgradeYsqlRequestPB, yb::tserver::UpgradeYsqlResponsePB>::request() Line | Count | Source | 101 | 8 | Req& request() override { | 102 | 8 | return req_; | 103 | 8 | } |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::CreateCDCStreamRequestPB, yb::cdc::CreateCDCStreamResponsePB>::request() Line | Count | Source | 101 | 614 | Req& request() override { | 102 | 614 | return req_; | 103 | 614 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::DeleteCDCStreamRequestPB, yb::cdc::DeleteCDCStreamResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::ListTabletsRequestPB, yb::cdc::ListTabletsResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetChangesRequestPB, yb::cdc::GetChangesResponsePB>::request() Line | Count | Source | 101 | 1.28k | Req& request() override { | 102 | 1.28k | return req_; | 103 | 1.28k | } |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetCheckpointRequestPB, yb::cdc::GetCheckpointResponsePB>::request() Line | Count | Source | 101 | 28 | Req& request() override { | 102 | 28 | return req_; | 103 | 28 | } |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::UpdateCdcReplicatedIndexRequestPB, yb::cdc::UpdateCdcReplicatedIndexResponsePB>::request() Line | Count | Source | 101 | 438 | Req& request() override { | 102 | 438 | return req_; | 103 | 438 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::BootstrapProducerRequestPB, yb::cdc::BootstrapProducerResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetLatestEntryOpIdRequestPB, yb::cdc::GetLatestEntryOpIdResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetCDCDBStreamInfoRequestPB, yb::cdc::GetCDCDBStreamInfoResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::cdc::SetCDCCheckpointRequestPB, yb::cdc::SetCDCCheckpointResponsePB>::request() Line | Count | Source | 101 | 12 | Req& request() override { | 102 | 12 | return req_; | 103 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::TabletSnapshotOpRequestPB, yb::tserver::TabletSnapshotOpResponsePB>::request() Line | Count | Source | 101 | 110 | Req& request() override { | 102 | 110 | return req_; | 103 | 110 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateSnapshotRequestPB, yb::master::CreateSnapshotResponsePB>::request() Line | Count | Source | 101 | 6 | Req& request() override { | 102 | 6 | return req_; | 103 | 6 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotsRequestPB, yb::master::ListSnapshotsResponsePB>::request() Line | Count | Source | 101 | 18 | Req& request() override { | 102 | 18 | return req_; | 103 | 18 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotRestorationsRequestPB, yb::master::ListSnapshotRestorationsResponsePB>::request() Line | Count | Source | 101 | 12 | Req& request() override { | 102 | 12 | return req_; | 103 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::RestoreSnapshotRequestPB, yb::master::RestoreSnapshotResponsePB>::request() Line | Count | Source | 101 | 6 | Req& request() override { | 102 | 6 | return req_; | 103 | 6 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteSnapshotRequestPB, yb::master::DeleteSnapshotResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ImportSnapshotMetaRequestPB, yb::master::ImportSnapshotMetaResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::CreateSnapshotScheduleRequestPB, yb::master::CreateSnapshotScheduleResponsePB>::request() Line | Count | Source | 101 | 16 | Req& request() override { | 102 | 16 | return req_; | 103 | 16 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotSchedulesRequestPB, yb::master::ListSnapshotSchedulesResponsePB>::request() Line | Count | Source | 101 | 22 | Req& request() override { | 102 | 22 | return req_; | 103 | 22 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteSnapshotScheduleRequestPB, yb::master::DeleteSnapshotScheduleResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgHeartbeatRequestPB, yb::tserver::PgHeartbeatResponsePB>::request() Line | Count | Source | 101 | 21.5k | Req& request() override { | 102 | 21.5k | return req_; | 103 | 21.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgAlterDatabaseRequestPB, yb::tserver::PgAlterDatabaseResponsePB>::request() Line | Count | Source | 101 | 6 | Req& request() override { | 102 | 6 | return req_; | 103 | 6 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgAlterTableRequestPB, yb::tserver::PgAlterTableResponsePB>::request() Line | Count | Source | 101 | 1.04k | Req& request() override { | 102 | 1.04k | return req_; | 103 | 1.04k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgBackfillIndexRequestPB, yb::tserver::PgBackfillIndexResponsePB>::request() Line | Count | Source | 101 | 1.08k | Req& request() override { | 102 | 1.08k | return req_; | 103 | 1.08k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateDatabaseRequestPB, yb::tserver::PgCreateDatabaseResponsePB>::request() Line | Count | Source | 101 | 268 | Req& request() override { | 102 | 268 | return req_; | 103 | 268 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateSequencesDataTableRequestPB, yb::tserver::PgCreateSequencesDataTableResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateTableRequestPB, yb::tserver::PgCreateTableResponsePB>::request() Line | Count | Source | 101 | 10.1k | Req& request() override { | 102 | 10.1k | return req_; | 103 | 10.1k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateTablegroupRequestPB, yb::tserver::PgCreateTablegroupResponsePB>::request() Line | Count | Source | 101 | 108 | Req& request() override { | 102 | 108 | return req_; | 103 | 108 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropDatabaseRequestPB, yb::tserver::PgDropDatabaseResponsePB>::request() Line | Count | Source | 101 | 144 | Req& request() override { | 102 | 144 | return req_; | 103 | 144 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropTableRequestPB, yb::tserver::PgDropTableResponsePB>::request() Line | Count | Source | 101 | 8.29k | Req& request() override { | 102 | 8.29k | return req_; | 103 | 8.29k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropTablegroupRequestPB, yb::tserver::PgDropTablegroupResponsePB>::request() Line | Count | Source | 101 | 78 | Req& request() override { | 102 | 78 | return req_; | 103 | 78 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgFinishTransactionRequestPB, yb::tserver::PgFinishTransactionResponsePB>::request() Line | Count | Source | 101 | 436k | Req& request() override { | 102 | 436k | return req_; | 103 | 436k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgGetCatalogMasterVersionRequestPB, yb::tserver::PgGetCatalogMasterVersionResponsePB>::request() Line | Count | Source | 101 | 44 | Req& request() override { | 102 | 44 | return req_; | 103 | 44 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgGetDatabaseInfoRequestPB, yb::tserver::PgGetDatabaseInfoResponsePB>::request() Line | Count | Source | 101 | 11.4k | Req& request() override { | 102 | 11.4k | return req_; | 103 | 11.4k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgIsInitDbDoneRequestPB, yb::tserver::PgIsInitDbDoneResponsePB>::request() Line | Count | Source | 101 | 4 | Req& request() override { | 102 | 4 | return req_; | 103 | 4 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgListLiveTabletServersRequestPB, yb::tserver::PgListLiveTabletServersResponsePB>::request() Line | Count | Source | 101 | 8 | Req& request() override { | 102 | 8 | return req_; | 103 | 8 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgOpenTableRequestPB, yb::tserver::PgOpenTableResponsePB>::request() Line | Count | Source | 101 | 383k | Req& request() override { | 102 | 383k | return req_; | 103 | 383k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgPerformRequestPB, yb::tserver::PgPerformResponsePB>::request() Line | Count | Source | 101 | 4.34M | Req& request() override { | 102 | 4.34M | return req_; | 103 | 4.34M | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgReserveOidsRequestPB, yb::tserver::PgReserveOidsResponsePB>::request() Line | Count | Source | 101 | 1.61k | Req& request() override { | 102 | 1.61k | return req_; | 103 | 1.61k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgRollbackSubTransactionRequestPB, yb::tserver::PgRollbackSubTransactionResponsePB>::request() Line | Count | Source | 101 | 27.1k | Req& request() override { | 102 | 27.1k | return req_; | 103 | 27.1k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgSetActiveSubTransactionRequestPB, yb::tserver::PgSetActiveSubTransactionResponsePB>::request() Line | Count | Source | 101 | 123k | Req& request() override { | 102 | 123k | return req_; | 103 | 123k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgTabletServerCountRequestPB, yb::tserver::PgTabletServerCountResponsePB>::request() Line | Count | Source | 101 | 296 | Req& request() override { | 102 | 296 | return req_; | 103 | 296 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgTruncateTableRequestPB, yb::tserver::PgTruncateTableResponsePB>::request() Line | Count | Source | 101 | 1.24k | Req& request() override { | 102 | 1.24k | return req_; | 103 | 1.24k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgValidatePlacementRequestPB, yb::tserver::PgValidatePlacementResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgInsertSequenceTupleRequestPB, yb::tserver::PgInsertSequenceTupleResponsePB>::request() Line | Count | Source | 101 | 590 | Req& request() override { | 102 | 590 | return req_; | 103 | 590 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgUpdateSequenceTupleRequestPB, yb::tserver::PgUpdateSequenceTupleResponsePB>::request() Line | Count | Source | 101 | 5.95k | Req& request() override { | 102 | 5.95k | return req_; | 103 | 5.95k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgReadSequenceTupleRequestPB, yb::tserver::PgReadSequenceTupleResponsePB>::request() Line | Count | Source | 101 | 6.46k | Req& request() override { | 102 | 6.46k | return req_; | 103 | 6.46k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDeleteSequenceTupleRequestPB, yb::tserver::PgDeleteSequenceTupleResponsePB>::request() Line | Count | Source | 101 | 564 | Req& request() override { | 102 | 564 | return req_; | 103 | 564 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDeleteDBSequencesRequestPB, yb::tserver::PgDeleteDBSequencesResponsePB>::request() Line | Count | Source | 101 | 142 | Req& request() override { | 102 | 142 | return req_; | 103 | 142 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::WriteRequestPB, yb::tserver::WriteResponsePB>::request() Line | Count | Source | 101 | 1.59M | Req& request() override { | 102 | 1.59M | return req_; | 103 | 1.59M | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::ReadRequestPB, yb::tserver::ReadResponsePB>::request() Line | Count | Source | 101 | 4.25M | Req& request() override { | 102 | 4.25M | return req_; | 103 | 4.25M | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::VerifyTableRowRangeRequestPB, yb::tserver::VerifyTableRowRangeResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::NoOpRequestPB, yb::tserver::NoOpResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::ListTabletsRequestPB, yb::tserver::ListTabletsResponsePB>::request() Line | Count | Source | 101 | 434 | Req& request() override { | 102 | 434 | return req_; | 103 | 434 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetLogLocationRequestPB, yb::tserver::GetLogLocationResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::ChecksumRequestPB, yb::tserver::ChecksumResponsePB>::request() Line | Count | Source | 101 | 6.60k | Req& request() override { | 102 | 6.60k | return req_; | 103 | 6.60k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::ListTabletsForTabletServerRequestPB, yb::tserver::ListTabletsForTabletServerResponsePB>::request() Line | Count | Source | 101 | 1.76k | Req& request() override { | 102 | 1.76k | return req_; | 103 | 1.76k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::ImportDataRequestPB, yb::tserver::ImportDataResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::UpdateTransactionRequestPB, yb::tserver::UpdateTransactionResponsePB>::request() Line | Count | Source | 101 | 2.44M | Req& request() override { | 102 | 2.44M | return req_; | 103 | 2.44M | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTransactionStatusRequestPB, yb::tserver::GetTransactionStatusResponsePB>::request() Line | Count | Source | 101 | 419k | Req& request() override { | 102 | 419k | return req_; | 103 | 419k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTransactionStatusAtParticipantRequestPB, yb::tserver::GetTransactionStatusAtParticipantResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::AbortTransactionRequestPB, yb::tserver::AbortTransactionResponsePB>::request() Line | Count | Source | 101 | 69.7k | Req& request() override { | 102 | 69.7k | return req_; | 103 | 69.7k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::TruncateRequestPB, yb::tserver::TruncateResponsePB>::request() Line | Count | Source | 101 | 114k | Req& request() override { | 102 | 114k | return req_; | 103 | 114k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTabletStatusRequestPB, yb::tserver::GetTabletStatusResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetMasterAddressesRequestPB, yb::tserver::GetMasterAddressesResponsePB>::request() Line | Count | Source | 101 | 18 | Req& request() override { | 102 | 18 | return req_; | 103 | 18 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PublishRequestPB, yb::tserver::PublishResponsePB>::request() Line | Count | Source | 101 | 1.36k | Req& request() override { | 102 | 1.36k | return req_; | 103 | 1.36k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::IsTabletServerReadyRequestPB, yb::tserver::IsTabletServerReadyResponsePB>::request() Line | Count | Source | 101 | 36 | Req& request() override { | 102 | 36 | return req_; | 103 | 36 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::TakeTransactionRequestPB, yb::tserver::TakeTransactionResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSplitKeyRequestPB, yb::tserver::GetSplitKeyResponsePB>::request() Line | Count | Source | 101 | 288 | Req& request() override { | 102 | 288 | return req_; | 103 | 288 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSharedDataRequestPB, yb::tserver::GetSharedDataResponsePB>::request() Line | Count | Source | 101 | 16 | Req& request() override { | 102 | 16 | return req_; | 103 | 16 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::AddRequestPB, yb::rpc_test::AddResponsePB>::request() Line | Count | Source | 101 | 1.27k | Req& request() override { | 102 | 1.27k | return req_; | 103 | 1.27k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::SleepRequestPB, yb::rpc_test::SleepResponsePB>::request() Line | Count | Source | 101 | 74 | Req& request() override { | 102 | 74 | return req_; | 103 | 74 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::EchoRequestPB, yb::rpc_test::EchoResponsePB>::request() Line | Count | Source | 101 | 27.2k | Req& request() override { | 102 | 27.2k | return req_; | 103 | 27.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::WhoAmIRequestPB, yb::rpc_test::WhoAmIResponsePB>::request() Line | Count | Source | 101 | 8 | Req& request() override { | 102 | 8 | return req_; | 103 | 8 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::rpc_test_diff_package::ReqDiffPackagePB, yb::rpc_test_diff_package::RespDiffPackagePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::PanicRequestPB, yb::rpc_test::PanicResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::PingRequestPB, yb::rpc_test::PingResponsePB>::request() Line | Count | Source | 101 | 99.7k | Req& request() override { | 102 | 99.7k | return req_; | 103 | 99.7k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::DisconnectRequestPB, yb::rpc_test::DisconnectResponsePB>::request() Line | Count | Source | 101 | 10.4k | Req& request() override { | 102 | 10.4k | return req_; | 103 | 10.4k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::ForwardRequestPB, yb::rpc_test::ForwardResponsePB>::request() Line | Count | Source | 101 | 24 | Req& request() override { | 102 | 24 | return req_; | 103 | 24 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::TrivialRequestPB, yb::rpc_test::TrivialResponsePB>::request() Line | Count | Source | 101 | 4 | Req& request() override { | 102 | 4 | return req_; | 103 | 4 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::ConcatRequestPB, yb::rpc_test::ConcatResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::FlushTablesRequestPB, yb::master::FlushTablesResponsePB>::request() Line | Count | Source | 101 | 20 | Req& request() override { | 102 | 20 | return req_; | 103 | 20 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsFlushTablesDoneRequestPB, yb::master::IsFlushTablesDoneResponsePB>::request() Line | Count | Source | 101 | 42 | Req& request() override { | 102 | 42 | return req_; | 103 | 42 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::FlushSysCatalogRequestPB, yb::master::FlushSysCatalogResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::CompactSysCatalogRequestPB, yb::master::CompactSysCatalogResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::IsInitDbDoneRequestPB, yb::master::IsInitDbDoneResponsePB>::request() Line | Count | Source | 101 | 10.2k | Req& request() override { | 102 | 10.2k | return req_; | 103 | 10.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::SplitTabletRequestPB, yb::master::SplitTabletResponsePB>::request() Line | Count | Source | 101 | 132 | Req& request() override { | 102 | 132 | return req_; | 103 | 132 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTransactionStatusTableRequestPB, yb::master::CreateTransactionStatusTableResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteNotServingTabletRequestPB, yb::master::DeleteNotServingTabletResponsePB>::request() Line | Count | Source | 101 | 12 | Req& request() override { | 102 | 12 | return req_; | 103 | 12 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DisableTabletSplittingRequestPB, yb::master::DisableTabletSplittingResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::IsTabletSplittingCompleteRequestPB, yb::master::IsTabletSplittingCompleteResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::DdlLogRequestPB, yb::master::DdlLogResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTabletLocationsRequestPB, yb::master::GetTabletLocationsResponsePB>::request() Line | Count | Source | 101 | 30.5k | Req& request() override { | 102 | 30.5k | return req_; | 103 | 30.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTableLocationsRequestPB, yb::master::GetTableLocationsResponsePB>::request() Line | Count | Source | 101 | 457k | Req& request() override { | 102 | 457k | return req_; | 103 | 457k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTransactionStatusTabletsRequestPB, yb::master::GetTransactionStatusTabletsResponsePB>::request() Line | Count | Source | 101 | 6.71k | Req& request() override { | 102 | 6.71k | return req_; | 103 | 6.71k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ReservePgsqlOidsRequestPB, yb::master::ReservePgsqlOidsResponsePB>::request() Line | Count | Source | 101 | 1.61k | Req& request() override { | 102 | 1.61k | return req_; | 103 | 1.61k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetYsqlCatalogConfigRequestPB, yb::master::GetYsqlCatalogConfigResponsePB>::request() Line | Count | Source | 101 | 44 | Req& request() override { | 102 | 44 | return req_; | 103 | 44 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::RedisConfigSetRequestPB, yb::master::RedisConfigSetResponsePB>::request() Line | Count | Source | 101 | 364 | Req& request() override { | 102 | 364 | return req_; | 103 | 364 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::RedisConfigGetRequestPB, yb::master::RedisConfigGetResponsePB>::request() Line | Count | Source | 101 | 2.35k | Req& request() override { | 102 | 2.35k | return req_; | 103 | 2.35k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTabletServersRequestPB, yb::master::ListTabletServersResponsePB>::request() Line | Count | Source | 101 | 53.6k | Req& request() override { | 102 | 53.6k | return req_; | 103 | 53.6k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListLiveTabletServersRequestPB, yb::master::ListLiveTabletServersResponsePB>::request() Line | Count | Source | 101 | 8 | Req& request() override { | 102 | 8 | return req_; | 103 | 8 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListMastersRequestPB, yb::master::ListMastersResponsePB>::request() Line | Count | Source | 101 | 134 | Req& request() override { | 102 | 134 | return req_; | 103 | 134 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ListMasterRaftPeersRequestPB, yb::master::ListMasterRaftPeersResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::GetMasterRegistrationRequestPB, yb::master::GetMasterRegistrationResponsePB>::request() Line | Count | Source | 101 | 58.8M | Req& request() override { | 102 | 58.8M | return req_; | 103 | 58.8M | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsMasterLeaderReadyRequestPB, yb::master::IsMasterLeaderReadyResponsePB>::request() Line | Count | Source | 101 | 344 | Req& request() override { | 102 | 344 | return req_; | 103 | 344 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DumpMasterStateRequestPB, yb::master::DumpMasterStateResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeLoadBalancerStateRequestPB, yb::master::ChangeLoadBalancerStateResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetLoadBalancerStateRequestPB, yb::master::GetLoadBalancerStateResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::RemovedMasterUpdateRequestPB, yb::master::RemovedMasterUpdateResponsePB>::request() Line | Count | Source | 101 | 76 | Req& request() override { | 102 | 76 | return req_; | 103 | 76 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::SetPreferredZonesRequestPB, yb::master::SetPreferredZonesResponsePB>::request() Line | Count | Source | 101 | 6 | Req& request() override { | 102 | 6 | return req_; | 103 | 6 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetMasterClusterConfigRequestPB, yb::master::GetMasterClusterConfigResponsePB>::request() Line | Count | Source | 101 | 668 | Req& request() override { | 102 | 668 | return req_; | 103 | 668 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeMasterClusterConfigRequestPB, yb::master::ChangeMasterClusterConfigResponsePB>::request() Line | Count | Source | 101 | 340 | Req& request() override { | 102 | 340 | return req_; | 103 | 340 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetLoadMovePercentRequestPB, yb::master::GetLoadMovePercentResponsePB>::request() Line | Count | Source | 101 | 4.12k | Req& request() override { | 102 | 4.12k | return req_; | 103 | 4.12k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetLeaderBlacklistPercentRequestPB, yb::master::GetLoadMovePercentResponsePB>::request() Line | Count | Source | 101 | 776 | Req& request() override { | 102 | 776 | return req_; | 103 | 776 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsLoadBalancedRequestPB, yb::master::IsLoadBalancedResponsePB>::request() Line | Count | Source | 101 | 476 | Req& request() override { | 102 | 476 | return req_; | 103 | 476 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsLoadBalancerIdleRequestPB, yb::master::IsLoadBalancerIdleResponsePB>::request() Line | Count | Source | 101 | 4.97k | Req& request() override { | 102 | 4.97k | return req_; | 103 | 4.97k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AreLeadersOnPreferredOnlyRequestPB, yb::master::AreLeadersOnPreferredOnlyResponsePB>::request() Line | Count | Source | 101 | 294 | Req& request() override { | 102 | 294 | return req_; | 103 | 294 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateRoleRequestPB, yb::master::CreateRoleResponsePB>::request() Line | Count | Source | 101 | 1.51k | Req& request() override { | 102 | 1.51k | return req_; | 103 | 1.51k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterRoleRequestPB, yb::master::AlterRoleResponsePB>::request() Line | Count | Source | 101 | 116 | Req& request() override { | 102 | 116 | return req_; | 103 | 116 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteRoleRequestPB, yb::master::DeleteRoleResponsePB>::request() Line | Count | Source | 101 | 1.46k | Req& request() override { | 102 | 1.46k | return req_; | 103 | 1.46k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GrantRevokeRoleRequestPB, yb::master::GrantRevokeRoleResponsePB>::request() Line | Count | Source | 101 | 104 | Req& request() override { | 102 | 104 | return req_; | 103 | 104 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GrantRevokePermissionRequestPB, yb::master::GrantRevokePermissionResponsePB>::request() Line | Count | Source | 101 | 1.44k | Req& request() override { | 102 | 1.44k | return req_; | 103 | 1.44k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetPermissionsRequestPB, yb::master::GetPermissionsResponsePB>::request() Line | Count | Source | 101 | 233k | Req& request() override { | 102 | 233k | return req_; | 103 | 233k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTableRequestPB, yb::master::CreateTableResponsePB>::request() Line | Count | Source | 101 | 14.9k | Req& request() override { | 102 | 14.9k | return req_; | 103 | 14.9k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsCreateTableDoneRequestPB, yb::master::IsCreateTableDoneResponsePB>::request() Line | Count | Source | 101 | 59.3k | Req& request() override { | 102 | 59.3k | return req_; | 103 | 59.3k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTablesRequestPB, yb::master::ListTablesResponsePB>::request() Line | Count | Source | 101 | 5.86k | Req& request() override { | 102 | 5.86k | return req_; | 103 | 5.86k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTableSchemaRequestPB, yb::master::GetTableSchemaResponsePB>::request() Line | Count | Source | 101 | 342k | Req& request() override { | 102 | 342k | return req_; | 103 | 342k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetTablegroupSchemaRequestPB, yb::master::GetTablegroupSchemaResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetColocatedTabletSchemaRequestPB, yb::master::GetColocatedTabletSchemaResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::TruncateTableRequestPB, yb::master::TruncateTableResponsePB>::request() Line | Count | Source | 101 | 25.2k | Req& request() override { | 102 | 25.2k | return req_; | 103 | 25.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsTruncateTableDoneRequestPB, yb::master::IsTruncateTableDoneResponsePB>::request() Line | Count | Source | 101 | 21.1k | Req& request() override { | 102 | 21.1k | return req_; | 103 | 21.1k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::BackfillIndexRequestPB, yb::master::BackfillIndexResponsePB>::request() Line | Count | Source | 101 | 1.08k | Req& request() override { | 102 | 1.08k | return req_; | 103 | 1.08k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::LaunchBackfillIndexForTableRequestPB, yb::master::LaunchBackfillIndexForTableResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetBackfillJobsRequestPB, yb::master::GetBackfillJobsResponsePB>::request() Line | Count | Source | 101 | 1.39k | Req& request() override { | 102 | 1.39k | return req_; | 103 | 1.39k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteTableRequestPB, yb::master::DeleteTableResponsePB>::request() Line | Count | Source | 101 | 11.0k | Req& request() override { | 102 | 11.0k | return req_; | 103 | 11.0k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsDeleteTableDoneRequestPB, yb::master::IsDeleteTableDoneResponsePB>::request() Line | Count | Source | 101 | 23.5k | Req& request() override { | 102 | 23.5k | return req_; | 103 | 23.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterTableRequestPB, yb::master::AlterTableResponsePB>::request() Line | Count | Source | 101 | 1.40k | Req& request() override { | 102 | 1.40k | return req_; | 103 | 1.40k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsAlterTableDoneRequestPB, yb::master::IsAlterTableDoneResponsePB>::request() Line | Count | Source | 101 | 2.79k | Req& request() override { | 102 | 2.79k | return req_; | 103 | 2.79k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateNamespaceRequestPB, yb::master::CreateNamespaceResponsePB>::request() Line | Count | Source | 101 | 5.29k | Req& request() override { | 102 | 5.29k | return req_; | 103 | 5.29k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsCreateNamespaceDoneRequestPB, yb::master::IsCreateNamespaceDoneResponsePB>::request() Line | Count | Source | 101 | 7.13k | Req& request() override { | 102 | 7.13k | return req_; | 103 | 7.13k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteNamespaceRequestPB, yb::master::DeleteNamespaceResponsePB>::request() Line | Count | Source | 101 | 3.29k | Req& request() override { | 102 | 3.29k | return req_; | 103 | 3.29k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsDeleteNamespaceDoneRequestPB, yb::master::IsDeleteNamespaceDoneResponsePB>::request() Line | Count | Source | 101 | 3.48k | Req& request() override { | 102 | 3.48k | return req_; | 103 | 3.48k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterNamespaceRequestPB, yb::master::AlterNamespaceResponsePB>::request() Line | Count | Source | 101 | 14 | Req& request() override { | 102 | 14 | return req_; | 103 | 14 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListNamespacesRequestPB, yb::master::ListNamespacesResponsePB>::request() Line | Count | Source | 101 | 10.2k | Req& request() override { | 102 | 10.2k | return req_; | 103 | 10.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetNamespaceInfoRequestPB, yb::master::GetNamespaceInfoResponsePB>::request() Line | Count | Source | 101 | 12.0k | Req& request() override { | 102 | 12.0k | return req_; | 103 | 12.0k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTablegroupRequestPB, yb::master::CreateTablegroupResponsePB>::request() Line | Count | Source | 101 | 112 | Req& request() override { | 102 | 112 | return req_; | 103 | 112 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteTablegroupRequestPB, yb::master::DeleteTablegroupResponsePB>::request() Line | Count | Source | 101 | 80 | Req& request() override { | 102 | 80 | return req_; | 103 | 80 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTablegroupsRequestPB, yb::master::ListTablegroupsResponsePB>::request() Line | Count | Source | 101 | 14 | Req& request() override { | 102 | 14 | return req_; | 103 | 14 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateUDTypeRequestPB, yb::master::CreateUDTypeResponsePB>::request() Line | Count | Source | 101 | 94 | Req& request() override { | 102 | 94 | return req_; | 103 | 94 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteUDTypeRequestPB, yb::master::DeleteUDTypeResponsePB>::request() Line | Count | Source | 101 | 108 | Req& request() override { | 102 | 108 | return req_; | 103 | 108 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ListUDTypesRequestPB, yb::master::ListUDTypesResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::GetUDTypeInfoRequestPB, yb::master::GetUDTypeInfoResponsePB>::request() Line | Count | Source | 101 | 112 | Req& request() override { | 102 | 112 | return req_; | 103 | 112 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeEncryptionInfoRequestPB, yb::master::ChangeEncryptionInfoResponsePB>::request() Line | Count | Source | 101 | 34 | Req& request() override { | 102 | 34 | return req_; | 103 | 34 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsEncryptionEnabledRequestPB, yb::master::IsEncryptionEnabledResponsePB>::request() Line | Count | Source | 101 | 34 | Req& request() override { | 102 | 34 | return req_; | 103 | 34 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AddUniverseKeysRequestPB, yb::master::AddUniverseKeysResponsePB>::request() Line | Count | Source | 101 | 102 | Req& request() override { | 102 | 102 | return req_; | 103 | 102 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetUniverseKeyRegistryRequestPB, yb::master::GetUniverseKeyRegistryResponsePB>::request() Line | Count | Source | 101 | 25.5k | Req& request() override { | 102 | 25.5k | return req_; | 103 | 25.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::HasUniverseKeyInMemoryRequestPB, yb::master::HasUniverseKeyInMemoryResponsePB>::request() Line | Count | Source | 101 | 138 | Req& request() override { | 102 | 138 | return req_; | 103 | 138 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::TSHeartbeatRequestPB, yb::master::TSHeartbeatResponsePB>::request() Line | Count | Source | 101 | 10.3M | Req& request() override { | 102 | 10.3M | return req_; | 103 | 10.3M | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ValidateReplicationInfoRequestPB, yb::master::ValidateReplicationInfoResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateCDCStreamRequestPB, yb::master::CreateCDCStreamResponsePB>::request() Line | Count | Source | 101 | 11.0k | Req& request() override { | 102 | 11.0k | return req_; | 103 | 11.0k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteCDCStreamRequestPB, yb::master::DeleteCDCStreamResponsePB>::request() Line | Count | Source | 101 | 4 | Req& request() override { | 102 | 4 | return req_; | 103 | 4 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListCDCStreamsRequestPB, yb::master::ListCDCStreamsResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetCDCStreamRequestPB, yb::master::GetCDCStreamResponsePB>::request() Line | Count | Source | 101 | 12 | Req& request() override { | 102 | 12 | return req_; | 103 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetCDCDBStreamInfoRequestPB, yb::master::GetCDCDBStreamInfoResponsePB>::request() Line | Count | Source | 101 | 44 | Req& request() override { | 102 | 44 | return req_; | 103 | 44 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::UpdateCDCStreamRequestPB, yb::master::UpdateCDCStreamResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::master::SetupUniverseReplicationRequestPB, yb::master::SetupUniverseReplicationResponsePB>::request() Line | Count | Source | 101 | 4 | Req& request() override { | 102 | 4 | return req_; | 103 | 4 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteUniverseReplicationRequestPB, yb::master::DeleteUniverseReplicationResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::AlterUniverseReplicationRequestPB, yb::master::AlterUniverseReplicationResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::SetUniverseReplicationEnabledRequestPB, yb::master::SetUniverseReplicationEnabledResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetUniverseReplicationRequestPB, yb::master::GetUniverseReplicationResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::IsSetupUniverseReplicationDoneRequestPB, yb::master::IsSetupUniverseReplicationDoneResponsePB>::request() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::UpdateConsumerOnProducerSplitRequestPB, yb::master::UpdateConsumerOnProducerSplitResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::consensus::ConsensusRequestPB, yb::consensus::ConsensusResponsePB>::request() Line | Count | Source | 101 | 51.1M | Req& request() override { | 102 | 51.1M | return req_; | 103 | 51.1M | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::consensus::MultiRaftConsensusRequestPB, yb::consensus::MultiRaftConsensusResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::consensus::VoteRequestPB, yb::consensus::VoteResponsePB>::request() Line | Count | Source | 101 | 2.78M | Req& request() override { | 102 | 2.78M | return req_; | 103 | 2.78M | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::ChangeConfigRequestPB, yb::consensus::ChangeConfigResponsePB>::request() Line | Count | Source | 101 | 10.5k | Req& request() override { | 102 | 10.5k | return req_; | 103 | 10.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::UnsafeChangeConfigRequestPB, yb::consensus::UnsafeChangeConfigResponsePB>::request() Line | Count | Source | 101 | 12 | Req& request() override { | 102 | 12 | return req_; | 103 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetNodeInstanceRequestPB, yb::consensus::GetNodeInstanceResponsePB>::request() Line | Count | Source | 101 | 41.9k | Req& request() override { | 102 | 41.9k | return req_; | 103 | 41.9k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::RunLeaderElectionRequestPB, yb::consensus::RunLeaderElectionResponsePB>::request() Line | Count | Source | 101 | 192k | Req& request() override { | 102 | 192k | return req_; | 103 | 192k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::LeaderElectionLostRequestPB, yb::consensus::LeaderElectionLostResponsePB>::request() Line | Count | Source | 101 | 154 | Req& request() override { | 102 | 154 | return req_; | 103 | 154 | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::LeaderStepDownRequestPB, yb::consensus::LeaderStepDownResponsePB>::request() Line | Count | Source | 101 | 108k | Req& request() override { | 102 | 108k | return req_; | 103 | 108k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetLastOpIdRequestPB, yb::consensus::GetLastOpIdResponsePB>::request() Line | Count | Source | 101 | 1.15k | Req& request() override { | 102 | 1.15k | return req_; | 103 | 1.15k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetConsensusStateRequestPB, yb::consensus::GetConsensusStateResponsePB>::request() Line | Count | Source | 101 | 8.13k | Req& request() override { | 102 | 8.13k | return req_; | 103 | 8.13k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::StartRemoteBootstrapRequestPB, yb::consensus::StartRemoteBootstrapResponsePB>::request() Line | Count | Source | 101 | 21.2k | Req& request() override { | 102 | 21.2k | return req_; | 103 | 21.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::SetFlagRequestPB, yb::server::SetFlagResponsePB>::request() Line | Count | Source | 101 | 704 | Req& request() override { | 102 | 704 | return req_; | 103 | 704 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::GetFlagRequestPB, yb::server::GetFlagResponsePB>::request() Line | Count | Source | 101 | 58 | Req& request() override { | 102 | 58 | return req_; | 103 | 58 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::RefreshFlagsRequestPB, yb::server::RefreshFlagsResponsePB>::request() Line | Count | Source | 101 | 4 | Req& request() override { | 102 | 4 | return req_; | 103 | 4 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::server::FlushCoverageRequestPB, yb::server::FlushCoverageResponsePB>::request() yb::rpc::RpcCallPBParamsImpl<yb::server::ServerClockRequestPB, yb::server::ServerClockResponsePB>::request() Line | Count | Source | 101 | 2 | Req& request() override { | 102 | 2 | return req_; | 103 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::GetStatusRequestPB, yb::server::GetStatusResponsePB>::request() Line | Count | Source | 101 | 14 | Req& request() override { | 102 | 14 | return req_; | 103 | 14 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::PingRequestPB, yb::server::PingResponsePB>::request() Line | Count | Source | 101 | 761k | Req& request() override { | 102 | 761k | return req_; | 103 | 761k | } |
|
104 | | |
105 | 140M | Resp& response() override { |
106 | 140M | return resp_; |
107 | 140M | } yb::rpc::RpcCallPBParamsImpl<yb::tserver::BeginRemoteBootstrapSessionRequestPB, yb::tserver::BeginRemoteBootstrapSessionResponsePB>::response() Line | Count | Source | 105 | 4.06k | Resp& response() override { | 106 | 4.06k | return resp_; | 107 | 4.06k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB, yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB>::response() Line | Count | Source | 105 | 10 | Resp& response() override { | 106 | 10 | return resp_; | 107 | 10 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::FetchDataRequestPB, yb::tserver::FetchDataResponsePB>::response() Line | Count | Source | 105 | 20.6k | Resp& response() override { | 106 | 20.6k | return resp_; | 107 | 20.6k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::EndRemoteBootstrapSessionRequestPB, yb::tserver::EndRemoteBootstrapSessionResponsePB>::response() Line | Count | Source | 105 | 4.04k | Resp& response() override { | 106 | 4.04k | return resp_; | 107 | 4.04k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::RemoveSessionRequestPB, yb::tserver::RemoveSessionResponsePB>::response() Line | Count | Source | 105 | 3.87k | Resp& response() override { | 106 | 3.87k | return resp_; | 107 | 3.87k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::CreateTabletRequestPB, yb::tserver::CreateTabletResponsePB>::response() Line | Count | Source | 105 | 279k | Resp& response() override { | 106 | 279k | return resp_; | 107 | 279k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::DeleteTabletRequestPB, yb::tserver::DeleteTabletResponsePB>::response() Line | Count | Source | 105 | 155k | Resp& response() override { | 106 | 155k | return resp_; | 107 | 155k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tablet::ChangeMetadataRequestPB, yb::tserver::ChangeMetadataResponsePB>::response() Line | Count | Source | 105 | 64.8k | Resp& response() override { | 106 | 64.8k | return resp_; | 107 | 64.8k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSafeTimeRequestPB, yb::tserver::GetSafeTimeResponsePB>::response() Line | Count | Source | 105 | 8.79k | Resp& response() override { | 106 | 8.79k | return resp_; | 107 | 8.79k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::BackfillIndexRequestPB, yb::tserver::BackfillIndexResponsePB>::response() Line | Count | Source | 105 | 8.88k | Resp& response() override { | 106 | 8.88k | return resp_; | 107 | 8.88k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::CopartitionTableRequestPB, yb::tserver::CopartitionTableResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::FlushTabletsRequestPB, yb::tserver::FlushTabletsResponsePB>::response() Line | Count | Source | 105 | 86 | Resp& response() override { | 106 | 86 | return resp_; | 107 | 86 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::CountIntentsRequestPB, yb::tserver::CountIntentsResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::AddTableToTabletRequestPB, yb::tserver::AddTableToTabletResponsePB>::response() Line | Count | Source | 105 | 252 | Resp& response() override { | 106 | 252 | return resp_; | 107 | 252 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::RemoveTableFromTabletRequestPB, yb::tserver::RemoveTableFromTabletResponsePB>::response() Line | Count | Source | 105 | 162 | Resp& response() override { | 106 | 162 | return resp_; | 107 | 162 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tablet::SplitTabletRequestPB, yb::tserver::SplitTabletResponsePB>::response() Line | Count | Source | 105 | 281 | Resp& response() override { | 106 | 281 | return resp_; | 107 | 281 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::UpgradeYsqlRequestPB, yb::tserver::UpgradeYsqlResponsePB>::response() Line | Count | Source | 105 | 8 | Resp& response() override { | 106 | 8 | return resp_; | 107 | 8 | } |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::CreateCDCStreamRequestPB, yb::cdc::CreateCDCStreamResponsePB>::response() Line | Count | Source | 105 | 614 | Resp& response() override { | 106 | 614 | return resp_; | 107 | 614 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::DeleteCDCStreamRequestPB, yb::cdc::DeleteCDCStreamResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::ListTabletsRequestPB, yb::cdc::ListTabletsResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetChangesRequestPB, yb::cdc::GetChangesResponsePB>::response() Line | Count | Source | 105 | 1.28k | Resp& response() override { | 106 | 1.28k | return resp_; | 107 | 1.28k | } |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetCheckpointRequestPB, yb::cdc::GetCheckpointResponsePB>::response() Line | Count | Source | 105 | 28 | Resp& response() override { | 106 | 28 | return resp_; | 107 | 28 | } |
yb::rpc::RpcCallPBParamsImpl<yb::cdc::UpdateCdcReplicatedIndexRequestPB, yb::cdc::UpdateCdcReplicatedIndexResponsePB>::response() Line | Count | Source | 105 | 438 | Resp& response() override { | 106 | 438 | return resp_; | 107 | 438 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::BootstrapProducerRequestPB, yb::cdc::BootstrapProducerResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetLatestEntryOpIdRequestPB, yb::cdc::GetLatestEntryOpIdResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::cdc::GetCDCDBStreamInfoRequestPB, yb::cdc::GetCDCDBStreamInfoResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::cdc::SetCDCCheckpointRequestPB, yb::cdc::SetCDCCheckpointResponsePB>::response() Line | Count | Source | 105 | 12 | Resp& response() override { | 106 | 12 | return resp_; | 107 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::TabletSnapshotOpRequestPB, yb::tserver::TabletSnapshotOpResponsePB>::response() Line | Count | Source | 105 | 110 | Resp& response() override { | 106 | 110 | return resp_; | 107 | 110 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateSnapshotRequestPB, yb::master::CreateSnapshotResponsePB>::response() Line | Count | Source | 105 | 6 | Resp& response() override { | 106 | 6 | return resp_; | 107 | 6 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotsRequestPB, yb::master::ListSnapshotsResponsePB>::response() Line | Count | Source | 105 | 18 | Resp& response() override { | 106 | 18 | return resp_; | 107 | 18 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotRestorationsRequestPB, yb::master::ListSnapshotRestorationsResponsePB>::response() Line | Count | Source | 105 | 12 | Resp& response() override { | 106 | 12 | return resp_; | 107 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::RestoreSnapshotRequestPB, yb::master::RestoreSnapshotResponsePB>::response() Line | Count | Source | 105 | 6 | Resp& response() override { | 106 | 6 | return resp_; | 107 | 6 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteSnapshotRequestPB, yb::master::DeleteSnapshotResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ImportSnapshotMetaRequestPB, yb::master::ImportSnapshotMetaResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::CreateSnapshotScheduleRequestPB, yb::master::CreateSnapshotScheduleResponsePB>::response() Line | Count | Source | 105 | 16 | Resp& response() override { | 106 | 16 | return resp_; | 107 | 16 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListSnapshotSchedulesRequestPB, yb::master::ListSnapshotSchedulesResponsePB>::response() Line | Count | Source | 105 | 22 | Resp& response() override { | 106 | 22 | return resp_; | 107 | 22 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteSnapshotScheduleRequestPB, yb::master::DeleteSnapshotScheduleResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgHeartbeatRequestPB, yb::tserver::PgHeartbeatResponsePB>::response() Line | Count | Source | 105 | 21.5k | Resp& response() override { | 106 | 21.5k | return resp_; | 107 | 21.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgAlterDatabaseRequestPB, yb::tserver::PgAlterDatabaseResponsePB>::response() Line | Count | Source | 105 | 6 | Resp& response() override { | 106 | 6 | return resp_; | 107 | 6 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgAlterTableRequestPB, yb::tserver::PgAlterTableResponsePB>::response() Line | Count | Source | 105 | 1.04k | Resp& response() override { | 106 | 1.04k | return resp_; | 107 | 1.04k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgBackfillIndexRequestPB, yb::tserver::PgBackfillIndexResponsePB>::response() Line | Count | Source | 105 | 1.08k | Resp& response() override { | 106 | 1.08k | return resp_; | 107 | 1.08k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateDatabaseRequestPB, yb::tserver::PgCreateDatabaseResponsePB>::response() Line | Count | Source | 105 | 268 | Resp& response() override { | 106 | 268 | return resp_; | 107 | 268 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateSequencesDataTableRequestPB, yb::tserver::PgCreateSequencesDataTableResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateTableRequestPB, yb::tserver::PgCreateTableResponsePB>::response() Line | Count | Source | 105 | 10.1k | Resp& response() override { | 106 | 10.1k | return resp_; | 107 | 10.1k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgCreateTablegroupRequestPB, yb::tserver::PgCreateTablegroupResponsePB>::response() Line | Count | Source | 105 | 108 | Resp& response() override { | 106 | 108 | return resp_; | 107 | 108 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropDatabaseRequestPB, yb::tserver::PgDropDatabaseResponsePB>::response() Line | Count | Source | 105 | 144 | Resp& response() override { | 106 | 144 | return resp_; | 107 | 144 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropTableRequestPB, yb::tserver::PgDropTableResponsePB>::response() Line | Count | Source | 105 | 8.29k | Resp& response() override { | 106 | 8.29k | return resp_; | 107 | 8.29k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDropTablegroupRequestPB, yb::tserver::PgDropTablegroupResponsePB>::response() Line | Count | Source | 105 | 78 | Resp& response() override { | 106 | 78 | return resp_; | 107 | 78 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgFinishTransactionRequestPB, yb::tserver::PgFinishTransactionResponsePB>::response() Line | Count | Source | 105 | 437k | Resp& response() override { | 106 | 437k | return resp_; | 107 | 437k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgGetCatalogMasterVersionRequestPB, yb::tserver::PgGetCatalogMasterVersionResponsePB>::response() Line | Count | Source | 105 | 44 | Resp& response() override { | 106 | 44 | return resp_; | 107 | 44 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgGetDatabaseInfoRequestPB, yb::tserver::PgGetDatabaseInfoResponsePB>::response() Line | Count | Source | 105 | 11.4k | Resp& response() override { | 106 | 11.4k | return resp_; | 107 | 11.4k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgIsInitDbDoneRequestPB, yb::tserver::PgIsInitDbDoneResponsePB>::response() Line | Count | Source | 105 | 4 | Resp& response() override { | 106 | 4 | return resp_; | 107 | 4 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgListLiveTabletServersRequestPB, yb::tserver::PgListLiveTabletServersResponsePB>::response() Line | Count | Source | 105 | 8 | Resp& response() override { | 106 | 8 | return resp_; | 107 | 8 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgOpenTableRequestPB, yb::tserver::PgOpenTableResponsePB>::response() Line | Count | Source | 105 | 383k | Resp& response() override { | 106 | 383k | return resp_; | 107 | 383k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgPerformRequestPB, yb::tserver::PgPerformResponsePB>::response() Line | Count | Source | 105 | 4.34M | Resp& response() override { | 106 | 4.34M | return resp_; | 107 | 4.34M | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgReserveOidsRequestPB, yb::tserver::PgReserveOidsResponsePB>::response() Line | Count | Source | 105 | 1.61k | Resp& response() override { | 106 | 1.61k | return resp_; | 107 | 1.61k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgRollbackSubTransactionRequestPB, yb::tserver::PgRollbackSubTransactionResponsePB>::response() Line | Count | Source | 105 | 27.1k | Resp& response() override { | 106 | 27.1k | return resp_; | 107 | 27.1k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgSetActiveSubTransactionRequestPB, yb::tserver::PgSetActiveSubTransactionResponsePB>::response() Line | Count | Source | 105 | 123k | Resp& response() override { | 106 | 123k | return resp_; | 107 | 123k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgTabletServerCountRequestPB, yb::tserver::PgTabletServerCountResponsePB>::response() Line | Count | Source | 105 | 296 | Resp& response() override { | 106 | 296 | return resp_; | 107 | 296 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgTruncateTableRequestPB, yb::tserver::PgTruncateTableResponsePB>::response() Line | Count | Source | 105 | 1.24k | Resp& response() override { | 106 | 1.24k | return resp_; | 107 | 1.24k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgValidatePlacementRequestPB, yb::tserver::PgValidatePlacementResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgInsertSequenceTupleRequestPB, yb::tserver::PgInsertSequenceTupleResponsePB>::response() Line | Count | Source | 105 | 590 | Resp& response() override { | 106 | 590 | return resp_; | 107 | 590 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgUpdateSequenceTupleRequestPB, yb::tserver::PgUpdateSequenceTupleResponsePB>::response() Line | Count | Source | 105 | 5.95k | Resp& response() override { | 106 | 5.95k | return resp_; | 107 | 5.95k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgReadSequenceTupleRequestPB, yb::tserver::PgReadSequenceTupleResponsePB>::response() Line | Count | Source | 105 | 6.46k | Resp& response() override { | 106 | 6.46k | return resp_; | 107 | 6.46k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDeleteSequenceTupleRequestPB, yb::tserver::PgDeleteSequenceTupleResponsePB>::response() Line | Count | Source | 105 | 564 | Resp& response() override { | 106 | 564 | return resp_; | 107 | 564 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PgDeleteDBSequencesRequestPB, yb::tserver::PgDeleteDBSequencesResponsePB>::response() Line | Count | Source | 105 | 142 | Resp& response() override { | 106 | 142 | return resp_; | 107 | 142 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::WriteRequestPB, yb::tserver::WriteResponsePB>::response() Line | Count | Source | 105 | 1.59M | Resp& response() override { | 106 | 1.59M | return resp_; | 107 | 1.59M | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::ReadRequestPB, yb::tserver::ReadResponsePB>::response() Line | Count | Source | 105 | 4.25M | Resp& response() override { | 106 | 4.25M | return resp_; | 107 | 4.25M | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::VerifyTableRowRangeRequestPB, yb::tserver::VerifyTableRowRangeResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::NoOpRequestPB, yb::tserver::NoOpResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::ListTabletsRequestPB, yb::tserver::ListTabletsResponsePB>::response() Line | Count | Source | 105 | 434 | Resp& response() override { | 106 | 434 | return resp_; | 107 | 434 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetLogLocationRequestPB, yb::tserver::GetLogLocationResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::ChecksumRequestPB, yb::tserver::ChecksumResponsePB>::response() Line | Count | Source | 105 | 6.61k | Resp& response() override { | 106 | 6.61k | return resp_; | 107 | 6.61k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::ListTabletsForTabletServerRequestPB, yb::tserver::ListTabletsForTabletServerResponsePB>::response() Line | Count | Source | 105 | 1.76k | Resp& response() override { | 106 | 1.76k | return resp_; | 107 | 1.76k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::ImportDataRequestPB, yb::tserver::ImportDataResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::UpdateTransactionRequestPB, yb::tserver::UpdateTransactionResponsePB>::response() Line | Count | Source | 105 | 2.43M | Resp& response() override { | 106 | 2.43M | return resp_; | 107 | 2.43M | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTransactionStatusRequestPB, yb::tserver::GetTransactionStatusResponsePB>::response() Line | Count | Source | 105 | 419k | Resp& response() override { | 106 | 419k | return resp_; | 107 | 419k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTransactionStatusAtParticipantRequestPB, yb::tserver::GetTransactionStatusAtParticipantResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::AbortTransactionRequestPB, yb::tserver::AbortTransactionResponsePB>::response() Line | Count | Source | 105 | 69.3k | Resp& response() override { | 106 | 69.3k | return resp_; | 107 | 69.3k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::TruncateRequestPB, yb::tserver::TruncateResponsePB>::response() Line | Count | Source | 105 | 114k | Resp& response() override { | 106 | 114k | return resp_; | 107 | 114k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetTabletStatusRequestPB, yb::tserver::GetTabletStatusResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetMasterAddressesRequestPB, yb::tserver::GetMasterAddressesResponsePB>::response() Line | Count | Source | 105 | 18 | Resp& response() override { | 106 | 18 | return resp_; | 107 | 18 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::PublishRequestPB, yb::tserver::PublishResponsePB>::response() Line | Count | Source | 105 | 1.36k | Resp& response() override { | 106 | 1.36k | return resp_; | 107 | 1.36k | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::IsTabletServerReadyRequestPB, yb::tserver::IsTabletServerReadyResponsePB>::response() Line | Count | Source | 105 | 36 | Resp& response() override { | 106 | 36 | return resp_; | 107 | 36 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::tserver::TakeTransactionRequestPB, yb::tserver::TakeTransactionResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSplitKeyRequestPB, yb::tserver::GetSplitKeyResponsePB>::response() Line | Count | Source | 105 | 288 | Resp& response() override { | 106 | 288 | return resp_; | 107 | 288 | } |
yb::rpc::RpcCallPBParamsImpl<yb::tserver::GetSharedDataRequestPB, yb::tserver::GetSharedDataResponsePB>::response() Line | Count | Source | 105 | 16 | Resp& response() override { | 106 | 16 | return resp_; | 107 | 16 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::AddRequestPB, yb::rpc_test::AddResponsePB>::response() Line | Count | Source | 105 | 1.27k | Resp& response() override { | 106 | 1.27k | return resp_; | 107 | 1.27k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::SleepRequestPB, yb::rpc_test::SleepResponsePB>::response() Line | Count | Source | 105 | 75 | Resp& response() override { | 106 | 75 | return resp_; | 107 | 75 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::EchoRequestPB, yb::rpc_test::EchoResponsePB>::response() Line | Count | Source | 105 | 27.2k | Resp& response() override { | 106 | 27.2k | return resp_; | 107 | 27.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::WhoAmIRequestPB, yb::rpc_test::WhoAmIResponsePB>::response() Line | Count | Source | 105 | 8 | Resp& response() override { | 106 | 8 | return resp_; | 107 | 8 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::rpc_test_diff_package::ReqDiffPackagePB, yb::rpc_test_diff_package::RespDiffPackagePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::PanicRequestPB, yb::rpc_test::PanicResponsePB>::response() Line | Count | Source | 105 | 1 | Resp& response() override { | 106 | 1 | return resp_; | 107 | 1 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::PingRequestPB, yb::rpc_test::PingResponsePB>::response() Line | Count | Source | 105 | 99.6k | Resp& response() override { | 106 | 99.6k | return resp_; | 107 | 99.6k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::DisconnectRequestPB, yb::rpc_test::DisconnectResponsePB>::response() Line | Count | Source | 105 | 10.5k | Resp& response() override { | 106 | 10.5k | return resp_; | 107 | 10.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::ForwardRequestPB, yb::rpc_test::ForwardResponsePB>::response() Line | Count | Source | 105 | 22 | Resp& response() override { | 106 | 22 | return resp_; | 107 | 22 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::TrivialRequestPB, yb::rpc_test::TrivialResponsePB>::response() Line | Count | Source | 105 | 4 | Resp& response() override { | 106 | 4 | return resp_; | 107 | 4 | } |
yb::rpc::RpcCallPBParamsImpl<yb::rpc_test::ConcatRequestPB, yb::rpc_test::ConcatResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::FlushTablesRequestPB, yb::master::FlushTablesResponsePB>::response() Line | Count | Source | 105 | 20 | Resp& response() override { | 106 | 20 | return resp_; | 107 | 20 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsFlushTablesDoneRequestPB, yb::master::IsFlushTablesDoneResponsePB>::response() Line | Count | Source | 105 | 42 | Resp& response() override { | 106 | 42 | return resp_; | 107 | 42 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::FlushSysCatalogRequestPB, yb::master::FlushSysCatalogResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::CompactSysCatalogRequestPB, yb::master::CompactSysCatalogResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::IsInitDbDoneRequestPB, yb::master::IsInitDbDoneResponsePB>::response() Line | Count | Source | 105 | 10.2k | Resp& response() override { | 106 | 10.2k | return resp_; | 107 | 10.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::SplitTabletRequestPB, yb::master::SplitTabletResponsePB>::response() Line | Count | Source | 105 | 132 | Resp& response() override { | 106 | 132 | return resp_; | 107 | 132 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTransactionStatusTableRequestPB, yb::master::CreateTransactionStatusTableResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteNotServingTabletRequestPB, yb::master::DeleteNotServingTabletResponsePB>::response() Line | Count | Source | 105 | 12 | Resp& response() override { | 106 | 12 | return resp_; | 107 | 12 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DisableTabletSplittingRequestPB, yb::master::DisableTabletSplittingResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::IsTabletSplittingCompleteRequestPB, yb::master::IsTabletSplittingCompleteResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::DdlLogRequestPB, yb::master::DdlLogResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTabletLocationsRequestPB, yb::master::GetTabletLocationsResponsePB>::response() Line | Count | Source | 105 | 30.5k | Resp& response() override { | 106 | 30.5k | return resp_; | 107 | 30.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTableLocationsRequestPB, yb::master::GetTableLocationsResponsePB>::response() Line | Count | Source | 105 | 457k | Resp& response() override { | 106 | 457k | return resp_; | 107 | 457k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTransactionStatusTabletsRequestPB, yb::master::GetTransactionStatusTabletsResponsePB>::response() Line | Count | Source | 105 | 6.66k | Resp& response() override { | 106 | 6.66k | return resp_; | 107 | 6.66k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ReservePgsqlOidsRequestPB, yb::master::ReservePgsqlOidsResponsePB>::response() Line | Count | Source | 105 | 1.61k | Resp& response() override { | 106 | 1.61k | return resp_; | 107 | 1.61k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetYsqlCatalogConfigRequestPB, yb::master::GetYsqlCatalogConfigResponsePB>::response() Line | Count | Source | 105 | 44 | Resp& response() override { | 106 | 44 | return resp_; | 107 | 44 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::RedisConfigSetRequestPB, yb::master::RedisConfigSetResponsePB>::response() Line | Count | Source | 105 | 364 | Resp& response() override { | 106 | 364 | return resp_; | 107 | 364 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::RedisConfigGetRequestPB, yb::master::RedisConfigGetResponsePB>::response() Line | Count | Source | 105 | 2.35k | Resp& response() override { | 106 | 2.35k | return resp_; | 107 | 2.35k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTabletServersRequestPB, yb::master::ListTabletServersResponsePB>::response() Line | Count | Source | 105 | 53.6k | Resp& response() override { | 106 | 53.6k | return resp_; | 107 | 53.6k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListLiveTabletServersRequestPB, yb::master::ListLiveTabletServersResponsePB>::response() Line | Count | Source | 105 | 8 | Resp& response() override { | 106 | 8 | return resp_; | 107 | 8 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListMastersRequestPB, yb::master::ListMastersResponsePB>::response() Line | Count | Source | 105 | 134 | Resp& response() override { | 106 | 134 | return resp_; | 107 | 134 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ListMasterRaftPeersRequestPB, yb::master::ListMasterRaftPeersResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::GetMasterRegistrationRequestPB, yb::master::GetMasterRegistrationResponsePB>::response() Line | Count | Source | 105 | 58.8M | Resp& response() override { | 106 | 58.8M | return resp_; | 107 | 58.8M | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsMasterLeaderReadyRequestPB, yb::master::IsMasterLeaderReadyResponsePB>::response() Line | Count | Source | 105 | 344 | Resp& response() override { | 106 | 344 | return resp_; | 107 | 344 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DumpMasterStateRequestPB, yb::master::DumpMasterStateResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeLoadBalancerStateRequestPB, yb::master::ChangeLoadBalancerStateResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetLoadBalancerStateRequestPB, yb::master::GetLoadBalancerStateResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::RemovedMasterUpdateRequestPB, yb::master::RemovedMasterUpdateResponsePB>::response() Line | Count | Source | 105 | 74 | Resp& response() override { | 106 | 74 | return resp_; | 107 | 74 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::SetPreferredZonesRequestPB, yb::master::SetPreferredZonesResponsePB>::response() Line | Count | Source | 105 | 6 | Resp& response() override { | 106 | 6 | return resp_; | 107 | 6 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetMasterClusterConfigRequestPB, yb::master::GetMasterClusterConfigResponsePB>::response() Line | Count | Source | 105 | 668 | Resp& response() override { | 106 | 668 | return resp_; | 107 | 668 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeMasterClusterConfigRequestPB, yb::master::ChangeMasterClusterConfigResponsePB>::response() Line | Count | Source | 105 | 340 | Resp& response() override { | 106 | 340 | return resp_; | 107 | 340 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetLoadMovePercentRequestPB, yb::master::GetLoadMovePercentResponsePB>::response() Line | Count | Source | 105 | 4.12k | Resp& response() override { | 106 | 4.12k | return resp_; | 107 | 4.12k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetLeaderBlacklistPercentRequestPB, yb::master::GetLoadMovePercentResponsePB>::response() Line | Count | Source | 105 | 776 | Resp& response() override { | 106 | 776 | return resp_; | 107 | 776 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsLoadBalancedRequestPB, yb::master::IsLoadBalancedResponsePB>::response() Line | Count | Source | 105 | 476 | Resp& response() override { | 106 | 476 | return resp_; | 107 | 476 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsLoadBalancerIdleRequestPB, yb::master::IsLoadBalancerIdleResponsePB>::response() Line | Count | Source | 105 | 4.97k | Resp& response() override { | 106 | 4.97k | return resp_; | 107 | 4.97k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AreLeadersOnPreferredOnlyRequestPB, yb::master::AreLeadersOnPreferredOnlyResponsePB>::response() Line | Count | Source | 105 | 294 | Resp& response() override { | 106 | 294 | return resp_; | 107 | 294 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateRoleRequestPB, yb::master::CreateRoleResponsePB>::response() Line | Count | Source | 105 | 1.51k | Resp& response() override { | 106 | 1.51k | return resp_; | 107 | 1.51k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterRoleRequestPB, yb::master::AlterRoleResponsePB>::response() Line | Count | Source | 105 | 116 | Resp& response() override { | 106 | 116 | return resp_; | 107 | 116 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteRoleRequestPB, yb::master::DeleteRoleResponsePB>::response() Line | Count | Source | 105 | 1.46k | Resp& response() override { | 106 | 1.46k | return resp_; | 107 | 1.46k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GrantRevokeRoleRequestPB, yb::master::GrantRevokeRoleResponsePB>::response() Line | Count | Source | 105 | 104 | Resp& response() override { | 106 | 104 | return resp_; | 107 | 104 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GrantRevokePermissionRequestPB, yb::master::GrantRevokePermissionResponsePB>::response() Line | Count | Source | 105 | 1.44k | Resp& response() override { | 106 | 1.44k | return resp_; | 107 | 1.44k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetPermissionsRequestPB, yb::master::GetPermissionsResponsePB>::response() Line | Count | Source | 105 | 232k | Resp& response() override { | 106 | 232k | return resp_; | 107 | 232k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTableRequestPB, yb::master::CreateTableResponsePB>::response() Line | Count | Source | 105 | 14.9k | Resp& response() override { | 106 | 14.9k | return resp_; | 107 | 14.9k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsCreateTableDoneRequestPB, yb::master::IsCreateTableDoneResponsePB>::response() Line | Count | Source | 105 | 59.3k | Resp& response() override { | 106 | 59.3k | return resp_; | 107 | 59.3k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTablesRequestPB, yb::master::ListTablesResponsePB>::response() Line | Count | Source | 105 | 5.86k | Resp& response() override { | 106 | 5.86k | return resp_; | 107 | 5.86k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetTableSchemaRequestPB, yb::master::GetTableSchemaResponsePB>::response() Line | Count | Source | 105 | 342k | Resp& response() override { | 106 | 342k | return resp_; | 107 | 342k | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetTablegroupSchemaRequestPB, yb::master::GetTablegroupSchemaResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetColocatedTabletSchemaRequestPB, yb::master::GetColocatedTabletSchemaResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::TruncateTableRequestPB, yb::master::TruncateTableResponsePB>::response() Line | Count | Source | 105 | 25.2k | Resp& response() override { | 106 | 25.2k | return resp_; | 107 | 25.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsTruncateTableDoneRequestPB, yb::master::IsTruncateTableDoneResponsePB>::response() Line | Count | Source | 105 | 21.1k | Resp& response() override { | 106 | 21.1k | return resp_; | 107 | 21.1k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::BackfillIndexRequestPB, yb::master::BackfillIndexResponsePB>::response() Line | Count | Source | 105 | 1.08k | Resp& response() override { | 106 | 1.08k | return resp_; | 107 | 1.08k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::LaunchBackfillIndexForTableRequestPB, yb::master::LaunchBackfillIndexForTableResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetBackfillJobsRequestPB, yb::master::GetBackfillJobsResponsePB>::response() Line | Count | Source | 105 | 1.39k | Resp& response() override { | 106 | 1.39k | return resp_; | 107 | 1.39k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteTableRequestPB, yb::master::DeleteTableResponsePB>::response() Line | Count | Source | 105 | 11.0k | Resp& response() override { | 106 | 11.0k | return resp_; | 107 | 11.0k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsDeleteTableDoneRequestPB, yb::master::IsDeleteTableDoneResponsePB>::response() Line | Count | Source | 105 | 23.5k | Resp& response() override { | 106 | 23.5k | return resp_; | 107 | 23.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterTableRequestPB, yb::master::AlterTableResponsePB>::response() Line | Count | Source | 105 | 1.40k | Resp& response() override { | 106 | 1.40k | return resp_; | 107 | 1.40k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsAlterTableDoneRequestPB, yb::master::IsAlterTableDoneResponsePB>::response() Line | Count | Source | 105 | 2.79k | Resp& response() override { | 106 | 2.79k | return resp_; | 107 | 2.79k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateNamespaceRequestPB, yb::master::CreateNamespaceResponsePB>::response() Line | Count | Source | 105 | 5.29k | Resp& response() override { | 106 | 5.29k | return resp_; | 107 | 5.29k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsCreateNamespaceDoneRequestPB, yb::master::IsCreateNamespaceDoneResponsePB>::response() Line | Count | Source | 105 | 7.13k | Resp& response() override { | 106 | 7.13k | return resp_; | 107 | 7.13k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteNamespaceRequestPB, yb::master::DeleteNamespaceResponsePB>::response() Line | Count | Source | 105 | 3.29k | Resp& response() override { | 106 | 3.29k | return resp_; | 107 | 3.29k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsDeleteNamespaceDoneRequestPB, yb::master::IsDeleteNamespaceDoneResponsePB>::response() Line | Count | Source | 105 | 3.48k | Resp& response() override { | 106 | 3.48k | return resp_; | 107 | 3.48k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AlterNamespaceRequestPB, yb::master::AlterNamespaceResponsePB>::response() Line | Count | Source | 105 | 14 | Resp& response() override { | 106 | 14 | return resp_; | 107 | 14 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListNamespacesRequestPB, yb::master::ListNamespacesResponsePB>::response() Line | Count | Source | 105 | 10.2k | Resp& response() override { | 106 | 10.2k | return resp_; | 107 | 10.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetNamespaceInfoRequestPB, yb::master::GetNamespaceInfoResponsePB>::response() Line | Count | Source | 105 | 12.0k | Resp& response() override { | 106 | 12.0k | return resp_; | 107 | 12.0k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateTablegroupRequestPB, yb::master::CreateTablegroupResponsePB>::response() Line | Count | Source | 105 | 112 | Resp& response() override { | 106 | 112 | return resp_; | 107 | 112 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteTablegroupRequestPB, yb::master::DeleteTablegroupResponsePB>::response() Line | Count | Source | 105 | 80 | Resp& response() override { | 106 | 80 | return resp_; | 107 | 80 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListTablegroupsRequestPB, yb::master::ListTablegroupsResponsePB>::response() Line | Count | Source | 105 | 14 | Resp& response() override { | 106 | 14 | return resp_; | 107 | 14 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateUDTypeRequestPB, yb::master::CreateUDTypeResponsePB>::response() Line | Count | Source | 105 | 94 | Resp& response() override { | 106 | 94 | return resp_; | 107 | 94 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteUDTypeRequestPB, yb::master::DeleteUDTypeResponsePB>::response() Line | Count | Source | 105 | 108 | Resp& response() override { | 106 | 108 | return resp_; | 107 | 108 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::ListUDTypesRequestPB, yb::master::ListUDTypesResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::GetUDTypeInfoRequestPB, yb::master::GetUDTypeInfoResponsePB>::response() Line | Count | Source | 105 | 112 | Resp& response() override { | 106 | 112 | return resp_; | 107 | 112 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ChangeEncryptionInfoRequestPB, yb::master::ChangeEncryptionInfoResponsePB>::response() Line | Count | Source | 105 | 34 | Resp& response() override { | 106 | 34 | return resp_; | 107 | 34 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::IsEncryptionEnabledRequestPB, yb::master::IsEncryptionEnabledResponsePB>::response() Line | Count | Source | 105 | 34 | Resp& response() override { | 106 | 34 | return resp_; | 107 | 34 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::AddUniverseKeysRequestPB, yb::master::AddUniverseKeysResponsePB>::response() Line | Count | Source | 105 | 102 | Resp& response() override { | 106 | 102 | return resp_; | 107 | 102 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetUniverseKeyRegistryRequestPB, yb::master::GetUniverseKeyRegistryResponsePB>::response() Line | Count | Source | 105 | 25.5k | Resp& response() override { | 106 | 25.5k | return resp_; | 107 | 25.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::HasUniverseKeyInMemoryRequestPB, yb::master::HasUniverseKeyInMemoryResponsePB>::response() Line | Count | Source | 105 | 138 | Resp& response() override { | 106 | 138 | return resp_; | 107 | 138 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::TSHeartbeatRequestPB, yb::master::TSHeartbeatResponsePB>::response() Line | Count | Source | 105 | 10.3M | Resp& response() override { | 106 | 10.3M | return resp_; | 107 | 10.3M | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ValidateReplicationInfoRequestPB, yb::master::ValidateReplicationInfoResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::CreateCDCStreamRequestPB, yb::master::CreateCDCStreamResponsePB>::response() Line | Count | Source | 105 | 11.0k | Resp& response() override { | 106 | 11.0k | return resp_; | 107 | 11.0k | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteCDCStreamRequestPB, yb::master::DeleteCDCStreamResponsePB>::response() Line | Count | Source | 105 | 4 | Resp& response() override { | 106 | 4 | return resp_; | 107 | 4 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::ListCDCStreamsRequestPB, yb::master::ListCDCStreamsResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetCDCStreamRequestPB, yb::master::GetCDCStreamResponsePB>::response() Line | Count | Source | 105 | 12 | Resp& response() override { | 106 | 12 | return resp_; | 107 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::master::GetCDCDBStreamInfoRequestPB, yb::master::GetCDCDBStreamInfoResponsePB>::response() Line | Count | Source | 105 | 44 | Resp& response() override { | 106 | 44 | return resp_; | 107 | 44 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::UpdateCDCStreamRequestPB, yb::master::UpdateCDCStreamResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::master::SetupUniverseReplicationRequestPB, yb::master::SetupUniverseReplicationResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::DeleteUniverseReplicationRequestPB, yb::master::DeleteUniverseReplicationResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::AlterUniverseReplicationRequestPB, yb::master::AlterUniverseReplicationResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::SetUniverseReplicationEnabledRequestPB, yb::master::SetUniverseReplicationEnabledResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::GetUniverseReplicationRequestPB, yb::master::GetUniverseReplicationResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::IsSetupUniverseReplicationDoneRequestPB, yb::master::IsSetupUniverseReplicationDoneResponsePB>::response() Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::master::UpdateConsumerOnProducerSplitRequestPB, yb::master::UpdateConsumerOnProducerSplitResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::consensus::ConsensusRequestPB, yb::consensus::ConsensusResponsePB>::response() Line | Count | Source | 105 | 51.1M | Resp& response() override { | 106 | 51.1M | return resp_; | 107 | 51.1M | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::consensus::MultiRaftConsensusRequestPB, yb::consensus::MultiRaftConsensusResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::consensus::VoteRequestPB, yb::consensus::VoteResponsePB>::response() Line | Count | Source | 105 | 2.78M | Resp& response() override { | 106 | 2.78M | return resp_; | 107 | 2.78M | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::ChangeConfigRequestPB, yb::consensus::ChangeConfigResponsePB>::response() Line | Count | Source | 105 | 10.5k | Resp& response() override { | 106 | 10.5k | return resp_; | 107 | 10.5k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::UnsafeChangeConfigRequestPB, yb::consensus::UnsafeChangeConfigResponsePB>::response() Line | Count | Source | 105 | 12 | Resp& response() override { | 106 | 12 | return resp_; | 107 | 12 | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetNodeInstanceRequestPB, yb::consensus::GetNodeInstanceResponsePB>::response() Line | Count | Source | 105 | 41.9k | Resp& response() override { | 106 | 41.9k | return resp_; | 107 | 41.9k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::RunLeaderElectionRequestPB, yb::consensus::RunLeaderElectionResponsePB>::response() Line | Count | Source | 105 | 192k | Resp& response() override { | 106 | 192k | return resp_; | 107 | 192k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::LeaderElectionLostRequestPB, yb::consensus::LeaderElectionLostResponsePB>::response() Line | Count | Source | 105 | 154 | Resp& response() override { | 106 | 154 | return resp_; | 107 | 154 | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::LeaderStepDownRequestPB, yb::consensus::LeaderStepDownResponsePB>::response() Line | Count | Source | 105 | 108k | Resp& response() override { | 106 | 108k | return resp_; | 107 | 108k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetLastOpIdRequestPB, yb::consensus::GetLastOpIdResponsePB>::response() Line | Count | Source | 105 | 1.15k | Resp& response() override { | 106 | 1.15k | return resp_; | 107 | 1.15k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::GetConsensusStateRequestPB, yb::consensus::GetConsensusStateResponsePB>::response() Line | Count | Source | 105 | 8.13k | Resp& response() override { | 106 | 8.13k | return resp_; | 107 | 8.13k | } |
yb::rpc::RpcCallPBParamsImpl<yb::consensus::StartRemoteBootstrapRequestPB, yb::consensus::StartRemoteBootstrapResponsePB>::response() Line | Count | Source | 105 | 21.2k | Resp& response() override { | 106 | 21.2k | return resp_; | 107 | 21.2k | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::SetFlagRequestPB, yb::server::SetFlagResponsePB>::response() Line | Count | Source | 105 | 704 | Resp& response() override { | 106 | 704 | return resp_; | 107 | 704 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::GetFlagRequestPB, yb::server::GetFlagResponsePB>::response() Line | Count | Source | 105 | 58 | Resp& response() override { | 106 | 58 | return resp_; | 107 | 58 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::RefreshFlagsRequestPB, yb::server::RefreshFlagsResponsePB>::response() Line | Count | Source | 105 | 4 | Resp& response() override { | 106 | 4 | return resp_; | 107 | 4 | } |
Unexecuted instantiation: yb::rpc::RpcCallPBParamsImpl<yb::server::FlushCoverageRequestPB, yb::server::FlushCoverageResponsePB>::response() yb::rpc::RpcCallPBParamsImpl<yb::server::ServerClockRequestPB, yb::server::ServerClockResponsePB>::response() Line | Count | Source | 105 | 2 | Resp& response() override { | 106 | 2 | return resp_; | 107 | 2 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::GetStatusRequestPB, yb::server::GetStatusResponsePB>::response() Line | Count | Source | 105 | 14 | Resp& response() override { | 106 | 14 | return resp_; | 107 | 14 | } |
yb::rpc::RpcCallPBParamsImpl<yb::server::PingRequestPB, yb::server::PingResponsePB>::response() Line | Count | Source | 105 | 761k | Resp& response() override { | 106 | 761k | return resp_; | 107 | 761k | } |
|
108 | | |
109 | | private: |
110 | | Req req_; |
111 | | Resp resp_; |
112 | | }; |
113 | | |
114 | | class RpcCallLWParams : public RpcCallParams { |
115 | | public: |
116 | | Result<size_t> ParseRequest(Slice param) override; |
117 | | AnyMessageConstPtr SerializableResponse() override; |
118 | | |
119 | | virtual LightweightMessage& request() = 0; |
120 | | virtual LightweightMessage& response() = 0; |
121 | | |
122 | | static LightweightMessage* CastMessage(const AnyMessagePtr& msg); |
123 | | |
124 | | static const LightweightMessage* CastMessage(const AnyMessageConstPtr& msg); |
125 | | }; |
126 | | |
127 | | template <class Req, class Resp> |
128 | | class RpcCallLWParamsImpl : public RpcCallLWParams { |
129 | | public: |
130 | | using RequestType = Req; |
131 | | using ResponseType = Resp; |
132 | | |
133 | 2 | Req& request() override { |
134 | 2 | return req_; |
135 | 2 | } |
136 | | |
137 | 2 | Resp& response() override { |
138 | 2 | return resp_; |
139 | 2 | } |
140 | | |
141 | 1 | RpcCallLWParamsImpl() : req_(&arena_), resp_(&arena_) {} |
142 | | |
143 | | private: |
144 | | Arena arena_; |
145 | | Req req_; |
146 | | Resp resp_; |
147 | | }; |
148 | | |
149 | | template <class T> |
150 | | using MutableErrorDetector = decltype(boost::declval<T&>().mutable_error()); |
151 | | |
152 | | template <bool> |
153 | | struct ResponseErrorHelper; |
154 | | |
155 | | template <> |
156 | | struct ResponseErrorHelper<true> { |
157 | | template <class T> |
158 | 1 | static auto Apply(T* t) { |
159 | 1 | return t->mutable_error(); |
160 | 1 | } Unexecuted instantiation: auto yb::rpc::ResponseErrorHelper<true>::Apply<yb::cdc::SetCDCCheckpointResponsePB>(yb::cdc::SetCDCCheckpointResponsePB*) auto yb::rpc::ResponseErrorHelper<true>::Apply<yb::rpc_test::TrivialResponsePB>(yb::rpc_test::TrivialResponsePB*) Line | Count | Source | 158 | 1 | static auto Apply(T* t) { | 159 | 1 | return t->mutable_error(); | 160 | 1 | } |
|
161 | | }; |
162 | | |
163 | | template <> |
164 | | struct ResponseErrorHelper<false> { |
165 | | template <class T> |
166 | | static auto Apply(T* t) { |
167 | | return t->mutable_status(); |
168 | | } |
169 | | }; |
170 | | |
171 | | template <class T> |
172 | 1 | auto ResponseError(T* t) { |
173 | 1 | return ResponseErrorHelper<boost::is_detected_v<MutableErrorDetector, T>>::Apply(t); |
174 | 1 | } Unexecuted instantiation: auto yb::rpc::ResponseError<yb::cdc::SetCDCCheckpointResponsePB>(yb::cdc::SetCDCCheckpointResponsePB*) auto yb::rpc::ResponseError<yb::rpc_test::TrivialResponsePB>(yb::rpc_test::TrivialResponsePB*) Line | Count | Source | 172 | 1 | auto ResponseError(T* t) { | 173 | 1 | return ResponseErrorHelper<boost::is_detected_v<MutableErrorDetector, T>>::Apply(t); | 174 | 1 | } |
|
175 | | |
176 | | // The context provided to a generated ServiceIf. This provides |
177 | | // methods to respond to the RPC. In the future, this will also |
178 | | // include methods to access information about the caller: e.g |
179 | | // authentication info, tracing info, and cancellation status. |
180 | | // |
181 | | // This is the server-side analogue to the RpcController class. |
182 | | class RpcContext { |
183 | | public: |
184 | | // Create an RpcContext. This is called only from generated code |
185 | | // and is not a public API. |
186 | | RpcContext(std::shared_ptr<YBInboundCall> call, |
187 | | std::shared_ptr<RpcCallParams> params); |
188 | | explicit RpcContext(std::shared_ptr<LocalYBInboundCall> call); |
189 | | |
190 | 222M | RpcContext(RpcContext&& rhs) = default; |
191 | | |
192 | | RpcContext(const RpcContext&) = delete; |
193 | | void operator=(const RpcContext&) = delete; |
194 | | |
195 | | ~RpcContext(); |
196 | | |
197 | 296k | explicit operator bool() const { |
198 | 296k | return call_ != nullptr; |
199 | 296k | } |
200 | | |
201 | | // Return the trace buffer for this call. |
202 | | Trace* trace(); |
203 | | |
204 | | // Send a response to the call. The service may call this method |
205 | | // before or after returning from the original handler method, |
206 | | // and it may call this method from a different thread. |
207 | | // |
208 | | // The response should be prepared already in the response PB pointer |
209 | | // which was passed to the handler method. |
210 | | // |
211 | | // After this method returns, this RpcContext object is destroyed. The request |
212 | | // and response protobufs are also destroyed. |
213 | | void RespondSuccess(); |
214 | | |
215 | | static void RespondSuccess(InboundCall* call); |
216 | | |
217 | | // Respond with an error to the client. This sends back an error with the code |
218 | | // ERROR_APPLICATION. Because there is no more specific error code passed back |
219 | | // to the client, most applications should create a custom error PB extension |
220 | | // and use RespondApplicationError(...) below. This method should only be used |
221 | | // for unexpected errors where the server doesn't expect the client to do any |
222 | | // more advanced handling. |
223 | | // |
224 | | // After this method returns, this RpcContext object is destroyed. The request |
225 | | // and response protobufs are also destroyed. |
226 | | void RespondFailure(const Status &status); |
227 | | |
228 | | // Respond with an RPC-level error. This typically manifests to the client as |
229 | | // a remote error, one whose handling is agnostic to the particulars of the |
230 | | // sent RPC. For example, ERROR_SERVER_TOO_BUSY usually causes the client to |
231 | | // retry the RPC at a later time. |
232 | | // |
233 | | // After this method returns, this RpcContext object is destroyed. The request |
234 | | // and response protobufs are also destroyed. |
235 | | void RespondRpcFailure(ErrorStatusPB_RpcErrorCodePB err, const Status& status); |
236 | | |
237 | | // Respond with an application-level error. This causes the caller to get a |
238 | | // RemoteError status with the provided string message. Additionally, a |
239 | | // service-specific error extension is passed back to the client. The |
240 | | // extension must be registered with the ErrorStatusPB protobuf. For |
241 | | // example: |
242 | | // |
243 | | // message MyServiceError { |
244 | | // extend yb.rpc.ErrorStatusPB { |
245 | | // optional MyServiceError my_service_error_ext = 101; |
246 | | // } |
247 | | // // Add any extra fields or status codes you want to pass back to |
248 | | // // the client here. |
249 | | // required string extra_error_data = 1; |
250 | | // } |
251 | | // |
252 | | // NOTE: the numeric '101' above must be an integer greater than 101 |
253 | | // and must be unique across your code base. |
254 | | // |
255 | | // Given the above definition in your service protobuf file, you would |
256 | | // use this method like: |
257 | | // |
258 | | // MyServiceError err; |
259 | | // err.set_extra_error_data("foo bar"); |
260 | | // ctx->RespondApplicationError(MyServiceError::my_service_error_ext.number(), |
261 | | // "Some error occurred", err); |
262 | | // |
263 | | // The client side may then retreieve the error by calling: |
264 | | // const MyServiceError& err_details = |
265 | | // controller->error_response()->GetExtension(MyServiceError::my_service_error_ext); |
266 | | // |
267 | | // After this method returns, this RpcContext object is destroyed. The request |
268 | | // and response protobufs are also destroyed. |
269 | | void RespondApplicationError(int error_ext_id, const std::string& message, |
270 | | const google::protobuf::Message& app_error_pb); |
271 | | |
272 | | // Adds an RpcSidecar to the response. This is the preferred method for |
273 | | // transferring large amounts of binary data, because this avoids additional |
274 | | // copies made by serializing the protobuf. |
275 | | // |
276 | | // Assumes no changes to the sidecar's data are made after insertion. |
277 | | // |
278 | | // Returns the index of the sidecar. |
279 | | size_t AddRpcSidecar(const Slice& car); |
280 | | |
281 | | // Removes all RpcSidecars. |
282 | | void ResetRpcSidecars(); |
283 | | |
284 | | // Like in STL reserve preallocates buffer, so adding new sidecars would not allocate memory |
285 | | // up to space bytes. |
286 | | void ReserveSidecarSpace(size_t space); |
287 | | |
288 | | // Return the remote endpoint which sent the current RPC call. |
289 | | const Endpoint& remote_address() const; |
290 | | // Return the local endpoint which received the current RPC call. |
291 | | const Endpoint& local_address() const; |
292 | | |
293 | | // A string identifying the requestor -- both the user info and the IP address. |
294 | | // Suitable for use in log messages. |
295 | | std::string requestor_string() const; |
296 | | |
297 | | // Return an upper bound on the client timeout deadline. This does not |
298 | | // account for transmission delays between the client and the server. |
299 | | // If the client did not specify a deadline, returns MonoTime::Max(). |
300 | | CoarseTimePoint GetClientDeadline() const; |
301 | | |
302 | | MonoTime ReceiveTime() const; |
303 | | |
304 | 0 | RpcCallParams& params() { |
305 | 0 | return *params_; |
306 | 0 | } |
307 | | |
308 | | // Panic the server. This logs a fatal error with the given message, and |
309 | | // also includes the current RPC request, requestor, trace information, etc, |
310 | | // to make it easier to debug. |
311 | | // |
312 | | // Call this via the PANIC_RPC() macro. |
313 | | void Panic(const char* filepath, int line_number, const std::string& message) |
314 | | __attribute__((noreturn)); |
315 | | |
316 | | // Returns true if the call has been responded. |
317 | 70.3M | bool responded() const { return responded_; } |
318 | | |
319 | | // Closes connection that received this request. |
320 | | void CloseConnection(); |
321 | | |
322 | | std::string ToString() const; |
323 | | |
324 | | private: |
325 | | std::shared_ptr<YBInboundCall> call_; |
326 | | std::shared_ptr<RpcCallParams> params_; |
327 | | bool responded_ = false; |
328 | | }; |
329 | | |
330 | | void PanicRpc(RpcContext* context, const char* file, int line_number, const std::string& message); |
331 | | |
332 | | #define PANIC_RPC(rpc_context, message) \ |
333 | 1 | do { \ |
334 | 1 | yb::rpc::PanicRpc((rpc_context), __FILE__, __LINE__, (message)); \ |
335 | 1 | } while (false) |
336 | | |
337 | | } // namespace rpc |
338 | | } // namespace yb |
339 | | #endif // YB_RPC_RPC_CONTEXT_H |