| /freebsd/tools/tools/netmap/ |
| H A D | lb.8 | 44 reads packets from an input netmap port and sends them to a number of netmap pipes,
58 Add a new pipe group of the given number of pipes.
60 among the available pipes.
61 The receiving ends of the pipes
75 option is given, a single group of two pipes with default name is assumed.
83 all pipes in all groups and work as an extension of the pipe rings.
103 pipes are read-only: they must not modify the buffers or the pipe ring slots
|
| /freebsd/contrib/ntp/sntp/libevent/test/ |
| H A D | bench_cascade.c | 63 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 D | bench.c | 70 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 D | bench_cascade.c | 63 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 D | bench.c | 70 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 D | sigfastblock2.sh | 51 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 D | pipe.sh | 75 #define PIPES 64
82 int fds[PIPES][2];
85 for (i = 0; i < PIPES; i++) {
92 for (i = 0; i < PIPES; i++) {
102 if (i != PIPES - 1)
112 for (i = 0; i < PIPES; i++) {
|
| H A D | selfd.sh | 77 #define PIPES 32
92 int fds[PIPES][2], i, n, r;
99 for (i = 0; i < PIPES; i++) {
114 n = arc4random() % PIPES;
117 if ((n = select(PIPES, &rset, NULL, NULL, &timeout)) < 0)
|
| H A D | pipe2.sh | 74 #define PIPES 128
100 if (share[R2] >= PIPES)
119 if (share[R2] == PIPES) {
|
| /freebsd/tests/sys/kern/pipe/ |
| H A D | pipe_overcommit1_test.c | 35 * This program just allocates as many pipes as it can to ensure
42 int pipes[10000]; in main() local
45 for (i = 0; i < nitems(pipes); i++) in main()
46 (void)pipe(&pipes[i]); in main()
|
| H A D | pipe_overcommit2_test.c | 47 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()
|
| /freebsd/contrib/flex/src/ |
| H A D | filter.c | 130 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()
167 flexfatal (_("dup2(pipes[0],0)")); 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()
194 flexfatal (_("dup2(pipes[1],1)")); in filter_apply_chain()
195 close (pipes[1]); in filter_apply_chain()
|
| /freebsd/crypto/openssl/ssl/record/ |
| H A D | ssl3_buffer.c | 168 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/sys/contrib/dev/athk/ath10k/ |
| H A D | usb.c | 120 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 D | usb.h | 59 /* tx/rx pipes for usb */
98 struct ath10k_usb_pipe pipes[ATH10K_USB_PIPE_MAX]; member
|
| /freebsd/contrib/netbsd-tests/fs/common/ |
| H A D | fstest_nfs.c | 83 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/share/doc/psd/20.ipctut/ |
| H A D | tutor.me | 59 demonstrate in a simple way the use of pipes, socketpairs, sockets
90 Pipes are another form of descriptor that have been used in UNIX
92 Pipes allow one-way data transmission from one process
180 .sh 1 "Pipes"
213 It is in this way that the shell is able to set up pipes. Before executing
261 the parent creates two pipes, one for use in each direction.
277 Berkeley UNIX 4.4BSD provides a slight generalization of pipes. A pipe is a
284 an extension of pipes, their use resembles that of pipes.
329 Pipes and socketpairs are a simple solution for communicating between
333 Neither standard UNIX pipes nor socketpairs are
[all …]
|
| /freebsd/share/doc/psd/21.ipc/ |
| H A D | 1.t | 60 pipes (the mpx files which were part of Version 7 were
61 experimental). Unfortunately, pipes are very restrictive
65 Further, the semantics of pipes makes them almost impossible
|
| /freebsd/sys/security/audit/ |
| H A D | audit_pipe.c | 66 static MALLOC_DEFINE(M_AUDIT_PIPE, "audit_pipe", "Audit pipes");
89 * Audit pipes allow processes to express "interest" in the set of records
194 * Global list of audit pipes, rwlock to protect it. Individual record
195 * queues on pipes are protected by per-pipe locks; these locks synchronize
196 * between threads walking the list to deliver to individual pipes and add/
197 * remove of pipes, and are mostly acquired for read.
249 * Some global statistics on audit pipes.
251 static int audit_pipe_count; /* Current number of pipes. */
252 static u_int64_t audit_pipe_ever; /* Pipes ever allocated. */
510 * Lockless read to avoid lock overhead if pipes are not in use. in audit_pipe_submit()
[all …]
|
| /freebsd/contrib/netbsd-tests/kernel/kqueue/write/ |
| H A D | t_pipe.c | 53 "Checks EVFILT_WRITE for pipes. This test used to trigger " in ATF_TC_HEAD()
76 "Checks EVFILT_WRITE for pipes. This test used to trigger problem " in ATF_TC_HEAD()
118 "Checks EVFILT_WRITE for pipes. This test used to trigger problem " in ATF_TC_HEAD()
|
| /freebsd/sys/sys/ |
| H A D | pipe.h | 26 * Pipe buffer size, keep moderate in value, pipes take kva space.
72 * Information to support direct transfers between processes for pipes.
102 * Two of these are linked together to produce bi-directional pipes.
|
| /freebsd/contrib/diff/src/ |
| H A D | util.c | 198 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/kern/ |
| H A D | sys_pipe.c | 23 * pipes scheme originally used in FreeBSD/4.4Lite. It does not support
24 * all features of sockets, but does do everything that pipes normally
30 * write mode. The small write mode acts like conventional pipes with
49 * In order to limit the resource use of pipes, two sysctls exist:
56 * memory in use by pipes.
62 * New pipes are given 16K of memory backing, pipes may dynamically
65 * New pipes are given 4K (or PAGE_SIZE) of memory backing,
66 * existing pipes may NOT grow.
68 * New pipes are given 4K (or PAGE_SIZE) of memory backing,
69 * existing pipes will be shrunk down to 4K whenever possible.
[all …]
|
| /freebsd/share/man/man4/ |
| H A D | auditpipe.4 | 49 Audit pipes are available via a clonable special device,
103 By default, the audit pipe facility configures pipes to present records
106 However, the preselection mechanism for audit pipes can be configured using
|
| /freebsd/contrib/llvm-project/llvm/include/llvm/Analysis/ |
| H A D | InteractiveModelRunner.h | 24 /// uses 2 files - ideally named pipes - one to send data to that agent, and
37 /// Note that the host can either open the pipes RW, or open first the pipe to
|