Lines Matching refs:msg
171 MessagePacketPtr* msg, in Read() argument
195 *msg = messages_.pop_front(); in Read()
204 zx_status_t ChannelDispatcher::Write(zx_koid_t owner, MessagePacketPtr msg) { in Write() argument
220 peer_->WriteSelf(ktl::move(msg)); in Write()
226 MessagePacketPtr msg, in Call() argument
269 msg->set_txid(txid); in Call()
276 peer_->WriteSelf(ktl::move(msg)); in Call()
327 void ChannelDispatcher::WriteSelf(MessagePacketPtr msg) { in WriteSelf() argument
334 zx_txid_t txid = msg->get_txid(); in WriteSelf()
340 waiter.Deliver(ktl::move(msg)); in WriteSelf()
345 messages_.push_back(ktl::move(msg)); in WriteSelf()
379 void ChannelDispatcher::MessageWaiter::Deliver(MessagePacketPtr msg) { in Deliver() argument
382 msg_ = ktl::move(msg); in Deliver()