| /net/nfc/hci/ |
| D | command.c | 19 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 …]
|
| D | core.c | 132 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
184 u8 gate = hdev->pipes[pipe].gate; in nfc_hci_cmd_received()
190 pr_debug("from gate %x pipe %x cmd %x\n", gate, pipe, cmd); in nfc_hci_cmd_received()
200 if (create_info->pipe >= NFC_HCI_MAX_PIPES) { in nfc_hci_cmd_received()
210 hdev->gate2pipe[create_info->dest_gate] = create_info->pipe; in nfc_hci_cmd_received()
211 hdev->pipes[create_info->pipe].gate = create_info->dest_gate; in nfc_hci_cmd_received()
212 hdev->pipes[create_info->pipe].dest_host = in nfc_hci_cmd_received()
[all …]
|
| D | hci.h | 13 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,
|
| D | hcp.c | 21 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/ |
| D | rpc_pipe.c | 86 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/ |
| D | hci.c | 20 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()
204 nci_hci_send_data(ndev, data->pipe, data->cmd, in nci_hci_send_data_req()
211 u8 pipe = ndev->hci_dev->gate2pipe[gate]; in nci_hci_send_event() local
213 if (pipe == NCI_HCI_INVALID_PIPE) in nci_hci_send_event()
216 return nci_hci_send_data(ndev, pipe, in nci_hci_send_event()
230 u8 pipe = ndev->hci_dev->gate2pipe[gate]; in nci_hci_send_cmd() local
[all …]
|
| /net/sunrpc/auth_gss/ |
| D | auth_gss.c | 60 struct rpc_pipe *pipe; member
276 struct rpc_pipe *pipe; member
325 __gss_find_upcall(struct rpc_pipe *pipe, kuid_t uid, const struct gss_auth *auth) in __gss_find_upcall() argument
328 list_for_each_entry(pos, &pipe->in_downcall, list) { in __gss_find_upcall()
346 struct rpc_pipe *pipe = gss_msg->pipe; in gss_add_msg() local
349 spin_lock(&pipe->lock); in gss_add_msg()
350 old = __gss_find_upcall(pipe, gss_msg->uid, gss_msg->auth); in gss_add_msg()
353 list_add(&gss_msg->list, &pipe->in_downcall); in gss_add_msg()
356 spin_unlock(&pipe->lock); in gss_add_msg()
372 struct rpc_pipe *pipe = gss_msg->pipe; in gss_unhash_msg() local
[all …]
|
| /net/smc/ |
| D | smc_rx.c | 108 static void smc_rx_pipe_buf_release(struct pipe_inode_info *pipe, in smc_rx_pipe_buf_release() argument
132 static int smc_rx_pipe_buf_nosteal(struct pipe_inode_info *pipe, in smc_rx_pipe_buf_nosteal() argument
151 static int smc_rx_splice(struct pipe_inode_info *pipe, char *src, size_t len, in smc_rx_splice() argument
175 bytes = splice_to_pipe(pipe, &spd); in smc_rx_splice()
284 struct pipe_inode_info *pipe, size_t len, int flags) in smc_rx_recvmsg() argument
314 if (read_done >= target || (pipe && read_done)) in smc_rx_recvmsg()
402 rc = smc_rx_splice(pipe, rcvbuf_base + in smc_rx_recvmsg()
|
| D | smc_rx.h | 23 struct pipe_inode_info *pipe, size_t len, int flags);
|
| D | af_smc.c | 1897 struct pipe_inode_info *pipe, size_t len, in smc_splice_read() argument
1923 pipe, len, flags); in smc_splice_read()
1933 rc = smc_rx_recvmsg(smc, NULL, pipe, len, flags); in smc_splice_read()
|
| /net/core/ |
| D | skbuff.c | 2308 struct pipe_inode_info *pipe, struct page *page, in spd_fill_page() argument
2339 struct pipe_inode_info *pipe) in __splice_segment() argument
2358 if (spd_fill_page(spd, pipe, page, &flen, poff, in __splice_segment()
2373 static bool __skb_splice_bits(struct sk_buff *skb, struct pipe_inode_info *pipe, in __skb_splice_bits() argument
2390 sk, pipe)) in __skb_splice_bits()
2401 offset, len, spd, false, sk, pipe)) in __skb_splice_bits()
2414 if (__skb_splice_bits(iter, pipe, offset, len, spd, sk)) in __skb_splice_bits()
2426 struct pipe_inode_info *pipe, unsigned int tlen, in skb_splice_bits() argument
2440 __skb_splice_bits(skb, pipe, &offset, &tlen, &spd, sk); in skb_splice_bits()
2443 ret = splice_to_pipe(pipe, &spd); in skb_splice_bits()
|
| /net/unix/ |
| D | af_unix.c | 2198 struct pipe_inode_info *pipe; member
2432 state->pipe, chunk, state->splice_flags); in unix_stream_splice_actor()
2436 struct pipe_inode_info *pipe, in unix_stream_splice_read() argument
2442 .pipe = pipe, in unix_stream_splice_read()
|
| /net/ipv4/ |
| D | tcp.c | 306 struct pipe_inode_info *pipe; member
735 ret = skb_splice_bits(skb, skb->sk, offset, tss->pipe, in tcp_splice_data_recv()
766 struct pipe_inode_info *pipe, size_t len, in tcp_splice_read() argument
771 .pipe = pipe, in tcp_splice_read()
|
| /net/ |
| D | socket.c | 128 struct pipe_inode_info *pipe, size_t len,
940 struct pipe_inode_info *pipe, size_t len, in sock_splice_read() argument
946 return generic_file_splice_read(file, ppos, pipe, len, flags); in sock_splice_read()
948 return sock->ops->splice_read(sock, ppos, pipe, len, flags); in sock_splice_read()
|
| /net/vmw_vsock/ |
| D | hyperv_transport.c | 338 conn_from_host = chan->offermsg.offer.u.pipe.user_def[0]; in hvs_open_connection()
|
| /net/kcm/ |
| D | kcmsock.c | 1173 struct pipe_inode_info *pipe, size_t len, in kcm_splice_read() argument
1201 copied = skb_splice_bits(skb, sk, stm->offset, pipe, len, flags); in kcm_splice_read()
|
| /net/tls/ |
| D | tls_sw.c | 1926 struct pipe_inode_info *pipe, in tls_sw_splice_read() argument
1966 copied = skb_splice_bits(skb, sk, rxm->offset, pipe, chunk, flags); in tls_sw_splice_read()
|