mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-02 13:06:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

multishard_combining_reader: pause *all* EOS'd readers

Browse Source 
Previously the last shard reader to reach EOS wasn't paused. This is a
mistake and can contribute to causing deadlocks when the number of
concurrently active readers on any shard is limited.
This commit is contained in:
Botond Dénes
2018-12-06 10:30:40 +02:00
parent 2c2d202354
commit 170fa382fa
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
mutation_reader.cc
View File

@@ -1351,8 +1351,8 @@ future<> multishard_combining_reader::handle_empty_reader_buffer(db::timeout_clo
_end_of_stream = true; _end_of_stream = true;
} else { } else {
move_to_next_shard(); move_to_next_shard();
reader.pause();
} }
reader.pause();
return make_ready_future<>(); return make_ready_future<>();
} else if (reader.is_read_ahead_in_progress()) { } else if (reader.is_read_ahead_in_progress()) {
return reader.fill_buffer(timeout); return reader.fill_buffer(timeout);