mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-28 18:50:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Commitlog: Delay timer by period/ncpus for each cpu

Browse Source 
To avoid having all shards doing sync at the same time.
This commit is contained in:
Calle Wilund
2015-09-21 13:30:35 +02:00
parent dcabf8c1d2
commit a10745cf0e
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
db/commitlog/commitlog.cc
View File

@@ -217,8 +217,8 @@ public:
const replay_position& pos);
void on_timer();
void sync();
void arm() {
_timer.arm(std::chrono::milliseconds(cfg.commitlog_sync_period_in_ms));
void arm(uint32_t extra = 0) {
_timer.arm(std::chrono::milliseconds(cfg.commitlog_sync_period_in_ms + extra));
}
std::vector<sstring> get_active_names() const;
@@ -704,7 +704,9 @@ future<> db::commitlog::segment_manager::init() {
_ids = replay_position(engine().cpu_id(), id).id;
// always run the timer now, since we need to handle segment pre-alloc etc as well.
_timer.set_callback(std::bind(&segment_manager::on_timer, this));
this->arm();
auto delay = engine().cpu_id() * std::ceil(double(cfg.commitlog_sync_period_in_ms) / smp::count);
logger.trace("Delaying timer loop {} ms", delay);
this->arm(delay);
});
}