Method add_worker_to_pool

components/scheduler/src/vmworkerpool.rs:203–232

(&self, worker: WorkerHandle)

    }

    fn add_worker_to_pool(&self, worker: WorkerHandle) {
        let mut w = self.inner.lock().unwrap();

        // potentially hand over to next queued request
        let mut i = MAX_PREMIUM_SLOT_TIER;
        loop {
            let queue = &mut w.req_queues[i];
            if let Some(req) = queue.pop_front() {
                let claim = ClaimedWorker::new_claim(req.guild_id, &worker);

                if req.tx.send(worker).is_err() {
                    panic!("worker request dropped")
                }

                w.track_claimed_worker(claim);

                return;
            }

            if i == worker.priority_index {
                break;
            }

            i -= 1;
        }

        // no pending worker requests
        metrics::gauge!("bl.scheduler.workerpool_available_workers", "priority_index" => worker.priority_index.to_string()).increment(1.0);
        w.pools[worker.priority_index].push(worker);
    }

    fn add_pending_worker(&self, worker: PendingWorkerHandle) {
        let mut w = self.inner.lock().unwrap();