Method return_worker

components/scheduler/src/vmworkerpool.rs:173–201

(&self, mut worker: WorkerHandle, broken: bool)

    }

    pub fn return_worker(&self, mut worker: WorkerHandle, broken: bool) {
        worker.returned_at = Instant::now();
        let elapsed = worker.returned_at - worker.claimed_at;
        if let Some(guild_id) = worker.last_active_guild {
            let micros = elapsed.as_micros() as u64;
            counter!("bl.worker.claimed_microseconds_total", "guild_id" => guild_id.get().to_string()).increment(micros);
        }

        {
            let mut w = self.inner.lock().unwrap();
            w.tracking_remove_claimed_worker(worker.priority_index, worker.worker_id);
        }

        if broken {
            error!(
                "returned broken worker to the pool: {:?}",
                worker.last_active_guild
            );
            metrics::counter!("bl.scheduler.broken_workers_total").increment(1);
            self.spawn_worker(worker.priority_index);
        } else {
            info!(
                tier = worker.priority_index,
                dur = elapsed.as_secs_f64(),
                "returned worker to the pool"
            );
            self.add_worker_to_pool(worker);
        }
    }

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