/external/compiler-rt/test/tsan/ |
fd_close_norace2.cc | 6 int pipes[2]; variable 10 while (read(pipes[0], &x, 1) != 1) { 12 close(pipes[0]); 13 close(pipes[1]); 18 if (pipe(pipes)) 23 while (write(pipes[1], &t, 1) != 1) {
|
/external/toybox/toys/other/ |
oneit.c | 65 int i, pid, pipes[] = {SIGUSR1, SIGUSR2, SIGTERM, SIGINT}; local 68 for (i = 0; i<ARRAY_LEN(pipes); i++) xsignal(pipes[i], oneit_signaled); 75 xpipe(pipes);
|
/external/compiler-rt/lib/asan/scripts/ |
symbolize.py | 17 pipes = {} variable 65 if not pipes.has_key(binary): 66 pipes[binary] = subprocess.Popen(["addr2line", "-i", "-f", "-e", binary], 68 p = pipes[binary]
|
/external/ltp/testcases/kernel/syscalls/pipe/ |
pipe06.c | 25 * Check what happens when the system runs out of pipes. 28 * Issue enough pipe calls to run the system out of pipes. 53 int pipe_ret, pipes[2]; variable 70 TEST(pipe(pipes)); 102 pipe_ret = pipe(pipes);
|
pipe05.c | 54 intptr_t pipes; variable 85 TEST(pipe((int *)pipes));
|
pipe07.c | 23 * descriptors permitted (or (maxfds - 3)/2 pipes) 27 * 2. open pipes until EMFILE is returned 28 * 3. check to see that the number of pipes opened is (maxfds - 3) / 2 60 int pipes[2], max_fd = 0; local 72 ret = pipe(pipes); 82 max_fd = MAX(pipes[0], max_fd); 83 max_fd = MAX(pipes[1], max_fd); 87 tst_resm(TPASS, "Opened %d pipes", npipes); 89 tst_resm(TFAIL, "Unable to open maxfds/2 pipes");
|
/external/strace/tests/ |
attach-f-p.c | 54 static pipefd pipes[N]; variable 62 if (read(pipes[no][0], &i, sizeof(i)) != (int) sizeof(i)) 79 if (pipe(pipes[i])) 102 if (write(pipes[i][1], &i, sizeof(i)) != (int) sizeof(i))
|
/external/strace/tests-m32/ |
attach-f-p.c | 54 static pipefd pipes[N]; variable 62 if (read(pipes[no][0], &i, sizeof(i)) != (int) sizeof(i)) 79 if (pipe(pipes[i])) 102 if (write(pipes[i][1], &i, sizeof(i)) != (int) sizeof(i))
|
/external/strace/tests-mx32/ |
attach-f-p.c | 54 static pipefd pipes[N]; variable 62 if (read(pipes[no][0], &i, sizeof(i)) != (int) sizeof(i)) 79 if (pipe(pipes[i])) 102 if (write(pipes[i][1], &i, sizeof(i)) != (int) sizeof(i))
|
/external/ltp/testcases/kernel/syscalls/splice/ |
splice01.c | 92 int pipes[2]; local 96 SAFE_PIPE(cleanup, pipes); 99 ret = splice(fd_in, NULL, pipes[1], NULL, TEST_BLOCK_SIZE, 0); 103 ret = splice(pipes[0], NULL, fd_out, NULL, TEST_BLOCK_SIZE, 0); 109 close(pipes[0]); 110 close(pipes[1]);
|
splice03.c | 58 static int pipes[2]; variable 68 { &badfd, NULL, &pipes[1], NULL, EBADF }, 69 { &pipes[0], NULL, &badfd, NULL, EBADF }, 70 { &wrfd, NULL, &pipes[1], NULL, EBADF }, 71 { &pipes[0], NULL, &appendfd, NULL, EINVAL }, 73 { &pipes[0], &offset, &wrfd, NULL, ESPIPE }, 74 { &rdfd, NULL, &pipes[1], &offset, ESPIPE }, 125 SAFE_PIPE(cleanup, pipes); 127 SAFE_WRITE(cleanup, 1, pipes[1], STR, sizeof(STR) - 1); 162 if (pipes[0] && close(pipes[0]) < 0 [all...] |
/external/ltp/testcases/kernel/syscalls/tee/ |
tee02.c | 45 static int pipes[2]; variable 52 { &fd, &pipes[1], EINVAL }, 53 { &pipes[0], &fd, EINVAL }, 54 { &pipes[0], &pipes[1], EINVAL }, 98 SAFE_PIPE(cleanup, pipes); 99 SAFE_WRITE(cleanup, 1, pipes[1], STR, sizeof(STR) - 1); 127 if (pipes[0] && close(pipes[0]) < 0) 128 tst_resm(TWARN | TERRNO, "close pipes[0] failed") [all...] |
/external/libbrillo/brillo/message_loops/ |
message_loop_unittest.cc | 278 ScopedPipe pipes[kNumTasks]; local 283 FROM_HERE, pipes[i].writer, MessageLoop::kWatchWrite, 324 ScopedPipe pipes[kNumTasks]; local 328 auto fd_callback = [this, &pipes, &reads, &total_calls](int i) { 332 EXPECT_EQ(1, HANDLE_EINTR(read(pipes[i].reader, &c, 1))); 339 FROM_HERE, pipes[i].reader, MessageLoop::kWatchRead, 347 HANDLE_EINTR(write(pipes[i].writer, blob.data(), blob.size()))); 356 EXPECT_GE(reads[i], 10) << "Reading from pipes[" << i << "], fd " 357 << pipes[i].reader;
|
/external/ltp/testcases/kernel/syscalls/vmsplice/ |
vmsplice01.c | 96 int pipes[2]; local 106 SAFE_PIPE(cleanup, pipes); 109 struct pollfd pfd = {.fd = pipes[1], .events = POLLOUT}; 121 written = vmsplice(pipes[1], &v, 1, 0); 133 ret = splice(pipes[0], NULL, fd_out, &offset, written, 0); 139 close(pipes[0]); 140 close(pipes[1]);
|
vmsplice02.c | 52 static int pipes[2]; variable 63 { &pipes[1], &ivc, IOV_MAX + 1, EINVAL }, 113 SAFE_PIPE(cleanup, pipes); 144 if (pipes[0] && close(pipes[0]) < 0) 145 tst_resm(TWARN | TERRNO, "close pipes[0] failed"); 147 if (pipes[1] && close(pipes[1]) < 0) 148 tst_resm(TWARN | TERRNO, "close pipes[1] failed");
|
/external/autotest/client/site_tests/security_ptraceRestrictions/src/ |
thread-prctl.c | 47 int pipes[2]; variable 78 close(pipes[1]); 82 saw = read(pipes[0], buf, 3); 124 close(pipes[0]); 157 write(pipes[1], "ok\n", 3); 220 if (pipe(pipes)<0) { 249 /* Leave the pipes for the tracee and tracer. */ 250 close(pipes[0]); 251 close(pipes[1]);
|
/external/mesa3d/src/gallium/drivers/r300/ |
r300_texture_desc.c | 323 * GPU Pipes 4x4 mode 8x8 mode 336 * With 2 pipes and an image of size 8xY, where Y >= 1, 344 * With 4 pipes and an image of size 8xY, where Y >= 4, 359 unsigned i, pipes; local 362 pipes = screen->info.r300_num_z_pipes; 364 pipes = screen->info.r300_num_gb_pipes; 382 zmask_blocks_x_per_dw[pipes-1] * zcompsize, 383 zmask_blocks_y_per_dw[pipes-1] * zcompsize); 387 zcomp_numdw <= screen->caps.zmask_ram * pipes) { 392 util_align_npot(stride, zmask_blocks_x_per_dw[pipes-1] * zcompsize) [all...] |
/system/extras/alloc-stress/ |
alloc-stress.cpp | 206 auto pipes = Pipe::createPipePair(); local 209 createProcess(std::move(std::get<1>(pipes)), argv[0], arg); 210 Pipe &p = std::get<0>(pipes);
|
/frameworks/base/services/backup/java/com/android/server/backup/ |
KeyValueAdbBackupEngine.java | 234 ParcelFileDescriptor[] pipes = null; local 236 pipes = ParcelFileDescriptor.createPipe(); 246 KeyValueAdbBackupDataCopier runner = new KeyValueAdbBackupDataCopier(mCurrentPackage, pipes[1], 248 pipes[1].close(); // the runner has dup'd it 249 pipes[1] = null; 254 BackupManagerService.routeSocketDataToOutput(pipes[0], mOutput); 268 if (pipes != null) { 269 IoUtils.closeQuietly(pipes[0]); 270 IoUtils.closeQuietly(pipes[1]);
|
/frameworks/native/libs/binder/tests/ |
binderThroughputTest.cpp | 275 vector<Pipe> pipes; local 303 pipes.push_back(make_worker(i, iterations, workers, payload_size, cs_pair)); 305 wait_all(pipes); 312 signal_all(pipes); 313 wait_all(pipes); 322 signal_all(pipes); 326 pipes[i].recv(tmp_results); 333 signal_all(pipes);
|
schd-dbg.cpp | 466 vector<Pipe> pipes; local 478 pipes.push_back(make_process(i, iterations, no_process, payload_size)); 481 wait_all(pipes); 483 signal_all(pipes); 485 wait_all(pipes); 487 signal_all(pipes); 491 pipes[i].signal();
|
/external/toybox/lib/ |
xwrap.c | 193 // pipes[2]: stdin, stdout of new process, only allocated if zero on way in, 196 pid_t xpopen_both(char **argv, int *pipes) 200 // Make the pipes? Note this won't set either pipe to 0 because if fds are 202 if (pipes) { 204 if (pipes[pid] != 0) continue; 206 pipes[pid] = cestnepasun[pid+1]; 213 if (pipes) { 216 if (pipes[1] != -1) close(cestnepasun[2]); 217 if (pipes[0] != -1) { 224 if (pipes[1] != -1) 286 int pipes[2], pid; local [all...] |
/external/fio/engines/ |
net.c | 30 int pipes[2]; member in struct:netio_data 378 return splice_io_u(io_u->file->fd, nd->pipes[1], io_u->xfer_buflen); 389 return splice_io_u(nd->pipes[0], io_u->file->fd, len); 427 return vmsplice_io_u(io_u, nd->pipes[0], len); 437 return vmsplice_io_u(io_u, nd->pipes[1], io_u->xfer_buflen); 1351 if (nd->pipes[0] != -1) 1352 close(nd->pipes[0]); 1353 if (nd->pipes[1] != -1) 1354 close(nd->pipes[1]); 1375 nd->pipes[0] = nd->pipes[1] = -1 [all...] |
/external/valgrind/VEX/priv/ |
tilegx_disasm.h | 1238 /* A bit mask of which of the five pipes this instruction 1245 unsigned char pipes; member in struct:tilegx_opcode
|
/toolchain/binutils/binutils-2.25/include/opcode/ |
tilegx.h | 1219 /* A bit mask of which of the five pipes this instruction 1226 unsigned char pipes; member in struct:tilegx_opcode
|