131             write(c2pPipe.writeFd(), "poo", 3);  in TEST_F()
136         c2pPipe.writeFd().reset();  in TEST_F()
155         p2cPipe.writeFd().reset();  in TEST_F()
157         ASSERT_TRUE(WriteStringToFd(HEAD, c2pPipe.writeFd()));  in TEST_F()
158         ASSERT_TRUE(DoDataStream(p2cPipe.readFd(), c2pPipe.writeFd()));  in TEST_F()
160         c2pPipe.writeFd().reset();  in TEST_F()
165         c2pPipe.writeFd().reset();  in TEST_F()
168                   buffer.readProcessedDataInStream(tf.fd, std::move(p2cPipe.writeFd()),  in TEST_F()
185         p2cPipe.writeFd().reset();  in TEST_F()
191         ASSERT_TRUE(WriteStringToFd(data, c2pPipe.writeFd()));  in TEST_F()
193         c2pPipe.writeFd().reset();  in TEST_F()
198         c2pPipe.writeFd().reset();  in TEST_F()
201                   buffer.readProcessedDataInStream(tf.fd, std::move(p2cPipe.writeFd()),  in TEST_F()
216         p2cPipe.writeFd().reset();  in TEST_F()
218         ASSERT_TRUE(DoDataStream(p2cPipe.readFd(), c2pPipe.writeFd()));  in TEST_F()
220         c2pPipe.writeFd().reset();  in TEST_F()
224         c2pPipe.writeFd().reset();  in TEST_F()
227                   buffer.readProcessedDataInStream(tf.fd, std::move(p2cPipe.writeFd()),  in TEST_F()
244         p2cPipe.writeFd().reset();  in TEST_F()
246         ASSERT_TRUE(DoDataStream(p2cPipe.readFd(), c2pPipe.writeFd()));  in TEST_F()
248         c2pPipe.writeFd().reset();  in TEST_F()
252         c2pPipe.writeFd().reset();  in TEST_F()
255                   buffer.readProcessedDataInStream(fd, std::move(p2cPipe.writeFd()),  in TEST_F()
278         p2cPipe.writeFd().reset();  in TEST_F()
280         ASSERT_TRUE(DoDataStream(p2cPipe.readFd(), c2pPipe.writeFd()));  in TEST_F()
282         c2pPipe.writeFd().reset();  in TEST_F()
286         c2pPipe.writeFd().reset();  in TEST_F()
289                   buffer.readProcessedDataInStream(fd, std::move(p2cPipe.writeFd()),  in TEST_F()
312         p2cPipe.writeFd().reset();  in TEST_F()
320         c2pPipe.writeFd().reset();  in TEST_F()
323                   buffer.readProcessedDataInStream(tf.fd, std::move(p2cPipe.writeFd()),  in TEST_F()