Home
last modified time | relevance | path

Searched refs:pipes (Results 1 – 25 of 81) sorted by relevance

1234

/freebsd/contrib/ntp/sntp/libevent/test/
H A Dbench_cascade.c63 static evutil_socket_t *pipes; variable
88 pipes = (evutil_socket_t *)calloc(num_pipes * 2, sizeof(evutil_socket_t)); in run_once()
90 if (events == NULL || pipes == NULL) { in run_once()
95 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
109 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
119 if (send(pipes[1], "e", 1, 0) < 0) in run_once()
127 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
133 free(pipes); in run_once()
H A Dbench.c70 static evutil_socket_t *pipes; variable
91 n = send(pipes[2 * widx + 1], "e", 1, 0); in read_cb()
106 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
119 (void) send(pipes[i * space + 1], "e", 1, 0); in run_once()
198 pipes = calloc(num_pipes * 2, sizeof(evutil_socket_t));
199 if (events == NULL || pipes == NULL) {
215 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
/freebsd/contrib/libevent/test/
H A Dbench_cascade.c63 static evutil_socket_t *pipes; variable
88 pipes = (evutil_socket_t *)calloc(num_pipes * 2, sizeof(evutil_socket_t)); in run_once()
90 if (events == NULL || pipes == NULL) { in run_once()
95 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
109 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
119 if (send(pipes[1], "e", 1, 0) < 0) in run_once()
127 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
133 free(pipes); in run_once()
H A Dbench.c70 static evutil_socket_t *pipes; variable
91 n = send(pipes[2 * widx + 1], "e", 1, 0); in read_cb()
106 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) { in run_once()
119 (void) send(pipes[i * space + 1], "e", 1, 0); in run_once()
198 pipes = calloc(num_pipes * 2, sizeof(evutil_socket_t));
199 if (events == NULL || pipes == NULL) {
215 for (cp = pipes, i = 0; i < num_pipes; i++, cp += 2) {
/freebsd/tools/test/stress2/misc/
H A Dsigfastblock2.sh51 static int pipes[2];
64 // Write a byte to the write end of pipes.
67 ssize_t amt = write(pipes[1], &c, 1);
95 // Make our self-pipes.
96 assert_noerr(pipe(pipes));
110 ssize_t amt = read(pipes[0], buf, sizeof buf);
H A Dcontext.sh58 * Pass a token thru pipes to CHILDREN+1 processes in a circular list
H A Dcontext2.sh56 * Pass a token thru pipes to NTHREADS+1 threads in a circular list.
/freebsd/tests/sys/kern/pipe/
H A Dpipe_overcommit2_test.c47 int lastfd, pipes[10000], returnval; in main() local
55 for (i = 0; i < nitems(pipes); i++) { in main()
65 returnval = pipe(&pipes[i]); in main()
75 returnval = pipe(&pipes[i]); in main()
H A Dpipe_overcommit1_test.c42 int pipes[10000]; in main() local
45 for (i = 0; i < nitems(pipes); i++) in main()
46 (void)pipe(&pipes[i]); in main()
/freebsd/contrib/flex/src/
H A Dfilter.c130 int pid, pipes[2]; in filter_apply_chain() local
149 if (pipe (pipes) == -1) in filter_apply_chain()
164 close (pipes[1]); in filter_apply_chain()
166 if (dup2 (pipes[0], fileno (stdin)) == -1) in filter_apply_chain()
168 close (pipes[0]); in filter_apply_chain()
192 close (pipes[0]); in filter_apply_chain()
193 if (dup2 (pipes[1], fileno (stdout)) == -1) in filter_apply_chain()
195 close (pipes[1]); in filter_apply_chain()
/freebsd/contrib/netbsd-tests/fs/common/
H A Dfstest_nfs.c83 int pipes[2]; in donewfs() local
106 if (pipe(pipes) == -1) in donewfs()
113 close(pipes[0]); in donewfs()
114 if (dup2(pipes[1], 3) == -1) in donewfs()
121 close(pipes[1]); in donewfs()
132 if (read(pipes[0], &devnull, 4) == -1) in donewfs()
/freebsd/crypto/openssl/ssl/record/
H A Dssl3_buffer.c168 size_t pipes; in ssl3_release_write_buffer() local
170 pipes = s->rlayer.numwpipes; in ssl3_release_write_buffer()
171 while (pipes > 0) { in ssl3_release_write_buffer()
172 wb = &RECORD_LAYER_get_wbuf(&s->rlayer)[pipes - 1]; in ssl3_release_write_buffer()
179 pipes--; in ssl3_release_write_buffer()
/freebsd/contrib/diff/src/
H A Dutil.c198 int pipes[2]; in begin_output() local
200 if (pipe (pipes) != 0) in begin_output()
209 close (pipes[1]); in begin_output()
210 if (pipes[0] != STDIN_FILENO) in begin_output()
212 if (dup2 (pipes[0], STDIN_FILENO) < 0) in begin_output()
214 close (pipes[0]); in begin_output()
222 close (pipes[0]); in begin_output()
223 outfile = fdopen (pipes[1], "w"); in begin_output()
/freebsd/sys/contrib/dev/athk/ath10k/
H A Dusb.c120 ath10k_usb_free_pipe_resources(ar, &ar_usb->pipes[i]); in ath10k_usb_cleanup_pipe_resources()
264 if (ar_usb->pipes[i].ar_usb) { in ath10k_usb_flush_all()
265 usb_kill_anchored_urbs(&ar_usb->pipes[i].urb_submitted); in ath10k_usb_flush_all()
266 cancel_work_sync(&ar_usb->pipes[i].io_complete_work); in ath10k_usb_flush_all()
275 ar_usb->pipes[ATH10K_USB_PIPE_RX_DATA].urb_cnt_thresh = 1; in ath10k_usb_start_recv_pipes()
278 &ar_usb->pipes[ATH10K_USB_PIPE_RX_DATA]); in ath10k_usb_start_recv_pipes()
402 ar_usb->pipes[i].urb_cnt_thresh = in ath10k_usb_hif_start()
403 ar_usb->pipes[i].urb_alloc / 2; in ath10k_usb_hif_start()
413 struct ath10k_usb_pipe *pipe = &ar_usb->pipes[pipe_id]; in ath10k_usb_hif_tx_sg()
479 return ar_usb->pipes[pipe_id].urb_cnt; in ath10k_usb_hif_get_free_queue_number()
[all …]
H A Dusb.h98 struct ath10k_usb_pipe pipes[ATH10K_USB_PIPE_MAX]; member
/freebsd/crypto/openssl/engines/
H A De_dasync.c749 unsigned int i, pipes; in dasync_cipher_helper() local
753 pipes = pipe_ctx->numpipes; in dasync_cipher_helper()
755 if (pipes == 0) { in dasync_cipher_helper()
767 if (pipe_ctx->aadctr > 0 && pipe_ctx->aadctr != pipes) in dasync_cipher_helper()
769 for (i = 0; i < pipes; i++) { in dasync_cipher_helper()
/freebsd/contrib/llvm-project/llvm/lib/Target/Hexagon/
H A DHexagonSchedule.td22 // CVI pipes from the "Hexagon Multimedia Co-Processor Extensions Arch Spec".
/freebsd/contrib/capsicum-test/
H A Dprocdesc.cc315 int pipes[2]; in PipePdforkBase() local
316 EXPECT_OK(pipe(pipes)); in PipePdforkBase()
317 pipe_ = pipes[1]; in PipePdforkBase()
327 read(pipes[0], &rc, sizeof(rc)); in PipePdforkBase()
/freebsd/contrib/llvm-project/llvm/lib/Target/ARM/
H A DARMScheduleA57WriteRes.td18 // 11 micro-ops to be issued as follows: one to I pipe, six to S pipes and
19 // four to V pipes.
/freebsd/tests/sys/aio/
H A Daio_test.c733 int pipes[2]; in aio_pipe_test() local
738 ATF_REQUIRE_MSG(pipe(pipes) != -1, in aio_pipe_test()
741 aio_context_init(&ac, pipes[0], pipes[1], PIPE_LEN); in aio_pipe_test()
745 close(pipes[0]); in aio_pipe_test()
746 close(pipes[1]); in aio_pipe_test()
/freebsd/contrib/llvm-project/llvm/lib/Target/AArch64/
H A DAArch64SchedCyclone.td30 // 4 integer pipes
46 // 2 shifter pipes: I[2..3]
69 // 2 ld/st pipes.
74 // 3 fp/vector pipes.
78 // 2 fp/vector arithmetic and multiply pipes: V[0-1]
H A DAArch64SchedA57WriteRes.td22 // 11 micro-ops to be issued down one I pipe, six S pipes and four V pipes.
/freebsd/contrib/llvm-project/llvm/lib/Target/X86/
H A DX86ScheduleZnver3.td92 // Execution pipes
96 // The processor contains 4 general purpose integer execution pipes.
186 // Execution pipes
190 // <...>, and six FPU pipes.
191 // Agner, 22.10 Floating point execution pipes
192 // There are six floating point/vector execution pipes,
230 // Some complex VADD operations are not available in all pipes.
275 // Some complex VADD operations are not available in all pipes.
302 // Some complex VADD operations are not available in all pipes.
H A DX86ScheduleBdVer2.td43 // There are total of eight pipes.
46 // Integer execution pipes
49 // Two EX (ALU) pipes.
54 // Two AGLU pipes, identical.
58 // Floating point execution pipes
61 // Four FPU pipes.
H A DX86ScheduleZnver4.td82 // Execution pipes
86 // The processor contains 4 general purpose integer execution pipes.
175 // Execution pipes
179 // <...>, and six FPU pipes.
180 // Agner, 22.10 Floating point execution pipes
181 // There are six floating point/vector execution pipes,
219 // Some complex VADD operations are not available in all pipes.
264 // Some complex VADD operations are not available in all pipes.
296 // Some complex VADD operations are not available in all pipes.

1234