Home
last modified time | relevance | path

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

12345678910>>...23

/src/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 …]
/src/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 …]
/src/sys/contrib/dev/athk/ath11k/
H A Dce.c273 static int ath11k_ce_rx_buf_enqueue_pipe(struct ath11k_ce_pipe *pipe, in ath11k_ce_rx_buf_enqueue_pipe() argument
276 struct ath11k_base *ab = pipe->ab; in ath11k_ce_rx_buf_enqueue_pipe()
277 struct ath11k_ce_ring *ring = pipe->dest_ring; in ath11k_ce_rx_buf_enqueue_pipe()
311 pipe->rx_buf_needed--; in ath11k_ce_rx_buf_enqueue_pipe()
322 static int ath11k_ce_rx_post_pipe(struct ath11k_ce_pipe *pipe) in ath11k_ce_rx_post_pipe() argument
324 struct ath11k_base *ab = pipe->ab; in ath11k_ce_rx_post_pipe()
329 if (!(pipe->dest_ring || pipe->status_ring)) in ath11k_ce_rx_post_pipe()
333 while (pipe->rx_buf_needed) { in ath11k_ce_rx_post_pipe()
334 skb = dev_alloc_skb(pipe->buf_sz); in ath11k_ce_rx_post_pipe()
354 ret = ath11k_ce_rx_buf_enqueue_pipe(pipe, skb, paddr); in ath11k_ce_rx_post_pipe()
[all …]
/src/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,
/src/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 …]
/src/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 …]
/src/sys/kern/
H A Dsys_pipe.c138 #define PIPE_PEER(pipe) \ argument
139 (((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
237 static void pipeclose(struct pipe *cpipe);
238 static void pipe_free_kmem(struct pipe *cpipe);
239 static int pipe_create(struct pipe *pipe, bool backing);
240 static void pipe_destroy(struct pipe *pipe);
242 static __inline int pipelock(struct pipe *cpipe, bool catch);
243 static __inline void pipeunlock(struct pipe *cpipe);
246 static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);
247 static void pipe_destroy_write_buffer(struct pipe *wpipe);
[all …]
/src/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 …]
/src/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 …]
/src/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)
/src/tests/sys/netinet6/
H A Dtest_ip6_output.py82 vnet.pipe.send(ll_data)
86 vnet.pipe.send(tx_obj)
108 self.wait_object(second_vnet.pipe)
112 rx_obj = self.wait_object(second_vnet.pipe)
133 self.wait_object(second_vnet.pipe)
138 rx_obj = self.wait_object(second_vnet.pipe)
197 self.wait_object(second_vnet.pipe)
213 rx_obj = self.wait_object(second_vnet.pipe)
238 ll_data = self.wait_object(second_vnet.pipe)
254 rx_obj = self.wait_object(second_vnet.pipe)
[all …]
/src/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
287 jexec alcatraz dnctl pipe 1 config bw 1MByte/s
[all …]
/src/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()
/src/crypto/krb5/src/ccapi/server/win/
H A Dccs_request_proc.c47 WIN_PIPE* pipe = NULL; in ccs_rpc_request() local
59 pipe = ccs_win_pipe_new(pszUUID, *p); in ccs_rpc_request()
60 worklist_add(rpcmsg, pipe, stream, serverStartTime); in ccs_rpc_request()
72 WIN_PIPE* pipe = ccs_win_pipe_new(pszUUID, *p); in ccs_rpc_connect() local
75 pipe, in ccs_rpc_connect()
H A DWorkQueue.cpp54 const ccs_pipe_t pipe, in worklist_add() argument
57 return worklist.add(new WorkItem(stream, pipe, rpcmsg, serverStartTime) ); in worklist_add()
61 ccs_pipe_t* pipe, in worklist_remove() argument
68 *pipe = item->take_pipe(); in worklist_remove()
/src/tests/sys/netpfil/pf/
H A Dsctp.py145 vnet.pipe.send(rcvd)
280 rcvd = self.wait_object(srv_vnet.pipe)
288 rcvd = self.wait_object(srv_vnet.pipe)
321 rcvd = self.wait_object(srv_vnet.pipe)
331 rcvd = self.wait_object(srv_vnet.pipe)
340 rcvd = self.wait_object(srv_vnet.pipe, 5)
359 rcvd = self.wait_object(srv_vnet.pipe, 5)
394 rcvd = self.wait_object(srv_vnet.pipe)
428 rcvd = self.wait_object(srv_vnet.pipe)
462 rcvd = self.wait_object(srv_vnet.pipe)
[all …]
/src/crypto/openssl/doc/designs/quic-design/
H A Dquic-concurrency.md187 destroyed. A pipe is a *unidirectional* transport for byte streams. Zero-copy
190 The CML (`QUIC_CML`) allows the caller to refer to a pipe by providing an opaque
191 pipe handle (`QUIC_CML_PIPE`). If the pipe is a sending pipe, the caller can use
193 pipe, the caller can use `ossl_cml_read` to try and read bytes from it.
196 of the provided pipe handles is ready. Ready means that at least one byte can be
197 written (for a sending pipe) or at least one byte can be read (for a receiving
198 pipe).
205 The caller retrieves a pipe handle using `ossl_cml_get_pipe`. This function
206 retrieves a pipe based on two values:
208 - a CML pipe class;
[all …]
/src/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 …]
/src/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
/src/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";
/src/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()
/src/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";
/src/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)
/src/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

12345678910>>...23