searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2024-12-05 02:55:46 +01:00
Code Issues Releases Wiki Activity

fix the leader election

Browse Source
This commit is contained in:
Tamo 2023-11-06 15:00:14 +01:00
parent d1bc7ec58a
commit 41178e59fc
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
index-scheduler/src/lib.rs
View File

@ -474,6 +474,8 @@ impl IndexScheduler {
let string_id = id.to_string(); let string_id = id.to_string();
log::info!("Entering the election game with the ID: {id}");
// there is at least us in the childrens of election // there is at least us in the childrens of election
if childrens[0].ends_with(&string_id) { if childrens[0].ends_with(&string_id) {
log::warn!("I'm the leader"); log::warn!("I'm the leader");
@ -483,7 +485,7 @@ impl IndexScheduler {
.into_iter() .into_iter()
.rfind(|path| &path[path.len() - string_id.len()..] < string_id.as_str()) .rfind(|path| &path[path.len() - string_id.len()..] < string_id.as_str())
.unwrap(); .unwrap();
log::warn!("I'm a follower When `{should_watch}` die I should check if I'm the new leader"); log::warn!("I'm a follower. When `{should_watch}` die I should check if I'm the new leader");
let leader_watcher = zk let leader_watcher = zk
.watch(&format!("/election/{should_watch}"), AddWatchMode::Persistent) .watch(&format!("/election/{should_watch}"), AddWatchMode::Persistent)
@ -524,8 +526,13 @@ impl IndexScheduler {
.rfind(|path| &path[path.len() - id.len()..] < id.as_str()) .rfind(|path| &path[path.len() - id.len()..] < id.as_str())
.unwrap(); .unwrap();
let watcher = log::warn!("Watching {should_watch} for now");
zk.watch(&should_watch, AddWatchMode::Persistent).unwrap(); let watcher = zk
.watch(
&format!("/election/{}", should_watch),
AddWatchMode::Persistent,
)
.unwrap();
watchers.replace(event, watcher).unwrap(); watchers.replace(event, watcher).unwrap();
} }