Searched refs:workers_kill_evt (Results 1 – 2 of 2) sorted by relevance
28 workers_kill_evt: Option<Event>, field97 workers_kill_evt: Some(kill_evt.try_clone().map_err(Error::CloneKillEvent)?), in new()118 if self.workers_kill_evt.is_none() { in drop()151 if let Some(workers_kill_evt) = &self.workers_kill_evt { in keep_rds()152 keep_rds.push(workers_kill_evt.as_raw_descriptor()); in keep_rds()206 if let Some(kill_evt) = self.workers_kill_evt.take() { in activate()326 if self.workers_kill_evt.is_none() && self.kill_evt.write(1).is_err() { in reset()341 self.workers_kill_evt = Some(worker.kill_evt); in reset()
426 workers_kill_evt: Vec<Event>, field486 let mut workers_kill_evt: Vec<Event> = Vec::new(); in from() localVariable491 workers_kill_evt.push(worker_kill_evt); in from()496 workers_kill_evt, in from()565 if self.workers_kill_evt.get(i).is_none() { in drop()591 for worker_kill_evt in &self.workers_kill_evt { in keep_rds()663 if self.workers_kill_evt.len() != vq_pairs { in activate()667 self.workers_kill_evt.len() in activate()677 let kill_evt = self.workers_kill_evt.remove(0); in activate()729 if self.workers_kill_evt.get(i).is_none() { in reset()[all …]