diff --git a/src/os/FileJournal.cc b/src/os/FileJournal.cc index e18ceba..21e57e7 100644 --- a/src/os/FileJournal.cc +++ b/src/os/FileJournal.cc @@ -1388,8 +1388,10 @@ void FileJournal::check_aio_completion() *Now we can only update journal header w/o other data. *The seq of for write journal header is 0.So we don't check the p->seq */ + if (p->seq) { new_journaled_seq = p->seq; completed_something = true; + } aio_num--; aio_bytes -= p->len; @@ -1415,8 +1417,8 @@ void FileJournal::check_aio_completion() } // maybe write queue was waiting for aio count to drop? - aio_cond.Signal(); } + aio_cond.Signal(); } #endif