/Users/deen/code/yugabyte-db/src/yb/client/client_master_rpc.h
Line | Count | Source |
1 | | // Copyright (c) YugaByte, Inc. |
2 | | // |
3 | | // Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except |
4 | | // in compliance with the License. You may obtain a copy of the License at |
5 | | // |
6 | | // http://www.apache.org/licenses/LICENSE-2.0 |
7 | | // |
8 | | // Unless required by applicable law or agreed to in writing, software distributed under the License |
9 | | // is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express |
10 | | // or implied. See the License for the specific language governing permissions and limitations |
11 | | // under the License. |
12 | | // |
13 | | |
14 | | #ifndef YB_CLIENT_CLIENT_MASTER_RPC_H |
15 | | #define YB_CLIENT_CLIENT_MASTER_RPC_H |
16 | | |
17 | | #include "yb/client/client.h" |
18 | | #include "yb/client/client-internal.h" |
19 | | |
20 | | #include "yb/master/master_fwd.h" |
21 | | #include "yb/master/master_error.h" |
22 | | |
23 | | #include "yb/rpc/rpc.h" |
24 | | |
25 | | namespace yb { |
26 | | namespace client { |
27 | | namespace internal { |
28 | | |
29 | | class ClientMasterRpcBase : public rpc::Rpc { |
30 | | public: |
31 | | ClientMasterRpcBase(YBClient::Data* client_data, CoarseTimePoint deadline); |
32 | | |
33 | | ClientMasterRpcBase(YBClient* client, CoarseTimePoint deadline) |
34 | 231k | : ClientMasterRpcBase(client->data_.get(), deadline) {} |
35 | | |
36 | 419k | virtual ~ClientMasterRpcBase() = default; |
37 | | |
38 | | void SendRpc() override; |
39 | | |
40 | 419k | rpc::Rpcs::Handle* RpcHandle() { |
41 | 419k | return &retained_self_; |
42 | 419k | } |
43 | | |
44 | 333k | virtual bool ShouldRetry(const Status& status) { |
45 | 333k | return false; |
46 | 333k | } |
47 | | |
48 | | protected: |
49 | | template <class Proxy> |
50 | 187k | std::shared_ptr<Proxy> master_proxy() { |
51 | 187k | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); |
52 | 187k | } _ZN2yb6client8internal19ClientMasterRpcBase12master_proxyINS_6master14MasterDdlProxyEEENSt3__110shared_ptrIT_EEv Line | Count | Source | 50 | 53.6k | std::shared_ptr<Proxy> master_proxy() { | 51 | 53.6k | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); | 52 | 53.6k | } |
_ZN2yb6client8internal19ClientMasterRpcBase12master_proxyINS_6master16MasterAdminProxyEEENSt3__110shared_ptrIT_EEv Line | Count | Source | 50 | 26 | std::shared_ptr<Proxy> master_proxy() { | 51 | 26 | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); | 52 | 26 | } |
_ZN2yb6client8internal19ClientMasterRpcBase12master_proxyINS_6master17MasterClientProxyEEENSt3__110shared_ptrIT_EEv Line | Count | Source | 50 | 5.49k | std::shared_ptr<Proxy> master_proxy() { | 51 | 5.49k | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); | 52 | 5.49k | } |
_ZN2yb6client8internal19ClientMasterRpcBase12master_proxyINS_6master18MasterClusterProxyEEENSt3__110shared_ptrIT_EEv Line | Count | Source | 50 | 5.32k | std::shared_ptr<Proxy> master_proxy() { | 51 | 5.32k | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); | 52 | 5.32k | } |
_ZN2yb6client8internal19ClientMasterRpcBase12master_proxyINS_6master14MasterDclProxyEEENSt3__110shared_ptrIT_EEv Line | Count | Source | 50 | 120k | std::shared_ptr<Proxy> master_proxy() { | 51 | 120k | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); | 52 | 120k | } |
_ZN2yb6client8internal19ClientMasterRpcBase12master_proxyINS_6master22MasterReplicationProxyEEENSt3__110shared_ptrIT_EEv Line | Count | Source | 50 | 2.69k | std::shared_ptr<Proxy> master_proxy() { | 51 | 2.69k | return master_proxy_helper(static_cast<const Proxy*>(nullptr)); | 52 | 2.69k | } |
|
53 | | |
54 | 34 | std::shared_ptr<master::MasterAdminProxy> master_admin_proxy() { |
55 | 34 | return client_data_->master_admin_proxy(); |
56 | 34 | } |
57 | | |
58 | 26 | auto master_proxy_helper(const master::MasterAdminProxy*) { |
59 | 26 | return master_admin_proxy(); |
60 | 26 | } |
61 | | |
62 | 5.32k | std::shared_ptr<master::MasterClusterProxy> master_cluster_proxy() { |
63 | 5.32k | return client_data_->master_cluster_proxy(); |
64 | 5.32k | } |
65 | | |
66 | 5.32k | auto master_proxy_helper(const master::MasterClusterProxy*) { |
67 | 5.32k | return master_cluster_proxy(); |
68 | 5.32k | } |
69 | | |
70 | 120k | std::shared_ptr<master::MasterDclProxy> master_dcl_proxy() { |
71 | 120k | return client_data_->master_dcl_proxy(); |
72 | 120k | } |
73 | | |
74 | 120k | auto master_proxy_helper(const master::MasterDclProxy*) { |
75 | 120k | return master_dcl_proxy(); |
76 | 120k | } |
77 | | |
78 | 143k | std::shared_ptr<master::MasterDdlProxy> master_ddl_proxy() { |
79 | 143k | return client_data_->master_ddl_proxy(); |
80 | 143k | } |
81 | | |
82 | 53.6k | auto master_proxy_helper(const master::MasterDdlProxy*) { |
83 | 53.6k | return master_ddl_proxy(); |
84 | 53.6k | } |
85 | | |
86 | 156k | std::shared_ptr<master::MasterClientProxy> master_client_proxy() { |
87 | 156k | return client_data_->master_client_proxy(); |
88 | 156k | } |
89 | | |
90 | 5.49k | auto master_proxy_helper(const master::MasterClientProxy*) { |
91 | 5.49k | return master_client_proxy(); |
92 | 5.49k | } |
93 | | |
94 | 2.69k | std::shared_ptr<master::MasterReplicationProxy> master_replication_proxy() { |
95 | 2.69k | return client_data_->master_replication_proxy(); |
96 | 2.69k | } |
97 | | |
98 | 2.69k | auto master_proxy_helper(const master::MasterReplicationProxy*) { |
99 | 2.69k | return master_replication_proxy(); |
100 | 2.69k | } |
101 | | |
102 | | virtual void CallRemoteMethod() = 0; |
103 | | |
104 | | virtual void ProcessResponse(const Status& status) = 0; |
105 | | |
106 | | virtual Status ResponseStatus() = 0; |
107 | | |
108 | | void ResetMasterLeader(Retry retry); |
109 | | |
110 | | void NewLeaderMasterDeterminedCb(const Status& status); |
111 | | |
112 | | void Finished(const Status& status) override; |
113 | | |
114 | | std::string LogPrefix() const; |
115 | | |
116 | | private: |
117 | | YBClient::Data* const client_data_; |
118 | | rpc::Rpcs::Handle retained_self_; |
119 | | }; |
120 | | |
121 | | template <class Resp> |
122 | 428k | Status StatusFromResp(const Resp& resp) { |
123 | 428k | if (!resp.has_error()) { |
124 | 414k | return Status::OK(); |
125 | 414k | } |
126 | 13.5k | auto result = StatusFromPB(resp.error().status()); |
127 | 13.5k | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && |
128 | 13.5k | master::MasterError(result) != resp.error().code()) { |
129 | 9.34k | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); |
130 | 9.34k | } |
131 | 13.5k | return result; |
132 | 13.5k | } Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master24AlterNamespaceResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master20AlterTableResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 323 | Status StatusFromResp(const Resp& resp) { | 123 | 323 | if (!resp.has_error()) { | 124 | 321 | return Status::OK(); | 125 | 321 | } | 126 | 2 | auto result = StatusFromPB(resp.error().status()); | 127 | 2 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1 | master::MasterError(result) != resp.error().code()) { | 129 | 1 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 1 | } | 131 | 2 | return result; | 132 | 2 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master23BackfillIndexResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 89 | Status StatusFromResp(const Resp& resp) { | 123 | 89 | if (!resp.has_error()) { | 124 | 89 | return Status::OK(); | 125 | 89 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master35ChangeMasterClusterConfigResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 4 | Status StatusFromResp(const Resp& resp) { | 123 | 4 | if (!resp.has_error()) { | 124 | 4 | return Status::OK(); | 125 | 4 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master25CreateNamespaceResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1.80k | Status StatusFromResp(const Resp& resp) { | 123 | 1.80k | if (!resp.has_error()) { | 124 | 1.80k | return Status::OK(); | 125 | 1.80k | } | 126 | 2 | auto result = StatusFromPB(resp.error().status()); | 127 | 2 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 2 | master::MasterError(result) != resp.error().code()) { | 129 | 2 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 2 | } | 131 | 2 | return result; | 132 | 2 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master21CreateTableResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 3.20k | Status StatusFromResp(const Resp& resp) { | 123 | 3.20k | if (!resp.has_error()) { | 124 | 3.18k | return Status::OK(); | 125 | 3.18k | } | 126 | 14 | auto result = StatusFromPB(resp.error().status()); | 127 | 14 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 8 | master::MasterError(result) != resp.error().code()) { | 129 | 6 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 6 | } | 131 | 14 | return result; | 132 | 14 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master26CreateTablegroupResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2 | Status StatusFromResp(const Resp& resp) { | 123 | 2 | if (!resp.has_error()) { | 124 | 2 | return Status::OK(); | 125 | 2 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master22CreateUDTypeResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 46 | Status StatusFromResp(const Resp& resp) { | 123 | 46 | if (!resp.has_error()) { | 124 | 45 | return Status::OK(); | 125 | 45 | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1 | master::MasterError(result) != resp.error().code()) { | 129 | 1 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 1 | } | 131 | 1 | return result; | 132 | 1 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master25DeleteNamespaceResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1.51k | Status StatusFromResp(const Resp& resp) { | 123 | 1.51k | if (!resp.has_error()) { | 124 | 1.51k | return Status::OK(); | 125 | 1.51k | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 1 | return result; | 132 | 1 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master21DeleteTableResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2.44k | Status StatusFromResp(const Resp& resp) { | 123 | 2.44k | if (!resp.has_error()) { | 124 | 2.43k | return Status::OK(); | 125 | 2.43k | } | 126 | 17 | auto result = StatusFromPB(resp.error().status()); | 127 | 17 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 15 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 17 | return result; | 132 | 17 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master26DeleteTablegroupResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1 | Status StatusFromResp(const Resp& resp) { | 123 | 1 | if (!resp.has_error()) { | 124 | 1 | return Status::OK(); | 125 | 1 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master22DeleteUDTypeResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 53 | Status StatusFromResp(const Resp& resp) { | 123 | 53 | if (!resp.has_error()) { | 124 | 45 | return Status::OK(); | 125 | 45 | } | 126 | 8 | auto result = StatusFromPB(resp.error().status()); | 127 | 8 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 8 | master::MasterError(result) != resp.error().code()) { | 129 | 8 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 8 | } | 131 | 8 | return result; | 132 | 8 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master21FlushTablesResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 7 | Status StatusFromResp(const Resp& resp) { | 123 | 7 | if (!resp.has_error()) { | 124 | 7 | return Status::OK(); | 125 | 7 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master29GetTablegroupSchemaResponsePBEEENS_6StatusERKT_ Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master34GetColocatedTabletSchemaResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master32GetMasterClusterConfigResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 6 | Status StatusFromResp(const Resp& resp) { | 123 | 6 | if (!resp.has_error()) { | 124 | 6 | return Status::OK(); | 125 | 6 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master26GetNamespaceInfoResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1.77k | Status StatusFromResp(const Resp& resp) { | 123 | 1.77k | if (!resp.has_error()) { | 124 | 1.77k | return Status::OK(); | 125 | 1.77k | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 1 | return result; | 132 | 1 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master24GetTableSchemaResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 89.9k | Status StatusFromResp(const Resp& resp) { | 123 | 89.9k | if (!resp.has_error()) { | 124 | 87.5k | return Status::OK(); | 125 | 87.5k | } | 126 | 2.39k | auto result = StatusFromPB(resp.error().status()); | 127 | 2.39k | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 2.39k | master::MasterError(result) != resp.error().code()) { | 129 | 14 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 14 | } | 131 | 2.39k | return result; | 132 | 2.39k | } |
_ZN2yb6client8internal14StatusFromRespINS_6master23GetUDTypeInfoResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 55 | Status StatusFromResp(const Resp& resp) { | 123 | 55 | if (!resp.has_error()) { | 124 | 48 | return Status::OK(); | 125 | 48 | } | 126 | 7 | auto result = StatusFromPB(resp.error().status()); | 127 | 7 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 7 | master::MasterError(result) != resp.error().code()) { | 129 | 7 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 7 | } | 131 | 7 | return result; | 132 | 7 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master26IsAlterTableDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 649 | Status StatusFromResp(const Resp& resp) { | 123 | 649 | if (!resp.has_error()) { | 124 | 649 | return Status::OK(); | 125 | 649 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master31IsCreateNamespaceDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2.03k | Status StatusFromResp(const Resp& resp) { | 123 | 2.03k | if (!resp.has_error()) { | 124 | 2.03k | return Status::OK(); | 125 | 2.03k | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 1 | return result; | 132 | 1 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master27IsCreateTableDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 15.9k | Status StatusFromResp(const Resp& resp) { | 123 | 15.9k | if (!resp.has_error()) { | 124 | 15.9k | return Status::OK(); | 125 | 15.9k | } | 126 | 15 | auto result = StatusFromPB(resp.error().status()); | 127 | 15 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 15 | master::MasterError(result) != resp.error().code()) { | 129 | 15 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 15 | } | 131 | 15 | return result; | 132 | 15 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master31IsDeleteNamespaceDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1.53k | Status StatusFromResp(const Resp& resp) { | 123 | 1.53k | if (!resp.has_error()) { | 124 | 1.53k | return Status::OK(); | 125 | 1.53k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master27IsDeleteTableDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 5.58k | Status StatusFromResp(const Resp& resp) { | 123 | 5.58k | if (!resp.has_error()) { | 124 | 5.48k | return Status::OK(); | 125 | 5.48k | } | 126 | 104 | auto result = StatusFromPB(resp.error().status()); | 127 | 104 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 104 | master::MasterError(result) != resp.error().code()) { | 129 | 104 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 104 | } | 131 | 104 | return result; | 132 | 104 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master27IsFlushTablesDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 19 | Status StatusFromResp(const Resp& resp) { | 123 | 19 | if (!resp.has_error()) { | 124 | 19 | return Status::OK(); | 125 | 19 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master29IsTruncateTableDoneResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 8.89k | Status StatusFromResp(const Resp& resp) { | 123 | 8.89k | if (!resp.has_error()) { | 124 | 8.89k | return Status::OK(); | 125 | 8.89k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master24ListNamespacesResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 4.40k | Status StatusFromResp(const Resp& resp) { | 123 | 4.40k | if (!resp.has_error()) { | 124 | 4.40k | return Status::OK(); | 125 | 4.40k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master25ListTablegroupsResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1 | Status StatusFromResp(const Resp& resp) { | 123 | 1 | if (!resp.has_error()) { | 124 | 1 | return Status::OK(); | 125 | 1 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master20ListTablesResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 170 | Status StatusFromResp(const Resp& resp) { | 123 | 170 | if (!resp.has_error()) { | 124 | 170 | return Status::OK(); | 125 | 170 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master21ListUDTypesResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master23TruncateTableResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 3.05k | Status StatusFromResp(const Resp& resp) { | 123 | 3.05k | if (!resp.has_error()) { | 124 | 3.05k | return Status::OK(); | 125 | 3.05k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master33ValidateReplicationInfoResponsePBEEENS_6StatusERKT_ Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master38CreateTransactionStatusTableResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master27GetTableLocationsResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 144k | Status StatusFromResp(const Resp& resp) { | 123 | 144k | if (!resp.has_error()) { | 124 | 135k | return Status::OK(); | 125 | 135k | } | 126 | 8.76k | auto result = StatusFromPB(resp.error().status()); | 127 | 8.76k | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 8.72k | master::MasterError(result) != resp.error().code()) { | 129 | 8.69k | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 8.69k | } | 131 | 8.76k | return result; | 132 | 8.76k | } |
_ZN2yb6client8internal14StatusFromRespINS_6master28GetTabletLocationsResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 9.10k | Status StatusFromResp(const Resp& resp) { | 123 | 9.10k | if (!resp.has_error()) { | 124 | 9.10k | return Status::OK(); | 125 | 9.10k | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1 | master::MasterError(result) != resp.error().code()) { | 129 | 1 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 1 | } | 131 | 1 | return result; | 132 | 1 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master37GetTransactionStatusTabletsResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2.01k | Status StatusFromResp(const Resp& resp) { | 123 | 2.01k | if (!resp.has_error()) { | 124 | 2.00k | return Status::OK(); | 125 | 2.00k | } | 126 | 3 | auto result = StatusFromPB(resp.error().status()); | 127 | 3 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 3 | return result; | 132 | 3 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master30GetYsqlCatalogConfigResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master24RedisConfigGetResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 291 | Status StatusFromResp(const Resp& resp) { | 123 | 291 | if (!resp.has_error()) { | 124 | 0 | return Status::OK(); | 125 | 0 | } | 126 | 291 | auto result = StatusFromPB(resp.error().status()); | 127 | 291 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 291 | master::MasterError(result) != resp.error().code()) { | 129 | 291 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 291 | } | 131 | 291 | return result; | 132 | 291 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master24RedisConfigSetResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master26ReservePgsqlOidsResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 380 | Status StatusFromResp(const Resp& resp) { | 123 | 380 | if (!resp.has_error()) { | 124 | 380 | return Status::OK(); | 125 | 380 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master24IsLoadBalancedResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 178 | Status StatusFromResp(const Resp& resp) { | 123 | 178 | if (!resp.has_error()) { | 124 | 2 | return Status::OK(); | 125 | 2 | } | 126 | 176 | auto result = StatusFromPB(resp.error().status()); | 127 | 176 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 176 | master::MasterError(result) != resp.error().code()) { | 129 | 176 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 176 | } | 131 | 176 | return result; | 132 | 176 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master28IsLoadBalancerIdleResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2.27k | Status StatusFromResp(const Resp& resp) { | 123 | 2.27k | if (!resp.has_error()) { | 124 | 539 | return Status::OK(); | 125 | 539 | } | 126 | 1.73k | auto result = StatusFromPB(resp.error().status()); | 127 | 1.73k | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1.73k | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 1.73k | return result; | 132 | 1.73k | } |
_ZN2yb6client8internal14StatusFromRespINS_6master31ListLiveTabletServersResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2 | Status StatusFromResp(const Resp& resp) { | 123 | 2 | if (!resp.has_error()) { | 124 | 2 | return Status::OK(); | 125 | 2 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master21ListMastersResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master27ListTabletServersResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2.86k | Status StatusFromResp(const Resp& resp) { | 123 | 2.86k | if (!resp.has_error()) { | 124 | 2.86k | return Status::OK(); | 125 | 2.86k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master19AlterRoleResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 58 | Status StatusFromResp(const Resp& resp) { | 123 | 58 | if (!resp.has_error()) { | 124 | 45 | return Status::OK(); | 125 | 45 | } | 126 | 13 | auto result = StatusFromPB(resp.error().status()); | 127 | 13 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 13 | master::MasterError(result) != resp.error().code()) { | 129 | 13 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 13 | } | 131 | 13 | return result; | 132 | 13 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master20CreateRoleResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 757 | Status StatusFromResp(const Resp& resp) { | 123 | 757 | if (!resp.has_error()) { | 124 | 751 | return Status::OK(); | 125 | 751 | } | 126 | 6 | auto result = StatusFromPB(resp.error().status()); | 127 | 6 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 6 | master::MasterError(result) != resp.error().code()) { | 129 | 6 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 6 | } | 131 | 6 | return result; | 132 | 6 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master20DeleteRoleResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 730 | Status StatusFromResp(const Resp& resp) { | 123 | 730 | if (!resp.has_error()) { | 124 | 724 | return Status::OK(); | 125 | 724 | } | 126 | 6 | auto result = StatusFromPB(resp.error().status()); | 127 | 6 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 6 | master::MasterError(result) != resp.error().code()) { | 129 | 6 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 6 | } | 131 | 6 | return result; | 132 | 6 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master24GetPermissionsResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 118k | Status StatusFromResp(const Resp& resp) { | 123 | 118k | if (!resp.has_error()) { | 124 | 118k | return Status::OK(); | 125 | 118k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master31GrantRevokePermissionResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 721 | Status StatusFromResp(const Resp& resp) { | 123 | 721 | if (!resp.has_error()) { | 124 | 721 | return Status::OK(); | 125 | 721 | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master25GrantRevokeRoleResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 52 | Status StatusFromResp(const Resp& resp) { | 123 | 52 | if (!resp.has_error()) { | 124 | 49 | return Status::OK(); | 125 | 49 | } | 126 | 3 | auto result = StatusFromPB(resp.error().status()); | 127 | 3 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 3 | master::MasterError(result) != resp.error().code()) { | 129 | 3 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 3 | } | 131 | 3 | return result; | 132 | 3 | } |
_ZN2yb6client8internal14StatusFromRespINS_6master25CreateCDCStreamResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 2.69k | Status StatusFromResp(const Resp& resp) { | 123 | 2.69k | if (!resp.has_error()) { | 124 | 2.69k | return Status::OK(); | 125 | 2.69k | } | 126 | 0 | auto result = StatusFromPB(resp.error().status()); | 127 | 0 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 0 | return result; | 132 | 0 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master25DeleteCDCStreamResponsePBEEENS_6StatusERKT_ Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master28GetCDCDBStreamInfoResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master22GetCDCStreamResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 1 | Status StatusFromResp(const Resp& resp) { | 123 | 1 | if (!resp.has_error()) { | 124 | 0 | return Status::OK(); | 125 | 0 | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 1 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 1 | return result; | 132 | 1 | } |
Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master24ListCDCStreamsResponsePBEEENS_6StatusERKT_ Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master25UpdateCDCStreamResponsePBEEENS_6StatusERKT_ Unexecuted instantiation: _ZN2yb6client8internal14StatusFromRespINS_6master39UpdateConsumerOnProducerSplitResponsePBEEENS_6StatusERKT_ _ZN2yb6client8internal14StatusFromRespINS_6master32DeleteNotServingTabletResponsePBEEENS_6StatusERKT_ Line | Count | Source | 122 | 8 | Status StatusFromResp(const Resp& resp) { | 123 | 8 | if (!resp.has_error()) { | 124 | 7 | return Status::OK(); | 125 | 7 | } | 126 | 1 | auto result = StatusFromPB(resp.error().status()); | 127 | 1 | if (resp.error().code() != master::MasterErrorPB::UNKNOWN_ERROR && | 128 | 0 | master::MasterError(result) != resp.error().code()) { | 129 | 0 | result = result.CloneAndAddErrorCode(master::MasterError(resp.error().code())); | 130 | 0 | } | 131 | 1 | return result; | 132 | 1 | } |
|
133 | | |
134 | | // Gets data from the leader master. If the leader master |
135 | | // is down, waits for a new master to become the leader, and then gets |
136 | | // the data from the new leader master. |
137 | | template<class Req, class Resp> |
138 | | class ClientMasterRpc : public ClientMasterRpcBase { |
139 | | public: |
140 | | template<class... Args> |
141 | 174k | explicit ClientMasterRpc(Args&&... args) : ClientMasterRpcBase(std::forward<Args>(args)...) {} _ZN2yb6client8internal15ClientMasterRpcINS_6master23GetTableSchemaRequestPBENS3_24GetTableSchemaResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Line | Count | Source | 141 | 89.5k | explicit ClientMasterRpc(Args&&... args) : ClientMasterRpcBase(std::forward<Args>(args)...) {} |
Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master28GetTablegroupSchemaRequestPBENS3_29GetTablegroupSchemaResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master33GetColocatedTabletSchemaRequestPBENS3_34GetColocatedTabletSchemaResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master24CreateCDCStreamRequestPBENS3_25CreateCDCStreamResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master24DeleteCDCStreamRequestPBENS3_25DeleteCDCStreamResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master27GetCDCDBStreamInfoRequestPBENS3_28GetCDCDBStreamInfoResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master21GetCDCStreamRequestPBENS3_22GetCDCStreamResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ _ZN2yb6client8internal15ClientMasterRpcINS_6master31DeleteNotServingTabletRequestPBENS3_32DeleteNotServingTabletResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Line | Count | Source | 141 | 8 | explicit ClientMasterRpc(Args&&... args) : ClientMasterRpcBase(std::forward<Args>(args)...) {} |
_ZN2yb6client8internal15ClientMasterRpcINS_6master26GetTableLocationsRequestPBENS3_27GetTableLocationsResponsePBEEC2IJRPNS0_8YBClientERNSt3__16chrono10time_pointINS_15CoarseMonoClockENSC_8durationIxNSB_5ratioILl1ELl1000000000EEEEEEEEEEDpOT_ Line | Count | Source | 141 | 85.4k | explicit ClientMasterRpc(Args&&... args) : ClientMasterRpcBase(std::forward<Args>(args)...) {} |
|
142 | | |
143 | | protected: |
144 | 184k | Status ResponseStatus() override { |
145 | 184k | return StatusFromResp(resp_); |
146 | 184k | } _ZN2yb6client8internal15ClientMasterRpcINS_6master31DeleteNotServingTabletRequestPBENS3_32DeleteNotServingTabletResponsePBEE14ResponseStatusEv Line | Count | Source | 144 | 8 | Status ResponseStatus() override { | 145 | 8 | return StatusFromResp(resp_); | 146 | 8 | } |
_ZN2yb6client8internal15ClientMasterRpcINS_6master26GetTableLocationsRequestPBENS3_27GetTableLocationsResponsePBEE14ResponseStatusEv Line | Count | Source | 144 | 94.1k | Status ResponseStatus() override { | 145 | 94.1k | return StatusFromResp(resp_); | 146 | 94.1k | } |
_ZN2yb6client8internal15ClientMasterRpcINS_6master23GetTableSchemaRequestPBENS3_24GetTableSchemaResponsePBEE14ResponseStatusEv Line | Count | Source | 144 | 89.9k | Status ResponseStatus() override { | 145 | 89.9k | return StatusFromResp(resp_); | 146 | 89.9k | } |
Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master28GetTablegroupSchemaRequestPBENS3_29GetTablegroupSchemaResponsePBEE14ResponseStatusEv Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master33GetColocatedTabletSchemaRequestPBENS3_34GetColocatedTabletSchemaResponsePBEE14ResponseStatusEv Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master24CreateCDCStreamRequestPBENS3_25CreateCDCStreamResponsePBEE14ResponseStatusEv Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master24DeleteCDCStreamRequestPBENS3_25DeleteCDCStreamResponsePBEE14ResponseStatusEv Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master27GetCDCDBStreamInfoRequestPBENS3_28GetCDCDBStreamInfoResponsePBEE14ResponseStatusEv Unexecuted instantiation: _ZN2yb6client8internal15ClientMasterRpcINS_6master21GetCDCStreamRequestPBENS3_22GetCDCStreamResponsePBEE14ResponseStatusEv |
147 | | |
148 | | Req req_; |
149 | | Resp resp_; |
150 | | }; |
151 | | |
152 | | } // namespace internal |
153 | | } // namespace client |
154 | | } // namespace yb |
155 | | |
156 | | #endif // YB_CLIENT_CLIENT_MASTER_RPC_H |