bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

db/commitlog: Use fragmented buffers to read entries

Browse Source 
Leverage fragmented_temporary_buffer when reading commit log
entries, avoiding large allocations.

Refs #4020

Signed-off-by: Duarte Nunes <duarte@scylladb.com>
This commit is contained in:
Duarte Nunes
2018-12-31 00:00:27 +00:00
parent 0e50a9bc6d
commit b7517183fa
8 changed files with 57 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
db/commitlog/commitlog_replayer.cc
View File

@@ -59,6 +59,7 @@
#include "commitlog_entry.hh"
#include "service/priority_manager.hh"
#include "db/extensions.hh"
#include "utils/fragmented_temporary_buffer.hh"
static logging::logger rlogger("commitlog_replayer");
@@ -110,7 +111,7 @@ public:
return _column_mappings.stop();
}
future<> process(stats*, temporary_buffer<char> buf, replay_position rp) const;
future<> process(stats*, fragmented_temporary_buffer buf, replay_position rp) const;
future<stats> recover(sstring file, const sstring& fname_prefix) const;
typedef std::unordered_map<utils::UUID, replay_position> rp_map;
@@ -241,7 +242,7 @@ db::commitlog_replayer::impl::recover(sstring file, const sstring& fname_prefix)
});
}
future<> db::commitlog_replayer::impl::process(stats* s, temporary_buffer<char> buf, replay_position rp) const {
future<> db::commitlog_replayer::impl::process(stats* s, fragmented_temporary_buffer buf, replay_position rp) const {
try {
commitlog_entry_reader cer(buf);