/Users/deen/code/yugabyte-db/src/yb/master/sys_catalog_writer.h
Line | Count | Source |
1 | | // Copyright (c) YugaByte, Inc. |
2 | | // |
3 | | // Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except |
4 | | // in compliance with the License. You may obtain a copy of the License at |
5 | | // |
6 | | // http://www.apache.org/licenses/LICENSE-2.0 |
7 | | // |
8 | | // Unless required by applicable law or agreed to in writing, software distributed under the License |
9 | | // is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express |
10 | | // or implied. See the License for the specific language governing permissions and limitations |
11 | | // under the License. |
12 | | // |
13 | | |
14 | | #ifndef YB_MASTER_SYS_CATALOG_WRITER_H |
15 | | #define YB_MASTER_SYS_CATALOG_WRITER_H |
16 | | |
17 | | #include <set> |
18 | | #include <utility> |
19 | | |
20 | | #include "yb/common/common_fwd.h" |
21 | | #include "yb/common/entity_ids_types.h" |
22 | | #include "yb/common/ql_protocol.pb.h" |
23 | | |
24 | | #include "yb/docdb/docdb_fwd.h" |
25 | | |
26 | | #include "yb/tablet/tablet_fwd.h" |
27 | | |
28 | | #include "yb/tserver/tserver_fwd.h" |
29 | | |
30 | | #include "yb/util/status.h" |
31 | | #include "yb/util/type_traits.h" |
32 | | |
33 | | namespace yb { |
34 | | namespace master { |
35 | | |
36 | | bool IsWrite(QLWriteRequestPB::QLStmtType op_type); |
37 | | |
38 | | class SysCatalogWriter { |
39 | | public: |
40 | | SysCatalogWriter(const Schema& schema_with_ids, int64_t leader_term); |
41 | | |
42 | | ~SysCatalogWriter(); |
43 | | |
44 | 261k | CHECKED_STATUS Mutate(QLWriteRequestPB::QLStmtType op_type) { |
45 | 261k | return Status::OK(); |
46 | 261k | } |
47 | | |
48 | | template <class Item, class... Items> |
49 | | CHECKED_STATUS Mutate( |
50 | 271k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { |
51 | 271k | RETURN_NOT_OK(MutateHelper(item, op_type)); |
52 | 271k | return Mutate(op_type, std::forward<Items>(items)...); |
53 | 271k | } _ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_9TableInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 50.5k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 50.5k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 50.5k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 50.5k | } |
_ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorIPNS0_10TabletInfoENS3_9allocatorIS6_EEEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 138k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 138k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 138k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 138k | } |
_ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorIPNS0_10TabletInfoENS3_9allocatorIS6_EEEEJRS9_EEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 1 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 1 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 1 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 1 | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_17ClusterConfigInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 2.06k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 2.06k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 2.06k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 2.06k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_13NamespaceInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 10.9k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 10.9k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 10.9k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 10.9k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_15RedisConfigInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 5 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 5 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 5 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 5 | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_13SysConfigInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 12.7k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 12.7k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 12.7k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 12.7k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_8RoleInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 5.79k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 5.79k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 5.79k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 5.79k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_10UDTypeInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 92 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 92 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 92 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 92 | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_13CDCStreamInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 2.69k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 2.69k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 2.69k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 2.69k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_23UniverseReplicationInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 4 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 4 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 4 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 4 | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_10TabletInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 6.62k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 6.62k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 6.62k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 6.62k | } |
_ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorI13scoped_refptrINS0_10TabletInfoEENS3_9allocatorIS7_EEEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 29.4k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 29.4k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 29.4k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 29.4k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_9TableInfoEEJRNSt3__16vectorIS3_INS0_10TabletInfoEENS6_9allocatorIS9_EEEEEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 4.00k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 4.00k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 4.00k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 4.00k | } |
_ZN2yb6master16SysCatalogWriter6MutateIPNS0_11DdlLogEntryEJR13scoped_refptrINS0_9TableInfoEEEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 2.76k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 2.76k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 2.76k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 2.76k | } |
_ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorIPNS0_9TableInfoENS3_9allocatorIS6_EEEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 76 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 76 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 76 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 76 | } |
_ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorIPKNS0_11DdlLogEntryENS3_9allocatorIS7_EEEEJR13scoped_refptrINS0_9TableInfoEEEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 2.86k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 2.86k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 2.86k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 2.86k | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_9TableInfoEEJRS3_INS0_10TabletInfoEERPS6_EEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 36 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 36 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 36 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 36 | } |
_ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_10TabletInfoEEJRPS4_EEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 36 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 36 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 36 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 36 | } |
_ZN2yb6master16SysCatalogWriter6MutateIPNS0_10TabletInfoEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 36 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 36 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 36 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 36 | } |
_ZN2yb6master16SysCatalogWriter6MutateIPNS0_9TableInfoEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 111 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 111 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 111 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 111 | } |
_ZN2yb6master16SysCatalogWriter6MutateIPNS0_13SysConfigInfoEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 1.94k | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 1.94k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 1.94k | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 1.94k | } |
Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_12SnapshotInfoEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateI13scoped_refptrINS0_9TableInfoEEJRNSt3__16vectorIS3_INS0_10TabletInfoEENS6_9allocatorIS9_EEEESD_EEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorI13scoped_refptrINS0_10TabletInfoEENS3_9allocatorIS7_EEEEJRSA_EEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorI13scoped_refptrINS0_9TableInfoEENS3_9allocatorIS7_EEEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ _ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorIPNS0_13CDCStreamInfoENS3_9allocatorIS6_EEEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Line | Count | Source | 50 | 2 | QLWriteRequestPB::QLStmtType op_type, const Item& item, Items&&... items) { | 51 | 2 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 52 | 2 | return Mutate(op_type, std::forward<Items>(items)...); | 53 | 2 | } |
Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateINSt3__16vectorIPNS0_23UniverseReplicationInfoENS3_9allocatorIS6_EEEEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateIPNS0_23UniverseReplicationInfoEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateIPNS0_23UniverseReplicationInfoEJPNS0_17ClusterConfigInfoEEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter6MutateIPNS0_17ClusterConfigInfoEJEEENS_6StatusENS_27QLWriteRequestPB_QLStmtTypeERKT_DpOT0_ |
54 | | |
55 | | // Insert a row into a Postgres sys catalog table. |
56 | | CHECKED_STATUS InsertPgsqlTableRow(const Schema& source_schema, |
57 | | const QLTableRow& source_row, |
58 | | const TableId& target_table_id, |
59 | | const Schema& target_schema, |
60 | | const uint32_t target_schema_version, |
61 | | bool is_upsert); |
62 | | |
63 | 532k | tserver::WriteRequestPB& req() { |
64 | 532k | return *req_; |
65 | 532k | } |
66 | | |
67 | 164k | int64_t leader_term() const { |
68 | 164k | return leader_term_; |
69 | 164k | } |
70 | | |
71 | | private: |
72 | | template <class Item> |
73 | 336k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { |
74 | 336k | const auto& old_pb = item->old_pb(); |
75 | 334k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; |
76 | 336k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); |
77 | 336k | } _ZN2yb6master16SysCatalogWriter12MutateHelperINS0_9TableInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 59.2k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 59.2k | const auto& old_pb = item->old_pb(); | 75 | 18.4E | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 59.2k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 59.2k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_10TabletInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 238k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 238k | const auto& old_pb = item->old_pb(); | 75 | 238k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 238k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 238k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_17ClusterConfigInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 2.06k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 2.06k | const auto& old_pb = item->old_pb(); | 75 | 2.06k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 2.06k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 2.06k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_13NamespaceInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 10.9k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 10.9k | const auto& old_pb = item->old_pb(); | 75 | 9.40k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 10.9k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 10.9k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_15RedisConfigInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 5 | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 5 | const auto& old_pb = item->old_pb(); | 75 | 3 | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 5 | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 5 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_13SysConfigInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 14.7k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 14.7k | const auto& old_pb = item->old_pb(); | 75 | 14.7k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 14.7k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 14.7k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_8RoleInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 5.79k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 5.79k | const auto& old_pb = item->old_pb(); | 75 | 5.06k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 5.79k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 5.79k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_10UDTypeInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 92 | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 92 | const auto& old_pb = item->old_pb(); | 75 | 46 | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 92 | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 92 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_13CDCStreamInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 2.69k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 2.69k | const auto& old_pb = item->old_pb(); | 75 | 2.69k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 2.69k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 2.69k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_23UniverseReplicationInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 4 | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 4 | const auto& old_pb = item->old_pb(); | 75 | 3 | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 4 | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 4 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_11DdlLogEntryEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 73 | 3.04k | CHECKED_STATUS MutateHelper(const Item* item, QLWriteRequestPB::QLStmtType op_type) { | 74 | 3.04k | const auto& old_pb = item->old_pb(); | 75 | 3.04k | const auto& new_pb = IsWrite(op_type) ? item->new_pb() : old_pb; | 76 | 3.04k | return DoMutateItem(Item::type(), item->id(), old_pb, new_pb, op_type); | 77 | 3.04k | } |
Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter12MutateHelperINS0_12SnapshotInfoEEENS_6StatusEPKT_NS_27QLWriteRequestPB_QLStmtTypeE |
78 | | |
79 | | |
80 | | template <class Item> |
81 | | CHECKED_STATUS MutateHelper(const scoped_refptr<Item>& item, |
82 | 149k | QLWriteRequestPB::QLStmtType op_type) { |
83 | 149k | return MutateHelper(item.get(), op_type); |
84 | 149k | } _ZN2yb6master16SysCatalogWriter12MutateHelperINS0_9TableInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 54.5k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 54.5k | return MutateHelper(item.get(), op_type); | 84 | 54.5k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_17ClusterConfigInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 2.06k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 2.06k | return MutateHelper(item.get(), op_type); | 84 | 2.06k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_13NamespaceInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 10.9k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 10.9k | return MutateHelper(item.get(), op_type); | 84 | 10.9k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_15RedisConfigInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 5 | QLWriteRequestPB::QLStmtType op_type) { | 83 | 5 | return MutateHelper(item.get(), op_type); | 84 | 5 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_13SysConfigInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 12.7k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 12.7k | return MutateHelper(item.get(), op_type); | 84 | 12.7k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_8RoleInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 5.79k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 5.79k | return MutateHelper(item.get(), op_type); | 84 | 5.79k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_10UDTypeInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 92 | QLWriteRequestPB::QLStmtType op_type) { | 83 | 92 | return MutateHelper(item.get(), op_type); | 84 | 92 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_13CDCStreamInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 2.69k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 2.69k | return MutateHelper(item.get(), op_type); | 84 | 2.69k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_23UniverseReplicationInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 4 | QLWriteRequestPB::QLStmtType op_type) { | 83 | 4 | return MutateHelper(item.get(), op_type); | 84 | 4 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINS0_10TabletInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 82 | 60.4k | QLWriteRequestPB::QLStmtType op_type) { | 83 | 60.4k | return MutateHelper(item.get(), op_type); | 84 | 60.4k | } |
Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter12MutateHelperINS0_12SnapshotInfoEEENS_6StatusERK13scoped_refptrIT_ENS_27QLWriteRequestPB_QLStmtTypeE |
85 | | |
86 | | template <class Items> |
87 | | typename std::enable_if<IsCollection<Items>::value, Status>::type |
88 | | MutateHelper(const Items& items, |
89 | 170k | QLWriteRequestPB::QLStmtType op_type) { |
90 | 236k | for (const auto& item : items) { |
91 | 236k | RETURN_NOT_OK(MutateHelper(item, op_type)); |
92 | 236k | } |
93 | 170k | return Status::OK(); |
94 | 170k | } _ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorIPNS0_10TabletInfoENS3_9allocatorIS6_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSB_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 89 | 138k | QLWriteRequestPB::QLStmtType op_type) { | 90 | 177k | for (const auto& item : items) { | 91 | 177k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 92 | 177k | } | 93 | 138k | return Status::OK(); | 94 | 138k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorI13scoped_refptrINS0_10TabletInfoEENS3_9allocatorIS7_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSC_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 89 | 29.4k | QLWriteRequestPB::QLStmtType op_type) { | 90 | 53.7k | for (const auto& item : items) { | 91 | 53.7k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 92 | 53.7k | } | 93 | 29.4k | return Status::OK(); | 94 | 29.4k | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorIPNS0_9TableInfoENS3_9allocatorIS6_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSB_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 89 | 76 | QLWriteRequestPB::QLStmtType op_type) { | 90 | 4.59k | for (const auto& item : items) { | 91 | 4.59k | RETURN_NOT_OK(MutateHelper(item, op_type)); | 92 | 4.59k | } | 93 | 76 | return Status::OK(); | 94 | 76 | } |
_ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorIPKNS0_11DdlLogEntryENS3_9allocatorIS7_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSC_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 89 | 2.86k | QLWriteRequestPB::QLStmtType op_type) { | 90 | 284 | for (const auto& item : items) { | 91 | 284 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 92 | 284 | } | 93 | 2.86k | return Status::OK(); | 94 | 2.86k | } |
Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorI13scoped_refptrINS0_9TableInfoEENS3_9allocatorIS7_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSC_NS_27QLWriteRequestPB_QLStmtTypeE _ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorIPNS0_13CDCStreamInfoENS3_9allocatorIS6_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSB_NS_27QLWriteRequestPB_QLStmtTypeE Line | Count | Source | 89 | 2 | QLWriteRequestPB::QLStmtType op_type) { | 90 | 2 | for (const auto& item : items) { | 91 | 2 | RETURN_NOT_OK(MutateHelper(item, op_type)); | 92 | 2 | } | 93 | 2 | return Status::OK(); | 94 | 2 | } |
Unexecuted instantiation: _ZN2yb6master16SysCatalogWriter12MutateHelperINSt3__16vectorIPNS0_23UniverseReplicationInfoENS3_9allocatorIS6_EEEEEENS3_9enable_ifIXsr12IsCollectionIT_EE5valueENS_6StatusEE4typeERKSB_NS_27QLWriteRequestPB_QLStmtTypeE |
95 | | |
96 | | CHECKED_STATUS DoMutateItem( |
97 | | int8_t type, |
98 | | const std::string& item_id, |
99 | | const google::protobuf::Message& prev_pb, |
100 | | const google::protobuf::Message& new_pb, |
101 | | QLWriteRequestPB::QLStmtType op_type); |
102 | | |
103 | | const Schema& schema_with_ids_; |
104 | | std::unique_ptr<tserver::WriteRequestPB> req_; |
105 | | const int64_t leader_term_; |
106 | | |
107 | | DISALLOW_COPY_AND_ASSIGN(SysCatalogWriter); |
108 | | }; |
109 | | |
110 | | CHECKED_STATUS FillSysCatalogWriteRequest( |
111 | | int8_t type, const std::string& item_id, const google::protobuf::Message& new_pb, |
112 | | QLWriteRequestPB::QLStmtType op_type, const Schema& schema_with_ids, QLWriteRequestPB* req); |
113 | | |
114 | | CHECKED_STATUS FillSysCatalogWriteRequest( |
115 | | int8_t type, const std::string& item_id, const Slice& data, |
116 | | QLWriteRequestPB::QLStmtType op_type, const Schema& schema_with_ids, QLWriteRequestPB* req); |
117 | | |
118 | | using EnumerationCallback = std::function<Status(const Slice& id, const Slice& data)>; |
119 | | |
120 | | // Enumerate sys catalog calling provided callback for all entries of the specified type in sys |
121 | | // catalog. |
122 | | CHECKED_STATUS EnumerateSysCatalog( |
123 | | tablet::Tablet* tablet, const Schema& schema, int8_t entry_type, |
124 | | const EnumerationCallback& callback); |
125 | | CHECKED_STATUS EnumerateSysCatalog( |
126 | | docdb::DocRowwiseIterator* doc_iter, const Schema& schema, int8_t entry_type, |
127 | | const EnumerationCallback& callback); |
128 | | |
129 | | } // namespace master |
130 | | } // namespace yb |
131 | | |
132 | | #endif // YB_MASTER_SYS_CATALOG_WRITER_H |