Lines Matching refs:data_offset
31 uint32_t data_offset; member
94 uint32_t data_offset, size_t data_len, uint16_t cid, uint16_t ttag, in tcp_alloc_command_buffer() argument
102 cb->data_offset = data_offset; in tcp_alloc_command_buffer()
498 uint32_t data_len, data_offset; in nvmf_tcp_handle_h2c_data() local
530 data_offset = le32toh(h2c->datao); in nvmf_tcp_handle_h2c_data()
531 if (data_offset < cb->data_offset || in nvmf_tcp_handle_h2c_data()
532 data_offset + data_len > cb->data_offset + cb->data_len) { in nvmf_tcp_handle_h2c_data()
540 if (data_offset != cb->data_offset + cb->data_xfered) { in nvmf_tcp_handle_h2c_data()
558 data_offset -= cb->data_offset; in nvmf_tcp_handle_h2c_data()
560 memcpy((char *)cb->data + data_offset, icd, data_len); in nvmf_tcp_handle_h2c_data()
571 uint32_t data_len, data_offset; in nvmf_tcp_handle_c2h_data() local
600 data_offset = le32toh(c2h->datao); in nvmf_tcp_handle_c2h_data()
601 if (data_offset < cb->data_offset || in nvmf_tcp_handle_c2h_data()
602 data_offset + data_len > cb->data_offset + cb->data_len) { in nvmf_tcp_handle_c2h_data()
610 if (data_offset != cb->data_offset + cb->data_xfered) { in nvmf_tcp_handle_c2h_data()
628 data_offset -= cb->data_offset; in nvmf_tcp_handle_c2h_data()
630 memcpy((char *)cb->data + data_offset, icd, data_len); in nvmf_tcp_handle_c2h_data()
658 uint32_t data_offset, void *buf, size_t len, bool last_pdu) in tcp_send_h2c_pdu() argument
668 h2c.datao = htole32(data_offset); in tcp_send_h2c_pdu()
677 uint32_t data_offset, void *buf, size_t len, bool last_pdu) in tcp_send_h2c_pdus() argument
689 error = tcp_send_h2c_pdu(qp, cid, ttag, data_offset, p, todo, in tcp_send_h2c_pdus()
704 uint32_t data_len, data_offset; in nvmf_tcp_handle_r2t() local
719 data_offset = le32toh(r2t->r2to); in nvmf_tcp_handle_r2t()
720 if (data_offset != cb->data_xfered) { in nvmf_tcp_handle_r2t()
733 if (data_offset + data_len > cb->data_len) { in nvmf_tcp_handle_r2t()
748 data_offset, (char *)cb->data + data_offset, data_len, true); in nvmf_tcp_handle_r2t()
1304 uint32_t data_offset, uint32_t data_len) in tcp_send_r2t() argument
1312 r2t.r2to = htole32(data_offset); in tcp_send_r2t()
1319 tcp_receive_r2t_data(const struct nvmf_capsule *nc, uint32_t data_offset, in tcp_receive_r2t_data() argument
1333 error = tcp_send_r2t(qp, nc->nc_sqe.cid, ttag, data_offset, len); in tcp_receive_r2t_data()
1337 cb = tcp_alloc_command_buffer(qp, buf, data_offset, len, in tcp_receive_r2t_data()
1351 tcp_receive_icd_data(const struct nvmf_capsule *nc, uint32_t data_offset, in tcp_receive_icd_data() argument
1357 icd = (const char *)tc->rx_pdu.hdr + tc->rx_pdu.hdr->pdo + data_offset; in tcp_receive_icd_data()
1363 tcp_receive_controller_data(const struct nvmf_capsule *nc, uint32_t data_offset, in tcp_receive_controller_data() argument
1375 if (data_offset + len > data_len) in tcp_receive_controller_data()
1379 return (tcp_receive_icd_data(nc, data_offset, buf, len)); in tcp_receive_controller_data()
1381 return (tcp_receive_r2t_data(nc, data_offset, buf, len)); in tcp_receive_controller_data()
1387 uint32_t data_offset, const void *buf, size_t len, bool last_pdu, in tcp_send_c2h_pdu() argument
1399 c2h.datao = htole32(data_offset); in tcp_send_c2h_pdu()
1415 uint32_t data_len, data_offset; in tcp_send_controller_data() local
1441 data_offset = 0; in tcp_send_controller_data()
1451 error = tcp_send_c2h_pdu(qp, nc->nc_sqe.cid, data_offset, in tcp_send_controller_data()
1458 data_offset += todo; in tcp_send_controller_data()