Searched refs:receivedMessage (Results 1 – 2 of 2) sorted by relevance
115 Pair<Message, MessageReceiver> receivedMessage = in sendMessageToRouter() local117 assertEquals(headerMessage.getData(), receivedMessage.first.getData()); in sendMessageToRouter()128 Pair<Message, MessageReceiver> receivedMessage = in sendResponseFromRouter() local131 long requestId = receivedMessage.first.asServiceMessage().getHeader().getRequestId(); in sendResponseFromRouter()138 receivedMessage.second.accept(message); in sendResponseFromRouter()161 for (Pair<Message, MessageReceiver> receivedMessage : in clearAllMessageReceivers()164 (RouterImpl.ResponderThunk) receivedMessage.second; in clearAllMessageReceivers()
556 char receivedMessage; in WaitForContinueSignal() local557 r = HANDLE_EINTR(sys_read(fdes[0], &receivedMessage, sizeof(char))); in WaitForContinueSignal()