Searched refs:msg_receiver (Results 1 – 10 of 10) sorted by relevance
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/zbus-2.1.1/src/ |
| H A D | message_stream.rs | 30 msg_receiver: ActiveReceiver<Arc<Message>>, field
43 if !this.msg_receiver.is_terminated() { in poll_next()
44 if let Some(msg) = ready!(Pin::new(&mut this.msg_receiver).poll_next(cx)) { in poll_next()
84 self.msg_receiver.is_terminated() && self.error_receiver.is_terminated() in is_terminated()
91 let msg_receiver = conn.msg_receiver.activate(); in from() localVariable
96 msg_receiver, in from()
112 msg_receiver: stream.msg_receiver.deactivate(), in from()
|
| H A D | connection.rs | 267 pub(crate) msg_receiver: InactiveReceiver<Arc<Message>>, field
604 self.msg_receiver.capacity() in max_queued()
609 self.msg_receiver.set_capacity(max); in set_max_queued()
829 let (msg_sender, msg_receiver) = broadcast(DEFAULT_MAX_QUEUED); in new()
830 let msg_receiver = msg_receiver.deactivate(); in new() localVariable
841 msg_receiver, in new()
992 msg_receiver: InactiveReceiver<Arc<Message>>, field
1001 msg_receiver: self.msg_receiver.clone(), in upgrade()
1011 msg_receiver: conn.msg_receiver.clone(), in from()
|
| H A D | proxy.rs | 749 let stream = conn.msg_receiver.activate_cloned(); in receive_signals()
|
| /dports/net/yami4/yami4-gpl-1.11.0/src/core/qnx/ |
| H A D | listener.cpp | 56 msg_receiver * msg_rcv = reinterpret_cast<msg_receiver *>(hint); in receiver_thread_function()
82 bool msg_receiver::start(channel_group * group, in start()
135 void msg_receiver::stop() in stop()
204 bool msg_receiver::is_frame_ready() const in is_frame_ready()
225 void msg_receiver::received_details(bool & io_error_occurred, in received_details()
249 void msg_receiver::release_buffer() in release_buffer()
272 void msg_receiver::do_run() in do_run()
|
| H A D | details-types.h | 38 class msg_receiver
|
| /dports/net/yami4/yami4-gpl-1.11.0/src/core/ |
| H A D | listener.h | 123 msg_receiver msg_receiver_;
|
| /dports/net/pjsip/pjproject-2.11.1/pjsip/src/test/ |
| H A D | tsx_uac_test.c | 123 static pjsip_module msg_receiver = variable
1386 status = pjsip_endpt_register_module(endpt, &msg_receiver); in tsx_uac_test()
1460 status = pjsip_endpt_unregister_module(endpt, &msg_receiver); in tsx_uac_test()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/ipc/ |
| H A D | msg.c | 75 struct msg_receiver { struct
251 struct msg_receiver *msr, *t; in expunge_all()
811 struct msg_receiver *msr, *t; in pipelined_send()
1122 struct msg_receiver msr_d; in do_msgrcv()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/ipc/ |
| H A D | msg.c | 75 struct msg_receiver { struct
251 struct msg_receiver *msr, *t; in expunge_all()
811 struct msg_receiver *msr, *t; in pipelined_send()
1122 struct msg_receiver msr_d; in do_msgrcv()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/ipc/ |
| H A D | msg.c | 75 struct msg_receiver { struct
251 struct msg_receiver *msr, *t; in expunge_all()
811 struct msg_receiver *msr, *t; in pipelined_send()
1122 struct msg_receiver msr_d; in do_msgrcv()
|