/Users/deen/code/yugabyte-db/src/yb/master/sys_catalog-internal.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_INTERNAL_H_ |
15 | | #define YB_MASTER_SYS_CATALOG_INTERNAL_H_ |
16 | | |
17 | | #include "yb/common/ql_expr.h" |
18 | | #include "yb/gutil/strings/substitute.h" |
19 | | #include "yb/master/sys_catalog_writer.h" |
20 | | #include "yb/util/pb_util.h" |
21 | | #include "yb/master/sys_catalog_constants.h" |
22 | | |
23 | | namespace yb { |
24 | | namespace master { |
25 | | |
26 | | class VisitorBase { |
27 | | public: |
28 | 41.3k | VisitorBase() {} |
29 | 41.3k | virtual ~VisitorBase() = default; |
30 | | |
31 | | virtual int entry_type() const = 0; |
32 | | |
33 | | virtual CHECKED_STATUS Visit(Slice id, Slice data) = 0; |
34 | | |
35 | | protected: |
36 | | }; |
37 | | |
38 | | template <class PersistentDataEntryClass> |
39 | | class Visitor : public VisitorBase { |
40 | | public: |
41 | 41.3k | Visitor() {} yb::master::Visitor<yb::master::PersistentRoleInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentSysConfigInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentTableInfo>::Visitor() Line | Count | Source | 41 | 3.76k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentTabletInfo>::Visitor() Line | Count | Source | 41 | 3.76k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentNamespaceInfo>::Visitor() Line | Count | Source | 41 | 3.76k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentUDTypeInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentClusterConfigInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentRedisConfigInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentSnapshotInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentCDCStreamInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
yb::master::Visitor<yb::master::PersistentUniverseReplicationInfo>::Visitor() Line | Count | Source | 41 | 3.75k | Visitor() {} |
|
42 | 41.3k | virtual ~Visitor() = default; yb::master::Visitor<yb::master::PersistentTableInfo>::~Visitor() Line | Count | Source | 42 | 3.76k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentTabletInfo>::~Visitor() Line | Count | Source | 42 | 3.76k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentNamespaceInfo>::~Visitor() Line | Count | Source | 42 | 3.76k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentUDTypeInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentClusterConfigInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentRedisConfigInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentRoleInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentSysConfigInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentSnapshotInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentCDCStreamInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
yb::master::Visitor<yb::master::PersistentUniverseReplicationInfo>::~Visitor() Line | Count | Source | 42 | 3.75k | virtual ~Visitor() = default; |
|
43 | | |
44 | 467k | virtual CHECKED_STATUS Visit(Slice id, Slice data) { |
45 | 467k | typename PersistentDataEntryClass::data_type metadata; |
46 | 467k | RETURN_NOT_OK_PREPEND( |
47 | 467k | pb_util::ParseFromArray(&metadata, data.data(), data.size()), |
48 | 467k | "Unable to parse metadata field for item id: " + id.ToBuffer()); |
49 | | |
50 | 467k | return Visit(id.ToBuffer(), metadata); |
51 | 467k | } yb::master::Visitor<yb::master::PersistentRoleInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 851 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 851 | typename PersistentDataEntryClass::data_type metadata; | 46 | 851 | RETURN_NOT_OK_PREPEND( | 47 | 851 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 851 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 851 | return Visit(id.ToBuffer(), metadata); | 51 | 851 | } |
yb::master::Visitor<yb::master::PersistentSysConfigInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 2.54k | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 2.54k | typename PersistentDataEntryClass::data_type metadata; | 46 | 2.54k | RETURN_NOT_OK_PREPEND( | 47 | 2.54k | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 2.54k | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 2.54k | return Visit(id.ToBuffer(), metadata); | 51 | 2.54k | } |
yb::master::Visitor<yb::master::PersistentTableInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 441k | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 441k | typename PersistentDataEntryClass::data_type metadata; | 46 | 441k | RETURN_NOT_OK_PREPEND( | 47 | 441k | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 441k | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 441k | return Visit(id.ToBuffer(), metadata); | 51 | 441k | } |
yb::master::Visitor<yb::master::PersistentTabletInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 15.6k | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 15.6k | typename PersistentDataEntryClass::data_type metadata; | 46 | 15.6k | RETURN_NOT_OK_PREPEND( | 47 | 15.6k | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 15.6k | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 15.6k | return Visit(id.ToBuffer(), metadata); | 51 | 15.6k | } |
yb::master::Visitor<yb::master::PersistentNamespaceInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 6.43k | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 6.43k | typename PersistentDataEntryClass::data_type metadata; | 46 | 6.43k | RETURN_NOT_OK_PREPEND( | 47 | 6.43k | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 6.43k | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 6.43k | return Visit(id.ToBuffer(), metadata); | 51 | 6.43k | } |
yb::master::Visitor<yb::master::PersistentUDTypeInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 1 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 1 | typename PersistentDataEntryClass::data_type metadata; | 46 | 1 | RETURN_NOT_OK_PREPEND( | 47 | 1 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 1 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 1 | return Visit(id.ToBuffer(), metadata); | 51 | 1 | } |
yb::master::Visitor<yb::master::PersistentClusterConfigInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 850 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 850 | typename PersistentDataEntryClass::data_type metadata; | 46 | 850 | RETURN_NOT_OK_PREPEND( | 47 | 850 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 850 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 850 | return Visit(id.ToBuffer(), metadata); | 51 | 850 | } |
yb::master::Visitor<yb::master::PersistentRedisConfigInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 5 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 5 | typename PersistentDataEntryClass::data_type metadata; | 46 | 5 | RETURN_NOT_OK_PREPEND( | 47 | 5 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 5 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 5 | return Visit(id.ToBuffer(), metadata); | 51 | 5 | } |
yb::master::Visitor<yb::master::PersistentSnapshotInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 8 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 8 | typename PersistentDataEntryClass::data_type metadata; | 46 | 8 | RETURN_NOT_OK_PREPEND( | 47 | 8 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 8 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 8 | return Visit(id.ToBuffer(), metadata); | 51 | 8 | } |
yb::master::Visitor<yb::master::PersistentCDCStreamInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 1 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 1 | typename PersistentDataEntryClass::data_type metadata; | 46 | 1 | RETURN_NOT_OK_PREPEND( | 47 | 1 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 1 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 1 | return Visit(id.ToBuffer(), metadata); | 51 | 1 | } |
yb::master::Visitor<yb::master::PersistentUniverseReplicationInfo>::Visit(yb::Slice, yb::Slice) Line | Count | Source | 44 | 1 | virtual CHECKED_STATUS Visit(Slice id, Slice data) { | 45 | 1 | typename PersistentDataEntryClass::data_type metadata; | 46 | 1 | RETURN_NOT_OK_PREPEND( | 47 | 1 | pb_util::ParseFromArray(&metadata, data.data(), data.size()), | 48 | 1 | "Unable to parse metadata field for item id: " + id.ToBuffer()); | 49 | | | 50 | 1 | return Visit(id.ToBuffer(), metadata); | 51 | 1 | } |
|
52 | | |
53 | 124k | int entry_type() const { return PersistentDataEntryClass::type(); } yb::master::Visitor<yb::master::PersistentRoleInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentSysConfigInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentTableInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentTabletInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentNamespaceInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentUDTypeInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentClusterConfigInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentRedisConfigInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentSnapshotInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentCDCStreamInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
yb::master::Visitor<yb::master::PersistentUniverseReplicationInfo>::entry_type() const Line | Count | Source | 53 | 11.2k | int entry_type() const { return PersistentDataEntryClass::type(); } |
|
54 | | |
55 | | protected: |
56 | | virtual CHECKED_STATUS Visit( |
57 | | const std::string& id, const typename PersistentDataEntryClass::data_type& metadata) = 0; |
58 | | |
59 | | private: |
60 | | DISALLOW_COPY_AND_ASSIGN(Visitor); |
61 | | }; |
62 | | |
63 | | // Template method defintions must go into a header file. |
64 | | template <class... Items> |
65 | 446k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { |
66 | 446k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); |
67 | 446k | } yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TableInfo> const&>(long long, scoped_refptr<yb::master::TableInfo> const&) Line | Count | Source | 65 | 26.7k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 26.7k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 26.7k | } |
yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<yb::master::TabletInfo*, std::__1::allocator<yb::master::TabletInfo*> >&>(long long, std::__1::vector<yb::master::TabletInfo*, std::__1::allocator<yb::master::TabletInfo*> >&) Line | Count | Source | 65 | 240k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 240k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 240k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TableInfo>&>(long long, scoped_refptr<yb::master::TableInfo>&) Line | Count | Source | 65 | 56.4k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 56.4k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 56.4k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TabletInfo> const&>(long long, scoped_refptr<yb::master::TabletInfo> const&) Line | Count | Source | 65 | 4.34k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 4.34k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 4.34k | } |
yb::Status yb::master::SysCatalogTable::Upsert<yb::master::ClusterConfigInfo*>(long long, yb::master::ClusterConfigInfo*&&) Line | Count | Source | 65 | 3.09k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 3.09k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 3.09k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::SysConfigInfo>&>(long long, scoped_refptr<yb::master::SysConfigInfo>&) Line | Count | Source | 65 | 16.6k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 16.6k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 16.6k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TabletInfo>&>(long long, scoped_refptr<yb::master::TabletInfo>&) Line | Count | Source | 65 | 15.7k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 15.7k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 15.7k | } |
yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&>(long long, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&) Line | Count | Source | 65 | 34.5k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 34.5k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 34.5k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::NamespaceInfo>&>(long long, scoped_refptr<yb::master::NamespaceInfo>&) Line | Count | Source | 65 | 12.8k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 12.8k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 12.8k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TableInfo>&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&>(long long, scoped_refptr<yb::master::TableInfo>&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&) Line | Count | Source | 65 | 8.42k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 8.42k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 8.42k | } |
yb::Status yb::master::SysCatalogTable::Upsert<yb::master::DdlLogEntry*, scoped_refptr<yb::master::TableInfo>&>(long long, yb::master::DdlLogEntry*&&, scoped_refptr<yb::master::TableInfo>&) Line | Count | Source | 65 | 5.88k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 5.88k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 5.88k | } |
yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<yb::master::TableInfo*, std::__1::allocator<yb::master::TableInfo*> >&>(long long, std::__1::vector<yb::master::TableInfo*, std::__1::allocator<yb::master::TableInfo*> >&) Line | Count | Source | 65 | 182 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 182 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 182 | } |
yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<yb::master::DdlLogEntry const*, std::__1::allocator<yb::master::DdlLogEntry const*> >&, scoped_refptr<yb::master::TableInfo>&>(long long, std::__1::vector<yb::master::DdlLogEntry const*, std::__1::allocator<yb::master::DdlLogEntry const*> >&, scoped_refptr<yb::master::TableInfo>&) Line | Count | Source | 65 | 5.89k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 5.89k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 5.89k | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TableInfo>&, scoped_refptr<yb::master::TabletInfo>&, yb::master::TabletInfo*&>(long long, scoped_refptr<yb::master::TableInfo>&, scoped_refptr<yb::master::TabletInfo>&, yb::master::TabletInfo*&) Line | Count | Source | 65 | 88 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 88 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 88 | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::RedisConfigInfo>&>(long long, scoped_refptr<yb::master::RedisConfigInfo>&) Line | Count | Source | 65 | 185 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 185 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 185 | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::UDTypeInfo>&>(long long, scoped_refptr<yb::master::UDTypeInfo>&) Line | Count | Source | 65 | 47 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 47 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 47 | } |
yb::Status yb::master::SysCatalogTable::Upsert<yb::master::TableInfo*>(long long, yb::master::TableInfo*&&) Line | Count | Source | 65 | 390 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 390 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 390 | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::RoleInfo>&>(long long, scoped_refptr<yb::master::RoleInfo>&) Line | Count | Source | 65 | 5.63k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 5.63k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 5.63k | } |
yb::Status yb::master::SysCatalogTable::Upsert<yb::master::SysConfigInfo*&>(long long, yb::master::SysConfigInfo*&) Line | Count | Source | 65 | 2.90k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 2.90k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 2.90k | } |
Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::SnapshotInfo>&>(long long, scoped_refptr<yb::master::SnapshotInfo>&) Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::TableInfo> const&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&>(long long, scoped_refptr<yb::master::TableInfo> const&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&) Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<scoped_refptr<yb::master::TableInfo>, std::__1::allocator<scoped_refptr<yb::master::TableInfo> > >&>(long long, std::__1::vector<scoped_refptr<yb::master::TableInfo>, std::__1::allocator<scoped_refptr<yb::master::TableInfo> > >&) yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::CDCStreamInfo>&>(long long, scoped_refptr<yb::master::CDCStreamInfo>&) Line | Count | Source | 65 | 5.50k | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 5.50k | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 5.50k | } |
yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<yb::master::CDCStreamInfo*, std::__1::allocator<yb::master::CDCStreamInfo*> >&>(long long, std::__1::vector<yb::master::CDCStreamInfo*, std::__1::allocator<yb::master::CDCStreamInfo*> >&) Line | Count | Source | 65 | 64 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 64 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 64 | } |
yb::Status yb::master::SysCatalogTable::Upsert<scoped_refptr<yb::master::UniverseReplicationInfo>&>(long long, scoped_refptr<yb::master::UniverseReplicationInfo>&) Line | Count | Source | 65 | 3 | CHECKED_STATUS SysCatalogTable::Upsert(int64_t leader_term, Items&&... items) { | 66 | 3 | return Mutate(QLWriteRequestPB::QL_STMT_UPDATE, leader_term, std::forward<Items>(items)...); | 67 | 3 | } |
Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Upsert<std::__1::vector<yb::master::UniverseReplicationInfo*, std::__1::allocator<yb::master::UniverseReplicationInfo*> >&>(long long, std::__1::vector<yb::master::UniverseReplicationInfo*, std::__1::allocator<yb::master::UniverseReplicationInfo*> >&) |
68 | | |
69 | | template <class... Items> |
70 | 2.37k | CHECKED_STATUS SysCatalogTable::Delete(int64_t leader_term, Items&&... items) { |
71 | 2.37k | return Mutate(QLWriteRequestPB::QL_STMT_DELETE, leader_term, std::forward<Items>(items)...); |
72 | 2.37k | } yb::Status yb::master::SysCatalogTable::Delete<scoped_refptr<yb::master::NamespaceInfo>&>(long long, scoped_refptr<yb::master::NamespaceInfo>&) Line | Count | Source | 70 | 1.54k | CHECKED_STATUS SysCatalogTable::Delete(int64_t leader_term, Items&&... items) { | 71 | 1.54k | return Mutate(QLWriteRequestPB::QL_STMT_DELETE, leader_term, std::forward<Items>(items)...); | 72 | 1.54k | } |
yb::Status yb::master::SysCatalogTable::Delete<scoped_refptr<yb::master::UDTypeInfo>&>(long long, scoped_refptr<yb::master::UDTypeInfo>&) Line | Count | Source | 70 | 47 | CHECKED_STATUS SysCatalogTable::Delete(int64_t leader_term, Items&&... items) { | 71 | 47 | return Mutate(QLWriteRequestPB::QL_STMT_DELETE, leader_term, std::forward<Items>(items)...); | 72 | 47 | } |
yb::Status yb::master::SysCatalogTable::Delete<scoped_refptr<yb::master::RoleInfo>&>(long long, scoped_refptr<yb::master::RoleInfo>&) Line | Count | Source | 70 | 725 | CHECKED_STATUS SysCatalogTable::Delete(int64_t leader_term, Items&&... items) { | 71 | 725 | return Mutate(QLWriteRequestPB::QL_STMT_DELETE, leader_term, std::forward<Items>(items)...); | 72 | 725 | } |
Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Delete<scoped_refptr<yb::master::SnapshotInfo>&>(long long, scoped_refptr<yb::master::SnapshotInfo>&) yb::Status yb::master::SysCatalogTable::Delete<std::__1::vector<yb::master::CDCStreamInfo*, std::__1::allocator<yb::master::CDCStreamInfo*> >&>(long long, std::__1::vector<yb::master::CDCStreamInfo*, std::__1::allocator<yb::master::CDCStreamInfo*> >&) Line | Count | Source | 70 | 63 | CHECKED_STATUS SysCatalogTable::Delete(int64_t leader_term, Items&&... items) { | 71 | 63 | return Mutate(QLWriteRequestPB::QL_STMT_DELETE, leader_term, std::forward<Items>(items)...); | 72 | 63 | } |
yb::Status yb::master::SysCatalogTable::Delete<scoped_refptr<yb::master::UniverseReplicationInfo>&>(long long, scoped_refptr<yb::master::UniverseReplicationInfo>&) Line | Count | Source | 70 | 1 | CHECKED_STATUS SysCatalogTable::Delete(int64_t leader_term, Items&&... items) { | 71 | 1 | return Mutate(QLWriteRequestPB::QL_STMT_DELETE, leader_term, std::forward<Items>(items)...); | 72 | 1 | } |
|
73 | | |
74 | | template <class... Items> |
75 | | CHECKED_STATUS SysCatalogTable::Mutate( |
76 | 448k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { |
77 | 448k | auto w = NewWriter(leader_term); |
78 | 448k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); |
79 | 448k | return SyncWrite(w.get()); |
80 | 448k | } yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TableInfo> const&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TableInfo> const&) Line | Count | Source | 76 | 26.7k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 26.7k | auto w = NewWriter(leader_term); | 78 | 26.7k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 26.7k | return SyncWrite(w.get()); | 80 | 26.7k | } |
yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<yb::master::TabletInfo*, std::__1::allocator<yb::master::TabletInfo*> >&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<yb::master::TabletInfo*, std::__1::allocator<yb::master::TabletInfo*> >&) Line | Count | Source | 76 | 240k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 240k | auto w = NewWriter(leader_term); | 78 | 240k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 240k | return SyncWrite(w.get()); | 80 | 240k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TableInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TableInfo>&) Line | Count | Source | 76 | 56.4k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 56.4k | auto w = NewWriter(leader_term); | 78 | 56.4k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 56.4k | return SyncWrite(w.get()); | 80 | 56.4k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TabletInfo> const&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TabletInfo> const&) Line | Count | Source | 76 | 4.34k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 4.34k | auto w = NewWriter(leader_term); | 78 | 4.34k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 4.34k | return SyncWrite(w.get()); | 80 | 4.34k | } |
yb::Status yb::master::SysCatalogTable::Mutate<yb::master::ClusterConfigInfo*>(yb::QLWriteRequestPB_QLStmtType, long long, yb::master::ClusterConfigInfo*&&) Line | Count | Source | 76 | 3.09k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 3.09k | auto w = NewWriter(leader_term); | 78 | 3.09k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 3.09k | return SyncWrite(w.get()); | 80 | 3.09k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::SysConfigInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::SysConfigInfo>&) Line | Count | Source | 76 | 16.6k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 16.6k | auto w = NewWriter(leader_term); | 78 | 16.6k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 16.6k | return SyncWrite(w.get()); | 80 | 16.6k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TabletInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TabletInfo>&) Line | Count | Source | 76 | 15.7k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 15.7k | auto w = NewWriter(leader_term); | 78 | 15.7k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 15.7k | return SyncWrite(w.get()); | 80 | 15.7k | } |
yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&) Line | Count | Source | 76 | 34.5k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 34.5k | auto w = NewWriter(leader_term); | 78 | 34.5k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 34.5k | return SyncWrite(w.get()); | 80 | 34.5k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::NamespaceInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::NamespaceInfo>&) Line | Count | Source | 76 | 14.4k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 14.4k | auto w = NewWriter(leader_term); | 78 | 14.4k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 14.4k | return SyncWrite(w.get()); | 80 | 14.4k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TableInfo>&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TableInfo>&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&) Line | Count | Source | 76 | 8.42k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 8.42k | auto w = NewWriter(leader_term); | 78 | 8.42k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 8.42k | return SyncWrite(w.get()); | 80 | 8.42k | } |
yb::Status yb::master::SysCatalogTable::Mutate<yb::master::DdlLogEntry*, scoped_refptr<yb::master::TableInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, yb::master::DdlLogEntry*&&, scoped_refptr<yb::master::TableInfo>&) Line | Count | Source | 76 | 5.88k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 5.88k | auto w = NewWriter(leader_term); | 78 | 5.88k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 5.88k | return SyncWrite(w.get()); | 80 | 5.88k | } |
yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<yb::master::TableInfo*, std::__1::allocator<yb::master::TableInfo*> >&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<yb::master::TableInfo*, std::__1::allocator<yb::master::TableInfo*> >&) Line | Count | Source | 76 | 182 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 182 | auto w = NewWriter(leader_term); | 78 | 182 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 182 | return SyncWrite(w.get()); | 80 | 182 | } |
yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<yb::master::DdlLogEntry const*, std::__1::allocator<yb::master::DdlLogEntry const*> >&, scoped_refptr<yb::master::TableInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<yb::master::DdlLogEntry const*, std::__1::allocator<yb::master::DdlLogEntry const*> >&, scoped_refptr<yb::master::TableInfo>&) Line | Count | Source | 76 | 5.89k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 5.89k | auto w = NewWriter(leader_term); | 78 | 5.89k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 5.89k | return SyncWrite(w.get()); | 80 | 5.89k | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TableInfo>&, scoped_refptr<yb::master::TabletInfo>&, yb::master::TabletInfo*&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TableInfo>&, scoped_refptr<yb::master::TabletInfo>&, yb::master::TabletInfo*&) Line | Count | Source | 76 | 88 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 88 | auto w = NewWriter(leader_term); | 78 | 88 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 88 | return SyncWrite(w.get()); | 80 | 88 | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::RedisConfigInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::RedisConfigInfo>&) Line | Count | Source | 76 | 187 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 187 | auto w = NewWriter(leader_term); | 78 | 187 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 187 | return SyncWrite(w.get()); | 80 | 187 | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::UDTypeInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::UDTypeInfo>&) Line | Count | Source | 76 | 94 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 94 | auto w = NewWriter(leader_term); | 78 | 94 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 94 | return SyncWrite(w.get()); | 80 | 94 | } |
yb::Status yb::master::SysCatalogTable::Mutate<yb::master::TableInfo*>(yb::QLWriteRequestPB_QLStmtType, long long, yb::master::TableInfo*&&) Line | Count | Source | 76 | 390 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 390 | auto w = NewWriter(leader_term); | 78 | 390 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 390 | return SyncWrite(w.get()); | 80 | 390 | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::RoleInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::RoleInfo>&) Line | Count | Source | 76 | 6.36k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 6.36k | auto w = NewWriter(leader_term); | 78 | 6.36k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 6.36k | return SyncWrite(w.get()); | 80 | 6.36k | } |
yb::Status yb::master::SysCatalogTable::Mutate<yb::master::SysConfigInfo*&>(yb::QLWriteRequestPB_QLStmtType, long long, yb::master::SysConfigInfo*&) Line | Count | Source | 76 | 2.90k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 2.90k | auto w = NewWriter(leader_term); | 78 | 2.90k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 2.90k | return SyncWrite(w.get()); | 80 | 2.90k | } |
Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::SnapshotInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::SnapshotInfo>&) Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::TableInfo> const&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::TableInfo> const&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&, std::__1::vector<scoped_refptr<yb::master::TabletInfo>, std::__1::allocator<scoped_refptr<yb::master::TabletInfo> > >&) Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<scoped_refptr<yb::master::TableInfo>, std::__1::allocator<scoped_refptr<yb::master::TableInfo> > >&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<scoped_refptr<yb::master::TableInfo>, std::__1::allocator<scoped_refptr<yb::master::TableInfo> > >&) yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::CDCStreamInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::CDCStreamInfo>&) Line | Count | Source | 76 | 5.50k | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 5.50k | auto w = NewWriter(leader_term); | 78 | 5.50k | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 5.50k | return SyncWrite(w.get()); | 80 | 5.50k | } |
yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<yb::master::CDCStreamInfo*, std::__1::allocator<yb::master::CDCStreamInfo*> >&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<yb::master::CDCStreamInfo*, std::__1::allocator<yb::master::CDCStreamInfo*> >&) Line | Count | Source | 76 | 127 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 127 | auto w = NewWriter(leader_term); | 78 | 127 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 127 | return SyncWrite(w.get()); | 80 | 127 | } |
yb::Status yb::master::SysCatalogTable::Mutate<scoped_refptr<yb::master::UniverseReplicationInfo>&>(yb::QLWriteRequestPB_QLStmtType, long long, scoped_refptr<yb::master::UniverseReplicationInfo>&) Line | Count | Source | 76 | 4 | QLWriteRequestPB::QLStmtType op_type, int64_t leader_term, Items&&... items) { | 77 | 4 | auto w = NewWriter(leader_term); | 78 | 4 | RETURN_NOT_OK(w->Mutate(op_type, std::forward<Items>(items)...)); | 79 | 4 | return SyncWrite(w.get()); | 80 | 4 | } |
Unexecuted instantiation: yb::Status yb::master::SysCatalogTable::Mutate<std::__1::vector<yb::master::UniverseReplicationInfo*, std::__1::allocator<yb::master::UniverseReplicationInfo*> >&>(yb::QLWriteRequestPB_QLStmtType, long long, std::__1::vector<yb::master::UniverseReplicationInfo*, std::__1::allocator<yb::master::UniverseReplicationInfo*> >&) |
81 | | |
82 | 450k | std::unique_ptr<SysCatalogWriter> SysCatalogTable::NewWriter(int64_t leader_term) { |
83 | 450k | return std::make_unique<SysCatalogWriter>(*schema_, leader_term); |
84 | 450k | } |
85 | | |
86 | | } // namespace master |
87 | | } // namespace yb |
88 | | |
89 | | #endif // YB_MASTER_SYS_CATALOG_INTERNAL_H_ |