diff options
Diffstat (limited to 'cpp/src/qpid/linearstore/journal/enq_rec.h')
| -rw-r--r-- | cpp/src/qpid/linearstore/journal/enq_rec.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/linearstore/journal/enq_rec.h b/cpp/src/qpid/linearstore/journal/enq_rec.h index 1655e2cc4d..d85cde42f5 100644 --- a/cpp/src/qpid/linearstore/journal/enq_rec.h +++ b/cpp/src/qpid/linearstore/journal/enq_rec.h @@ -51,7 +51,7 @@ public: void reset(const uint64_t serial, const uint64_t rid, const void* const dbuf, const std::size_t dlen, const void* const xidp, const std::size_t xidlen, const bool transient, const bool external); uint32_t encode(void* wptr, uint32_t rec_offs_dblks, uint32_t max_size_dblks, Checksum& checksum); - bool decode(::rec_hdr_t& h, std::ifstream* ifsp, std::size_t& rec_offs); + bool decode(::rec_hdr_t& h, std::ifstream* ifsp, std::size_t& rec_offs, const std::streampos rec_start); std::size_t get_xid(void** const xidpp); std::size_t get_data(void** const datapp); @@ -63,7 +63,7 @@ public: std::size_t rec_size() const; static std::size_t rec_size(const std::size_t xidsize, const std::size_t dsize, const bool external); inline uint64_t rid() const { return _enq_hdr._rhdr._rid; } - void check_rec_tail() const; + void check_rec_tail(const std::streampos rec_start) const; private: virtual void clean(); |