Lines Matching refs:message
127 bool sendMessage(int *pipes, const PipeMessage &message) { in sendMessage() argument
128 int ret = write(pipes[1], message.array, sizeof(PipeMessage)); in sendMessage()
132 bool receiveMessage(int *pipes, PipeMessage *message) { in receiveMessage() argument
133 int ret = read(pipes[0], message->array, sizeof(PipeMessage)); in receiveMessage()
139 PipeMessage message; in doReceiver() local
142 message.data.command = PipeCommand::INIT_ERROR; in doReceiver()
143 sendMessage(mResultPipeFds, message); in doReceiver()
148 message.data.command = PipeCommand::INIT_ERROR; in doReceiver()
149 sendMessage(mResultPipeFds, message); in doReceiver()
152 message.data.command = PipeCommand::INIT_OK; in doReceiver()
153 sendMessage(mResultPipeFds, message); in doReceiver()
155 receiveMessage(mCommandPipeFds, &message); in doReceiver()
160 message.data.connectionId, message.data.transactionId, in doReceiver()
161 message.data.bufferId, message.data.timestampUs, &rhandle, &rbuffer); in doReceiver()
162 mManager->close(message.data.connectionId); in doReceiver()
164 message.data.command = PipeCommand::RECEIVE_ERROR; in doReceiver()
165 sendMessage(mResultPipeFds, message); in doReceiver()
169 message.data.command = PipeCommand::RECEIVE_ERROR; in doReceiver()
170 sendMessage(mResultPipeFds, message); in doReceiver()
178 message.data.command = PipeCommand::RECEIVE_OK; in doReceiver()
179 sendMessage(mResultPipeFds, message); in doReceiver()
186 PipeMessage message; in TEST_F() local
188 ASSERT_TRUE(receiveMessage(mResultPipeFds, &message)); in TEST_F()
216 message.data.command = PipeCommand::SEND; in TEST_F()
217 message.data.bufferId = sbuffer->mId; in TEST_F()
218 message.data.connectionId = receiverId; in TEST_F()
219 message.data.transactionId = transactionId; in TEST_F()
220 message.data.timestampUs = postUs; in TEST_F()
221 sendMessage(mCommandPipeFds, message); in TEST_F()
223 EXPECT_TRUE(receiveMessage(mResultPipeFds, &message)); in TEST_F()
224 EXPECT_TRUE(message.data.command == PipeCommand::RECEIVE_OK); in TEST_F()