diff options
| -rw-r--r-- | zenstore/caslog.cpp | 8 | ||||
| -rw-r--r-- | zenstore/include/zenstore/caslog.h | 1 |
2 files changed, 8 insertions, 1 deletions
diff --git a/zenstore/caslog.cpp b/zenstore/caslog.cpp index 38d0f818e..369bc55ad 100644 --- a/zenstore/caslog.cpp +++ b/zenstore/caslog.cpp @@ -102,6 +102,12 @@ CasLogFile::Close() m_File.Close(); } +uint64_t +CasLogFile::GetLogSize() +{ + return m_File.FileSize(); +} + void CasLogFile::Replay(std::function<void(const void*)>&& Handler) { @@ -132,7 +138,7 @@ CasLogFile::Replay(std::function<void(const void*)>&& Handler) Handler(ReadBuffer.data() + (i * m_RecordSize)); } - m_AppendOffset = LogBaseOffset + (LogFileSize * LogEntryCount); + m_AppendOffset = LogBaseOffset + (m_RecordSize * LogEntryCount); } void diff --git a/zenstore/include/zenstore/caslog.h b/zenstore/include/zenstore/caslog.h index 065a74b25..bb9d07726 100644 --- a/zenstore/include/zenstore/caslog.h +++ b/zenstore/include/zenstore/caslog.h @@ -27,6 +27,7 @@ public: void Replay(std::function<void(const void*)>&& Handler); void Flush(); void Close(); + uint64_t GetLogSize(); private: struct FileHeader |