RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-23 19:17:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #14489 from liewegas/wip-bluestore-fix-flush

Browse Source 
os/bluestore: fix narrow osr->flush() race
This commit is contained in:
Sage Weil 2017-04-14 08:35:35 -05:00 committed by GitHub
commit 08d3fa490f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/os/bluestore/BlueStore.h
View File

@ -1655,10 +1655,13 @@ public:
void flush() override {
std::unique_lock<std::mutex> l(qlock);
while (true) {
// set flag before the check because the condition
// may become true outside qlock, and we need to make
// sure those threads see waiters and signal qcond.
++kv_submitted_waiters;
if (_is_all_kv_submitted()) {
return;
}
++kv_submitted_waiters;
qcond.wait(l);
--kv_submitted_waiters;
}