YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

Coverage Report

Created: 2022-03-22 16:43

/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_