Searched refs:SocketRunnerActions (Results 1 – 1 of 1) sorted by relevance
405 tx: Sender<SocketRunnerActions>,418 tx: Sender<SocketRunnerActions>, in new() argument471 pub(crate) enum SocketRunnerActions { enum630 let (runner_tx, runner_rx) = channel::<SocketRunnerActions>(10); in socket_listen()760 mut runner_rx: Receiver<SocketRunnerActions>, in listening_task() argument829 SocketRunnerActions::AcceptTimeout(socket_id, may_timeout) => { in listening_task()985 SocketRunnerActions::Close(socket_id) => { in listening_task()1216 .collect::<Vec<(u64, Sender<SocketRunnerActions>, Uuid)>>(); in handle_admin_policy_changed()1225 let _ = tx.send(SocketRunnerActions::Close(id)).await; in handle_admin_policy_changed()1245 let _ = tx.send(SocketRunnerActions::Close(id)).await; in remove_callback()[all …]