/Users/deen/code/yugabyte-db/src/yb/master/scoped_leader_shared_lock-internal.h
Line | Count | Source (jump to first uncovered line) |
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_MASTER_SCOPED_LEADER_SHARED_LOCK_INTERNAL_H |
15 | | #define YB_MASTER_SCOPED_LEADER_SHARED_LOCK_INTERNAL_H |
16 | | |
17 | | #include "yb/common/wire_protocol.h" |
18 | | |
19 | | #include "yb/master/master_types.pb.h" |
20 | | #include "yb/master/scoped_leader_shared_lock.h" |
21 | | |
22 | | #include "yb/rpc/rpc_context.h" |
23 | | |
24 | | #include "yb/tserver/tserver_types.pb.h" |
25 | | |
26 | | #include "yb/util/type_traits.h" |
27 | | |
28 | | namespace yb { |
29 | | namespace master { |
30 | | |
31 | | // ------------------------------------------------------------------------------------------------ |
32 | | // These functions are not strictly limited to ScopedLeaderSharedLock but are needed both here in |
33 | | // catalog_manager-internal.h and this file is included from there. |
34 | | // ------------------------------------------------------------------------------------------------ |
35 | | |
36 | | HAS_MEMBER_FUNCTION(mutable_error); |
37 | | HAS_MEMBER_FUNCTION(mutable_status); |
38 | | |
39 | | template <class T, class ErrorCode> |
40 | | typename std::enable_if<HasMemberFunction_mutable_error<T>::value, void>::type |
41 | 15.0k | FillStatus(const Status& status, ErrorCode code, T* resp) { |
42 | 15.0k | StatusToPB(status, resp->mutable_error()->mutable_status()); |
43 | 15.0k | resp->mutable_error()->set_code(code); |
44 | 15.0k | } Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_21FlushTablesResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_27IsFlushTablesDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25FlushSysCatalogResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_27CompactSysCatalogResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_22IsInitDbDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 91 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 91 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 91 | resp->mutable_error()->set_code(code); | 44 | 91 | } |
_ZN2yb6master10FillStatusINS0_21SplitTabletResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 59 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 59 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 59 | resp->mutable_error()->set_code(code); | 44 | 59 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_38CreateTransactionStatusTableResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_32DeleteNotServingTabletResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 1 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 1 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 1 | resp->mutable_error()->set_code(code); | 44 | 1 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_16DdlLogResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_28GetTabletLocationsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 1 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 1 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 1 | resp->mutable_error()->set_code(code); | 44 | 1 | } |
_ZN2yb6master10FillStatusINS0_27GetTableLocationsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 39 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 39 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 39 | resp->mutable_error()->set_code(code); | 44 | 39 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_37GetTransactionStatusTabletsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_26ReservePgsqlOidsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_30GetYsqlCatalogConfigResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24RedisConfigSetResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24RedisConfigGetResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_27ListTabletServersResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 11.7k | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 11.7k | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 11.7k | resp->mutable_error()->set_code(code); | 44 | 11.7k | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_31ListLiveTabletServersResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_31GetMasterRegistrationResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_29IsMasterLeaderReadyResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25DumpMasterStateResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_29RemovedMasterUpdateResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_27SetPreferredZonesResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_32GetMasterClusterConfigResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_35ChangeMasterClusterConfigResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_28GetLoadMovePercentResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24IsLoadBalancedResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_28IsLoadBalancerIdleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_35AreLeadersOnPreferredOnlyResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_20CreateRoleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_19AlterRoleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_20DeleteRoleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25GrantRevokeRoleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_31GrantRevokePermissionResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24GetPermissionsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_21CreateTableResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 13 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 13 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 13 | resp->mutable_error()->set_code(code); | 44 | 13 | } |
_ZN2yb6master10FillStatusINS0_27IsCreateTableDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 5 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 5 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 5 | resp->mutable_error()->set_code(code); | 44 | 5 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_20ListTablesResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_24GetTableSchemaResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 2.38k | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 2.38k | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 2.38k | resp->mutable_error()->set_code(code); | 44 | 2.38k | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_29GetTablegroupSchemaResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_34GetColocatedTabletSchemaResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_23TruncateTableResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_29IsTruncateTableDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_23BackfillIndexResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_37LaunchBackfillIndexForTableResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25GetBackfillJobsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_21DeleteTableResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 19 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 19 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 19 | resp->mutable_error()->set_code(code); | 44 | 19 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_27IsDeleteTableDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_20AlterTableResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 2 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 2 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 2 | resp->mutable_error()->set_code(code); | 44 | 2 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_26IsAlterTableDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_25CreateNamespaceResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 10 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 10 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 10 | resp->mutable_error()->set_code(code); | 44 | 10 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_31IsCreateNamespaceDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25DeleteNamespaceResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_31IsDeleteNamespaceDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24AlterNamespaceResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24ListNamespacesResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_26GetNamespaceInfoResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_26CreateTablegroupResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_26DeleteTablegroupResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25ListTablegroupsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_22CreateUDTypeResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_22DeleteUDTypeResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_21ListUDTypesResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_23GetUDTypeInfoResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_30ChangeEncryptionInfoResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_29IsEncryptionEnabledResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25AddUniverseKeysResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_32GetUniverseKeyRegistryResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_32HasUniverseKeyInMemoryResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_21TSHeartbeatResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 708 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 708 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 708 | resp->mutable_error()->set_code(code); | 44 | 708 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_33ValidateReplicationInfoResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_25CreateCDCStreamResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 1 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 1 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 1 | resp->mutable_error()->set_code(code); | 44 | 1 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25DeleteCDCStreamResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24ListCDCStreamsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ _ZN2yb6master10FillStatusINS0_22GetCDCStreamResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Line | Count | Source | 41 | 2 | FillStatus(const Status& status, ErrorCode code, T* resp) { | 42 | 2 | StatusToPB(status, resp->mutable_error()->mutable_status()); | 43 | 2 | resp->mutable_error()->set_code(code); | 44 | 2 | } |
Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_28GetCDCDBStreamInfoResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25UpdateCDCStreamResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_34SetupUniverseReplicationResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_35DeleteUniverseReplicationResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_34AlterUniverseReplicationResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_39SetUniverseReplicationEnabledResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_32GetUniverseReplicationResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_40IsSetupUniverseReplicationDoneResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_39UpdateConsumerOnProducerSplitResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS_7tserver15WriteResponsePBENS2_24TabletServerErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS7_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS_7tserver29IsTabletServerReadyResponsePBENS2_24TabletServerErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS7_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24CreateSnapshotResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_23ListSnapshotsResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_25RestoreSnapshotResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_24DeleteSnapshotResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_28ImportSnapshotMetaResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_32CreateSnapshotScheduleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_31ListSnapshotSchedulesResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ Unexecuted instantiation: _ZN2yb6master10FillStatusINS0_32DeleteSnapshotScheduleResponsePBENS0_18MasterErrorPB_CodeEEENSt3__19enable_ifIXsr31HasMemberFunction_mutable_errorIT_EE5valueEvE4typeERKNS_6StatusET0_PS6_ |
45 | | |
46 | | template <class T, class ErrorCode> |
47 | | typename std::enable_if<!HasMemberFunction_mutable_error<T>::value, void>::type |
48 | 0 | FillStatus(const Status& status, ErrorCode code, T* resp) { |
49 | 0 | StatusToPB(status, resp->mutable_status()); |
50 | 0 | } |
51 | | |
52 | | // ------------------------------------------------------------------------------------------------ |
53 | | |
54 | | template<typename RespClass> |
55 | | bool ScopedLeaderSharedLock::CheckIsInitializedOrRespond( |
56 | 4.30M | RespClass* resp, rpc::RpcContext* rpc) { |
57 | 4.30M | if (PREDICT_FALSE(!catalog_status_.ok())) { |
58 | 398k | StatusToPB(catalog_status_, resp->mutable_error()->mutable_status()); |
59 | 398k | resp->mutable_error()->set_code(MasterErrorPB::CATALOG_MANAGER_NOT_INITIALIZED); |
60 | 398k | rpc->RespondSuccess(); |
61 | 398k | return false; |
62 | 398k | } |
63 | 3.90M | return true; |
64 | 3.90M | } _ZN2yb6master22ScopedLeaderSharedLock27CheckIsInitializedOrRespondINS0_31GetMasterRegistrationResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 56 | 4.30M | RespClass* resp, rpc::RpcContext* rpc) { | 57 | 4.30M | if (PREDICT_FALSE(!catalog_status_.ok())) { | 58 | 398k | StatusToPB(catalog_status_, resp->mutable_error()->mutable_status()); | 59 | 398k | resp->mutable_error()->set_code(MasterErrorPB::CATALOG_MANAGER_NOT_INITIALIZED); | 60 | 398k | rpc->RespondSuccess(); | 61 | 398k | return false; | 62 | 398k | } | 63 | 3.90M | return true; | 64 | 3.90M | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock27CheckIsInitializedOrRespondINS0_25DumpMasterStateResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock27CheckIsInitializedOrRespondINS0_29RemovedMasterUpdateResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 56 | 27 | RespClass* resp, rpc::RpcContext* rpc) { | 57 | 27 | if (PREDICT_FALSE(!catalog_status_.ok())) { | 58 | 0 | StatusToPB(catalog_status_, resp->mutable_error()->mutable_status()); | 59 | 0 | resp->mutable_error()->set_code(MasterErrorPB::CATALOG_MANAGER_NOT_INITIALIZED); | 60 | 0 | rpc->RespondSuccess(); | 61 | 0 | return false; | 62 | 0 | } | 63 | 27 | return true; | 64 | 27 | } |
|
65 | | |
66 | | template<typename RespClass, typename ErrorClass> |
67 | | bool ScopedLeaderSharedLock::CheckIsInitializedAndIsLeaderOrRespondInternal( |
68 | | RespClass* resp, |
69 | 939k | rpc::RpcContext* rpc) { |
70 | 939k | const Status* status = &catalog_status_; |
71 | 939k | if (PREDICT_TRUE(status->ok())) { |
72 | 938k | status = &leader_status_; |
73 | 938k | if (PREDICT_TRUE(status->ok())) { |
74 | 926k | return true; |
75 | 926k | } |
76 | 12.7k | } |
77 | | |
78 | 12.7k | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); |
79 | 12.7k | rpc->RespondSuccess(); |
80 | 12.7k | return false; |
81 | 12.7k | } _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_21FlushTablesResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 7 | rpc::RpcContext* rpc) { | 70 | 7 | const Status* status = &catalog_status_; | 71 | 7 | if (PREDICT_TRUE(status->ok())) { | 72 | 7 | status = &leader_status_; | 73 | 7 | if (PREDICT_TRUE(status->ok())) { | 74 | 7 | return true; | 75 | 7 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27IsFlushTablesDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 19 | rpc::RpcContext* rpc) { | 70 | 19 | const Status* status = &catalog_status_; | 71 | 19 | if (PREDICT_TRUE(status->ok())) { | 72 | 19 | status = &leader_status_; | 73 | 19 | if (PREDICT_TRUE(status->ok())) { | 74 | 19 | return true; | 75 | 19 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25FlushSysCatalogResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27CompactSysCatalogResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_22IsInitDbDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 806 | rpc::RpcContext* rpc) { | 70 | 806 | const Status* status = &catalog_status_; | 71 | 806 | if (PREDICT_TRUE(status->ok())) { | 72 | 798 | status = &leader_status_; | 73 | 798 | if (PREDICT_TRUE(status->ok())) { | 74 | 715 | return true; | 75 | 715 | } | 76 | 91 | } | 77 | | | 78 | 91 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 91 | rpc->RespondSuccess(); | 80 | 91 | return false; | 81 | 91 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_21SplitTabletResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 69 | rpc::RpcContext* rpc) { | 70 | 69 | const Status* status = &catalog_status_; | 71 | 69 | if (PREDICT_TRUE(status->ok())) { | 72 | 60 | status = &leader_status_; | 73 | 60 | if (PREDICT_TRUE(status->ok())) { | 74 | 10 | return true; | 75 | 10 | } | 76 | 59 | } | 77 | | | 78 | 59 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 59 | rpc->RespondSuccess(); | 80 | 59 | return false; | 81 | 59 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_38CreateTransactionStatusTableResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_32DeleteNotServingTabletResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 8 | rpc::RpcContext* rpc) { | 70 | 8 | const Status* status = &catalog_status_; | 71 | 8 | if (PREDICT_TRUE(status->ok())) { | 72 | 8 | status = &leader_status_; | 73 | 8 | if (PREDICT_TRUE(status->ok())) { | 74 | 8 | return true; | 75 | 8 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_16DdlLogResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_28GetTabletLocationsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 9.12k | rpc::RpcContext* rpc) { | 70 | 9.12k | const Status* status = &catalog_status_; | 71 | 9.12k | if (PREDICT_TRUE(status->ok())) { | 72 | 9.12k | status = &leader_status_; | 73 | 9.12k | if (PREDICT_TRUE(status->ok())) { | 74 | 9.12k | return true; | 75 | 9.12k | } | 76 | 2 | } | 77 | | | 78 | 2 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 2 | rpc->RespondSuccess(); | 80 | 2 | return false; | 81 | 2 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27GetTableLocationsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 167k | rpc::RpcContext* rpc) { | 70 | 167k | const Status* status = &catalog_status_; | 71 | 167k | if (PREDICT_TRUE(status->ok())) { | 72 | 167k | status = &leader_status_; | 73 | 167k | if (PREDICT_TRUE(status->ok())) { | 74 | 167k | return true; | 75 | 167k | } | 76 | 3 | } | 77 | | | 78 | 3 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 3 | rpc->RespondSuccess(); | 80 | 3 | return false; | 81 | 3 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_37GetTransactionStatusTabletsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2.01k | rpc::RpcContext* rpc) { | 70 | 2.01k | const Status* status = &catalog_status_; | 71 | 2.01k | if (PREDICT_TRUE(status->ok())) { | 72 | 2.01k | status = &leader_status_; | 73 | 2.01k | if (PREDICT_TRUE(status->ok())) { | 74 | 2.01k | return true; | 75 | 2.01k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_26ReservePgsqlOidsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 380 | rpc::RpcContext* rpc) { | 70 | 380 | const Status* status = &catalog_status_; | 71 | 380 | if (PREDICT_TRUE(status->ok())) { | 72 | 380 | status = &leader_status_; | 73 | 380 | if (PREDICT_TRUE(status->ok())) { | 74 | 380 | return true; | 75 | 380 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_30GetYsqlCatalogConfigResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24RedisConfigSetResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24RedisConfigGetResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 291 | rpc::RpcContext* rpc) { | 70 | 291 | const Status* status = &catalog_status_; | 71 | 291 | if (PREDICT_TRUE(status->ok())) { | 72 | 291 | status = &leader_status_; | 73 | 291 | if (PREDICT_TRUE(status->ok())) { | 74 | 291 | return true; | 75 | 291 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27ListTabletServersResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 20.1k | rpc::RpcContext* rpc) { | 70 | 20.1k | const Status* status = &catalog_status_; | 71 | 20.1k | if (PREDICT_TRUE(status->ok())) { | 72 | 20.0k | status = &leader_status_; | 73 | 20.0k | if (PREDICT_TRUE(status->ok())) { | 74 | 8.37k | return true; | 75 | 8.37k | } | 76 | 11.7k | } | 77 | | | 78 | 11.7k | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 11.7k | rpc->RespondSuccess(); | 80 | 11.7k | return false; | 81 | 11.7k | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_31ListLiveTabletServersResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2 | rpc::RpcContext* rpc) { | 70 | 2 | const Status* status = &catalog_status_; | 71 | 2 | if (PREDICT_TRUE(status->ok())) { | 72 | 2 | status = &leader_status_; | 73 | 2 | if (PREDICT_TRUE(status->ok())) { | 74 | 2 | return true; | 75 | 2 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_29IsMasterLeaderReadyResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 24 | rpc::RpcContext* rpc) { | 70 | 24 | const Status* status = &catalog_status_; | 71 | 24 | if (PREDICT_TRUE(status->ok())) { | 72 | 24 | status = &leader_status_; | 73 | 24 | if (PREDICT_TRUE(status->ok())) { | 74 | 24 | return true; | 75 | 24 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27SetPreferredZonesResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 3 | rpc::RpcContext* rpc) { | 70 | 3 | const Status* status = &catalog_status_; | 71 | 3 | if (PREDICT_TRUE(status->ok())) { | 72 | 3 | status = &leader_status_; | 73 | 3 | if (PREDICT_TRUE(status->ok())) { | 74 | 3 | return true; | 75 | 3 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_32GetMasterClusterConfigResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 206 | rpc::RpcContext* rpc) { | 70 | 206 | const Status* status = &catalog_status_; | 71 | 206 | if (PREDICT_TRUE(status->ok())) { | 72 | 206 | status = &leader_status_; | 73 | 206 | if (PREDICT_TRUE(status->ok())) { | 74 | 206 | return true; | 75 | 206 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_35ChangeMasterClusterConfigResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 109 | rpc::RpcContext* rpc) { | 70 | 109 | const Status* status = &catalog_status_; | 71 | 109 | if (PREDICT_TRUE(status->ok())) { | 72 | 109 | status = &leader_status_; | 73 | 109 | if (PREDICT_TRUE(status->ok())) { | 74 | 109 | return true; | 75 | 109 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_28GetLoadMovePercentResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1.20k | rpc::RpcContext* rpc) { | 70 | 1.20k | const Status* status = &catalog_status_; | 71 | 1.20k | if (PREDICT_TRUE(status->ok())) { | 72 | 1.20k | status = &leader_status_; | 73 | 1.20k | if (PREDICT_TRUE(status->ok())) { | 74 | 1.20k | return true; | 75 | 1.20k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24IsLoadBalancedResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 202 | rpc::RpcContext* rpc) { | 70 | 202 | const Status* status = &catalog_status_; | 71 | 202 | if (PREDICT_TRUE(status->ok())) { | 72 | 202 | status = &leader_status_; | 73 | 202 | if (PREDICT_TRUE(status->ok())) { | 74 | 202 | return true; | 75 | 202 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_28IsLoadBalancerIdleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2.25k | rpc::RpcContext* rpc) { | 70 | 2.25k | const Status* status = &catalog_status_; | 71 | 2.25k | if (PREDICT_TRUE(status->ok())) { | 72 | 2.25k | status = &leader_status_; | 73 | 2.25k | if (PREDICT_TRUE(status->ok())) { | 74 | 2.25k | return true; | 75 | 2.25k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_35AreLeadersOnPreferredOnlyResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 153 | rpc::RpcContext* rpc) { | 70 | 153 | const Status* status = &catalog_status_; | 71 | 153 | if (PREDICT_TRUE(status->ok())) { | 72 | 153 | status = &leader_status_; | 73 | 153 | if (PREDICT_TRUE(status->ok())) { | 74 | 153 | return true; | 75 | 153 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_20CreateRoleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 757 | rpc::RpcContext* rpc) { | 70 | 757 | const Status* status = &catalog_status_; | 71 | 757 | if (PREDICT_TRUE(status->ok())) { | 72 | 757 | status = &leader_status_; | 73 | 757 | if (PREDICT_TRUE(status->ok())) { | 74 | 757 | return true; | 75 | 757 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_19AlterRoleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 58 | rpc::RpcContext* rpc) { | 70 | 58 | const Status* status = &catalog_status_; | 71 | 58 | if (PREDICT_TRUE(status->ok())) { | 72 | 58 | status = &leader_status_; | 73 | 58 | if (PREDICT_TRUE(status->ok())) { | 74 | 58 | return true; | 75 | 58 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_20DeleteRoleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 730 | rpc::RpcContext* rpc) { | 70 | 730 | const Status* status = &catalog_status_; | 71 | 730 | if (PREDICT_TRUE(status->ok())) { | 72 | 730 | status = &leader_status_; | 73 | 730 | if (PREDICT_TRUE(status->ok())) { | 74 | 730 | return true; | 75 | 730 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25GrantRevokeRoleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 52 | rpc::RpcContext* rpc) { | 70 | 52 | const Status* status = &catalog_status_; | 71 | 52 | if (PREDICT_TRUE(status->ok())) { | 72 | 52 | status = &leader_status_; | 73 | 52 | if (PREDICT_TRUE(status->ok())) { | 74 | 52 | return true; | 75 | 52 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_31GrantRevokePermissionResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 721 | rpc::RpcContext* rpc) { | 70 | 721 | const Status* status = &catalog_status_; | 71 | 721 | if (PREDICT_TRUE(status->ok())) { | 72 | 721 | status = &leader_status_; | 73 | 721 | if (PREDICT_TRUE(status->ok())) { | 74 | 721 | return true; | 75 | 721 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24GetPermissionsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 117k | rpc::RpcContext* rpc) { | 70 | 117k | const Status* status = &catalog_status_; | 71 | 117k | if (PREDICT_TRUE(status->ok())) { | 72 | 117k | status = &leader_status_; | 73 | 117k | if (PREDICT_TRUE(status->ok())) { | 74 | 117k | return true; | 75 | 117k | } | 76 | 17 | } | 77 | | | 78 | 17 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 17 | rpc->RespondSuccess(); | 80 | 17 | return false; | 81 | 17 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_21CreateTableResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 3.36k | rpc::RpcContext* rpc) { | 70 | 3.36k | const Status* status = &catalog_status_; | 71 | 3.36k | if (PREDICT_TRUE(status->ok())) { | 72 | 3.36k | status = &leader_status_; | 73 | 3.36k | if (PREDICT_TRUE(status->ok())) { | 74 | 3.36k | return true; | 75 | 3.36k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27IsCreateTableDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 16.2k | rpc::RpcContext* rpc) { | 70 | 16.2k | const Status* status = &catalog_status_; | 71 | 16.2k | if (PREDICT_TRUE(status->ok())) { | 72 | 16.2k | status = &leader_status_; | 73 | 16.2k | if (PREDICT_TRUE(status->ok())) { | 74 | 16.2k | return true; | 75 | 16.2k | } | 76 | 5 | } | 77 | | | 78 | 5 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 5 | rpc->RespondSuccess(); | 80 | 5 | return false; | 81 | 5 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_20ListTablesResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1.83k | rpc::RpcContext* rpc) { | 70 | 1.83k | const Status* status = &catalog_status_; | 71 | 1.83k | if (PREDICT_TRUE(status->ok())) { | 72 | 1.83k | status = &leader_status_; | 73 | 1.83k | if (PREDICT_TRUE(status->ok())) { | 74 | 1.83k | return true; | 75 | 1.83k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24GetTableSchemaResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 117k | rpc::RpcContext* rpc) { | 70 | 117k | const Status* status = &catalog_status_; | 71 | 117k | if (PREDICT_TRUE(status->ok())) { | 72 | 117k | status = &leader_status_; | 73 | 117k | if (PREDICT_TRUE(status->ok())) { | 74 | 117k | return true; | 75 | 117k | } | 76 | 2 | } | 77 | | | 78 | 2 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 2 | rpc->RespondSuccess(); | 80 | 2 | return false; | 81 | 2 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_29GetTablegroupSchemaResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_34GetColocatedTabletSchemaResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_23TruncateTableResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 11.8k | rpc::RpcContext* rpc) { | 70 | 11.8k | const Status* status = &catalog_status_; | 71 | 11.8k | if (PREDICT_TRUE(status->ok())) { | 72 | 11.8k | status = &leader_status_; | 73 | 11.8k | if (PREDICT_TRUE(status->ok())) { | 74 | 11.8k | return true; | 75 | 11.8k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_29IsTruncateTableDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 8.89k | rpc::RpcContext* rpc) { | 70 | 8.89k | const Status* status = &catalog_status_; | 71 | 8.89k | if (PREDICT_TRUE(status->ok())) { | 72 | 8.89k | status = &leader_status_; | 73 | 8.89k | if (PREDICT_TRUE(status->ok())) { | 74 | 8.89k | return true; | 75 | 8.89k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_23BackfillIndexResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 89 | rpc::RpcContext* rpc) { | 70 | 89 | const Status* status = &catalog_status_; | 71 | 89 | if (PREDICT_TRUE(status->ok())) { | 72 | 89 | status = &leader_status_; | 73 | 89 | if (PREDICT_TRUE(status->ok())) { | 74 | 89 | return true; | 75 | 89 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_37LaunchBackfillIndexForTableResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1 | rpc::RpcContext* rpc) { | 70 | 1 | const Status* status = &catalog_status_; | 71 | 1 | if (PREDICT_TRUE(status->ok())) { | 72 | 1 | status = &leader_status_; | 73 | 1 | if (PREDICT_TRUE(status->ok())) { | 74 | 1 | return true; | 75 | 1 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25GetBackfillJobsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 695 | rpc::RpcContext* rpc) { | 70 | 695 | const Status* status = &catalog_status_; | 71 | 695 | if (PREDICT_TRUE(status->ok())) { | 72 | 695 | status = &leader_status_; | 73 | 695 | if (PREDICT_TRUE(status->ok())) { | 74 | 695 | return true; | 75 | 695 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_21DeleteTableResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2.46k | rpc::RpcContext* rpc) { | 70 | 2.46k | const Status* status = &catalog_status_; | 71 | 2.46k | if (PREDICT_TRUE(status->ok())) { | 72 | 2.46k | status = &leader_status_; | 73 | 2.46k | if (PREDICT_TRUE(status->ok())) { | 74 | 2.46k | return true; | 75 | 2.46k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_27IsDeleteTableDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 5.58k | rpc::RpcContext* rpc) { | 70 | 5.58k | const Status* status = &catalog_status_; | 71 | 5.58k | if (PREDICT_TRUE(status->ok())) { | 72 | 5.58k | status = &leader_status_; | 73 | 5.58k | if (PREDICT_TRUE(status->ok())) { | 74 | 5.58k | return true; | 75 | 5.58k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_20AlterTableResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 327 | rpc::RpcContext* rpc) { | 70 | 327 | const Status* status = &catalog_status_; | 71 | 327 | if (PREDICT_TRUE(status->ok())) { | 72 | 327 | status = &leader_status_; | 73 | 327 | if (PREDICT_TRUE(status->ok())) { | 74 | 326 | return true; | 75 | 326 | } | 76 | 1 | } | 77 | | | 78 | 1 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 1 | rpc->RespondSuccess(); | 80 | 1 | return false; | 81 | 1 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_26IsAlterTableDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 649 | rpc::RpcContext* rpc) { | 70 | 649 | const Status* status = &catalog_status_; | 71 | 649 | if (PREDICT_TRUE(status->ok())) { | 72 | 649 | status = &leader_status_; | 73 | 649 | if (PREDICT_TRUE(status->ok())) { | 74 | 649 | return true; | 75 | 649 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25CreateNamespaceResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2.08k | rpc::RpcContext* rpc) { | 70 | 2.08k | const Status* status = &catalog_status_; | 71 | 2.08k | if (PREDICT_TRUE(status->ok())) { | 72 | 2.08k | status = &leader_status_; | 73 | 2.08k | if (PREDICT_TRUE(status->ok())) { | 74 | 2.08k | return true; | 75 | 2.08k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_31IsCreateNamespaceDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2.13k | rpc::RpcContext* rpc) { | 70 | 2.13k | const Status* status = &catalog_status_; | 71 | 2.13k | if (PREDICT_TRUE(status->ok())) { | 72 | 2.13k | status = &leader_status_; | 73 | 2.13k | if (PREDICT_TRUE(status->ok())) { | 74 | 2.13k | return true; | 75 | 2.13k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25DeleteNamespaceResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1.55k | rpc::RpcContext* rpc) { | 70 | 1.55k | const Status* status = &catalog_status_; | 71 | 1.55k | if (PREDICT_TRUE(status->ok())) { | 72 | 1.55k | status = &leader_status_; | 73 | 1.55k | if (PREDICT_TRUE(status->ok())) { | 74 | 1.55k | return true; | 75 | 1.55k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_31IsDeleteNamespaceDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1.59k | rpc::RpcContext* rpc) { | 70 | 1.59k | const Status* status = &catalog_status_; | 71 | 1.59k | if (PREDICT_TRUE(status->ok())) { | 72 | 1.59k | status = &leader_status_; | 73 | 1.59k | if (PREDICT_TRUE(status->ok())) { | 74 | 1.59k | return true; | 75 | 1.59k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24AlterNamespaceResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 4 | rpc::RpcContext* rpc) { | 70 | 4 | const Status* status = &catalog_status_; | 71 | 4 | if (PREDICT_TRUE(status->ok())) { | 72 | 4 | status = &leader_status_; | 73 | 4 | if (PREDICT_TRUE(status->ok())) { | 74 | 4 | return true; | 75 | 4 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24ListNamespacesResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 4.44k | rpc::RpcContext* rpc) { | 70 | 4.44k | const Status* status = &catalog_status_; | 71 | 4.44k | if (PREDICT_TRUE(status->ok())) { | 72 | 4.44k | status = &leader_status_; | 73 | 4.44k | if (PREDICT_TRUE(status->ok())) { | 74 | 4.44k | return true; | 75 | 4.44k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_26GetNamespaceInfoResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1.77k | rpc::RpcContext* rpc) { | 70 | 1.77k | const Status* status = &catalog_status_; | 71 | 1.77k | if (PREDICT_TRUE(status->ok())) { | 72 | 1.77k | status = &leader_status_; | 73 | 1.77k | if (PREDICT_TRUE(status->ok())) { | 74 | 1.77k | return true; | 75 | 1.77k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_26CreateTablegroupResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 3 | rpc::RpcContext* rpc) { | 70 | 3 | const Status* status = &catalog_status_; | 71 | 3 | if (PREDICT_TRUE(status->ok())) { | 72 | 3 | status = &leader_status_; | 73 | 3 | if (PREDICT_TRUE(status->ok())) { | 74 | 3 | return true; | 75 | 3 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_26DeleteTablegroupResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2 | rpc::RpcContext* rpc) { | 70 | 2 | const Status* status = &catalog_status_; | 71 | 2 | if (PREDICT_TRUE(status->ok())) { | 72 | 2 | status = &leader_status_; | 73 | 2 | if (PREDICT_TRUE(status->ok())) { | 74 | 2 | return true; | 75 | 2 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25ListTablegroupsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 3 | rpc::RpcContext* rpc) { | 70 | 3 | const Status* status = &catalog_status_; | 71 | 3 | if (PREDICT_TRUE(status->ok())) { | 72 | 3 | status = &leader_status_; | 73 | 3 | if (PREDICT_TRUE(status->ok())) { | 74 | 3 | return true; | 75 | 3 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_22CreateUDTypeResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 46 | rpc::RpcContext* rpc) { | 70 | 46 | const Status* status = &catalog_status_; | 71 | 46 | if (PREDICT_TRUE(status->ok())) { | 72 | 46 | status = &leader_status_; | 73 | 46 | if (PREDICT_TRUE(status->ok())) { | 74 | 46 | return true; | 75 | 46 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_22DeleteUDTypeResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 53 | rpc::RpcContext* rpc) { | 70 | 53 | const Status* status = &catalog_status_; | 71 | 53 | if (PREDICT_TRUE(status->ok())) { | 72 | 53 | status = &leader_status_; | 73 | 53 | if (PREDICT_TRUE(status->ok())) { | 74 | 53 | return true; | 75 | 53 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_21ListUDTypesResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_23GetUDTypeInfoResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 55 | rpc::RpcContext* rpc) { | 70 | 55 | const Status* status = &catalog_status_; | 71 | 55 | if (PREDICT_TRUE(status->ok())) { | 72 | 55 | status = &leader_status_; | 73 | 55 | if (PREDICT_TRUE(status->ok())) { | 74 | 55 | return true; | 75 | 55 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_30ChangeEncryptionInfoResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 6 | rpc::RpcContext* rpc) { | 70 | 6 | const Status* status = &catalog_status_; | 71 | 6 | if (PREDICT_TRUE(status->ok())) { | 72 | 6 | status = &leader_status_; | 73 | 6 | if (PREDICT_TRUE(status->ok())) { | 74 | 6 | return true; | 75 | 6 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_29IsEncryptionEnabledResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 6 | rpc::RpcContext* rpc) { | 70 | 6 | const Status* status = &catalog_status_; | 71 | 6 | if (PREDICT_TRUE(status->ok())) { | 72 | 6 | status = &leader_status_; | 73 | 6 | if (PREDICT_TRUE(status->ok())) { | 74 | 6 | return true; | 75 | 6 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_21TSHeartbeatResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 384k | rpc::RpcContext* rpc) { | 70 | 384k | const Status* status = &catalog_status_; | 71 | 384k | if (PREDICT_TRUE(status->ok())) { | 72 | 384k | status = &leader_status_; | 73 | 384k | if (PREDICT_TRUE(status->ok())) { | 74 | 383k | return true; | 75 | 383k | } | 76 | 800 | } | 77 | | | 78 | 800 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 800 | rpc->RespondSuccess(); | 80 | 800 | return false; | 81 | 800 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_33ValidateReplicationInfoResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25CreateCDCStreamResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2.69k | rpc::RpcContext* rpc) { | 70 | 2.69k | const Status* status = &catalog_status_; | 71 | 2.69k | if (PREDICT_TRUE(status->ok())) { | 72 | 2.69k | status = &leader_status_; | 73 | 2.69k | if (PREDICT_TRUE(status->ok())) { | 74 | 2.69k | return true; | 75 | 2.69k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25DeleteCDCStreamResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2 | rpc::RpcContext* rpc) { | 70 | 2 | const Status* status = &catalog_status_; | 71 | 2 | if (PREDICT_TRUE(status->ok())) { | 72 | 2 | status = &leader_status_; | 73 | 2 | if (PREDICT_TRUE(status->ok())) { | 74 | 2 | return true; | 75 | 2 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24ListCDCStreamsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 1 | rpc::RpcContext* rpc) { | 70 | 1 | const Status* status = &catalog_status_; | 71 | 1 | if (PREDICT_TRUE(status->ok())) { | 72 | 1 | status = &leader_status_; | 73 | 1 | if (PREDICT_TRUE(status->ok())) { | 74 | 1 | return true; | 75 | 1 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_22GetCDCStreamResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 6 | rpc::RpcContext* rpc) { | 70 | 6 | const Status* status = &catalog_status_; | 71 | 6 | if (PREDICT_TRUE(status->ok())) { | 72 | 6 | status = &leader_status_; | 73 | 6 | if (PREDICT_TRUE(status->ok())) { | 74 | 6 | return true; | 75 | 6 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
_ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_28GetCDCDBStreamInfoResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 11 | rpc::RpcContext* rpc) { | 70 | 11 | const Status* status = &catalog_status_; | 71 | 11 | if (PREDICT_TRUE(status->ok())) { | 72 | 11 | status = &leader_status_; | 73 | 11 | if (PREDICT_TRUE(status->ok())) { | 74 | 11 | return true; | 75 | 11 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25UpdateCDCStreamResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_34SetupUniverseReplicationResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 2 | rpc::RpcContext* rpc) { | 70 | 2 | const Status* status = &catalog_status_; | 71 | 2 | if (PREDICT_TRUE(status->ok())) { | 72 | 2 | status = &leader_status_; | 73 | 2 | if (PREDICT_TRUE(status->ok())) { | 74 | 2 | return true; | 75 | 2 | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_35DeleteUniverseReplicationResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_34AlterUniverseReplicationResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_39SetUniverseReplicationEnabledResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_32GetUniverseReplicationResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_40IsSetupUniverseReplicationDoneResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_39UpdateConsumerOnProducerSplitResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS_7tserver15WriteResponsePBENS3_19TabletServerErrorPBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 69 | 44.1k | rpc::RpcContext* rpc) { | 70 | 44.1k | const Status* status = &catalog_status_; | 71 | 44.1k | if (PREDICT_TRUE(status->ok())) { | 72 | 44.1k | status = &leader_status_; | 73 | 44.1k | if (PREDICT_TRUE(status->ok())) { | 74 | 44.1k | return true; | 75 | 44.1k | } | 76 | 0 | } | 77 | | | 78 | 0 | FillStatus(*status, ErrorClass::NOT_THE_LEADER, resp); | 79 | 0 | rpc->RespondSuccess(); | 80 | 0 | return false; | 81 | 0 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24CreateSnapshotResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_23ListSnapshotsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_34ListSnapshotRestorationsResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_25RestoreSnapshotResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_24DeleteSnapshotResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_28ImportSnapshotMetaResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_32CreateSnapshotScheduleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_31ListSnapshotSchedulesResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock46CheckIsInitializedAndIsLeaderOrRespondInternalINS0_32DeleteSnapshotScheduleResponsePBENS0_13MasterErrorPBEEEbPT_PNS_3rpc10RpcContextE |
82 | | |
83 | | template<typename RespClass, typename ErrorClass> |
84 | | bool ScopedLeaderSharedLock::CheckIsInitializedOrRespondInternal( |
85 | | RespClass* resp, |
86 | | rpc::RpcContext* rpc, |
87 | 9 | bool set_error) { |
88 | 9 | const Status* status = &catalog_status_; |
89 | 9 | if (PREDICT_TRUE(status->ok())) { |
90 | 9 | return true; |
91 | 9 | } |
92 | | |
93 | 0 | if (set_error) { |
94 | 0 | FillStatus(*status, ErrorClass::UNKNOWN_ERROR, resp); |
95 | 0 | } |
96 | 0 | rpc->RespondSuccess(); |
97 | 0 | return false; |
98 | 0 | } |
99 | | |
100 | | template<typename RespClass> |
101 | | bool ScopedLeaderSharedLock::CheckIsInitializedAndIsLeaderOrRespond( |
102 | | RespClass* resp, |
103 | 894k | rpc::RpcContext* rpc) { |
104 | 894k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); |
105 | 894k | } _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_21FlushTablesResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 7 | rpc::RpcContext* rpc) { | 104 | 7 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 7 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27IsFlushTablesDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 19 | rpc::RpcContext* rpc) { | 104 | 19 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 19 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25FlushSysCatalogResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27CompactSysCatalogResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_22IsInitDbDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 806 | rpc::RpcContext* rpc) { | 104 | 806 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 806 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_21SplitTabletResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 69 | rpc::RpcContext* rpc) { | 104 | 69 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 69 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_38CreateTransactionStatusTableResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_32DeleteNotServingTabletResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 8 | rpc::RpcContext* rpc) { | 104 | 8 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 8 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_16DdlLogResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_28GetTabletLocationsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 9.12k | rpc::RpcContext* rpc) { | 104 | 9.12k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 9.12k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27GetTableLocationsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 167k | rpc::RpcContext* rpc) { | 104 | 167k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 167k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_37GetTransactionStatusTabletsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2.01k | rpc::RpcContext* rpc) { | 104 | 2.01k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2.01k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_26ReservePgsqlOidsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 380 | rpc::RpcContext* rpc) { | 104 | 380 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 380 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_30GetYsqlCatalogConfigResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24RedisConfigSetResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24RedisConfigGetResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 291 | rpc::RpcContext* rpc) { | 104 | 291 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 291 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27ListTabletServersResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 20.1k | rpc::RpcContext* rpc) { | 104 | 20.1k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 20.1k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_31ListLiveTabletServersResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2 | rpc::RpcContext* rpc) { | 104 | 2 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_29IsMasterLeaderReadyResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 24 | rpc::RpcContext* rpc) { | 104 | 24 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 24 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27SetPreferredZonesResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 3 | rpc::RpcContext* rpc) { | 104 | 3 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 3 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_32GetMasterClusterConfigResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 206 | rpc::RpcContext* rpc) { | 104 | 206 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 206 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_35ChangeMasterClusterConfigResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 109 | rpc::RpcContext* rpc) { | 104 | 109 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 109 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_28GetLoadMovePercentResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1.20k | rpc::RpcContext* rpc) { | 104 | 1.20k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1.20k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24IsLoadBalancedResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 202 | rpc::RpcContext* rpc) { | 104 | 202 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 202 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_28IsLoadBalancerIdleResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2.25k | rpc::RpcContext* rpc) { | 104 | 2.25k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2.25k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_35AreLeadersOnPreferredOnlyResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 153 | rpc::RpcContext* rpc) { | 104 | 153 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 153 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_20CreateRoleResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 757 | rpc::RpcContext* rpc) { | 104 | 757 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 757 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_19AlterRoleResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 58 | rpc::RpcContext* rpc) { | 104 | 58 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 58 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_20DeleteRoleResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 730 | rpc::RpcContext* rpc) { | 104 | 730 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 730 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25GrantRevokeRoleResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 52 | rpc::RpcContext* rpc) { | 104 | 52 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 52 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_31GrantRevokePermissionResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 721 | rpc::RpcContext* rpc) { | 104 | 721 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 721 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24GetPermissionsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 117k | rpc::RpcContext* rpc) { | 104 | 117k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 117k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_21CreateTableResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 3.36k | rpc::RpcContext* rpc) { | 104 | 3.36k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 3.36k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27IsCreateTableDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 16.2k | rpc::RpcContext* rpc) { | 104 | 16.2k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 16.2k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_20ListTablesResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1.83k | rpc::RpcContext* rpc) { | 104 | 1.83k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1.83k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24GetTableSchemaResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 117k | rpc::RpcContext* rpc) { | 104 | 117k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 117k | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_29GetTablegroupSchemaResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_34GetColocatedTabletSchemaResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_23TruncateTableResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 11.8k | rpc::RpcContext* rpc) { | 104 | 11.8k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 11.8k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_29IsTruncateTableDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 8.89k | rpc::RpcContext* rpc) { | 104 | 8.89k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 8.89k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_23BackfillIndexResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 89 | rpc::RpcContext* rpc) { | 104 | 89 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 89 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_37LaunchBackfillIndexForTableResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1 | rpc::RpcContext* rpc) { | 104 | 1 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25GetBackfillJobsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 695 | rpc::RpcContext* rpc) { | 104 | 695 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 695 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_21DeleteTableResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2.46k | rpc::RpcContext* rpc) { | 104 | 2.46k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2.46k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_27IsDeleteTableDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 5.58k | rpc::RpcContext* rpc) { | 104 | 5.58k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 5.58k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_20AlterTableResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 327 | rpc::RpcContext* rpc) { | 104 | 327 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 327 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_26IsAlterTableDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 649 | rpc::RpcContext* rpc) { | 104 | 649 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 649 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25CreateNamespaceResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2.08k | rpc::RpcContext* rpc) { | 104 | 2.08k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2.08k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_31IsCreateNamespaceDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2.13k | rpc::RpcContext* rpc) { | 104 | 2.13k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2.13k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25DeleteNamespaceResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1.55k | rpc::RpcContext* rpc) { | 104 | 1.55k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1.55k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_31IsDeleteNamespaceDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1.59k | rpc::RpcContext* rpc) { | 104 | 1.59k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1.59k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24AlterNamespaceResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 4 | rpc::RpcContext* rpc) { | 104 | 4 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 4 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24ListNamespacesResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 4.44k | rpc::RpcContext* rpc) { | 104 | 4.44k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 4.44k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_26GetNamespaceInfoResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1.77k | rpc::RpcContext* rpc) { | 104 | 1.77k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1.77k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_26CreateTablegroupResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 3 | rpc::RpcContext* rpc) { | 104 | 3 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 3 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_26DeleteTablegroupResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2 | rpc::RpcContext* rpc) { | 104 | 2 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25ListTablegroupsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 3 | rpc::RpcContext* rpc) { | 104 | 3 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 3 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_22CreateUDTypeResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 46 | rpc::RpcContext* rpc) { | 104 | 46 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 46 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_22DeleteUDTypeResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 53 | rpc::RpcContext* rpc) { | 104 | 53 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 53 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_21ListUDTypesResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_23GetUDTypeInfoResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 55 | rpc::RpcContext* rpc) { | 104 | 55 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 55 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_30ChangeEncryptionInfoResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 6 | rpc::RpcContext* rpc) { | 104 | 6 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 6 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_29IsEncryptionEnabledResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 6 | rpc::RpcContext* rpc) { | 104 | 6 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 6 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_21TSHeartbeatResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 384k | rpc::RpcContext* rpc) { | 104 | 384k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 384k | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_33ValidateReplicationInfoResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25CreateCDCStreamResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2.69k | rpc::RpcContext* rpc) { | 104 | 2.69k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2.69k | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25DeleteCDCStreamResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2 | rpc::RpcContext* rpc) { | 104 | 2 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24ListCDCStreamsResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 1 | rpc::RpcContext* rpc) { | 104 | 1 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 1 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_22GetCDCStreamResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 6 | rpc::RpcContext* rpc) { | 104 | 6 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 6 | } |
_ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_28GetCDCDBStreamInfoResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 11 | rpc::RpcContext* rpc) { | 104 | 11 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 11 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25UpdateCDCStreamResponsePBEEEbPT_PNS_3rpc10RpcContextE _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_34SetupUniverseReplicationResponsePBEEEbPT_PNS_3rpc10RpcContextE Line | Count | Source | 103 | 2 | rpc::RpcContext* rpc) { | 104 | 2 | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, MasterErrorPB>(resp, rpc); | 105 | 2 | } |
Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_35DeleteUniverseReplicationResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_34AlterUniverseReplicationResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_39SetUniverseReplicationEnabledResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_32GetUniverseReplicationResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_40IsSetupUniverseReplicationDoneResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_39UpdateConsumerOnProducerSplitResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24CreateSnapshotResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_23ListSnapshotsResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_34ListSnapshotRestorationsResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_25RestoreSnapshotResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_24DeleteSnapshotResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_28ImportSnapshotMetaResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_32CreateSnapshotScheduleResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_31ListSnapshotSchedulesResponsePBEEEbPT_PNS_3rpc10RpcContextE Unexecuted instantiation: _ZN2yb6master22ScopedLeaderSharedLock38CheckIsInitializedAndIsLeaderOrRespondINS0_32DeleteSnapshotScheduleResponsePBEEEbPT_PNS_3rpc10RpcContextE |
106 | | |
107 | | // Variation of the above methods using TabletServerErrorPB instead. |
108 | | template<typename RespClass> |
109 | | bool ScopedLeaderSharedLock::CheckIsInitializedOrRespondTServer( |
110 | | RespClass* resp, |
111 | | rpc::RpcContext* rpc, |
112 | 9 | bool set_error) { |
113 | 9 | return CheckIsInitializedOrRespondInternal<RespClass, tserver::TabletServerErrorPB> |
114 | 9 | (resp, rpc, set_error); |
115 | 9 | } |
116 | | |
117 | | template<typename RespClass> |
118 | | bool ScopedLeaderSharedLock::CheckIsInitializedAndIsLeaderOrRespondTServer( |
119 | | RespClass* resp, |
120 | 44.1k | rpc::RpcContext* rpc) { |
121 | 44.1k | return CheckIsInitializedAndIsLeaderOrRespondInternal<RespClass, tserver::TabletServerErrorPB> |
122 | 44.1k | (resp, rpc); |
123 | 44.1k | } |
124 | | |
125 | 49.8k | inline std::string RequestorString(yb::rpc::RpcContext* rpc) { |
126 | 49.8k | if (rpc) { |
127 | 48.9k | return rpc->requestor_string(); |
128 | 943 | } else { |
129 | 943 | return "internal request"; |
130 | 943 | } |
131 | 49.8k | } |
132 | | |
133 | | } // namespace master |
134 | | } // namespace yb |
135 | | |
136 | | #endif // YB_MASTER_SCOPED_LEADER_SHARED_LOCK_INTERNAL_H |