diff --git a/crates/lox-distributor/src/lox_context.rs b/crates/lox-distributor/src/lox_context.rs index bb4f351..6111aba 100644 --- a/crates/lox-distributor/src/lox_context.rs +++ b/crates/lox-distributor/src/lox_context.rs @@ -100,6 +100,15 @@ impl LoxServerContext { } + pub fn allocate_leftover_bridges(&self) { + let mut ba_obj = self.ba.lock().unwrap(); + let mut db_obj = self.db.lock().unwrap(); + let mut extra_bridges = self.extra_bridges.lock().unwrap(); + ba_obj.allocate_bridges(&mut extra_bridges, &mut db_obj); + + + } + pub fn add_openinv_bucket(&self, bucket: [BridgeLine; 3]) { let mut ba_obj = self.ba.lock().unwrap(); let mut db_obj = self.db.lock().unwrap(); diff --git a/crates/lox-distributor/src/main.rs b/crates/lox-distributor/src/main.rs index a9aad1d..07f8234 100644 --- a/crates/lox-distributor/src/main.rs +++ b/crates/lox-distributor/src/main.rs @@ -354,6 +354,7 @@ async fn context_manager(mut context_rx: mpsc::Receiver) { } } } + context.allocate_leftover_bridges(); context.encrypt_table(); sleep(Duration::from_millis(1)).await; }