YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

Coverage Report

Created: 2022-03-09 17:30

/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