131   bool sendMessage(int *pipes, const PipeMessage &message) {  in sendMessage()  argument
132     int ret = write(pipes[1], message.array, sizeof(PipeMessage));  in sendMessage()
136   bool receiveMessage(int *pipes, PipeMessage *message) {  in receiveMessage()  argument
137     int ret = read(pipes[0], message->array, sizeof(PipeMessage));  in receiveMessage()
144     PipeMessage message;  in doReceiver()  local
147       message.data.command = PipeCommand::INIT_ERROR;  in doReceiver()
148       sendMessage(mResultPipeFds, message);  in doReceiver()
157       message.data.command = PipeCommand::INIT_ERROR;  in doReceiver()
158       sendMessage(mResultPipeFds, message);  in doReceiver()
161     message.data.command = PipeCommand::INIT_OK;  in doReceiver()
162     sendMessage(mResultPipeFds, message);  in doReceiver()
165     receiveMessage(mCommandPipeFds, &message);  in doReceiver()
172           message.data.connectionId, message.data.transactionId,  in doReceiver()
173           message.data.bufferId, message.data.timestampUs, &rhandle, &rbuffer);  in doReceiver()
174       mManager->close(message.data.connectionId);  in doReceiver()
176           message.data.command = PipeCommand::RECEIVE_ERROR;  in doReceiver()
177           sendMessage(mResultPipeFds, message);  in doReceiver()
181           message.data.command = PipeCommand::RECEIVE_ERROR;  in doReceiver()
182           sendMessage(mResultPipeFds, message);  in doReceiver()
200       message.data.command = PipeCommand::RECEIVE_OK;  in doReceiver()
202       message.data.command = PipeCommand::RECEIVE_ERROR;  in doReceiver()
204     sendMessage(mResultPipeFds, message);  in doReceiver()
211   PipeMessage message;  in TEST_F()  local
213   ASSERT_TRUE(receiveMessage(mResultPipeFds, &message));  in TEST_F()
248     message.data.command = PipeCommand::SEND;  in TEST_F()
249     message.data.bufferId = sbuffer->mId;  in TEST_F()
250     message.data.connectionId = receiverId;  in TEST_F()
251     message.data.transactionId = transactionId;  in TEST_F()
252     message.data.timestampUs = postUs;  in TEST_F()
253     sendMessage(mCommandPipeFds, message);  in TEST_F()
269   EXPECT_TRUE(receiveMessage(mResultPipeFds, &message));  in TEST_F()
270   EXPECT_TRUE(message.data.command == PipeCommand::RECEIVE_OK);  in TEST_F()