Method worker_connected

components/scheduler/src/vmworkerpool.rs:269–283

(
        &self,
        #[cfg(target_family = "windows")] stream: tokio::net::TcpStream,
        #[cfg(target_family = "unix")] stream: tokio::net::UnixStream,
        id: u64,
    )

    }

    pub fn worker_connected(
        &self,
        #[cfg(target_family = "windows")] stream: tokio::net::TcpStream,
        #[cfg(target_family = "unix")] stream: tokio::net::UnixStream,
        id: u64,
    ) {
        let mut w = self.inner.lock().unwrap();
        if let Some(pending) = w.pending_starts.remove(&id) {
            drop(w);

            let full = init_worker_handles(pending, stream);
            info!(tier = full.priority_index, "worker connected");
            self.add_worker_to_pool(full);
        }
    }

    pub fn worker_statuses(&self) -> Vec<WorkerStatus> {
        let w = self.inner.lock().unwrap();