Home
last modified time | relevance | path

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

/net/nfc/hci/
Dcommand.c19 static int nfc_hci_execute_cmd_async(struct nfc_hci_dev *hdev, u8 pipe, u8 cmd, in nfc_hci_execute_cmd_async() argument
23 pr_debug("exec cmd async through pipe=%d, cmd=%d, plen=%zd\n", pipe, in nfc_hci_execute_cmd_async()
29 return nfc_hci_hcp_message_tx(hdev, pipe, NFC_HCI_HCP_COMMAND, cmd, in nfc_hci_execute_cmd_async()
55 static int nfc_hci_execute_cmd(struct nfc_hci_dev *hdev, u8 pipe, u8 cmd, in nfc_hci_execute_cmd() argument
65 pr_debug("exec cmd sync through pipe=%d, cmd=%d, plen=%zd\n", pipe, in nfc_hci_execute_cmd()
71 hcp_ew.exec_result = nfc_hci_hcp_message_tx(hdev, pipe, in nfc_hci_execute_cmd()
94 u8 pipe; in nfc_hci_send_event() local
98 pipe = hdev->gate2pipe[gate]; in nfc_hci_send_event()
99 if (pipe == NFC_HCI_INVALID_PIPE) in nfc_hci_send_event()
102 return nfc_hci_hcp_message_tx(hdev, pipe, NFC_HCI_HCP_EVENT, event, in nfc_hci_send_event()
[all …]
Dcore.c132 u8 pipe; in nfc_hci_msg_rx_work() local
137 pipe = skb->data[0]; in nfc_hci_msg_rx_work()
144 nfc_hci_hcp_message_rx(hdev, pipe, type, instruction, skb); in nfc_hci_msg_rx_work()
181 void nfc_hci_cmd_received(struct nfc_hci_dev *hdev, u8 pipe, u8 cmd, in nfc_hci_cmd_received() argument
190 pr_debug("from pipe %x cmd %x\n", pipe, cmd); in nfc_hci_cmd_received()
192 if (pipe >= NFC_HCI_MAX_PIPES) { in nfc_hci_cmd_received()
197 gate = hdev->pipes[pipe].gate; in nfc_hci_cmd_received()
207 if (create_info->pipe >= NFC_HCI_MAX_PIPES) { in nfc_hci_cmd_received()
217 hdev->gate2pipe[create_info->dest_gate] = create_info->pipe; in nfc_hci_cmd_received()
218 hdev->pipes[create_info->pipe].gate = create_info->dest_gate; in nfc_hci_cmd_received()
[all …]
Dhci.h13 u8 pipe; member
53 u8 pipe; member
57 u8 pipe; member
70 int nfc_hci_hcp_message_tx(struct nfc_hci_dev *hdev, u8 pipe,
76 void nfc_hci_hcp_message_rx(struct nfc_hci_dev *hdev, u8 pipe, u8 type,
Dhcp.c21 int nfc_hci_hcp_message_tx(struct nfc_hci_dev *hdev, u8 pipe, in nfc_hci_hcp_message_tx() argument
72 packet->header = pipe; in nfc_hci_hcp_message_tx()
119 void nfc_hci_hcp_message_rx(struct nfc_hci_dev *hdev, u8 pipe, u8 type, in nfc_hci_hcp_message_rx() argument
127 nfc_hci_cmd_received(hdev, pipe, instruction, skb); in nfc_hci_hcp_message_rx()
130 nfc_hci_event_received(hdev, pipe, instruction, skb); in nfc_hci_hcp_message_rx()
/net/sunrpc/
Drpc_pipe.c86 struct rpc_pipe *pipe = in rpc_timeout_upcall_queue() local
91 spin_lock(&pipe->lock); in rpc_timeout_upcall_queue()
92 destroy_msg = pipe->ops->destroy_msg; in rpc_timeout_upcall_queue()
93 if (pipe->nreaders == 0) { in rpc_timeout_upcall_queue()
94 list_splice_init(&pipe->pipe, &free_list); in rpc_timeout_upcall_queue()
95 pipe->pipelen = 0; in rpc_timeout_upcall_queue()
97 dentry = dget(pipe->dentry); in rpc_timeout_upcall_queue()
98 spin_unlock(&pipe->lock); in rpc_timeout_upcall_queue()
135 rpc_queue_upcall(struct rpc_pipe *pipe, struct rpc_pipe_msg *msg) in rpc_queue_upcall() argument
140 spin_lock(&pipe->lock); in rpc_queue_upcall()
[all …]
/net/nfc/nci/
Dhci.c20 u8 pipe; member
37 u8 pipe; member
41 u8 pipe; member
141 static int nci_hci_send_data(struct nci_dev *ndev, u8 pipe, in nci_hci_send_data() argument
148 u8 cb = pipe; in nci_hci_send_data()
202 nci_hci_send_data(ndev, data->pipe, data->cmd, in nci_hci_send_data_req()
209 u8 pipe = ndev->hci_dev->gate2pipe[gate]; in nci_hci_send_event() local
211 if (pipe == NCI_HCI_INVALID_PIPE) in nci_hci_send_event()
214 return nci_hci_send_data(ndev, pipe, in nci_hci_send_event()
228 u8 pipe = ndev->hci_dev->gate2pipe[gate]; in nci_hci_send_cmd() local
[all …]
/net/sunrpc/auth_gss/
Dauth_gss.c62 struct rpc_pipe *pipe; member
249 struct rpc_pipe *pipe; member
298 __gss_find_upcall(struct rpc_pipe *pipe, kuid_t uid, const struct gss_auth *auth) in __gss_find_upcall() argument
301 list_for_each_entry(pos, &pipe->in_downcall, list) { in __gss_find_upcall()
319 struct rpc_pipe *pipe = gss_msg->pipe; in gss_add_msg() local
322 spin_lock(&pipe->lock); in gss_add_msg()
323 old = __gss_find_upcall(pipe, gss_msg->uid, gss_msg->auth); in gss_add_msg()
326 list_add(&gss_msg->list, &pipe->in_downcall); in gss_add_msg()
329 spin_unlock(&pipe->lock); in gss_add_msg()
345 struct rpc_pipe *pipe = gss_msg->pipe; in gss_unhash_msg() local
[all …]
/net/smc/
Dsmc_rx.c109 static void smc_rx_pipe_buf_release(struct pipe_inode_info *pipe, in smc_rx_pipe_buf_release() argument
144 static int smc_rx_splice(struct pipe_inode_info *pipe, char *src, size_t len, in smc_rx_splice() argument
168 bytes = splice_to_pipe(pipe, &spd); in smc_rx_splice()
282 struct pipe_inode_info *pipe, size_t len, int flags) in smc_rx_recvmsg() argument
318 if (read_done >= target || (pipe && read_done)) in smc_rx_recvmsg()
408 rc = smc_rx_splice(pipe, rcvbuf_base + in smc_rx_recvmsg()
Dsmc_rx.h23 struct pipe_inode_info *pipe, size_t len, int flags);
Daf_smc.c2597 struct pipe_inode_info *pipe, size_t len, in smc_splice_read() argument
2623 pipe, len, flags); in smc_splice_read()
2634 rc = smc_rx_recvmsg(smc, NULL, pipe, len, flags); in smc_splice_read()
/net/core/
Dskbuff.c2498 struct pipe_inode_info *pipe, struct page *page, in spd_fill_page() argument
2529 struct pipe_inode_info *pipe) in __splice_segment() argument
2548 if (spd_fill_page(spd, pipe, page, &flen, poff, in __splice_segment()
2563 static bool __skb_splice_bits(struct sk_buff *skb, struct pipe_inode_info *pipe, in __skb_splice_bits() argument
2580 sk, pipe)) in __skb_splice_bits()
2591 offset, len, spd, false, sk, pipe)) in __skb_splice_bits()
2604 if (__skb_splice_bits(iter, pipe, offset, len, spd, sk)) in __skb_splice_bits()
2616 struct pipe_inode_info *pipe, unsigned int tlen, in skb_splice_bits() argument
2630 __skb_splice_bits(skb, pipe, &offset, &tlen, &spd, sk); in skb_splice_bits()
2633 ret = splice_to_pipe(pipe, &spd); in skb_splice_bits()
/net/unix/
Daf_unix.c2502 struct pipe_inode_info *pipe; member
2855 state->pipe, chunk, state->splice_flags); in unix_stream_splice_actor()
2859 struct pipe_inode_info *pipe, in unix_stream_splice_read() argument
2865 .pipe = pipe, in unix_stream_splice_read()
/net/
Dsocket.c130 struct pipe_inode_info *pipe, size_t len,
1029 struct pipe_inode_info *pipe, size_t len, in sock_splice_read() argument
1035 return generic_file_splice_read(file, ppos, pipe, len, flags); in sock_splice_read()
1037 return sock->ops->splice_read(sock, ppos, pipe, len, flags); in sock_splice_read()
/net/vmw_vsock/
Dhyperv_transport.c302 conn_from_host = chan->offermsg.offer.u.pipe.user_def[0]; in hvs_open_connection()
/net/ipv4/
Dtcp.c314 struct pipe_inode_info *pipe; member
746 ret = skb_splice_bits(skb, skb->sk, offset, tss->pipe, in tcp_splice_data_recv()
777 struct pipe_inode_info *pipe, size_t len, in tcp_splice_read() argument
782 .pipe = pipe, in tcp_splice_read()
/net/kcm/
Dkcmsock.c1141 struct pipe_inode_info *pipe, size_t len, in kcm_splice_read() argument
1165 copied = skb_splice_bits(skb, sk, stm->offset, pipe, len, flags); in kcm_splice_read()
/net/tls/
Dtls_sw.c1993 struct pipe_inode_info *pipe, in tls_sw_splice_read() argument
2037 copied = skb_splice_bits(skb, sk, rxm->offset, pipe, chunk, flags); in tls_sw_splice_read()