| /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/ltp/testcases/kernel/syscalls/splice/ |
| splice01.c | 68 int pipes[2]; local
73 SAFE_PIPE(pipes);
75 ret = splice(fd_in, NULL, pipes[1], NULL, TEST_BLOCK_SIZE, 0);
79 ret = splice(pipes[0], NULL, fd_out, NULL, TEST_BLOCK_SIZE, 0);
85 SAFE_CLOSE(pipes[0]);
86 SAFE_CLOSE(pipes[1]);
|
| splice03.c | 57 static int pipes[2]; variable
67 { &badfd, NULL, &pipes[1], NULL, EBADF },
68 { &pipes[0], NULL, &badfd, NULL, EBADF },
69 { &wrfd, NULL, &pipes[1], NULL, EBADF },
70 { &pipes[0], NULL, &appendfd, NULL, EINVAL },
72 { &pipes[0], &offset, &wrfd, NULL, ESPIPE },
73 { &rdfd, NULL, &pipes[1], &offset, ESPIPE },
85 SAFE_PIPE(pipes);
87 SAFE_WRITE(1, pipes[1], STR, sizeof(STR) - 1);
124 if (pipes[0] > 0
[all...] |
| /external/ltp/testcases/kernel/syscalls/tee/ |
| tee02.c | 44 static int pipes[2]; variable
51 { &fd, &pipes[1], EINVAL },
52 { &pipes[0], &fd, EINVAL },
53 { &pipes[0], &pipes[1], EINVAL },
59 SAFE_PIPE(pipes);
60 SAFE_WRITE(1, pipes[1], STR, sizeof(STR) - 1);
91 if (pipes[0] > 0)
92 SAFE_CLOSE(pipes[0]);
94 if (pipes[1] > 0
[all...] |
| /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/libevent/test/ |
| bench_cascade.c | 63 static evutil_socket_t *pipes; variable
88 pipes = (evutil_socket_t *)calloc(num_pipes * 2, sizeof(evutil_socket_t));
90 if (events == NULL || pipes == NULL) {
95 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
109 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
119 if (send(pipes[1], "e", 1, 0) < 0)
127 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
133 free(pipes);
|
| bench.c | 68 static evutil_socket_t *pipes; variable
88 n = send(pipes[2 * widx + 1], "e", 1, 0);
103 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
116 (void) send(pipes[i * space + 1], "e", 1, 0);
179 pipes = calloc(num_pipes * 2, sizeof(evutil_socket_t));
180 if (events == NULL || pipes == NULL) {
187 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
|
| /external/ltp/testcases/kernel/syscalls/vmsplice/ |
| vmsplice01.c | 71 int pipes[2]; local
82 SAFE_PIPE(pipes);
84 struct pollfd pfd = {.fd = pipes[1], .events = POLLOUT};
96 written = vmsplice(pipes[1], &v, 1, 0);
108 ret = splice(pipes[0], NULL, fd_out, &offset, written, 0);
114 SAFE_CLOSE(pipes[0]);
115 SAFE_CLOSE(pipes[1]);
|
| vmsplice02.c | 52 static int pipes[2]; variable
63 { &pipes[1], &ivc, IOV_MAX + 1, EINVAL },
75 SAFE_PIPE(pipes);
109 if (pipes[0] > 0)
110 SAFE_CLOSE(pipes[0]);
112 if (pipes[1] > 0)
113 SAFE_CLOSE(pipes[1]);
|
| /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/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]);
|
| /frameworks/base/services/backup/java/com/android/server/backup/fullbackup/ |
| FullBackupObbConnection.java | 79 ParcelFileDescriptor[] pipes = null; local
81 pipes = ParcelFileDescriptor.createPipe();
87 mService.backupObbs(pkg.packageName, pipes[1], token,
89 FullBackupUtils.routeSocketDataToOutput(pipes[0], out);
96 if (pipes != null) {
97 if (pipes[0] != null) {
98 pipes[0].close();
100 if (pipes[1] != null) {
101 pipes[1].close();
|
| /cts/tests/tests/hardware/src/android/hardware/input/cts/tests/ |
| InputTestCase.java | 184 ParcelFileDescriptor[] pipes = ui.executeShellCommandRw(HID_COMMAND); local
186 mOutputStream = new ParcelFileDescriptor.AutoCloseOutputStream(pipes[1]);
187 IoUtils.closeQuietly(pipes[0]); // hid command is write-only
|
| /external/mesa3d/src/amd/addrlib/r800/ |
| egbaddrlib.cpp | 703 UINT_32 pipes, ///< [in] pipes
744 (tileSize * pipes * pTileInfo->bankWidth)
825 UINT_32 pipes = HwlGetPipes(pTileInfo); local
851 (tileSize * pipes * pTileInfo->bankWidth)
861 pipes,
867 macroTileWidth = MicroTileWidth * pTileInfo->bankWidth * pipes *
885 *pBaseAlign = pipes *
[all...] |
| /external/mesa3d/src/gallium/drivers/r300/ |
| r300_texture_desc.c | 319 * GPU Pipes 4x4 mode 8x8 mode
332 * With 2 pipes and an image of size 8xY, where Y >= 1,
340 * With 4 pipes and an image of size 8xY, where Y >= 4,
355 unsigned i, pipes; local
358 pipes = screen->info.r300_num_z_pipes;
360 pipes = screen->info.r300_num_gb_pipes;
378 zmask_blocks_x_per_dw[pipes-1] * zcompsize,
379 zmask_blocks_y_per_dw[pipes-1] * zcompsize);
383 zcomp_numdw <= screen->caps.zmask_ram * pipes) {
388 util_align_npot(stride, zmask_blocks_x_per_dw[pipes-1] * zcompsize)
419 unsigned pipes, stride, cmask_num_dw, cmask_max_size; local
[all...] |
| /external/perfetto/src/ipc/ |
| unix_socket_unittest.cc | 248 int pipes[2]; local
249 ASSERT_EQ(0, pipe(pipes));
268 ASSERT_EQ(1, PERFETTO_EINTR(write(pipes[1], ".", 1)));
288 ASSERT_EQ(1, PERFETTO_EINTR(read(pipes[0], &sync_cmd, 1)));
|
| /system/extras/alloc-stress/ |
| alloc-stress.cpp | 255 auto pipes = Pipe::createPipePair(); local
259 ch_pid = createProcess(std::move(std::get<1>(pipes)),
261 Pipe &p = std::get<0>(pipes);
|
| /external/scapy/scapy/ |
| pipetool.py | 27 pipes = {} variable in class:PipeEngine
30 for pn,pc in sorted(cls.pipes.items()):
37 for pn,pc in sorted(cls.pipes.items()):
43 def __init__(self, *pipes):
48 self._add_pipes(*pipes)
57 if dname in self.pipes:
59 k = self.pipes[dname]
102 def _add_pipes(self, *pipes):
104 for p in pipes:
181 def add(self, *pipes)
[all...] |
