Lines Matching refs:recv
117 hmdfs_err("tcp recv error %d", rc);
153 hmdfs_err("tcp recv error %d", rc);
166 struct hmdfs_head_cmd *recv)
172 len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd);
174 hmdfs_err("recv invalid readpage length %u", len);
190 struct hmdfs_head_cmd *recv,
197 out_len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd);
199 hmdfs_err("recv invalid readpage length %u", out_len);
216 struct hmdfs_head_cmd *recv)
232 rd_err = le32_to_cpu(recv->ret_code);
238 le32_to_cpu(recv->msg_id), recv->operations);
249 ret = hmdfs_get_readpage_buffer(tcp->sock, recv, page);
253 hmdfs_client_recv_readpage(recv, rd_err, async_work);
264 ret = hmdfs_drop_readpage_buffer(tcp->sock, recv);
394 struct hmdfs_head_cmd *recv)
402 __u32 recv_len = le32_to_cpu(recv->data_len);
438 connect_recv_callback[connect->status](connect, recv, outdata,
453 struct hmdfs_head_cmd *recv)
459 __u32 recv_len = le32_to_cpu(recv->data_len);
484 connect_recv_callback[connect->status](connect, recv, outdata,
495 struct hmdfs_head_cmd *recv = NULL;
499 hmdfs_info("tcp recv thread !tcp");
504 hmdfs_info("tcp recv thread !sock");
508 recv = kmem_cache_alloc(tcp->recv_cache, GFP_KERNEL);
509 if (!recv) {
510 hmdfs_info("tcp recv thread !cache");
514 ret = tcp_read_head_from_socket(tcp->sock, recv,
522 if (recv->magic != HMDFS_MSG_MAGIC || recv->version != HMDFS_VERSION) {
523 hmdfs_info_ratelimited("tcp recv fd %d wrong magic. drop message",
528 if ((le32_to_cpu(recv->data_len) >
530 (le32_to_cpu(recv->data_len) < sizeof(struct hmdfs_head_cmd))) {
531 hmdfs_info("tcp recv fd %d length error. drop message",
537 recv->operations.command == F_READPAGE &&
538 recv->operations.cmd_flag == C_RESPONSE) {
539 ret = tcp_recvpage_tls(tcp->connect, recv);
544 ret = tcp_recvbuffer_tls(tcp->connect, recv);
546 ret = tcp_recvbuffer_cipher(tcp->connect, recv);
549 kmem_cache_free(tcp->recv_cache, recv);
959 /* send key and recv key, default MASTER KEY */