lib/libnvmf/nvmf_tcp.c

48 	struct nvme_tcp_common_pdu_hdr *hdr;
195 	struct nvme_tcp_term_req_hdr hdr;
205 	memset(&hdr, 0, sizeof(hdr));
206 	hdr.common.pdu_type = na->na_controller ?
208 	hdr.common.hlen = sizeof(hdr);
209 	hdr.common.plen = sizeof(hdr) + hlen;
210 	hdr.fes = htole16(fes);
211 	le32enc(hdr.fei, fei);
212 	iov[0].iov_base = &hdr;
213 	iov[0].iov_len = sizeof(hdr);
217 	(void)nvmf_tcp_write_pdu_iov(qp, iov, nitems(iov), sizeof(hdr) + hlen);
234 	ch = pdu->hdr;
325 		pdu->hdr = &ch;
327 		pdu->hdr = NULL;
333 	pdu->hdr = malloc(plen);
334 	memcpy(pdu->hdr, &ch, sizeof(ch));
335 	error = nvmf_tcp_read_buffer(qp->s, pdu->hdr + 1, plen - sizeof(ch));
340 		free(pdu->hdr);
341 		pdu->hdr = NULL;
349 	free(pdu->hdr);
350 	pdu->hdr = NULL;
356 	struct nvme_tcp_term_req_hdr *hdr;
358 	hdr = (void *)pdu->hdr;
361 	    le16toh(hdr->fes), le32dec(hdr->fei));
374 	cmd = (void *)pdu->hdr;
395 	rsp = (void *)pdu->hdr;
423 nvmf_tcp_construct_pdu(struct nvmf_tcp_qpair *qp, void *hdr, size_t hlen,
446 	ch = hdr;
456 	iov[0].iov_base = hdr;
462 		header_digest = compute_digest(hdr, hlen);
501 	h2c = (void *)pdu->hdr;
505 		    pdu->hdr, le32toh(pdu->hdr->plen), pdu->hdr->hlen);
514 		    offsetof(struct nvme_tcp_h2c_data_hdr, ttag), pdu->hdr,
515 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
524 		    offsetof(struct nvme_tcp_h2c_data_hdr, datal), pdu->hdr,
525 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
535 		    pdu->hdr, le32toh(pdu->hdr->plen), pdu->hdr->hlen);
542 		    NVME_TCP_TERM_REQ_FES_PDU_SEQUENCE_ERROR, 0, pdu->hdr,
543 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
549 	    ((pdu->hdr->flags & NVME_TCP_H2C_DATA_FLAGS_LAST_PDU) != 0)) {
551 		    NVME_TCP_TERM_REQ_FES_PDU_SEQUENCE_ERROR, 0, pdu->hdr,
552 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
559 	icd = (const char *)pdu->hdr + pdu->hdr->pdo;
574 	c2h = (void *)pdu->hdr;
584 		    offsetof(struct nvme_tcp_c2h_data_hdr, cccid), pdu->hdr,
585 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
594 		    offsetof(struct nvme_tcp_c2h_data_hdr, datal), pdu->hdr,
595 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
605 		    pdu->hdr, le32toh(pdu->hdr->plen), pdu->hdr->hlen);
612 		    NVME_TCP_TERM_REQ_FES_PDU_SEQUENCE_ERROR, 0, pdu->hdr,
613 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
619 	    ((pdu->hdr->flags & NVME_TCP_C2H_DATA_FLAGS_LAST_PDU) != 0)) {
621 		    NVME_TCP_TERM_REQ_FES_PDU_SEQUENCE_ERROR, 0, pdu->hdr,
622 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
629 	icd = (const char *)pdu->hdr + pdu->hdr->pdo;
632 	if ((pdu->hdr->flags & NVME_TCP_C2H_DATA_FLAGS_SUCCESS) != 0) {
707 	r2t = (void *)pdu->hdr;
713 		    offsetof(struct nvme_tcp_r2t_hdr, cccid), pdu->hdr,
714 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
722 		    NVME_TCP_TERM_REQ_FES_PDU_SEQUENCE_ERROR, 0, pdu->hdr,
723 		    le32toh(pdu->hdr->plen), pdu->hdr->hlen);
736 		    pdu->hdr, le32toh(pdu->hdr->plen), pdu->hdr->hlen);
764 	switch (pdu.hdr->pdu_type) {
1257 	assert(tc->rx_pdu.hdr != NULL);
1349 	icd = (const char *)tc->rx_pdu.hdr + tc->rx_pdu.hdr->pdo + data_offset;