Home
last modified time | relevance | path

Searched refs:pipe (Results 1 – 25 of 531) sorted by relevance

12345678910>>...22

/freebsd/sys/contrib/dev/athk/ath12k/
H A Dce.c222 static int ath12k_ce_rx_buf_enqueue_pipe(struct ath12k_ce_pipe *pipe, in ath12k_ce_rx_buf_enqueue_pipe() argument
225 struct ath12k_base *ab = pipe->ab; in ath12k_ce_rx_buf_enqueue_pipe()
226 struct ath12k_ce_ring *ring = pipe->dest_ring; in ath12k_ce_rx_buf_enqueue_pipe()
260 pipe->rx_buf_needed--; in ath12k_ce_rx_buf_enqueue_pipe()
271 static int ath12k_ce_rx_post_pipe(struct ath12k_ce_pipe *pipe) in ath12k_ce_rx_post_pipe() argument
273 struct ath12k_base *ab = pipe->ab; in ath12k_ce_rx_post_pipe()
278 if (!(pipe->dest_ring || pipe->status_ring)) in ath12k_ce_rx_post_pipe()
282 while (pipe->rx_buf_needed) { in ath12k_ce_rx_post_pipe()
283 skb = dev_alloc_skb(pipe->buf_sz); in ath12k_ce_rx_post_pipe()
303 ret = ath12k_ce_rx_buf_enqueue_pipe(pipe, skb, paddr); in ath12k_ce_rx_post_pipe()
[all …]
/freebsd/sys/contrib/xen/io/
H A Dusbif.h312 #define usbif_pipeportnum(pipe) ((pipe) & USBIF_PIPE_PORT_MASK) argument
313 #define usbif_setportnum_pipe(pipe, portnum) ((pipe) | (portnum)) argument
315 #define usbif_pipeunlink(pipe) ((pipe) & USBIF_PIPE_UNLINK) argument
316 #define usbif_pipesubmit(pipe) (!usbif_pipeunlink(pipe)) argument
317 #define usbif_setunlink_pipe(pipe) ((pipe) | USBIF_PIPE_UNLINK) argument
319 #define usbif_pipein(pipe) ((pipe) & USBIF_PIPE_DIR) argument
320 #define usbif_pipeout(pipe) (!usbif_pipein(pipe)) argument
322 #define usbif_pipedevice(pipe) \ argument
323 (((pipe) >> USBIF_PIPE_DEV_SHIFT) & USBIF_PIPE_DEV_MASK)
325 #define usbif_pipeendpoint(pipe) \ argument
[all …]
/freebsd/sys/contrib/dev/athk/ath11k/
H A Dce.c271 static int ath11k_ce_rx_buf_enqueue_pipe(struct ath11k_ce_pipe *pipe, in ath11k_ce_rx_buf_enqueue_pipe() argument
274 struct ath11k_base *ab = pipe->ab; in ath11k_ce_rx_buf_enqueue_pipe()
275 struct ath11k_ce_ring *ring = pipe->dest_ring; in ath11k_ce_rx_buf_enqueue_pipe()
309 pipe->rx_buf_needed--; in ath11k_ce_rx_buf_enqueue_pipe()
320 static int ath11k_ce_rx_post_pipe(struct ath11k_ce_pipe *pipe) in ath11k_ce_rx_post_pipe() argument
322 struct ath11k_base *ab = pipe->ab; in ath11k_ce_rx_post_pipe()
327 if (!(pipe->dest_ring || pipe->status_ring)) in ath11k_ce_rx_post_pipe()
331 while (pipe->rx_buf_needed) { in ath11k_ce_rx_post_pipe()
332 skb = dev_alloc_skb(pipe->buf_sz); in ath11k_ce_rx_post_pipe()
352 ret = ath11k_ce_rx_buf_enqueue_pipe(pipe, skb, paddr); in ath11k_ce_rx_post_pipe()
[all …]
/freebsd/sys/contrib/dev/athk/ath10k/
H A Dusb.c36 ath10k_usb_alloc_urb_from_pipe(struct ath10k_usb_pipe *pipe) in ath10k_usb_alloc_urb_from_pipe() argument
42 if (!pipe->ar_usb) in ath10k_usb_alloc_urb_from_pipe()
45 spin_lock_irqsave(&pipe->ar_usb->cs_lock, flags); in ath10k_usb_alloc_urb_from_pipe()
46 if (!list_empty(&pipe->urb_list_head)) { in ath10k_usb_alloc_urb_from_pipe()
47 urb_context = list_first_entry(&pipe->urb_list_head, in ath10k_usb_alloc_urb_from_pipe()
50 pipe->urb_cnt--; in ath10k_usb_alloc_urb_from_pipe()
52 spin_unlock_irqrestore(&pipe->ar_usb->cs_lock, flags); in ath10k_usb_alloc_urb_from_pipe()
57 static void ath10k_usb_free_urb_to_pipe(struct ath10k_usb_pipe *pipe, in ath10k_usb_free_urb_to_pipe() argument
63 if (!pipe->ar_usb) in ath10k_usb_free_urb_to_pipe()
66 spin_lock_irqsave(&pipe->ar_usb->cs_lock, flags); in ath10k_usb_free_urb_to_pipe()
[all …]
H A Dce.h189 void __ath10k_ce_send_revert(struct ath10k_ce_pipe *pipe);
191 int ath10k_ce_num_free_src_entries(struct ath10k_ce_pipe *pipe);
195 int __ath10k_ce_rx_num_free_bufs(struct ath10k_ce_pipe *pipe);
196 int ath10k_ce_rx_post_buf(struct ath10k_ce_pipe *pipe, void *ctx,
198 void ath10k_ce_rx_update_write_idx(struct ath10k_ce_pipe *pipe, u32 nentries);
312 int (*ce_rx_post_buf)(struct ath10k_ce_pipe *pipe, void *ctx,
325 int (*ce_send_nolock)(struct ath10k_ce_pipe *pipe,
/freebsd/sys/sys/
H A Dpipe.h104 struct pipe { struct
112 struct pipe *pipe_peer; /* link with other direction */ argument
135 struct pipe pp_rpipe;
136 struct pipe pp_wpipe;
142 #define PIPE_MTX(pipe) (&(pipe)->pipe_pair->pp_mtx) argument
143 #define PIPE_LOCK(pipe) mtx_lock(PIPE_MTX(pipe)) argument
144 #define PIPE_UNLOCK(pipe) mtx_unlock(PIPE_MTX(pipe)) argument
145 #define PIPE_LOCK_ASSERT(pipe, type) mtx_assert(PIPE_MTX(pipe), (type)) argument
148 void pipe_dtor(struct pipe *dpipe);
149 int pipe_named_ctor(struct pipe **ppipe, struct thread *td);
[all …]
/freebsd/tests/sys/ses/
H A Dnondestructive.c47 FILE *pipe; in do_getelmdesc() local
64 pipe = popen(cmd, "r"); in do_getelmdesc()
65 ATF_REQUIRE(pipe != NULL); in do_getelmdesc()
66 while(NULL != fgets(line, sizeof(line), pipe)) { in do_getelmdesc()
98 r = pclose(pipe); in do_getelmdesc()
250 FILE *pipe; in do_getelmmap() local
266 pipe = popen(cmd, "r"); in do_getelmmap()
267 ATF_REQUIRE(pipe != NULL); in do_getelmmap()
268 while(NULL != fgets(line, sizeof(line), pipe)) { in do_getelmmap()
300 r = pclose(pipe); in do_getelmmap()
[all …]
/freebsd/sys/kern/
H A Dsys_pipe.c138 #define PIPE_PEER(pipe) \ argument
139 (((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
234 static void pipeclose(struct pipe *cpipe);
235 static void pipe_free_kmem(struct pipe *cpipe);
236 static int pipe_create(struct pipe *pipe, bool backing);
238 static __inline int pipelock(struct pipe *cpipe, bool catch);
239 static __inline void pipeunlock(struct pipe *cpipe);
242 static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);
243 static void pipe_destroy_write_buffer(struct pipe *wpipe);
244 static int pipe_direct_write(struct pipe *wpipe, struct uio *uio);
[all …]
/freebsd/contrib/wpa/wpa_supplicant/
H A Dctrl_iface_named_pipe.c65 HANDLE pipe; member
100 static int ctrl_broken_pipe(HANDLE pipe, int used) in ctrl_broken_pipe() argument
104 if (PeekNamedPipe(pipe, NULL, 0, NULL, NULL, NULL)) in ctrl_broken_pipe()
122 if (ctrl_broken_pipe(dst->pipe, dst->used)) { in ctrl_flush_broken_pipes()
145 dst->pipe = INVALID_HANDLE_VALUE; in ctrl_open_pipe()
167 dst->pipe = CreateNamedPipe(name, in ctrl_open_pipe()
175 if (dst->pipe == INVALID_HANDLE_VALUE) { in ctrl_open_pipe()
181 if (ConnectNamedPipe(dst->pipe, &dst->overlap)) { in ctrl_open_pipe()
184 CloseHandle(dst->pipe); in ctrl_open_pipe()
204 CloseHandle(dst->pipe); in ctrl_open_pipe()
[all …]
/freebsd/tests/examples/
H A Dtest_examples.py182 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, "if2")
204 old_stat = self.wait_object(pipe)
206 self.send_object(pipe, "if2")
[all …]
/freebsd/tools/test/stress2/misc/
H A Dpipe.sh39 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)
/freebsd/tests/sys/netinet6/
H A Dtest_ip6_output.py83 vnet.pipe.send(ll_data)
87 vnet.pipe.send(tx_obj)
109 self.wait_object(second_vnet.pipe)
113 rx_obj = self.wait_object(second_vnet.pipe)
134 self.wait_object(second_vnet.pipe)
139 rx_obj = self.wait_object(second_vnet.pipe)
198 self.wait_object(second_vnet.pipe)
214 rx_obj = self.wait_object(second_vnet.pipe)
239 ll_data = self.wait_object(second_vnet.pipe)
255 rx_obj = self.wait_object(second_vnet.pipe)
[all …]
/freebsd/tests/sys/netpfil/common/
H A Ddummynet.sh51 jexec alcatraz dnctl pipe 1 config delay 1500
98 jexec alcatraz dnctl pipe 1 config bw 30Byte/s
142 jexec alcatraz dnctl pipe 1 config bw 100Byte/s
186 jexec alcatraz dnctl pipe 1 config bw 10Mb queue 100 droptail
187 …jexec alcatraz dnctl sched 1 config pipe 1 type fq_codel target 0ms interval 0ms quantum 1514 limi…
188 jexec alcatraz dnctl queue 1 config pipe 1 droptail
237 jexec ${j}b dnctl pipe 1 config bw 10Mb queue 100 delay 500 droptail
238 jexec ${j}b dnctl sched 1 config pipe 1 type wf2q+
239 jexec ${j}b dnctl queue 1 config pipe 1 droptail
291 jexec alcatraz dnctl pipe 1 config bw 1MByte/s
[all …]
/freebsd/contrib/netbsd-tests/kernel/kqueue/read/
H A Dt_pipe.c46 ATF_TC(pipe);
47 ATF_TC_HEAD(pipe, tc) in ATF_TC_HEAD() argument
51 ATF_TC_BODY(pipe, tc) in ATF_TC_BODY() argument
58 RL(pipe(fds)); in ATF_TC_BODY()
85 ATF_TP_ADD_TC(tp, pipe); in ATF_TP_ADD_TCS()
/freebsd/tests/sys/netpfil/pf/
H A Dsctp.py145 vnet.pipe.send(rcvd)
259 # Start an SCTP server process, pipe the ppid + data back to the other vnet?
277 rcvd = self.wait_object(srv_vnet.pipe)
285 rcvd = self.wait_object(srv_vnet.pipe)
315 rcvd = self.wait_object(srv_vnet.pipe)
325 rcvd = self.wait_object(srv_vnet.pipe)
334 rcvd = self.wait_object(srv_vnet.pipe, 5)
353 rcvd = self.wait_object(srv_vnet.pipe, 5)
385 rcvd = self.wait_object(srv_vnet.pipe)
416 rcvd = self.wait_object(srv_vnet.pipe)
[all...]
/freebsd/sys/netpfil/ipfw/
H A Ddummynet.txt19 Add a pipe
24 Delete a pipe
44 with a tag such as "pipe 10" or "queue 5" which tells what to
179 (plus one for each 'pipe X config').
184 (plus one for each 'pipe X config').
292 TRADITIONAL DUMMYNET QUEUES "queue N config ... pipe M ..."
295 TRADITIONAL DUMMYNET PIPES "pipe N config ..."
303 DELAY PROFILE "pipe N config profile ..."
310 "pipe N config ..." configures:
352 To create a pipe, queue or scheduler, the user should type commands like:
[all …]
/freebsd/contrib/netbsd-tests/fs/tmpfs/
H A Dt_mknod.sh100 atf_test_case pipe
109 atf_check -s eq:0 -o empty -e empty mknod pipe p
110 eval $(stat -s pipe)
141 atf_add_test_case pipe
/freebsd/sys/netinet/cc/
H A Dcc_htcp.c285 uint32_t mss, pipe; in htcp_cong_signal() local
328 pipe = tcp_compute_pipe(ccv->tp); in htcp_cong_signal()
330 min(CCV(ccv, snd_wnd), pipe) / 2 / mss) * mss; in htcp_cong_signal()
366 int pipe; in htcp_post_recovery() local
370 pipe = 0; in htcp_post_recovery()
379 pipe = tcp_compute_pipe(ccv->tp); in htcp_post_recovery()
380 if (pipe < CCV(ccv, snd_ssthresh)) in htcp_post_recovery()
385 CCV(ccv, snd_cwnd) = max(pipe, mss) + mss; in htcp_post_recovery()
/freebsd/sys/contrib/device-tree/Bindings/goldfish/
H A Dpipe.txt3 Andorid pipe virtual device generated by android emulator.
7 - compatible : should contain "google,android-pipe" to match emulator
14 compatible = "google,android-pipe";
/freebsd/sys/contrib/device-tree/Bindings/phy/
H A Dqcom-pcie2-phy.txt14 - clocks: a clock-specifier pair for the "pipe" clock
19 - resets: reset-specifier pairs for the "phy" and "pipe" resets
21 "phy" and "pipe"
34 reset-names = "phy", "pipe";
/freebsd/sys/security/mac/
H A Dmac_syscalls.c356 struct pipe *pipe; in sys___mac_get_fd() local
393 pipe = fp->f_data; in sys___mac_get_fd()
395 PIPE_LOCK(pipe); in sys___mac_get_fd()
396 mac_pipe_copy_label(pipe->pipe_pair->pp_label, intlabel); in sys___mac_get_fd()
397 PIPE_UNLOCK(pipe); in sys___mac_get_fd()
490 struct pipe *pipe; in sys___mac_set_fd() local
542 pipe = fp->f_data; in sys___mac_set_fd()
543 PIPE_LOCK(pipe); in sys___mac_set_fd()
545 pipe->pipe_pair, intlabel); in sys___mac_set_fd()
546 PIPE_UNLOCK(pipe); in sys___mac_set_fd()
/freebsd/sys/contrib/dev/mediatek/mt76/
H A Dusb_trace.h58 DEV_ENTRY __field(unsigned int, pipe) __field(u32, len)
62 __entry->pipe = u->pipe;
66 DEV_PR_ARG, __entry->pipe, __entry->len)
/freebsd/tests/atf_python/sys/net/
H A Dvnet.py225 self.pipe = None
236 def set_pipe(self, pipe): argument
237 self.pipe = pipe
345 def _setup_vnet(self, vnet: VnetInstance, obj_map: Dict, pipe): argument
352 if pipe is not None:
353 vnet.set_pipe(pipe)
503 def wait_object(self, pipe, timeout=5): argument
504 if pipe.poll(timeout):
505 return pipe.recv()
514 def send_object(self, pipe, obj): argument
[all …]
/freebsd/usr.sbin/periodic/
H A Dperiodic.sh21 /*) pipe="cat >>$output";;
22 "") pipe=cat;;
23 *) pipe="mail -E -s '$host ${2}${2:+ }${1##*/} run output' $output";;
25 eval $pipe
/freebsd/usr.sbin/bhyve/
H A Dnet_backend_slirp.c149 int pipe[2]; /* used to buffer data sent to the guest */ member
166 priv->pipe[0] = priv->pipe[1] = -1; in slirp_priv_init()
177 checked_close(&priv->pipe[0]); in slirp_priv_cleanup()
178 checked_close(&priv->pipe[1]); in slirp_priv_cleanup()
227 n = send(priv->pipe[1], buf, len, 0); in slirp_cb_send_packet()
553 error = socketpair(PF_LOCAL, SOCK_DGRAM | SOCK_CLOEXEC, 0, priv->pipe); in _slirp_init()
569 error = setsockopt(priv->pipe[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, in _slirp_init()
577 be->fd = priv->pipe[0]; in _slirp_init()
647 n = recv(priv->pipe[0], NULL, 0, MSG_PEEK | MSG_DONTWAIT | MSG_TRUNC); in slirp_peek_recvlen()
668 n = recvmsg(priv->pipe[0], &hdr, MSG_DONTWAIT); in slirp_recv()

12345678910>>...22