thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-01 20:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix unit tests in debug mode

Browse Source
This commit is contained in:
Antonio Andelic 2022-07-12 07:52:50 +00:00
parent ee4828b084
commit c296e84cab
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Coordination/tests/gtest_coordination.cpp
View File

@ -1064,6 +1064,13 @@ void addNode(DB::KeeperStorage & storage, const std::string & path, const std::s
node.setData(data); node.setData(data);
node.stat.ephemeralOwner = ephemeral_owner; node.stat.ephemeralOwner = ephemeral_owner;
storage.container.insertOrReplace(path, node); storage.container.insertOrReplace(path, node);
auto child_it = storage.container.find(path);
auto child_path = DB::getBaseName(child_it->key);
storage.container.updateValue(DB::parentPath(StringRef{path}), [&](auto & parent)
{
parent.addChild(child_path);
parent.stat.numChildren++;
});
} }
TEST_P(CoordinationTest, TestStorageSnapshotSimple) TEST_P(CoordinationTest, TestStorageSnapshotSimple)
@ -1221,7 +1228,7 @@ TEST_P(CoordinationTest, TestStorageSnapshotMode)
storage.container.erase("/hello_" + std::to_string(i)); storage.container.erase("/hello_" + std::to_string(i));
} }
EXPECT_EQ(storage.container.size(), 26); EXPECT_EQ(storage.container.size(), 26);
EXPECT_EQ(storage.container.snapshotSizeWithVersion().first, 101); EXPECT_EQ(storage.container.snapshotSizeWithVersion().first, 102);
EXPECT_EQ(storage.container.snapshotSizeWithVersion().second, 1); EXPECT_EQ(storage.container.snapshotSizeWithVersion().second, 1);
auto buf = manager.serializeSnapshotToBuffer(snapshot); auto buf = manager.serializeSnapshotToBuffer(snapshot);
manager.serializeSnapshotBufferToDisk(*buf, 50); manager.serializeSnapshotBufferToDisk(*buf, 50);
@ -1776,6 +1783,7 @@ TEST_P(CoordinationTest, TestStorageSnapshotEqual)
DB::KeeperSnapshotManager manager("./snapshots", 3, params.enable_compression); DB::KeeperSnapshotManager manager("./snapshots", 3, params.enable_compression);
DB::KeeperStorage storage(500, "", true); DB::KeeperStorage storage(500, "", true);
addNode(storage, "/hello", "");
for (size_t j = 0; j < 5000; ++j) for (size_t j = 0; j < 5000; ++j)
{ {
addNode(storage, "/hello_" + std::to_string(j), "world", 1); addNode(storage, "/hello_" + std::to_string(j), "world", 1);