Home | History | Annotate | Download | only in CoreIPC

Lines Matching defs:messageID

133     MessageID messageID = incomingMessage.messageID();
134 if (!messageID.shouldDispatchMessageWhenWaitingForSyncReply())
284 bool Connection::sendMessage(MessageID messageID, PassOwnPtr<ArgumentEncoder> arguments, unsigned messageSendFlags)
292 messageID = messageID.messageIDWithAddedFlags(MessageID::DispatchMessageWhenWaitingForSyncReply);
295 m_outgoingMessages.append(OutgoingMessage(messageID, arguments));
304 return sendMessage(MessageID(CoreIPCMessage::SyncMessageReply), arguments);
307 PassOwnPtr<ArgumentDecoder> Connection::waitForMessage(MessageID messageID, uint64_t destinationID, double timeout)
316 if (message.messageID() == messageID && message.arguments()->destinationID() == destinationID) {
328 std::pair<unsigned, uint64_t> messageAndDestination(std::make_pair(messageID.toInt(), destinationID));
364 PassOwnPtr<ArgumentDecoder> Connection::sendSyncMessage(MessageID messageID, uint64_t syncRequestID, PassOwnPtr<ArgumentEncoder> encoder, double timeout)
386 sendMessage(messageID.messageIDWithAddedFlags(MessageID::SyncMessage), encoder, DispatchMessageEvenWhenWaitingForSyncReply);
481 void Connection::processIncomingMessage(MessageIDmessageID, PassOwnPtr<ArgumentDecoder> arguments)
484 if (messageID == MessageID(CoreIPCMessage::SyncMessageReply)) {
489 IncomingMessage incomingMessage(messageID, arguments);
501 HashMap<std::pair<unsigned, uint64_t>, ArgumentDecoder*>::iterator it = m_waitForMessageMap.find(std::make_pair(messageID.toInt(), incomingMessage.destinationID()));
571 if (!sendOutgoingMessage(message.messageID(), adoptPtr(message.arguments())))
576 void Connection::dispatchSyncMessage(MessageID messageID, ArgumentDecoder* arguments)
578 ASSERT(messageID.isSync());
593 SyncReplyMode syncReplyMode = m_client->didReceiveSyncMessage(this, messageID, arguments, replyEncoder);
635 if (message.messageID().shouldDispatchMessageWhenWaitingForSyncReply())
641 if (message.messageID().isSync())
642 dispatchSyncMessage(message.messageID(), arguments.get());
644 m_client->didReceiveMessage(this, message.messageID(), arguments.get());
649 if (message.messageID().shouldDispatchMessageWhenWaitingForSyncReply())
653 m_client->didReceiveInvalidMessage(this, message.messageID());