diff options
Diffstat (limited to 'db/blob/blob_log_writer.h')
-rw-r--r-- | db/blob/blob_log_writer.h | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/db/blob/blob_log_writer.h b/db/blob/blob_log_writer.h index c1f9f31ad..0ba4f9c2a 100644 --- a/db/blob/blob_log_writer.h +++ b/db/blob/blob_log_writer.h @@ -43,20 +43,24 @@ class BlobLogWriter { static void ConstructBlobHeader(std::string* buf, const Slice& key, const Slice& val, uint64_t expiration); - Status AddRecord(const Slice& key, const Slice& val, uint64_t* key_offset, + Status AddRecord(const WriteOptions& write_options, const Slice& key, + const Slice& val, uint64_t* key_offset, uint64_t* blob_offset); - Status AddRecord(const Slice& key, const Slice& val, uint64_t expiration, - uint64_t* key_offset, uint64_t* blob_offset); + Status AddRecord(const WriteOptions& write_options, const Slice& key, + const Slice& val, uint64_t expiration, uint64_t* key_offset, + uint64_t* blob_offset); - Status EmitPhysicalRecord(const std::string& headerbuf, const Slice& key, + Status EmitPhysicalRecord(const WriteOptions& write_options, + const std::string& headerbuf, const Slice& key, const Slice& val, uint64_t* key_offset, uint64_t* blob_offset); - Status AppendFooter(BlobLogFooter& footer, std::string* checksum_method, + Status AppendFooter(const WriteOptions& write_options, BlobLogFooter& footer, + std::string* checksum_method, std::string* checksum_value); - Status WriteHeader(BlobLogHeader& header); + Status WriteHeader(const WriteOptions& write_options, BlobLogHeader& header); WritableFileWriter* file() { return dest_.get(); } @@ -64,7 +68,7 @@ class BlobLogWriter { uint64_t get_log_number() const { return log_number_; } - Status Sync(); + Status Sync(const WriteOptions& write_options); private: std::unique_ptr<WritableFileWriter> dest_; |