dragonflyoss
/
client
mirror of https://github.com/dragonflyoss/client.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: sync available scheduler addresses from manager (#208) 

Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
Gaius 2024-01-10 12:37:22 +08:00 committed by GitHub
parent a4f09fb39c
commit e8cdb9d8b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/announcer/mod.rs
View File

@ -169,7 +169,7 @@ impl SchedulerAnnouncer {
}
};
if let Err(err) = self.scheduler_client.init_announce_host(request).await {
if let Err(err) = self.scheduler_client.announce_host(request).await {
error!("announce host to scheduler failed: {}", err);
};
}

3
src/grpc/scheduler.rs
View File

@ -313,7 +313,8 @@ impl SchedulerClient {
&& data
.available_schedulers
.iter()
.all(|available_scheduler| available_schedulers.contains(available_scheduler))
.zip(available_schedulers.iter())
.all(|(a, b)| a == b)
{
info!(
"available schedulers is not changed: {:?}",