Lines Matching defs:msg
159 fbl::unique_ptr<MessagePacket>* msg,
180 *msg = messages_.pop_front();
189 zx_status_t ChannelDispatcher::Write(fbl::unique_ptr<MessagePacket> msg) {
198 peer_->WriteSelf(fbl::move(msg));
203 zx_status_t ChannelDispatcher::Call(fbl::unique_ptr<MessagePacket> msg,
243 msg->set_txid(txid);
250 peer_->WriteSelf(fbl::move(msg));
301 void ChannelDispatcher::WriteSelf(fbl::unique_ptr<MessagePacket> msg) {
308 zx_txid_t txid = msg->get_txid();
314 waiter.Deliver(fbl::move(msg));
319 messages_.push_back(fbl::move(msg));
353 void ChannelDispatcher::MessageWaiter::Deliver(fbl::unique_ptr<MessagePacket> msg) {
356 msg_ = fbl::move(msg);