Lines Matching refs:IncomingMessage
64 bool processIncomingMessage(Connection*, IncomingMessage&);
96 IncomingMessage incomingMessage;
131 bool Connection::SyncMessageState::processIncomingMessage(Connection* connection, IncomingMessage& incomingMessage)
133 MessageID messageID = incomingMessage.messageID();
139 connectionAndIncomingMessage.incomingMessage = incomingMessage;
170 connectionAndIncomingMessage.connection->dispatchMessage(connectionAndIncomingMessage.incomingMessage);
314 const IncomingMessage& message = m_incomingMessages[i];
489 IncomingMessage incomingMessage(messageID, arguments);
494 if (m_syncMessageState->processIncomingMessage(this, incomingMessage))
501 HashMap<std::pair<unsigned, uint64_t>, ArgumentDecoder*>::iterator it = m_waitForMessageMap.find(std::make_pair(messageID.toInt(), incomingMessage.destinationID()));
503 it->second = incomingMessage.releaseArguments().leakPtr();
511 enqueueIncomingMessage(incomingMessage);
616 void Connection::enqueueIncomingMessage(IncomingMessage& incomingMessage)
619 m_incomingMessages.append(incomingMessage);
624 void Connection::dispatchMessage(IncomingMessage& message)
660 Vector<IncomingMessage> incomingMessages;
