Searched refs:pipes (Results 1 – 8 of 8) sorted by relevance
| /frameworks/base/services/backup/java/com/android/server/backup/fullbackup/ |
| D | FullBackupObbConnection.java | 79 ParcelFileDescriptor[] pipes = null; in backupObbs() local
81 pipes = ParcelFileDescriptor.createPipe(); in backupObbs()
87 mService.backupObbs(pkg.packageName, pipes[1], token, in backupObbs()
89 FullBackupUtils.routeSocketDataToOutput(pipes[0], out); in backupObbs()
96 if (pipes != null) { in backupObbs()
97 if (pipes[0] != null) { in backupObbs()
98 pipes[0].close(); in backupObbs()
100 if (pipes[1] != null) { in backupObbs()
101 pipes[1].close(); in backupObbs()
|
| D | FullBackupEngine.java | 232 ParcelFileDescriptor[] pipes = null; in backupOnePackage() local
234 pipes = ParcelFileDescriptor.createPipe(); in backupOnePackage()
241 pipes[1], in backupOnePackage()
244 pipes[1].close(); // the runner has dup'd it in backupOnePackage()
245 pipes[1] = null; in backupOnePackage()
249 FullBackupUtils.routeSocketDataToOutput(pipes[0], mOutput); in backupOnePackage()
266 if (pipes != null) { in backupOnePackage()
267 if (pipes[0] != null) { in backupOnePackage()
268 pipes[0].close(); in backupOnePackage()
270 if (pipes[1] != null) { in backupOnePackage()
[all …]
|
| D | PerformFullTransportBackupTask.java | 661 void cleanUpPipes(ParcelFileDescriptor[] pipes) { in cleanUpPipes() argument
662 if (pipes != null) { in cleanUpPipes()
663 if (pipes[0] != null) { in cleanUpPipes()
664 ParcelFileDescriptor fd = pipes[0]; in cleanUpPipes()
665 pipes[0] = null; in cleanUpPipes()
672 if (pipes[1] != null) { in cleanUpPipes()
673 ParcelFileDescriptor fd = pipes[1]; in cleanUpPipes()
674 pipes[1] = null; in cleanUpPipes()
|
| /frameworks/base/services/backup/java/com/android/server/backup/ |
| D | KeyValueAdbBackupEngine.java | 258 ParcelFileDescriptor[] pipes = null; in writeBackupData() local
260 pipes = ParcelFileDescriptor.createPipe(); in writeBackupData()
270 … KeyValueAdbBackupDataCopier runner = new KeyValueAdbBackupDataCopier(mCurrentPackage, pipes[1], in writeBackupData()
272 pipes[1].close(); // the runner has dup'd it in writeBackupData()
273 pipes[1] = null; in writeBackupData()
278 FullBackupUtils.routeSocketDataToOutput(pipes[0], mOutput); in writeBackupData()
292 if (pipes != null) { in writeBackupData()
293 IoUtils.closeQuietly(pipes[0]); in writeBackupData()
294 IoUtils.closeQuietly(pipes[1]); in writeBackupData()
|
| /frameworks/native/libs/binder/tests/ |
| D | binderThroughputTest.cpp | 282 vector<Pipe> pipes; in run_main() local
285 pipes.push_back(make_worker(i, iterations, workers, payload_size, cs_pair)); in run_main()
287 wait_all(pipes); in run_main()
293 signal_all(pipes); in run_main()
294 wait_all(pipes); in run_main()
303 signal_all(pipes); in run_main()
307 pipes[i].recv(tmp_results); in run_main()
313 signal_all(pipes); in run_main()
|
| D | schd-dbg.cpp | 466 vector<Pipe> pipes; in main() local
478 pipes.push_back(make_process(i, iterations, no_process, payload_size)); in main()
481 wait_all(pipes); in main()
483 signal_all(pipes); in main()
485 wait_all(pipes); in main()
487 signal_all(pipes); in main()
491 pipes[i].signal(); in main()
|
| /frameworks/av/media/bufferpool/2.0/tests/ |
| D | multi.cpp | 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()
|
| /frameworks/av/media/bufferpool/1.0/vts/ |
| D | multi.cpp | 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()
|