Searched refs:message_wrapper (Results 1 – 3 of 3) sorted by relevance
284 MessageWrapper message_wrapper) { in CreateMessageTask()286 task->message_wrapper = std::move(message_wrapper); in CreateMessageTask()301 MessageWrapper message_wrapper; member588 MessageWrapper message_wrapper(this, std::move(*message)); in Accept() local590 &message_wrapper, client_call_behavior, in Accept()596 tasks_.push_back(Task::CreateMessageTask(std::move(message_wrapper))); in Accept()599 if (task->message_wrapper.value().has_flag(Message::kFlagIsSync)) { in Accept()600 InterfaceId id = task->message_wrapper.value().interface_id(); in Accept()687 task->IsMessageTask() && !task->message_wrapper.value().IsNull() && in ProcessTasks()688 task->message_wrapper.value().has_flag(Message::kFlagIsSync); in ProcessTasks()[all …]
215 bool ProcessIncomingMessage(MessageWrapper* message_wrapper,
544 MessageWrapper message_wrapper = in OnSyncMessageEventReady() local553 client->HandleIncomingMessage(&message_wrapper.value()); in OnSyncMessageEventReady()810 MessageWrapper message_wrapper(this, std::move(*message)); in Accept() local817 endpoint->EnqueueSyncMessage(std::move(message_wrapper)); in Accept()886 MessageWrapper message_wrapper = endpoint->PopSyncMessage(message_id); in AcceptSyncMessage() local890 if (message_wrapper.value().IsNull()) in AcceptSyncMessage()896 result = client->HandleIncomingMessage(&message_wrapper.value()); in AcceptSyncMessage()