diff options
| author | Dan Engelbrecht <[email protected]> | 2022-03-23 14:47:29 +0100 |
|---|---|---|
| committer | Dan Engelbrecht <[email protected]> | 2022-03-31 11:29:27 +0200 |
| commit | cad2fba69bd503a49c29aceb05e1c2c41debd15d (patch) | |
| tree | 33c35ce854a2e778d4a7919a91f0d03ab7088455 | |
| parent | Add timing stats to garbage collection (diff) | |
| download | zen-cad2fba69bd503a49c29aceb05e1c2c41debd15d.tar.xz zen-cad2fba69bd503a49c29aceb05e1c2c41debd15d.zip | |
Add CasLog::Append with multiple entries
| -rw-r--r-- | zenstore/caslog.cpp | 2 | ||||
| -rw-r--r-- | zenstore/include/zenstore/caslog.h | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/zenstore/caslog.cpp b/zenstore/caslog.cpp index 055e3feda..909605af9 100644 --- a/zenstore/caslog.cpp +++ b/zenstore/caslog.cpp @@ -142,7 +142,7 @@ CasLogFile::Replay(std::function<void(const void*)>&& Handler) void CasLogFile::Append(const void* DataPointer, uint64_t DataSize) { - ZEN_ASSERT(DataSize == m_RecordSize); + ZEN_ASSERT((DataSize % m_RecordSize) == 0); uint64_t AppendOffset = m_AppendOffset.fetch_add(DataSize); diff --git a/zenstore/include/zenstore/caslog.h b/zenstore/include/zenstore/caslog.h index ff4b8c130..4c1bf8196 100644 --- a/zenstore/include/zenstore/caslog.h +++ b/zenstore/include/zenstore/caslog.h @@ -72,6 +72,8 @@ public: CasLogFile::Append(&Record, sizeof Record); } + + void Append(const std::span<T>& Records) { CasLogFile::Append(Records.data(), sizeof T * Records.size()); } }; } // namespace zen |