Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion conanfile.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@

class HomestoreConan(ConanFile):
name = "homestore"
version = "7.4.4"
version = "7.4.5"

homepage = "https://github.com/eBay/Homestore"
description = "HomeStore Storage Engine"
Expand Down
9 changes: 9 additions & 0 deletions src/lib/index/wb_cache.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -863,6 +863,15 @@ folly::Future< bool > IndexWBCache::async_cp_flush(IndexCPContext* cp_ctx) {
IndexBufferPtrList buf_list;
get_next_bufs(cp_ctx, resource_mgr().get_dirty_buf_qd(), buf_list);

if (buf_list.empty()) {
LOGTRACEMOD(wbcache, "No more buffers to flush for cp {}, exiting flush iteration", cp_ctx->id());
// if no dirty buffer, we should complete the cp_ctx here, otherwise it will be waiting for ever and
// block the next CP from flushing
m_vdev->cp_flush(cp_ctx);
cp_ctx->complete(true);
return;
}

for (auto& buf : buf_list) {
do_flush_one_buf(cp_ctx, buf, true);
}
Expand Down
Loading