MCPcopy Create free account
hub / github.com/Botloader/botloader / spawn_worker

Method spawn_worker

components/scheduler/src/vmworkerpool.rs:245–267  ·  view source on GitHub ↗
(&self, tier: usize)

Source from the content-addressed store, hash-verified

243 }
244
245 fn spawn_worker(&self, tier: usize) {
246 info!("spawning vm worker");
247
248 let mut cmd = Command::new(&self.launch_config.cmd);
249 cmd.args(&self.launch_config.args);
250
251 // cmd.stdin(Stdio::piped());
252 cmd.stdout(Stdio::inherit());
253 cmd.stderr(Stdio::inherit());
254 cmd.envs(std::env::vars());
255 let worker_id = self.gen_id();
256 cmd.env("BL_WORKER_ID", worker_id.to_string());
257
258 let child = cmd.spawn().expect("spawn script vm worker");
259 // let handle = init_worker_handles(child);
260
261 // self.self.add_worker_to_pool(handle);
262 self.add_pending_worker(PendingWorkerHandle {
263 child,
264 worker_id,
265 priority_index: tier,
266 })
267 }
268
269 pub fn worker_connected(
270 &self,

Callers 2

spawn_workersMethod · 0.80
return_workerMethod · 0.80

Calls 3

gen_idMethod · 0.80
add_pending_workerMethod · 0.80
spawnMethod · 0.45

Tested by

no test coverage detected