Lines Matching refs:pdu
42 void *pdu; member
85 void *pdu; member
339 void *pdu, size_t len) in nvme_tcp_hdgst() argument
343 sg_init_one(&sg, pdu, len); in nvme_tcp_hdgst()
344 ahash_request_set_crypt(hash, &sg, pdu + len, len); in nvme_tcp_hdgst()
349 void *pdu, size_t pdu_len) in nvme_tcp_verify_hdgst() argument
351 struct nvme_tcp_hdr *hdr = pdu; in nvme_tcp_verify_hdgst()
362 recv_digest = *(__le32 *)(pdu + hdr->hlen); in nvme_tcp_verify_hdgst()
363 nvme_tcp_hdgst(queue->rcv_hash, pdu, pdu_len); in nvme_tcp_verify_hdgst()
364 exp_digest = *(__le32 *)(pdu + hdr->hlen); in nvme_tcp_verify_hdgst()
375 static int nvme_tcp_check_ddgst(struct nvme_tcp_queue *queue, void *pdu) in nvme_tcp_check_ddgst() argument
377 struct nvme_tcp_hdr *hdr = pdu; in nvme_tcp_check_ddgst()
400 page_frag_free(req->pdu); in nvme_tcp_exit_request()
413 req->pdu = page_frag_alloc(&queue->pf_cache, in nvme_tcp_init_request()
416 if (!req->pdu) in nvme_tcp_init_request()
493 struct nvme_tcp_data_pdu *pdu) in nvme_tcp_handle_c2h_data() argument
497 rq = blk_mq_tag_to_rq(nvme_tcp_tagset(queue), pdu->command_id); in nvme_tcp_handle_c2h_data()
501 nvme_tcp_queue_id(queue), pdu->command_id); in nvme_tcp_handle_c2h_data()
512 queue->data_remaining = le32_to_cpu(pdu->data_length); in nvme_tcp_handle_c2h_data()
514 if (pdu->hdr.flags & NVME_TCP_F_DATA_SUCCESS && in nvme_tcp_handle_c2h_data()
515 unlikely(!(pdu->hdr.flags & NVME_TCP_F_DATA_LAST))) { in nvme_tcp_handle_c2h_data()
527 struct nvme_tcp_rsp_pdu *pdu) in nvme_tcp_handle_comp() argument
529 struct nvme_completion *cqe = &pdu->cqe; in nvme_tcp_handle_comp()
549 struct nvme_tcp_r2t_pdu *pdu) in nvme_tcp_setup_h2c_data_pdu() argument
551 struct nvme_tcp_data_pdu *data = req->pdu; in nvme_tcp_setup_h2c_data_pdu()
557 req->pdu_len = le32_to_cpu(pdu->r2t_length); in nvme_tcp_setup_h2c_data_pdu()
568 if (unlikely(le32_to_cpu(pdu->r2t_offset) < req->data_sent)) { in nvme_tcp_setup_h2c_data_pdu()
571 rq->tag, le32_to_cpu(pdu->r2t_offset), in nvme_tcp_setup_h2c_data_pdu()
587 data->ttag = pdu->ttag; in nvme_tcp_setup_h2c_data_pdu()
595 struct nvme_tcp_r2t_pdu *pdu) in nvme_tcp_handle_r2t() argument
601 rq = blk_mq_tag_to_rq(nvme_tcp_tagset(queue), pdu->command_id); in nvme_tcp_handle_r2t()
605 nvme_tcp_queue_id(queue), pdu->command_id); in nvme_tcp_handle_r2t()
610 ret = nvme_tcp_setup_h2c_data_pdu(req, pdu); in nvme_tcp_handle_r2t()
626 char *pdu = queue->pdu; in nvme_tcp_recv_pdu() local
631 &pdu[queue->pdu_offset], rcv_len); in nvme_tcp_recv_pdu()
642 hdr = queue->pdu; in nvme_tcp_recv_pdu()
644 ret = nvme_tcp_verify_hdgst(queue, queue->pdu, hdr->hlen); in nvme_tcp_recv_pdu()
651 ret = nvme_tcp_check_ddgst(queue, queue->pdu); in nvme_tcp_recv_pdu()
658 return nvme_tcp_handle_c2h_data(queue, (void *)queue->pdu); in nvme_tcp_recv_pdu()
661 return nvme_tcp_handle_comp(queue, (void *)queue->pdu); in nvme_tcp_recv_pdu()
664 return nvme_tcp_handle_r2t(queue, (void *)queue->pdu); in nvme_tcp_recv_pdu()
683 struct nvme_tcp_data_pdu *pdu = (void *)queue->pdu; in nvme_tcp_recv_data() local
687 rq = blk_mq_tag_to_rq(nvme_tcp_tagset(queue), pdu->command_id); in nvme_tcp_recv_data()
691 nvme_tcp_queue_id(queue), pdu->command_id); in nvme_tcp_recv_data()
747 if (pdu->hdr.flags & NVME_TCP_F_DATA_SUCCESS) { in nvme_tcp_recv_data()
761 struct nvme_tcp_data_pdu *pdu = (void *)queue->pdu; in nvme_tcp_recv_ddgst() local
785 if (pdu->hdr.flags & NVME_TCP_F_DATA_SUCCESS) { in nvme_tcp_recv_ddgst()
787 pdu->command_id); in nvme_tcp_recv_ddgst()
949 struct nvme_tcp_cmd_pdu *pdu = req->pdu; in nvme_tcp_try_send_cmd_pdu() local
952 int len = sizeof(*pdu) + hdgst - req->offset; in nvme_tcp_try_send_cmd_pdu()
962 nvme_tcp_hdgst(queue->snd_hash, pdu, sizeof(*pdu)); in nvme_tcp_try_send_cmd_pdu()
964 ret = kernel_sendpage(queue->sock, virt_to_page(pdu), in nvme_tcp_try_send_cmd_pdu()
965 offset_in_page(pdu) + req->offset, len, flags); in nvme_tcp_try_send_cmd_pdu()
989 struct nvme_tcp_data_pdu *pdu = req->pdu; in nvme_tcp_try_send_data_pdu() local
991 int len = sizeof(*pdu) - req->offset + hdgst; in nvme_tcp_try_send_data_pdu()
995 nvme_tcp_hdgst(queue->snd_hash, pdu, sizeof(*pdu)); in nvme_tcp_try_send_data_pdu()
997 ret = kernel_sendpage(queue->sock, virt_to_page(pdu), in nvme_tcp_try_send_data_pdu()
998 offset_in_page(pdu) + req->offset, len, in nvme_tcp_try_send_data_pdu()
1180 page_frag_free(async->pdu); in nvme_tcp_free_async_req()
1189 async->pdu = page_frag_alloc(&queue->pf_cache, in nvme_tcp_alloc_async_req()
1192 if (!async->pdu) in nvme_tcp_alloc_async_req()
1211 kfree(queue->pdu); in nvme_tcp_free_queue()
1450 queue->pdu = kmalloc(rcv_pdu_size, GFP_KERNEL); in nvme_tcp_alloc_queue()
1451 if (!queue->pdu) { in nvme_tcp_alloc_queue()
1493 kfree(queue->pdu); in nvme_tcp_alloc_queue()
1596 if (to_tcp_ctrl(ctrl)->async_req.pdu) { in nvme_tcp_free_admin_queue()
1599 to_tcp_ctrl(ctrl)->async_req.pdu = NULL; in nvme_tcp_free_admin_queue()
2141 struct nvme_tcp_cmd_pdu *pdu = ctrl->async_req.pdu; in nvme_tcp_submit_async_event() local
2142 struct nvme_command *cmd = &pdu->cmd; in nvme_tcp_submit_async_event()
2145 memset(pdu, 0, sizeof(*pdu)); in nvme_tcp_submit_async_event()
2146 pdu->hdr.type = nvme_tcp_cmd; in nvme_tcp_submit_async_event()
2148 pdu->hdr.flags |= NVME_TCP_F_HDGST; in nvme_tcp_submit_async_event()
2149 pdu->hdr.hlen = sizeof(*pdu); in nvme_tcp_submit_async_event()
2150 pdu->hdr.plen = cpu_to_le32(pdu->hdr.hlen + hdgst); in nvme_tcp_submit_async_event()
2182 struct nvme_tcp_cmd_pdu *pdu = req->pdu; in nvme_tcp_timeout() local
2186 nvme_tcp_queue_id(req->queue), rq->tag, pdu->hdr.type); in nvme_tcp_timeout()
2218 struct nvme_tcp_cmd_pdu *pdu = req->pdu; in nvme_tcp_map_data() local
2219 struct nvme_command *c = &pdu->cmd; in nvme_tcp_map_data()
2238 struct nvme_tcp_cmd_pdu *pdu = req->pdu; in nvme_tcp_setup_cmd_pdu() local
2243 ret = nvme_setup_cmd(ns, rq, &pdu->cmd); in nvme_tcp_setup_cmd_pdu()
2262 pdu->hdr.type = nvme_tcp_cmd; in nvme_tcp_setup_cmd_pdu()
2263 pdu->hdr.flags = 0; in nvme_tcp_setup_cmd_pdu()
2265 pdu->hdr.flags |= NVME_TCP_F_HDGST; in nvme_tcp_setup_cmd_pdu()
2267 pdu->hdr.flags |= NVME_TCP_F_DDGST; in nvme_tcp_setup_cmd_pdu()
2270 pdu->hdr.hlen = sizeof(*pdu); in nvme_tcp_setup_cmd_pdu()
2271 pdu->hdr.pdo = req->pdu_len ? pdu->hdr.hlen + hdgst : 0; in nvme_tcp_setup_cmd_pdu()
2272 pdu->hdr.plen = in nvme_tcp_setup_cmd_pdu()
2273 cpu_to_le32(pdu->hdr.hlen + hdgst + req->pdu_len + ddgst); in nvme_tcp_setup_cmd_pdu()