• Home
  • Raw
  • Download

Lines Matching refs:recv

166 				      struct hmdfs_head_cmd *recv)  in hmdfs_drop_readpage_buffer()  argument
172 len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd); in hmdfs_drop_readpage_buffer()
190 struct hmdfs_head_cmd *recv, in hmdfs_get_readpage_buffer() argument
197 out_len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd); in hmdfs_get_readpage_buffer()
216 struct hmdfs_head_cmd *recv) in tcp_recvpage_tls() argument
232 rd_err = le32_to_cpu(recv->ret_code); in tcp_recvpage_tls()
238 le32_to_cpu(recv->msg_id)); in tcp_recvpage_tls()
249 ret = hmdfs_get_readpage_buffer(tcp->sock, recv, page); in tcp_recvpage_tls()
253 node->conn_operations->recvpage(node, recv, rd_err, async_work); in tcp_recvpage_tls()
264 ret = hmdfs_drop_readpage_buffer(tcp->sock, recv); in tcp_recvpage_tls()
394 struct hmdfs_head_cmd *recv) in tcp_recvbuffer_cipher() argument
402 __u32 recv_len = le32_to_cpu(recv->data_len); in tcp_recvbuffer_cipher()
438 connect_recv_callback[connect->status](connect, recv, outdata, in tcp_recvbuffer_cipher()
453 struct hmdfs_head_cmd *recv) in tcp_recvbuffer_tls() argument
459 __u32 recv_len = le32_to_cpu(recv->data_len); in tcp_recvbuffer_tls()
484 connect_recv_callback[connect->status](connect, recv, outdata, in tcp_recvbuffer_tls()
495 struct hmdfs_head_cmd *recv = NULL; in tcp_receive_from_sock() local
508 recv = kmem_cache_alloc(tcp->recv_cache, GFP_KERNEL); in tcp_receive_from_sock()
509 if (!recv) { in tcp_receive_from_sock()
514 ret = tcp_read_head_from_socket(tcp->sock, recv, in tcp_receive_from_sock()
522 if (recv->magic != HMDFS_MSG_MAGIC) { in tcp_receive_from_sock()
528 if ((le32_to_cpu(recv->data_len) > in tcp_receive_from_sock()
530 (le32_to_cpu(recv->data_len) < sizeof(struct hmdfs_head_cmd))) { in tcp_receive_from_sock()
536 if (recv->version > USERSPACE_MAX_VER && in tcp_receive_from_sock()
538 recv->operations.command == F_READPAGE && in tcp_receive_from_sock()
539 recv->operations.cmd_flag == C_RESPONSE) { in tcp_receive_from_sock()
540 ret = tcp_recvpage_tls(tcp->connect, recv); in tcp_receive_from_sock()
545 recv->version > USERSPACE_MAX_VER) in tcp_receive_from_sock()
546 ret = tcp_recvbuffer_tls(tcp->connect, recv); in tcp_receive_from_sock()
548 ret = tcp_recvbuffer_cipher(tcp->connect, recv); in tcp_receive_from_sock()
551 kmem_cache_free(tcp->recv_cache, recv); in tcp_receive_from_sock()