Compare commits
5 Commits
copilot/in
...
copilot/fi
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1eca538536 | ||
|
|
1ad7a5e0f1 | ||
|
|
6ed8f1a24b | ||
|
|
a87e72004d | ||
|
|
e7317e9f39 |
@@ -248,7 +248,7 @@ future<db::commitlog> hint_endpoint_manager::add_store() noexcept {
|
||||
// which is larger than the segment ID of the RP of the last written hint.
|
||||
cfg.base_segment_id = _last_written_rp.base_id();
|
||||
|
||||
return commitlog::create_commitlog(std::move(cfg)).then([this] (commitlog l) -> future<commitlog> {
|
||||
return commitlog::create_commitlog(std::move(cfg)).then([this] (this auto, commitlog l) -> future<commitlog> {
|
||||
// add_store() is triggered every time hint files are forcefully flushed to I/O (every hints_flush_period).
|
||||
// When this happens we want to refill _sender's segments only if it has finished with the segments he had before.
|
||||
if (_sender.have_segments()) {
|
||||
|
||||
Reference in New Issue
Block a user