Searched refs:dispatcher (Results 1 – 3 of 3) sorted by relevance
| /trusty/user/app/secretkeeper/ |
| D | lib.rs | 227 dispatcher: &mut SkServiceDispatcher<PORT_COUNT>, in add_service_port()
246 dispatcher.add_service(Rc::new(service), cfg).map_err(|e| { in add_service_port()
277 let mut dispatcher = SkServiceDispatcher::<PORT_COUNT>::new().map_err(|e| { in inner_main() localVariable
283 add_service_port(&mut dispatcher, ag_service, AG_PORT_NAME, SecureConnections(false))?; in inner_main()
284 add_service_port(&mut dispatcher, sk_service, SK_PORT_NAME, SecureConnections(false))?; in inner_main()
287 add_service_port(&mut dispatcher, bl_service, BL_PORT_NAME, SecureConnections(true))?; in inner_main()
291 Manager::<_, _, PORT_COUNT, MAX_CONNECTION_COUNT>::new_with_dispatcher(dispatcher, buffer) in inner_main()
|
| /trusty/user/base/lib/tipc/rust/src/ |
| D | service.rs | 910 dispatcher: D, field
964 let dispatcher = SingleDispatcher::new(service, port_cfg); in new() localVariable
965 Self::new_with_dispatcher(dispatcher, buffer) in new()
977 let dispatcher = SingleUnbufferedDispatcher::new(service, port_cfg); in new_unbuffered() localVariable
978 Self::new_with_dispatcher(dispatcher, []) in new_unbuffered()
1025 pub fn new_with_dispatcher(dispatcher: D, buffer: B) -> Result<Self> { in new_with_dispatcher()
1026 if buffer.as_ref().len() < dispatcher.max_message_length() { in new_with_dispatcher()
1030 let ports: Vec<Rc<Channel<D>>> = dispatcher in new_with_dispatcher()
1040 Ok(Self { dispatcher, handle_set, buffer }) in new_with_dispatcher()
1170 let connection_data = self.dispatcher.on_connect(&cfg, &connection_handle, &peer)?; in handle_connect()
[all …]
|
| /trusty/user/app/keymint/ |
| D | ipc_manager.rs | 572 let mut dispatcher = KMServiceDispatcher::<3>::new() in handle_port_connections() localVariable
585 dispatcher.add_service(Rc::new(ns_service), cfg).map_err(|e| { in handle_port_connections()
598 dispatcher.add_service(Rc::new(sec_service), cfg).map_err(|e| { in handle_port_connections()
612 dispatcher.add_service(Rc::new(legacy_service), cfg).map_err(|e| { in handle_port_connections()
617 Manager::<_, _, PORT_COUNT, MAX_CONNECTION_COUNT>::new_with_dispatcher(dispatcher, buffer) in handle_port_connections()
|