Searched refs:Channel (Results 1 – 3 of 3) sorted by relevance
| /trusty/user/base/lib/tipc/rust/src/service/ |
| D | handle_set.rs | 23 use super::{Channel, Dispatcher};
38 ports: [Rc<Channel<D>>; PORT_COUNT],
39 connections: [Option<Rc<Channel<D>>>; MAX_CONNECTION_COUNT],
47 pub fn try_new(ports: [Rc<Channel<D>>; PORT_COUNT]) -> Result<Self> { in try_new()
84 pub fn add_connection(&mut self, connection: Rc<Channel<D>>) -> Result<()> { in add_connection()
119 pub fn close(&mut self, connection: Rc<Channel<D>>) { in close()
156 fn do_set_ctrl(&self, cmd: u32, event: u32, channel: &Rc<Channel<D>>) -> Result<()> { in do_set_ctrl()
|
| /trusty/user/base/lib/tipc/rust/src/ |
| D | service.rs | 131 pub(crate) struct Channel<D: Dispatcher> { struct
136 impl<D: Dispatcher> PartialEq for Channel<D> { argument
142 impl<D: Dispatcher> Eq for Channel<D> {} implementation
144 impl<D: Dispatcher> fmt::Debug for Channel<D> { implementation
170 impl<D: Dispatcher> Channel<D> { implementation
1030 let ports: Vec<Rc<Channel<D>>> = dispatcher in new_with_dispatcher()
1033 .map(Channel::try_new_port) in new_with_dispatcher()
1035 let ports: [Rc<Channel<D>>; PORT_COUNT] = ports in new_with_dispatcher()
1099 let channel: Rc<Channel<D>> = unsafe { Channel::from_opaque_ptr(event.cookie) } in event_loop_inner()
1110 fn handler(&mut self, channel: Rc<Channel<D>>, event: &trusty_sys::uevent) -> Result<()> { in handler()
[all …]
|
| D | handle.rs | 491 type Channel = crate::service::Channel<crate::service::SingleDispatcher<()>>; in first_free_handle_index() typedef
494 let chan = Channel::try_new_port( in first_free_handle_index()
|