/freebsd-current/sys/contrib/xen/io/ |
H A D | usbif.h | 161 * | pipe | 8 180 * pipe - uint32_t, bit field with multiple information: 276 * USB pipe in usbif_request 293 * - pipe type: bits 30-31 312 #define usbif_pipeportnum(pipe) ((pipe) & USBIF_PIPE_PORT_MASK) 313 #define usbif_setportnum_pipe(pipe, portnum) ((pipe) | (portnum)) 315 #define usbif_pipeunlink(pipe) ((pipe) 353 uint32_t pipe; member in struct:usbif_urb_request [all...] |
/freebsd-current/tools/test/stress2/misc/ |
H A D | vmtotal.sh | 32 # "pid 88456 (pipe), uid 0: exited on signal 11" 37 ../misc/pipe.sh
|
H A D | pipe.sh | 39 sed '1,/^EOF/d' < $odir/$0 > $dir/pipe.c 40 mycc -o pipe -Wall -Wextra -O0 -g pipe.c || exit 1 41 rm -f pipe.c 51 /tmp/pipe & 64 rm -rf /tmp/pipe pipe.core 86 if (pipe(fds[i]) == -1) 87 err(1, "pipe"); 91 err(1, "pipe writ [all...] |
/freebsd-current/tools/regression/tmpfs/ |
H A D | t_pipes | 44 test_name "Creation of named pipe" 45 mkfifo pipe || die 47 test_name "Writing to pipe and waiting for response" 48 echo -n foo >pipe & 49 [ "$(cat pipe)" = foo ] || die
|
/freebsd-current/sys/sys/ |
H A D | pipe.h | 98 #define PIPE_TYPE_NAMED 0x001 /* Is a named pipe. */ 101 * Per-pipe data structure. 104 struct pipe { struct 112 struct pipe *pipe_peer; /* link with other direction */ 114 u_short pipe_state; /* pipe status info */ 115 u_char pipe_type; /* pipe type info */ 119 int pipe_wgen; /* writer generation for named pipe */ 131 * Container structure to hold the two pipe endpoints, mutex, and label 135 struct pipe pp_rpipe; 136 struct pipe pp_wpip [all...] |
/freebsd-current/contrib/netbsd-tests/fs/tmpfs/ |
H A D | t_pipes.sh | 38 atf_check -s eq:0 -o empty -e empty mknod pipe p 40 echo "Writing to pipe and waiting for response" 41 echo -n foo >pipe & 42 [ "$(cat pipe)" = foo ] || atf_fail "Received data is incorrect"
|
H A D | t_mknod.sh | 100 atf_test_case pipe 109 atf_check -s eq:0 -o empty -e empty mknod pipe p 110 eval $(stat -s pipe) 118 atf_set "descr" "Tests that creating a named pipe raises the" \ 127 echo 'mknod dir/pipe p' | kqueue_monitor 1 dir 141 atf_add_test_case pipe
|
/freebsd-current/sys/contrib/dev/athk/ath12k/ |
H A D | ce.c | 222 static int ath12k_ce_rx_buf_enqueue_pipe(struct ath12k_ce_pipe *pipe, argument 225 struct ath12k_base *ab = pipe->ab; 226 struct ath12k_ce_ring *ring = pipe->dest_ring; 260 pipe->rx_buf_needed--; 271 static int ath12k_ce_rx_post_pipe(struct ath12k_ce_pipe *pipe) argument 273 struct ath12k_base *ab = pipe->ab; 278 if (!(pipe->dest_ring || pipe->status_ring)) 282 while (pipe->rx_buf_needed) { 283 skb = dev_alloc_skb(pipe 319 ath12k_ce_completed_recv_next(struct ath12k_ce_pipe *pipe, struct sk_buff **skb, int *nbytes) argument 369 ath12k_ce_recv_process_cb(struct ath12k_ce_pipe *pipe) argument 409 ath12k_ce_completed_send_next(struct ath12k_ce_pipe *pipe) argument 450 ath12k_ce_send_done_cb(struct ath12k_ce_pipe *pipe) argument 582 struct ath12k_ce_pipe *pipe = &ab->ce.ce_pipe[ce_id]; local 621 struct ath12k_ce_pipe *pipe = &ab->ce.ce_pipe[ce_id]; local 632 struct ath12k_ce_pipe *pipe = &ab->ce.ce_pipe[pipe_id]; local 641 struct ath12k_ce_pipe *pipe = &ab->ce.ce_pipe[pipe_id]; local 719 ath12k_ce_rx_pipe_cleanup(struct ath12k_ce_pipe *pipe) argument 743 struct ath12k_ce_pipe *pipe; local 759 struct ath12k_ce_pipe *pipe; local 827 struct ath12k_ce_pipe *pipe; local 888 struct ath12k_ce_pipe *pipe; local 933 struct ath12k_ce_pipe *pipe; local [all...] |
/freebsd-current/sys/contrib/dev/athk/ath11k/ |
H A D | ce.c | 271 static int ath11k_ce_rx_buf_enqueue_pipe(struct ath11k_ce_pipe *pipe, argument 274 struct ath11k_base *ab = pipe->ab; 275 struct ath11k_ce_ring *ring = pipe->dest_ring; 309 pipe->rx_buf_needed--; 320 static int ath11k_ce_rx_post_pipe(struct ath11k_ce_pipe *pipe) argument 322 struct ath11k_base *ab = pipe->ab; 327 if (!(pipe->dest_ring || pipe->status_ring)) 331 while (pipe->rx_buf_needed) { 332 skb = dev_alloc_skb(pipe 369 ath11k_ce_completed_recv_next(struct ath11k_ce_pipe *pipe, struct sk_buff **skb, int *nbytes) argument 419 ath11k_ce_recv_process_cb(struct ath11k_ce_pipe *pipe) argument 459 ath11k_ce_completed_send_next(struct ath11k_ce_pipe *pipe) argument 500 ath11k_ce_tx_process_cb(struct ath11k_ce_pipe *pipe) argument 652 struct ath11k_ce_pipe *pipe = &ab->ce.ce_pipe[ce_id]; local 691 struct ath11k_ce_pipe *pipe = &ab->ce.ce_pipe[ce_id]; local 703 struct ath11k_ce_pipe *pipe = &ab->ce.ce_pipe[pipe_id]; local 714 struct ath11k_ce_pipe *pipe = &ab->ce.ce_pipe[pipe_id]; local 801 ath11k_ce_rx_pipe_cleanup(struct ath11k_ce_pipe *pipe) argument 868 struct ath11k_ce_pipe *pipe; local 887 struct ath11k_ce_pipe *pipe; local 918 struct ath11k_ce_pipe *pipe; local 976 struct ath11k_ce_pipe *pipe; local 1029 struct ath11k_ce_pipe *pipe; local [all...] |
/freebsd-current/lib/libc/sys/ |
H A D | pipe.c | 34 __weak_reference(__sys_pipe, pipe);
|
/freebsd-current/sys/contrib/dev/athk/ath10k/ |
H A D | usb.c | 34 /* pipe/urb operations */ 36 ath10k_usb_alloc_urb_from_pipe(struct ath10k_usb_pipe *pipe) argument 41 /* bail if this pipe is not initialized */ 42 if (!pipe->ar_usb) 45 spin_lock_irqsave(&pipe->ar_usb->cs_lock, flags); 46 if (!list_empty(&pipe->urb_list_head)) { 47 urb_context = list_first_entry(&pipe->urb_list_head, 50 pipe->urb_cnt--; 52 spin_unlock_irqrestore(&pipe->ar_usb->cs_lock, flags); 57 static void ath10k_usb_free_urb_to_pipe(struct ath10k_usb_pipe *pipe, argument 82 ath10k_usb_free_pipe_resources(struct ath10k *ar, struct ath10k_usb_pipe *pipe) argument 128 struct ath10k_usb_pipe *pipe = urb_context->pipe; local 185 struct ath10k_usb_pipe *pipe = urb_context->pipe; local 362 struct ath10k_usb_pipe *pipe = container_of(work, local 413 struct ath10k_usb_pipe *pipe = &ar_usb->pipes[pipe_id]; local 791 ath10k_usb_alloc_pipe_resources(struct ath10k *ar, struct ath10k_usb_pipe *pipe, int urb_cnt) argument 829 struct ath10k_usb_pipe *pipe; local 938 struct ath10k_usb_pipe *pipe; local [all...] |
/freebsd-current/contrib/netbsd-tests/kernel/kqueue/read/ |
H A D | t_pipe.c | 46 ATF_TC(pipe); variable 47 ATF_TC_HEAD(pipe, tc) 51 ATF_TC_BODY(pipe, tc) 58 RL(pipe(fds)); 64 /* make sure there is something in the pipe */ 66 (void)printf("pipe: wrote 'foo' to pipe\n"); 79 (void)printf("pipe: read '%s'\n", buffer); 80 (void)printf("pipe: successful end\n"); 85 ATF_TP_ADD_TC(tp, pipe); [all...] |
/freebsd-current/tests/examples/ |
H A D | test_examples.py | 147 inside vnetX jail. The framework automatically creates a pipe 182 iface_alias = self.wait_object(vnet.pipe, None) 185 self.send_object(vnet.pipe, self._get_iface_stat(os_ifname)) 192 pipe = second_vnet.pipe 195 self.send_object(pipe, "if1") 196 old_stat = self.wait_object(pipe) 198 self.send_object(pipe, "if1") 199 new_stat = self.wait_object(pipe) 203 self.send_object(pipe, "if [all...] |
/freebsd-current/crypto/openssl/test/recipes/ |
H A D | 15-test_gensm2.t | 14 use OpenSSL::Test qw(:DEFAULT pipe); 51 my $result_ec = join("", run(pipe($cmd_genec, $cmd_asn1parse), 57 my $result_sm2 = join("", run(pipe($cmd_gensm2, $cmd_asn1parse),
|
/freebsd-current/tests/sys/ses/ |
H A D | nondestructive.c | 47 FILE *pipe; local 64 pipe = popen(cmd, "r"); 65 ATF_REQUIRE(pipe != NULL); 66 while(NULL != fgets(line, sizeof(line), pipe)) { 98 r = pclose(pipe); 250 FILE *pipe; local 266 pipe = popen(cmd, "r"); 267 ATF_REQUIRE(pipe != NULL); 268 while(NULL != fgets(line, sizeof(line), pipe)) { 300 r = pclose(pipe); 345 FILE *pipe; local 404 FILE *pipe; local 456 FILE *pipe; local 503 FILE *pipe; local 548 FILE *pipe; local 598 FILE *pipe; local [all...] |
/freebsd-current/contrib/kyua/utils/process/ |
H A D | system.cpp | 54 /// Indirection to execute the pipe(2) system call. 55 int (*detail::syscall_pipe)(int[2]) = ::pipe;
|
H A D | fdstream_test.cpp | 51 ATF_REQUIRE(::pipe(fds) != -1); 58 // XXX This assumes that the pipe's buffer is big enough to accept
|
/freebsd-current/tests/sys/kern/pipe/ |
H A D | Makefile | 2 TESTSDIR= ${TESTSBASE}/sys/kern/pipe
|
H A D | pipe_overcommit1_test.c | 36 * that using up all pipe memory doesn't cause a panic. 46 (void)pipe(&pipes[i]);
|
H A D | pipe_overcommit2_test.c | 39 * is ample memory to allocate a pipe, but the file descriptor 46 char template[] = "pipe.XXXXXXXXXX"; 63 /* First falloc failure case in sys_pipe.c:pipe() */ 65 returnval = pipe(&pipes[i]); 75 returnval = pipe(&pipes[i]);
|
H A D | pipe_ino_test.c | 47 if (pipe(pipefd) == -1) 48 err(1, "FAIL: pipe");
|
/freebsd-current/sys/contrib/dev/mediatek/mt76/ |
H A D | usb_trace.h | 58 DEV_ENTRY __field(unsigned int, pipe) __field(u32, len) 62 __entry->pipe = u->pipe; 66 DEV_PR_ARG, __entry->pipe, __entry->len)
|
/freebsd-current/contrib/wpa/wpa_supplicant/ |
H A D | ctrl_iface_named_pipe.c | 44 #define NAMED_PIPE_PREFIX TEXT("\\\\.\\pipe\\") TEXT(WPA_SUPPLICANT_NAMED_PIPE) 65 HANDLE pipe; member in struct:wpa_ctrl_dst 100 static int ctrl_broken_pipe(HANDLE pipe, int used) argument 104 if (PeekNamedPipe(pipe, NULL, 0, NULL, NULL, NULL)) 122 if (ctrl_broken_pipe(dst->pipe, dst->used)) { 123 wpa_printf(MSG_DEBUG, "CTRL: closing broken pipe %p", 141 wpa_printf(MSG_DEBUG, "CTRL: Open pipe %p", dst); 145 dst->pipe = INVALID_HANDLE_VALUE; 166 /* TODO: add support for configuring access list for the pipe */ 167 dst->pipe 547 HANDLE pipe; member in struct:wpa_global_dst [all...] |
/freebsd-current/sys/kern/ |
H A D | sys_pipe.c | 32 * "normal" pipe buffering is done. If the buffer is between PIPE_MINDIRECT 39 * is returned back to the user-mode side. In that case, the pipe code 85 * both directions of a pipe. 111 #include <sys/pipe.h> 137 #define PIPE_PEER(pipe) \ 138 (((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer)) 195 * Default pipe buffer size(s), this can be kind-of large now because pipe 698 pipe_create(struct pipe *pipe, bool large_backing) argument 1534 struct pipe *pipe; local [all...] |
/freebsd-current/sys/contrib/openzfs/include/sys/ |
H A D | edonr.h | 65 } pipe[1]; member in struct:__anon390
|