Skip to content

Commit bf220c9

Browse files
committed
update conan version
1 parent ad5b877 commit bf220c9

File tree

4 files changed

+7
-1
lines changed

4 files changed

+7
-1
lines changed

conanfile.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99

1010
class HomestoreConan(ConanFile):
1111
name = "homestore"
12-
version = "7.1.3"
12+
version = "7.2.1"
1313

1414
homepage = "https://github.com/eBay/Homestore"
1515
description = "HomeStore Storage Engine"

src/include/homestore/replication/repl_dev.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -439,6 +439,10 @@ class ReplDevListener {
439439
/// @brief when restart, after all the logs are replayed and before joining raft group, notify the upper layer
440440
virtual void on_log_replay_done(const group_id_t& group_id) {};
441441

442+
virtual void on_become_leader(const group_id_t& group_id) {};
443+
444+
virtual void on_become_follower(const group_id_t& group_id) {};
445+
442446
private:
443447
std::weak_ptr< ReplDev > m_repl_dev;
444448
};

src/lib/replication/repl_dev/raft_repl_dev.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2820,6 +2820,7 @@ void RaftReplDev::become_leader_cb() {
28202820
// becoming a leader.
28212821

28222822
RD_LOGD(NO_TRACE_ID, "become_leader_cb: setting traffic_ready_lsn from {} to {}", current_gate, new_gate);
2823+
listener->on_become_leader(m_group_id);
28232824
}
28242825

28252826
bool RaftReplDev::is_ready_for_traffic() const {

src/lib/replication/repl_dev/raft_repl_dev.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -356,6 +356,7 @@ class RaftReplDev : public ReplDev,
356356
void become_follower_cb() {
357357
m_traffic_ready_lsn.store(0);
358358
RD_LOGD(NO_TRACE_ID, "become_follower_cb called!");
359+
listener->on_become_follower(m_group_id);
359360
}
360361

361362
/// @brief This method is called when the data journal is compacted

0 commit comments

Comments
 (0)