HomeSort by relevance Sort by last modified time
    Searched defs:pipes (Results 1 - 25 of 28) sorted by null

1 2

  /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

Completed in 521 milliseconds

1 2