We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1017b9a commit 365844fCopy full SHA for 365844f
core/src/cluster_slots_service.rs
@@ -83,6 +83,11 @@ impl ClusterSlotsService {
83
let mut cluster_slots_service_timing = ClusterSlotsServiceTiming::default();
84
let mut last_stats = Instant::now();
85
let mut epoch_specs = EpochSpecs::from(bank_forks.clone());
86
+
87
+ // initialize cluster slots with the current root bank
88
+ let root_bank = bank_forks.read().unwrap().root_bank();
89
+ cluster_slots.update(&root_bank, &cluster_info);
90
91
while !exit.load(Ordering::Relaxed) {
92
let slots = match cluster_slots_update_receiver.recv_timeout(Duration::from_millis(200))
93
{
0 commit comments