Home
last modified time | relevance | path

Searched refs:wal_additions (Results 1 – 15 of 15) sorted by relevance

/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dversion_set.cc4060 VersionEdit wal_additions; in ProcessManifestWrites() local
4079 wal_additions.AddWal(wal.first, wal.second); in ProcessManifestWrites()
4135 s = WriteCurrentStateToManifest(curr_state, wal_additions, in ProcessManifestWrites()
5033 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s) { in WriteCurrentStateToManifest() argument
5059 if (!wal_additions.GetWalAdditions().empty()) { in WriteCurrentStateToManifest()
5061 const_cast<VersionEdit*>(&wal_additions)); in WriteCurrentStateToManifest()
5063 if (!wal_additions.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5065 wal_additions.DebugString(true)); in WriteCurrentStateToManifest()
H A Dversion_set_test.cc1468 std::vector<WalAddition> wal_additions; in TEST_F() local
1474 wal_additions.push_back(addition); in TEST_F()
1484 ASSERT_EQ(wal_additions.size(), 1); in TEST_F()
1485 ASSERT_EQ(wal_additions[0].GetLogNumber(), kNonClosedLogNumber); in TEST_F()
1486 ASSERT_FALSE(wal_additions[0].GetMetadata().HasSyncedSize()); in TEST_F()
H A Dversion_set.h1327 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s);
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dversion_set.cc4060 VersionEdit wal_additions; in ProcessManifestWrites() local
4079 wal_additions.AddWal(wal.first, wal.second); in ProcessManifestWrites()
4135 s = WriteCurrentStateToManifest(curr_state, wal_additions, in ProcessManifestWrites()
5033 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s) { in WriteCurrentStateToManifest() argument
5059 if (!wal_additions.GetWalAdditions().empty()) { in WriteCurrentStateToManifest()
5061 const_cast<VersionEdit*>(&wal_additions)); in WriteCurrentStateToManifest()
5063 if (!wal_additions.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5065 wal_additions.DebugString(true)); in WriteCurrentStateToManifest()
H A Dversion_set_test.cc1468 std::vector<WalAddition> wal_additions; in TEST_F() local
1474 wal_additions.push_back(addition); in TEST_F()
1484 ASSERT_EQ(wal_additions.size(), 1); in TEST_F()
1485 ASSERT_EQ(wal_additions[0].GetLogNumber(), kNonClosedLogNumber); in TEST_F()
1486 ASSERT_FALSE(wal_additions[0].GetMetadata().HasSyncedSize()); in TEST_F()
H A Dversion_set.h1327 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s);
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dversion_set.cc4060 VersionEdit wal_additions; in ProcessManifestWrites() local
4079 wal_additions.AddWal(wal.first, wal.second); in ProcessManifestWrites()
4135 s = WriteCurrentStateToManifest(curr_state, wal_additions, in ProcessManifestWrites()
5033 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s) { in WriteCurrentStateToManifest() argument
5059 if (!wal_additions.GetWalAdditions().empty()) { in WriteCurrentStateToManifest()
5061 const_cast<VersionEdit*>(&wal_additions)); in WriteCurrentStateToManifest()
5063 if (!wal_additions.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5065 wal_additions.DebugString(true)); in WriteCurrentStateToManifest()
H A Dversion_set_test.cc1468 std::vector<WalAddition> wal_additions; in TEST_F() local
1474 wal_additions.push_back(addition); in TEST_F()
1484 ASSERT_EQ(wal_additions.size(), 1); in TEST_F()
1485 ASSERT_EQ(wal_additions[0].GetLogNumber(), kNonClosedLogNumber); in TEST_F()
1486 ASSERT_FALSE(wal_additions[0].GetMetadata().HasSyncedSize()); in TEST_F()
H A Dversion_set.h1327 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s);
/dports/databases/rocksdb-lite/rocksdb-6.26.1/db/
H A Dversion_set.cc4327 VersionEdit wal_additions; in ProcessManifestWrites() local
4346 wal_additions.AddWal(wal.first, wal.second); in ProcessManifestWrites()
4403 s = WriteCurrentStateToManifest(curr_state, wal_additions, in ProcessManifestWrites()
5309 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s) { in WriteCurrentStateToManifest() argument
5335 if (!wal_additions.GetWalAdditions().empty()) { in WriteCurrentStateToManifest()
5337 const_cast<VersionEdit*>(&wal_additions)); in WriteCurrentStateToManifest()
5339 if (!wal_additions.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5341 wal_additions.DebugString(true)); in WriteCurrentStateToManifest()
H A Dversion_set_test.cc1664 std::vector<WalAddition> wal_additions; in TEST_F() local
1670 wal_additions.push_back(addition); in TEST_F()
1680 ASSERT_EQ(wal_additions.size(), 1); in TEST_F()
1681 ASSERT_EQ(wal_additions[0].GetLogNumber(), kNonClosedLogNumber); in TEST_F()
1682 ASSERT_FALSE(wal_additions[0].GetMetadata().HasSyncedSize()); in TEST_F()
H A Dversion_set.h1349 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s);
/dports/databases/rocksdb/rocksdb-6.26.1/db/
H A Dversion_set.cc4327 VersionEdit wal_additions; in ProcessManifestWrites() local
4346 wal_additions.AddWal(wal.first, wal.second); in ProcessManifestWrites()
4403 s = WriteCurrentStateToManifest(curr_state, wal_additions, in ProcessManifestWrites()
5309 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s) { in WriteCurrentStateToManifest() argument
5335 if (!wal_additions.GetWalAdditions().empty()) { in WriteCurrentStateToManifest()
5337 const_cast<VersionEdit*>(&wal_additions)); in WriteCurrentStateToManifest()
5339 if (!wal_additions.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5341 wal_additions.DebugString(true)); in WriteCurrentStateToManifest()
H A Dversion_set_test.cc1664 std::vector<WalAddition> wal_additions; in TEST_F() local
1670 wal_additions.push_back(addition); in TEST_F()
1680 ASSERT_EQ(wal_additions.size(), 1); in TEST_F()
1681 ASSERT_EQ(wal_additions[0].GetLogNumber(), kNonClosedLogNumber); in TEST_F()
1682 ASSERT_FALSE(wal_additions[0].GetMetadata().HasSyncedSize()); in TEST_F()
H A Dversion_set.h1349 const VersionEdit& wal_additions, log::Writer* log, IOStatus& io_s);