Method
run_ctrl
(
&mut self,
paused: &AtomicBool,
paused_sync: &Barrier,
)
Source from the content-addressed store, hash-verified
| 74 | } |
| 75 | |
| 76 | pub fn run_ctrl( |
| 77 | &mut self, |
| 78 | paused: &AtomicBool, |
| 79 | paused_sync: &Barrier, |
| 80 | ) -> std::result::Result<(), EpollHelperError> { |
| 81 | let mut helper = EpollHelper::new(&self.kill_evt, &self.pause_evt)?; |
| 82 | helper.add_event(self.queue_evt.as_raw_fd(), CTRL_QUEUE_EVENT)?; |
| 83 | helper.run(paused, paused_sync, self)?; |
| 84 | |
| 85 | Ok(()) |
| 86 | } |
| 87 | } |
| 88 | |
| 89 | impl EpollHelperHandler for NetCtrlEpollHandler { |
Tested by
no test coverage detected