Lines Matching refs:cfg
164 ChannelTy::Port(cfg) => write!(f, "ChannelTy::Port({:?})", cfg), in fmt()
205 pub(crate) fn try_new_port(cfg: &PortCfg) -> Result<Rc<Self>> { in try_new_port()
210 cfg.path.as_ptr(), in try_new_port()
211 cfg.msg_queue_len, in try_new_port()
212 cfg.msg_max_size, in try_new_port()
213 cfg.flags, in try_new_port()
221 ty: ChannelTy::Port(cfg.try_clone()?), in try_new_port()
845 .position(|cfg| cfg == port)
1113 ChannelTy::Port(cfg) if event.event & (sys::IPC_HANDLE_POLL_READY as u32) != 0 => { in handler()
1114 self.handle_connect(&channel.handle, cfg) in handler()
1157 fn handle_connect(&mut self, handle: &Handle, cfg: &PortCfg) -> Result<()> { in handle_connect()
1170 let connection_data = self.dispatcher.on_connect(&cfg, &connection_handle, &peer)?; in handle_connect()
1188 #[cfg(test)]
1252 let cfg = PortCfg::new(&path).unwrap().msg_queue_len(0); in port_create_negative() localVariable
1254 Channel::try_new_port(&cfg).err(), in port_create_negative()
1259 let cfg = PortCfg::new(&path).unwrap().msg_max_size(0); in port_create_negative() localVariable
1261 Channel::try_new_port(&cfg).err(), in port_create_negative()
1266 let cfg = PortCfg::new(&path).unwrap().msg_queue_len(MAX_PORT_BUF_NUM * 100); in port_create_negative() localVariable
1268 Channel::try_new_port(&cfg).err(), in port_create_negative()
1273 let cfg = PortCfg::new(&path).unwrap().msg_max_size(MAX_PORT_BUF_SIZE * 100); in port_create_negative() localVariable
1275 Channel::try_new_port(&cfg).err(), in port_create_negative()
1284 let cfg = PortCfg::new(&path).unwrap(); in port_create_negative() localVariable
1286 Channel::try_new_port(&cfg).err(), in port_create_negative()
1298 let cfg = PortCfg::new(path).unwrap(); in port_create() localVariable
1299 let channel = Channel::try_new_port(&cfg); in port_create()
1304 Channel::try_new_port(&cfg).err(), in port_create()
1312 let cfg = PortCfg::new(path).unwrap(); in port_create() localVariable
1313 let channel = Channel::try_new_port(&cfg); in port_create()
1321 Channel::try_new_port(&cfg).err(), in port_create()
1327 let cfg = PortCfg::new(path).unwrap(); in port_create() localVariable
1329 Channel::try_new_port(&cfg).err(), in port_create()
1341 let cfg = PortCfg::new(path).unwrap(); in wait_on_port() localVariable
1342 let channel = Channel::try_new_port(&cfg); in wait_on_port()
1479 let cfg = PortCfg::new(&path1).unwrap(); in multiple_services() localVariable
1480 dispatcher.add_service(Rc::new(Service1), cfg).expect("Could not add service 1"); in multiple_services()
1483 let cfg = PortCfg::new(&path2).unwrap(); in multiple_services() localVariable
1484 dispatcher.add_service(Rc::new(Service2), cfg).expect("Could not add service 2"); in multiple_services()
1487 let cfg = PortCfg::new(&path).unwrap(); in multiple_services() localVariable
1488 dispatcher.add_service(Rc::new(Service3), cfg).expect("Could not add service 3"); in multiple_services()
1491 let cfg = PortCfg::new(&path).unwrap(); in multiple_services() localVariable
1493 .add_service(Rc::new(WrappedService2(Service2)), cfg) in multiple_services()
1497 let cfg = PortCfg::new(&path).unwrap(); in multiple_services() localVariable
1499 .add_service(Rc::new(WrappedService3(Service3)), cfg) in multiple_services()
1510 let cfg = PortCfg::new(&path).unwrap(); in unbuffered_service() localVariable
1511 Manager::<_, _, 1, 4>::new_unbuffered(Service3, cfg) in unbuffered_service()
1516 #[cfg(test)]
1593 let cfg = PortCfg::new(&path1).unwrap(); in manager_creation() localVariable
1595 .add_service(Rc::new(Service1 { phantom: PhantomData }), cfg) in manager_creation()
1599 let cfg = PortCfg::new(&path2).unwrap(); in manager_creation() localVariable
1601 .add_service(Rc::new(Service2 { phantom: PhantomData }), cfg) in manager_creation()
1610 #[cfg(test)]