| /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 | 243 ParcelFileDescriptor[] pipes = null; in backupOnePackage() local
245 pipes = ParcelFileDescriptor.createPipe(); in backupOnePackage()
252 pipes[1], in backupOnePackage()
255 pipes[1].close(); // the runner has dup'd it in backupOnePackage()
256 pipes[1] = null; in backupOnePackage()
260 FullBackupUtils.routeSocketDataToOutput(pipes[0], mOutput); in backupOnePackage()
279 if (pipes != null) { in backupOnePackage()
280 if (pipes[0] != null) { in backupOnePackage()
281 pipes[0].close(); in backupOnePackage()
283 if (pipes[1] != null) { in backupOnePackage()
[all …]
|
| D | PerformFullTransportBackupTask.java | 702 void cleanUpPipes(ParcelFileDescriptor[] pipes) { in cleanUpPipes() argument
703 if (pipes != null) { in cleanUpPipes()
704 if (pipes[0] != null) { in cleanUpPipes()
705 ParcelFileDescriptor fd = pipes[0]; in cleanUpPipes()
706 pipes[0] = null; in cleanUpPipes()
713 if (pipes[1] != null) { in cleanUpPipes()
714 ParcelFileDescriptor fd = pipes[1]; in cleanUpPipes()
715 pipes[1] = null; in cleanUpPipes()
|
| /frameworks/base/services/backup/java/com/android/server/backup/ |
| D | KeyValueAdbBackupEngine.java | 260 ParcelFileDescriptor[] pipes = null; in writeBackupData() local
262 pipes = ParcelFileDescriptor.createPipe(); in writeBackupData()
272 … KeyValueAdbBackupDataCopier runner = new KeyValueAdbBackupDataCopier(mCurrentPackage, pipes[1], in writeBackupData()
274 pipes[1].close(); // the runner has dup'd it in writeBackupData()
275 pipes[1] = null; in writeBackupData()
280 FullBackupUtils.routeSocketDataToOutput(pipes[0], mOutput); in writeBackupData()
294 if (pipes != null) { in writeBackupData()
295 IoUtils.closeQuietly(pipes[0]); in writeBackupData()
296 IoUtils.closeQuietly(pipes[1]); in writeBackupData()
|
| /frameworks/native/libs/binder/tests/ |
| D | binderThroughputTest.cpp | 311 vector<Pipe> pipes; in run_main() local
314 pipes.push_back(make_worker(i, iterations, workers, payload_size, cs_pair)); in run_main()
316 wait_all(pipes); in run_main()
320 signal_all(pipes); in run_main()
323 wait_all(pipes); in run_main()
329 signal_all(pipes); in run_main()
330 wait_all(pipes); in run_main()
339 signal_all(pipes); in run_main()
342 pipes[i].recv(tmp_results); in run_main()
348 signal_all(pipes); in run_main()
|
| D | schd-dbg.cpp | 469 vector<Pipe> pipes; in main() local
481 pipes.push_back(make_process(i, iterations, no_process, payload_size)); in main()
484 wait_all(pipes); in main()
486 signal_all(pipes); in main()
488 wait_all(pipes); in main()
490 signal_all(pipes); in main()
494 pipes[i].signal(); in main()
|
| /frameworks/base/core/tests/coretests/src/android/app/backup/ |
| D | BackupAgentTest.java | 160 ParcelFileDescriptor[] pipes = ParcelFileDescriptor.createPipe(); in doRestoreFile_agentOverrideIgnoresFile_consumesAllBytesInBuffer() local
162 pipes[1].getFileDescriptor()); in doRestoreFile_agentOverrideIgnoresFile_consumesAllBytesInBuffer()
165 agentBinder.doRestoreFile(pipes[0], /* length= */ 5, BackupAgent.TYPE_FILE, in doRestoreFile_agentOverrideIgnoresFile_consumesAllBytesInBuffer()
169 try (FileInputStream in = new FileInputStream(pipes[0].getFileDescriptor())) { in doRestoreFile_agentOverrideIgnoresFile_consumesAllBytesInBuffer()
172 pipes[0].close(); in doRestoreFile_agentOverrideIgnoresFile_consumesAllBytesInBuffer()
173 pipes[1].close(); in doRestoreFile_agentOverrideIgnoresFile_consumesAllBytesInBuffer()
|
| /frameworks/av/media/module/bufferpool/1.0/vts/ |
| D | multi.cpp | 129 bool sendMessage(int *pipes, const PipeMessage &message) { in sendMessage() argument
130 int ret = write(pipes[1], message.array, sizeof(PipeMessage)); in sendMessage()
134 bool receiveMessage(int *pipes, PipeMessage *message) { in receiveMessage() argument
135 int ret = read(pipes[0], message->array, sizeof(PipeMessage)); in receiveMessage()
|
| /frameworks/av/media/module/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()
|
| D | cond.cpp | 130 bool sendMessage(int *pipes, const PipeMessage &message) { in sendMessage() argument
131 int ret = write(pipes[1], message.array, sizeof(PipeMessage)); in sendMessage()
135 bool receiveMessage(int *pipes, PipeMessage *message) { in receiveMessage() argument
136 int ret = read(pipes[0], message->array, sizeof(PipeMessage)); in receiveMessage()
|
| D | BufferpoolUnitTest.cpp | 149 bool sendMessage(int* pipes, const PipeMessage& message) { in sendMessage() argument
150 int ret = write(pipes[1], message.array, sizeof(PipeMessage)); in sendMessage()
154 bool receiveMessage(int* pipes, PipeMessage* message) { in receiveMessage() argument
155 int ret = read(pipes[0], message->array, sizeof(PipeMessage)); in receiveMessage()
|
| /frameworks/base/services/backup/ |
| D | flags.aconfig | 25 description: "Enables the write buffer to pipes to be of maximum size."
|
| /frameworks/base/core/java/android/os/ |
| D | FileUtils.java | 547 FileDescriptor[] pipes = Os.pipe(); in copyInternalSpliceSocket() local
551 … t = Os.splice(in, null, pipes[1], null, Math.min(countToRead, COPY_CHECKPOINT_BYTES), in copyInternalSpliceSocket()
574 … t = Os.splice(pipes[0], null, out, null, Math.min(countInPipe, COPY_CHECKPOINT_BYTES), in copyInternalSpliceSocket()
583 Os.close(pipes[0]); in copyInternalSpliceSocket()
584 Os.close(pipes[1]); in copyInternalSpliceSocket()
612 Os.close(pipes[0]); in copyInternalSpliceSocket()
613 Os.close(pipes[1]); in copyInternalSpliceSocket()
|