Skip to content

Commit

Permalink
fix test case
Browse files Browse the repository at this point in the history
  • Loading branch information
yamingk committed May 23, 2024
1 parent b636f50 commit 5285092
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 3 deletions.
2 changes: 1 addition & 1 deletion conanfile.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

class HomestoreConan(ConanFile):
name = "homestore"
version = "6.4.7"
version = "6.4.9"

homepage = "https://github.com/eBay/Homestore"
description = "HomeStore Storage Engine"
Expand Down
4 changes: 2 additions & 2 deletions src/lib/replication/service/raft_repl_service.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -336,8 +336,8 @@ void RaftReplService::start_reaper_thread() {
m_rdev_gc_timer_hdl = iomanager.schedule_thread_timer(
HS_DYNAMIC_CONFIG(generic.repl_dev_cleanup_interval_sec) * 1000 * 1000 * 1000, true /* recurring */,
nullptr, [this](void*) {
gc_repl_devs();
gc_repl_reqs();
gc_repl_devs();
});

// Check for queued fetches at the minimum every second
Expand Down Expand Up @@ -384,7 +384,7 @@ void RaftReplService::fetch_pending_data() {

void RaftReplService::gc_repl_reqs() {
std::shared_lock lg(m_rd_map_mtx);
for (auto it = m_rd_map.begin(); it != m_rd_map.end();) {
for (auto it = m_rd_map.begin(); it != m_rd_map.end(); ++it) {
auto rdev = std::dynamic_pointer_cast< RaftReplDev >(it->second);
rdev->gc_repl_reqs();
}
Expand Down
3 changes: 3 additions & 0 deletions src/tests/test_raft_repl_dev.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -686,6 +686,9 @@ TEST_F(RaftReplDevTest, GCReplReqs) {
// Step 2: Restart replica-0 (Leader)
this->restart_replica(0, 10);

LOGINFO("After original leader is shutdown, insert more entries into the new leader");
this->write_on_leader(100, true /* wait for commit on all replicas */);

g_helper->sync_for_verify_start();

LOGINFO("Validate all data written so far by reading them");
Expand Down

0 comments on commit 5285092

Please sign in to comment.