| lists.openwall.net | lists / announce owl-users owl-dev john-users john-dev passwdqc-users yescrypt popa3d-users / oss-security kernel-hardening musl sabotage tlsify passwords / crypt-dev xvendor / Bugtraq Full-Disclosure linux-kernel linux-netdev linux-ext4 linux-hardening linux-cve-announce PHC | |
|
Open Source and information security mailing list archives
| ||
|
Message-ID: <88d052a4-4a91-b5e7-5d53-1fb2a1507909@suse.de>
Date: Sun, 2 May 2021 13:24:59 +0200
From: Hannes Reinecke <hare@...e.de>
To: Shai Malin <smalin@...vell.com>, netdev@...r.kernel.org,
linux-nvme@...ts.infradead.org, sagi@...mberg.me, hch@....de,
axboe@...com, kbusch@...nel.org
Cc: "David S . Miller davem @ davemloft . net --cc=Jakub Kicinski"
<kuba@...nel.org>, aelior@...vell.com, mkalderon@...vell.com,
okulkarni@...vell.com, pkushwaha@...vell.com, malin1024@...il.com
Subject: Re: [RFC PATCH v4 06/27] qed: Add NVMeTCP Offload IO Level FW
Initializations
On 4/29/21 9:09 PM, Shai Malin wrote:
> This patch introduces the NVMeTCP FW initializations which is used
> to initialize the IO level configuration into a per IO HW
> resource ("task") as part of the IO path flow.
>
> This includes:
> - Write IO FW initialization
> - Read IO FW initialization.
> - IC-Req and IC-Resp FW exchange.
> - FW Cleanup flow (Flush IO).
>
> Acked-by: Igor Russkikh <irusskikh@...vell.com>
> Signed-off-by: Prabhakar Kushwaha <pkushwaha@...vell.com>
> Signed-off-by: Omkar Kulkarni <okulkarni@...vell.com>
> Signed-off-by: Shai Malin <smalin@...vell.com>
> Signed-off-by: Michal Kalderon <mkalderon@...vell.com>
> Signed-off-by: Ariel Elior <aelior@...vell.com>
> ---
> drivers/net/ethernet/qlogic/qed/Makefile | 5 +-
> drivers/net/ethernet/qlogic/qed/qed_nvmetcp.c | 7 +-
> .../qlogic/qed/qed_nvmetcp_fw_funcs.c | 372 ++++++++++++++++++
> .../qlogic/qed/qed_nvmetcp_fw_funcs.h | 43 ++
> include/linux/qed/nvmetcp_common.h | 3 +
> include/linux/qed/qed_nvmetcp_if.h | 17 +
> 6 files changed, 445 insertions(+), 2 deletions(-)
> create mode 100644 drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.c
> create mode 100644 drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.h
>
> diff --git a/drivers/net/ethernet/qlogic/qed/Makefile b/drivers/net/ethernet/qlogic/qed/Makefile
> index 7cb0db67ba5b..0d9c2fe0245d 100644
> --- a/drivers/net/ethernet/qlogic/qed/Makefile
> +++ b/drivers/net/ethernet/qlogic/qed/Makefile
> @@ -28,7 +28,10 @@ qed-$(CONFIG_QED_ISCSI) += qed_iscsi.o
> qed-$(CONFIG_QED_LL2) += qed_ll2.o
> qed-$(CONFIG_QED_OOO) += qed_ooo.o
>
> -qed-$(CONFIG_QED_NVMETCP) += qed_nvmetcp.o
> +qed-$(CONFIG_QED_NVMETCP) += \
> + qed_nvmetcp.o \
> + qed_nvmetcp_fw_funcs.o \
> + qed_nvmetcp_ip_services.o
>
> qed-$(CONFIG_QED_RDMA) += \
> qed_iwarp.o \
> diff --git a/drivers/net/ethernet/qlogic/qed/qed_nvmetcp.c b/drivers/net/ethernet/qlogic/qed/qed_nvmetcp.c
> index 1e2eb6dcbd6e..434363f8b5c0 100644
> --- a/drivers/net/ethernet/qlogic/qed/qed_nvmetcp.c
> +++ b/drivers/net/ethernet/qlogic/qed/qed_nvmetcp.c
> @@ -27,6 +27,7 @@
> #include "qed_mcp.h"
> #include "qed_sp.h"
> #include "qed_reg_addr.h"
> +#include "qed_nvmetcp_fw_funcs.h"
>
> static int qed_nvmetcp_async_event(struct qed_hwfn *p_hwfn, u8 fw_event_code,
> u16 echo, union event_ring_data *data,
> @@ -848,7 +849,11 @@ static const struct qed_nvmetcp_ops qed_nvmetcp_ops_pass = {
> .remove_src_tcp_port_filter = &qed_llh_remove_src_tcp_port_filter,
> .add_dst_tcp_port_filter = &qed_llh_add_dst_tcp_port_filter,
> .remove_dst_tcp_port_filter = &qed_llh_remove_dst_tcp_port_filter,
> - .clear_all_filters = &qed_llh_clear_all_filters
> + .clear_all_filters = &qed_llh_clear_all_filters,
> + .init_read_io = &init_nvmetcp_host_read_task,
> + .init_write_io = &init_nvmetcp_host_write_task,
> + .init_icreq_exchange = &init_nvmetcp_init_conn_req_task,
> + .init_task_cleanup = &init_cleanup_task_nvmetcp
> };
>
> const struct qed_nvmetcp_ops *qed_get_nvmetcp_ops(void)
> diff --git a/drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.c b/drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.c
> new file mode 100644
> index 000000000000..8485ad678284
> --- /dev/null
> +++ b/drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.c
> @@ -0,0 +1,372 @@
> +// SPDX-License-Identifier: (GPL-2.0-only OR BSD-3-Clause)
> +/* Copyright 2021 Marvell. All rights reserved. */
> +
> +#include <linux/kernel.h>
> +#include <linux/module.h>
> +#include <linux/pci.h>
> +#include <linux/kernel.h>
> +#include <linux/list.h>
> +#include <linux/mm.h>
> +#include <linux/types.h>
> +#include <asm/byteorder.h>
> +#include <linux/qed/common_hsi.h>
> +#include <linux/qed/storage_common.h>
> +#include <linux/qed/nvmetcp_common.h>
> +#include <linux/qed/qed_nvmetcp_if.h>
> +#include "qed_nvmetcp_fw_funcs.h"
> +
> +#define NVMETCP_NUM_SGES_IN_CACHE 0x4
> +
> +bool nvmetcp_is_slow_sgl(u16 num_sges, bool small_mid_sge)
> +{
> + return (num_sges > SCSI_NUM_SGES_SLOW_SGL_THR && small_mid_sge);
> +}
> +
> +void init_scsi_sgl_context(struct scsi_sgl_params *ctx_sgl_params,
> + struct scsi_cached_sges *ctx_data_desc,
> + struct storage_sgl_task_params *sgl_params)
> +{
> + u8 num_sges_to_init = (u8)(sgl_params->num_sges > NVMETCP_NUM_SGES_IN_CACHE ?
> + NVMETCP_NUM_SGES_IN_CACHE : sgl_params->num_sges);
> + u8 sge_index;
> +
> + /* sgl params */
> + ctx_sgl_params->sgl_addr.lo = cpu_to_le32(sgl_params->sgl_phys_addr.lo);
> + ctx_sgl_params->sgl_addr.hi = cpu_to_le32(sgl_params->sgl_phys_addr.hi);
> + ctx_sgl_params->sgl_total_length = cpu_to_le32(sgl_params->total_buffer_size);
> + ctx_sgl_params->sgl_num_sges = cpu_to_le16(sgl_params->num_sges);
> +
> + for (sge_index = 0; sge_index < num_sges_to_init; sge_index++) {
> + ctx_data_desc->sge[sge_index].sge_addr.lo =
> + cpu_to_le32(sgl_params->sgl[sge_index].sge_addr.lo);
> + ctx_data_desc->sge[sge_index].sge_addr.hi =
> + cpu_to_le32(sgl_params->sgl[sge_index].sge_addr.hi);
> + ctx_data_desc->sge[sge_index].sge_len =
> + cpu_to_le32(sgl_params->sgl[sge_index].sge_len);
> + }
> +}
> +
> +static inline u32 calc_rw_task_size(struct nvmetcp_task_params *task_params,
> + enum nvmetcp_task_type task_type)
> +{
> + u32 io_size;
> +
> + if (task_type == NVMETCP_TASK_TYPE_HOST_WRITE)
> + io_size = task_params->tx_io_size;
> + else
> + io_size = task_params->rx_io_size;
> +
> + if (unlikely(!io_size))
> + return 0;
> +
> + return io_size;
> +}
> +
> +static inline void init_sqe(struct nvmetcp_task_params *task_params,
> + struct storage_sgl_task_params *sgl_task_params,
> + enum nvmetcp_task_type task_type)
> +{
> + if (!task_params->sqe)
> + return;
> +
> + memset(task_params->sqe, 0, sizeof(*task_params->sqe));
> + task_params->sqe->task_id = cpu_to_le16(task_params->itid);
> +
> + switch (task_type) {
> + case NVMETCP_TASK_TYPE_HOST_WRITE: {
> + u32 buf_size = 0;
> + u32 num_sges = 0;
> +
> + SET_FIELD(task_params->sqe->contlen_cdbsize,
> + NVMETCP_WQE_CDB_SIZE_OR_NVMETCP_CMD, 1);
> + SET_FIELD(task_params->sqe->flags, NVMETCP_WQE_WQE_TYPE,
> + NVMETCP_WQE_TYPE_NORMAL);
> + if (task_params->tx_io_size) {
> + if (task_params->send_write_incapsule)
> + buf_size = calc_rw_task_size(task_params, task_type);
> +
> + if (nvmetcp_is_slow_sgl(sgl_task_params->num_sges,
> + sgl_task_params->small_mid_sge))
> + num_sges = NVMETCP_WQE_NUM_SGES_SLOWIO;
> + else
> + num_sges = min((u16)sgl_task_params->num_sges,
> + (u16)SCSI_NUM_SGES_SLOW_SGL_THR);
> + }
> + SET_FIELD(task_params->sqe->flags, NVMETCP_WQE_NUM_SGES, num_sges);
> + SET_FIELD(task_params->sqe->contlen_cdbsize, NVMETCP_WQE_CONT_LEN, buf_size);
> + } break;
> +
> + case NVMETCP_TASK_TYPE_HOST_READ: {
> + SET_FIELD(task_params->sqe->flags, NVMETCP_WQE_WQE_TYPE,
> + NVMETCP_WQE_TYPE_NORMAL);
> + SET_FIELD(task_params->sqe->contlen_cdbsize,
> + NVMETCP_WQE_CDB_SIZE_OR_NVMETCP_CMD, 1);
> + } break;
> +
> + case NVMETCP_TASK_TYPE_INIT_CONN_REQUEST: {
> + SET_FIELD(task_params->sqe->flags, NVMETCP_WQE_WQE_TYPE,
> + NVMETCP_WQE_TYPE_MIDDLE_PATH);
> +
> + if (task_params->tx_io_size) {
> + SET_FIELD(task_params->sqe->contlen_cdbsize, NVMETCP_WQE_CONT_LEN,
> + task_params->tx_io_size);
> + SET_FIELD(task_params->sqe->flags, NVMETCP_WQE_NUM_SGES,
> + min((u16)sgl_task_params->num_sges,
> + (u16)SCSI_NUM_SGES_SLOW_SGL_THR));
> + }
> + } break;
> +
> + case NVMETCP_TASK_TYPE_CLEANUP:
> + SET_FIELD(task_params->sqe->flags, NVMETCP_WQE_WQE_TYPE,
> + NVMETCP_WQE_TYPE_TASK_CLEANUP);
> +
> + default:
> + break;
> + }
> +}
> +
> +/* The following function initializes of NVMeTCP task params */
> +static inline void
> +init_nvmetcp_task_params(struct e5_nvmetcp_task_context *context,
> + struct nvmetcp_task_params *task_params,
> + enum nvmetcp_task_type task_type)
> +{
> + context->ystorm_st_context.state.cccid = task_params->host_cccid;
> + SET_FIELD(context->ustorm_st_context.error_flags, USTORM_NVMETCP_TASK_ST_CTX_NVME_TCP, 1);
> + context->ustorm_st_context.nvme_tcp_opaque_lo = cpu_to_le32(task_params->opq.lo);
> + context->ustorm_st_context.nvme_tcp_opaque_hi = cpu_to_le32(task_params->opq.hi);
> +}
> +
> +/* The following function initializes default values to all tasks */
> +static inline void
> +init_default_nvmetcp_task(struct nvmetcp_task_params *task_params, void *pdu_header,
> + enum nvmetcp_task_type task_type)
> +{
> + struct e5_nvmetcp_task_context *context = task_params->context;
> + const u8 val_byte = context->mstorm_ag_context.cdu_validation;
> + u8 dw_index;
> +
> + memset(context, 0, sizeof(*context));
> +
> + init_nvmetcp_task_params(context, task_params,
> + (enum nvmetcp_task_type)task_type);
> +
> + if (task_type == NVMETCP_TASK_TYPE_HOST_WRITE ||
> + task_type == NVMETCP_TASK_TYPE_HOST_READ) {
> + for (dw_index = 0; dw_index < QED_NVMETCP_CMD_HDR_SIZE / 4; dw_index++)
> + context->ystorm_st_context.pdu_hdr.task_hdr.reg[dw_index] =
> + cpu_to_le32(((u32 *)pdu_header)[dw_index]);
> + } else {
> + for (dw_index = 0; dw_index < QED_NVMETCP_CMN_HDR_SIZE / 4; dw_index++)
> + context->ystorm_st_context.pdu_hdr.task_hdr.reg[dw_index] =
> + cpu_to_le32(((u32 *)pdu_header)[dw_index]);
> + }
> +
And this is what I meant. You are twiddling with the bytes already, so
why bother with a separate struct at all?
> + /* M-Storm Context: */
> + context->mstorm_ag_context.cdu_validation = val_byte;
> + context->mstorm_st_context.task_type = (u8)(task_type);
> + context->mstorm_ag_context.task_cid = cpu_to_le16(task_params->conn_icid);
> +
> + /* Ustorm Context: */
> + SET_FIELD(context->ustorm_ag_context.flags1, E5_USTORM_NVMETCP_TASK_AG_CTX_R2T2RECV, 1);
> + context->ustorm_st_context.task_type = (u8)(task_type);
> + context->ustorm_st_context.cq_rss_number = task_params->cq_rss_number;
> + context->ustorm_ag_context.icid = cpu_to_le16(task_params->conn_icid);
> +}
> +
> +/* The following function initializes the U-Storm Task Contexts */
> +static inline void
> +init_ustorm_task_contexts(struct ustorm_nvmetcp_task_st_ctx *ustorm_st_context,
> + struct e5_ustorm_nvmetcp_task_ag_ctx *ustorm_ag_context,
> + u32 remaining_recv_len,
> + u32 expected_data_transfer_len, u8 num_sges,
> + bool tx_dif_conn_err_en)
> +{
> + /* Remaining data to be received in bytes. Used in validations*/
> + ustorm_st_context->rem_rcv_len = cpu_to_le32(remaining_recv_len);
> + ustorm_ag_context->exp_data_acked = cpu_to_le32(expected_data_transfer_len);
> + ustorm_st_context->exp_data_transfer_len = cpu_to_le32(expected_data_transfer_len);
> + SET_FIELD(ustorm_st_context->reg1.reg1_map, NVMETCP_REG1_NUM_SGES, num_sges);
> + SET_FIELD(ustorm_ag_context->flags2, E5_USTORM_NVMETCP_TASK_AG_CTX_DIF_ERROR_CF_EN,
> + tx_dif_conn_err_en ? 1 : 0);
> +}
> +
> +/* The following function initializes Local Completion Contexts: */
> +static inline void
> +set_local_completion_context(struct e5_nvmetcp_task_context *context)
> +{
> + SET_FIELD(context->ystorm_st_context.state.flags,
> + YSTORM_NVMETCP_TASK_STATE_LOCAL_COMP, 1);
> + SET_FIELD(context->ustorm_st_context.flags,
> + USTORM_NVMETCP_TASK_ST_CTX_LOCAL_COMP, 1);
> +}
> +
> +/* Common Fastpath task init function: */
> +static inline void
> +init_rw_nvmetcp_task(struct nvmetcp_task_params *task_params,
> + enum nvmetcp_task_type task_type,
> + struct nvmetcp_conn_params *conn_params, void *pdu_header,
> + struct storage_sgl_task_params *sgl_task_params)
> +{
> + struct e5_nvmetcp_task_context *context = task_params->context;
> + u32 task_size = calc_rw_task_size(task_params, task_type);
> + u32 exp_data_transfer_len = conn_params->max_burst_length;
> + bool slow_io = false;
> + u8 num_sges = 0;
> +
> + init_default_nvmetcp_task(task_params, pdu_header, task_type);
> +
> + /* Tx/Rx: */
> + if (task_params->tx_io_size) {
> + /* if data to transmit: */
> + init_scsi_sgl_context(&context->ystorm_st_context.state.sgl_params,
> + &context->ystorm_st_context.state.data_desc,
> + sgl_task_params);
> + slow_io = nvmetcp_is_slow_sgl(sgl_task_params->num_sges,
> + sgl_task_params->small_mid_sge);
> + num_sges =
> + (u8)(!slow_io ? min((u32)sgl_task_params->num_sges,
> + (u32)SCSI_NUM_SGES_SLOW_SGL_THR) :
> + NVMETCP_WQE_NUM_SGES_SLOWIO);
> + if (slow_io) {
> + SET_FIELD(context->ystorm_st_context.state.flags,
> + YSTORM_NVMETCP_TASK_STATE_SLOW_IO, 1);
> + }
> + } else if (task_params->rx_io_size) {
> + /* if data to receive: */
> + init_scsi_sgl_context(&context->mstorm_st_context.sgl_params,
> + &context->mstorm_st_context.data_desc,
> + sgl_task_params);
> + num_sges =
> + (u8)(!nvmetcp_is_slow_sgl(sgl_task_params->num_sges,
> + sgl_task_params->small_mid_sge) ?
> + min((u32)sgl_task_params->num_sges,
> + (u32)SCSI_NUM_SGES_SLOW_SGL_THR) :
> + NVMETCP_WQE_NUM_SGES_SLOWIO);
> + context->mstorm_st_context.rem_task_size = cpu_to_le32(task_size);
> + }
> +
> + /* Ustorm context: */
> + if (exp_data_transfer_len > task_size)
> + /* The size of the transmitted task*/
> + exp_data_transfer_len = task_size;
> + init_ustorm_task_contexts(&context->ustorm_st_context,
> + &context->ustorm_ag_context,
> + /* Remaining Receive length is the Task Size */
> + task_size,
> + /* The size of the transmitted task */
> + exp_data_transfer_len,
> + /* num_sges */
> + num_sges,
> + false);
> +
> + /* Set exp_data_acked */
> + if (task_type == NVMETCP_TASK_TYPE_HOST_WRITE) {
> + if (task_params->send_write_incapsule)
> + context->ustorm_ag_context.exp_data_acked = task_size;
> + else
> + context->ustorm_ag_context.exp_data_acked = 0;
> + } else if (task_type == NVMETCP_TASK_TYPE_HOST_READ) {
> + context->ustorm_ag_context.exp_data_acked = 0;
> + }
> +
> + context->ustorm_ag_context.exp_cont_len = 0;
> +
> + init_sqe(task_params, sgl_task_params, task_type);
> +}
> +
> +static void
> +init_common_initiator_read_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params)
> +{
> + init_rw_nvmetcp_task(task_params, NVMETCP_TASK_TYPE_HOST_READ,
> + conn_params, cmd_pdu_header, sgl_task_params);
> +}
> +
> +void init_nvmetcp_host_read_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params)
> +{
> + init_common_initiator_read_task(task_params, conn_params,
> + (void *)cmd_pdu_header, sgl_task_params);
> +}
> +
> +static void
> +init_common_initiator_write_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params)
> +{
> + init_rw_nvmetcp_task(task_params, NVMETCP_TASK_TYPE_HOST_WRITE,
> + conn_params, cmd_pdu_header, sgl_task_params);
> +}
> +
> +void init_nvmetcp_host_write_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params)
> +{
> + init_common_initiator_write_task(task_params, conn_params,
> + (void *)cmd_pdu_header,
> + sgl_task_params);
> +}
> +
> +static void
> +init_common_login_request_task(struct nvmetcp_task_params *task_params,
> + void *login_req_pdu_header,
> + struct storage_sgl_task_params *tx_sgl_task_params,
> + struct storage_sgl_task_params *rx_sgl_task_params)
> +{
> + struct e5_nvmetcp_task_context *context = task_params->context;
> +
> + init_default_nvmetcp_task(task_params, (void *)login_req_pdu_header,
> + NVMETCP_TASK_TYPE_INIT_CONN_REQUEST);
> +
> + /* Ustorm Context: */
> + init_ustorm_task_contexts(&context->ustorm_st_context,
> + &context->ustorm_ag_context,
> +
> + /* Remaining Receive length is the Task Size */
> + task_params->rx_io_size ?
> + rx_sgl_task_params->total_buffer_size : 0,
> +
> + /* The size of the transmitted task */
> + task_params->tx_io_size ?
> + tx_sgl_task_params->total_buffer_size : 0,
> + 0, /* num_sges */
> + 0); /* tx_dif_conn_err_en */
> +
> + /* SGL context: */
> + if (task_params->tx_io_size)
> + init_scsi_sgl_context(&context->ystorm_st_context.state.sgl_params,
> + &context->ystorm_st_context.state.data_desc,
> + tx_sgl_task_params);
> + if (task_params->rx_io_size)
> + init_scsi_sgl_context(&context->mstorm_st_context.sgl_params,
> + &context->mstorm_st_context.data_desc,
> + rx_sgl_task_params);
> +
> + context->mstorm_st_context.rem_task_size =
> + cpu_to_le32(task_params->rx_io_size ?
> + rx_sgl_task_params->total_buffer_size : 0);
> +
> + init_sqe(task_params, tx_sgl_task_params, NVMETCP_TASK_TYPE_INIT_CONN_REQUEST);
> +}
> +
> +/* The following function initializes Login task in Host mode: */
> +void init_nvmetcp_init_conn_req_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_init_conn_req_hdr *init_conn_req_pdu_hdr,
> + struct storage_sgl_task_params *tx_sgl_task_params,
> + struct storage_sgl_task_params *rx_sgl_task_params)
> +{
> + init_common_login_request_task(task_params, init_conn_req_pdu_hdr,
> + tx_sgl_task_params, rx_sgl_task_params);
> +}
> +
> +void init_cleanup_task_nvmetcp(struct nvmetcp_task_params *task_params)
> +{
> + init_sqe(task_params, NULL, NVMETCP_TASK_TYPE_CLEANUP);
> +}
> diff --git a/drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.h b/drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.h
> new file mode 100644
> index 000000000000..3a8c74356c4c
> --- /dev/null
> +++ b/drivers/net/ethernet/qlogic/qed/qed_nvmetcp_fw_funcs.h
> @@ -0,0 +1,43 @@
> +/* SPDX-License-Identifier: (GPL-2.0-only OR BSD-3-Clause) */
> +/* Copyright 2021 Marvell. All rights reserved. */
> +
> +#ifndef _QED_NVMETCP_FW_FUNCS_H
> +#define _QED_NVMETCP_FW_FUNCS_H
> +
> +#include <linux/kernel.h>
> +#include <linux/module.h>
> +#include <linux/pci.h>
> +#include <linux/kernel.h>
> +#include <linux/list.h>
> +#include <linux/mm.h>
> +#include <linux/types.h>
> +#include <asm/byteorder.h>
> +#include <linux/qed/common_hsi.h>
> +#include <linux/qed/storage_common.h>
> +#include <linux/qed/nvmetcp_common.h>
> +#include <linux/qed/qed_nvmetcp_if.h>
> +
> +#if IS_ENABLED(CONFIG_QED_NVMETCP)
> +
> +void init_nvmetcp_host_read_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params);
> +
> +void init_nvmetcp_host_write_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params);
> +
> +void init_nvmetcp_init_conn_req_task(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_init_conn_req_hdr *init_conn_req_pdu_hdr,
> + struct storage_sgl_task_params *tx_sgl_task_params,
> + struct storage_sgl_task_params *rx_sgl_task_params);
> +
> +void init_cleanup_task_nvmetcp(struct nvmetcp_task_params *task_params);
> +
> +#else /* IS_ENABLED(CONFIG_QED_NVMETCP) */
> +
> +#endif /* IS_ENABLED(CONFIG_QED_NVMETCP) */
> +
> +#endif /* _QED_NVMETCP_FW_FUNCS_H */
> diff --git a/include/linux/qed/nvmetcp_common.h b/include/linux/qed/nvmetcp_common.h
> index dda7a785c321..c0023bb185dd 100644
> --- a/include/linux/qed/nvmetcp_common.h
> +++ b/include/linux/qed/nvmetcp_common.h
> @@ -9,6 +9,9 @@
> #define NVMETCP_SLOW_PATH_LAYER_CODE (6)
> #define NVMETCP_WQE_NUM_SGES_SLOWIO (0xf)
>
> +#define QED_NVMETCP_CMD_HDR_SIZE 72
> +#define QED_NVMETCP_CMN_HDR_SIZE 24
> +
> /* NVMeTCP firmware function init parameters */
> struct nvmetcp_spe_func_init {
> __le16 half_way_close_timeout;
> diff --git a/include/linux/qed/qed_nvmetcp_if.h b/include/linux/qed/qed_nvmetcp_if.h
> index 04e90dc42c12..d971be84f804 100644
> --- a/include/linux/qed/qed_nvmetcp_if.h
> +++ b/include/linux/qed/qed_nvmetcp_if.h
> @@ -220,6 +220,23 @@ struct qed_nvmetcp_ops {
> void (*remove_dst_tcp_port_filter)(struct qed_dev *cdev, u16 dest_port);
>
> void (*clear_all_filters)(struct qed_dev *cdev);
> +
> + void (*init_read_io)(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params);
> +
> + void (*init_write_io)(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_conn_params *conn_params,
> + struct nvmetcp_cmd_capsule_hdr *cmd_pdu_header,
> + struct storage_sgl_task_params *sgl_task_params);
> +
> + void (*init_icreq_exchange)(struct nvmetcp_task_params *task_params,
> + struct nvmetcp_init_conn_req_hdr *init_conn_req_pdu_hdr,
> + struct storage_sgl_task_params *tx_sgl_task_params,
> + struct storage_sgl_task_params *rx_sgl_task_params);
> +
> + void (*init_task_cleanup)(struct nvmetcp_task_params *task_params);
> };
>
> const struct qed_nvmetcp_ops *qed_get_nvmetcp_ops(void);
>
Cheers,
Hannes
--
Dr. Hannes Reinecke Kernel Storage Architect
hare@...e.de +49 911 74053 688
SUSE Software Solutions GmbH, Maxfeldstr. 5, 90409 Nürnberg
HRB 36809 (AG Nürnberg), Geschäftsführer: Felix Imendörffer
Powered by blists - more mailing lists