tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix CommitLog namespace in storage v2

Browse Source 
Reviewers: mtomic

Reviewed By: mtomic

Subscribers: pullbot

Differential Revision: https://phabricator.memgraph.io/D2179
This commit is contained in:
Matej Ferencevic 2019-07-05 12:47:46 +02:00
parent 26f14443c2
commit 069000a92a
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/v2/commit_log.hpp
View File

@ -7,6 +7,8 @@
#include "utils/memory.hpp" #include "utils/memory.hpp"
#include "utils/spin_lock.hpp" #include "utils/spin_lock.hpp"
namespace storage {
/// This class keeps track of finalized transactions to provide info on the /// This class keeps track of finalized transactions to provide info on the
/// oldest active transaction (minimal transaction ID which could still be /// oldest active transaction (minimal transaction ID which could still be
/// active). /// active).
@ -128,3 +130,5 @@ class CommitLog final {
utils::SpinLock lock_; utils::SpinLock lock_;
utils::Allocator<Block> allocator_; utils::Allocator<Block> allocator_;
}; };
} // namespace storage

6
tests/unit/commit_log_v2.cpp
View File

@ -3,7 +3,7 @@
#include "gtest/gtest.h" #include "gtest/gtest.h"
TEST(CommitLog, Simple) { TEST(CommitLog, Simple) {
CommitLog log; storage::CommitLog log;
EXPECT_EQ(log.OldestActive(), 0); EXPECT_EQ(log.OldestActive(), 0);
log.MarkFinished(1); log.MarkFinished(1);
@ -14,7 +14,7 @@ TEST(CommitLog, Simple) {
} }
TEST(CommitLog, Fields) { TEST(CommitLog, Fields) {
CommitLog log; storage::CommitLog log;
for (uint64_t i = 0; i < 64; ++i) { for (uint64_t i = 0; i < 64; ++i) {
log.MarkFinished(i); log.MarkFinished(i);
@ -33,7 +33,7 @@ TEST(CommitLog, Fields) {
} }
TEST(CommitLog, Blocks) { TEST(CommitLog, Blocks) {
CommitLog log; storage::CommitLog log;
for (uint64_t i = 0; i < 8192 * 64; ++i) { for (uint64_t i = 0; i < 8192 * 64; ++i) {
log.MarkFinished(i); log.MarkFinished(i);