Home
last modified time | relevance | path

Searched refs:SyncMessage (Results 1 – 11 of 11) sorted by relevance

/external/libchrome/ipc/
Dipc_sync_message.cc23 SyncMessage::SyncMessage(int32_t routing_id, in SyncMessage() function in IPC::SyncMessage
38 SyncMessage::~SyncMessage() = default;
40 MessageReplyDeserializer* SyncMessage::GetReplyDeserializer() { in GetReplyDeserializer()
45 bool SyncMessage::IsMessageReplyTo(const Message& msg, int request_id) { in IsMessageReplyTo()
52 base::PickleIterator SyncMessage::GetDataIterator(const Message* msg) { in GetDataIterator()
60 int SyncMessage::GetMessageId(const Message& msg) { in GetMessageId()
71 Message* SyncMessage::GenerateReply(const Message* msg) { in GenerateReply()
87 bool SyncMessage::ReadSyncHeader(const Message& msg, SyncHeader* header) { in ReadSyncHeader()
100 bool SyncMessage::WriteSyncHeader(Message* msg, const SyncHeader& header) { in WriteSyncHeader()
113 return SerializeOutputParameters(msg, SyncMessage::GetDataIterator(&msg)); in SerializeOutputParameters()
Dipc_sync_message.h29 class IPC_MESSAGE_SUPPORT_EXPORT SyncMessage : public Message {
31 SyncMessage(int32_t routing_id,
35 ~SyncMessage() override;
Dipc_sync_message_filter.cc49 SyncMessage::GetMessageId(*message), in Send()
50 static_cast<SyncMessage*>(message)->GetReplyDeserializer(), in Send()
129 if (SyncMessage::IsMessageReplyTo(message, (*iter)->id)) { in OnMessageReceived()
Dipc_message_templates_impl.h57 : SyncMessage( in MessageT()
69 base::PickleIterator iter = SyncMessage::GetDataIterator(msg); in ReadSendParam()
77 base::PickleIterator iter = SyncMessage::GetDataIterator(msg); in ReadReplyParam()
Dipc_message_templates.h159 : public SyncMessage {
195 Message* reply = SyncMessage::GenerateReply(msg); in Dispatch()
219 Message* reply = SyncMessage::GenerateReply(msg); in DispatchDelayReply()
241 Message* reply = SyncMessage::GenerateReply(msg); in DispatchWithParamDelayReply()
Dipc_sync_channel.h37 class SyncMessage; variable
151 bool Push(SyncMessage* sync_msg); in COMPONENT_EXPORT()
Dipc_sync_channel.cc381 bool SyncChannel::SyncContext::Push(SyncMessage* sync_msg) { in Push()
394 SyncMessage::GetMessageId(*sync_msg), sync_msg->GetReplyDeserializer(), in Push()
441 !SyncMessage::IsMessageReplyTo(*msg, deserializers_.back().id)) { in TryToUnblockListener()
619 SyncMessage* sync_msg = static_cast<SyncMessage*>(message); in Send()
Dipc_channel_mojo_unittest.cc1118 IPC::SyncMessage::GenerateReply(&message)); in OnMessageReceived()
1195 std::unique_ptr<IPC::SyncMessage> request( in TEST_F()
1196 new IPC::SyncMessage(0, 0, IPC::Message::PRIORITY_NORMAL, in TEST_F()
1229 std::unique_ptr<IPC::SyncMessage> reply(new IPC::SyncMessage( in RequestValue()
1249 IPC::SyncMessage::GenerateReply(&message)); in OnMessageReceived()
Dipc_message.h243 friend class SyncMessage; variable
Dipc_sync_message_unittest.cc168 void Send(IPC::SyncMessage* msg) { in Send()
Dipc_sync_channel_unittest.cc120 SyncMessage* msg = new SyncChannelTestMsg_AnswerToLife(&answer); in SendAnswerToLife()
130 SyncMessage* msg = new SyncChannelTestMsg_Double(5, &answer); in SendDouble()
538 SyncMessage* msg = new SyncChannelTestMsg_AnswerToLife(&answer); in Run()
885 SyncMessage* msg = new SyncChannelNestedTestMsg_String(&response); in Run()