Commit 90107455 authored by Jay Sternberg's avatar Jay Sternberg Committed by Jens Axboe

nvmet: make kato and AEN processing for use by other controllers

Make common process of get/set features available to other controllers by
making simple functions static inline and others not static and prototypes
in nvmet.h file

Also remove static from nvmet_execute_async_event and add prototype to
nvmet.h to allow used by other controllers
Signed-off-by: default avatarJay Sternberg <jay.e.sternberg@intel.com>
Reviewed-by: default avatarHannes Reinecke <hare@suse.com>
Reviewed-by: default avatarSagi Grimberg <sagi@grimberg.me>
Reviewed-by: default avatarJohannes Thumshirn <jthumshirn@suse.de>
Reviewed-by: default avatarChristoph Hellwig <hch@lst.de>
Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Signed-off-by: default avatarJens Axboe <axboe@kernel.dk>
parent f9362ac1
...@@ -587,11 +587,34 @@ static u16 nvmet_set_feat_write_protect(struct nvmet_req *req) ...@@ -587,11 +587,34 @@ static u16 nvmet_set_feat_write_protect(struct nvmet_req *req)
return status; return status;
} }
u16 nvmet_set_feat_kato(struct nvmet_req *req)
{
u32 val32 = le32_to_cpu(req->cmd->common.cdw10[1]);
req->sq->ctrl->kato = DIV_ROUND_UP(val32, 1000);
nvmet_set_result(req, req->sq->ctrl->kato);
return 0;
}
u16 nvmet_set_feat_async_event(struct nvmet_req *req, u32 mask)
{
u32 val32 = le32_to_cpu(req->cmd->common.cdw10[1]);
if (val32 & ~mask)
return NVME_SC_INVALID_FIELD | NVME_SC_DNR;
WRITE_ONCE(req->sq->ctrl->aen_enabled, val32);
nvmet_set_result(req, val32);
return 0;
}
static void nvmet_execute_set_features(struct nvmet_req *req) static void nvmet_execute_set_features(struct nvmet_req *req)
{ {
struct nvmet_subsys *subsys = req->sq->ctrl->subsys; struct nvmet_subsys *subsys = req->sq->ctrl->subsys;
u32 cdw10 = le32_to_cpu(req->cmd->common.cdw10[0]); u32 cdw10 = le32_to_cpu(req->cmd->common.cdw10[0]);
u32 val32;
u16 status = 0; u16 status = 0;
switch (cdw10 & 0xff) { switch (cdw10 & 0xff) {
...@@ -600,19 +623,10 @@ static void nvmet_execute_set_features(struct nvmet_req *req) ...@@ -600,19 +623,10 @@ static void nvmet_execute_set_features(struct nvmet_req *req)
(subsys->max_qid - 1) | ((subsys->max_qid - 1) << 16)); (subsys->max_qid - 1) | ((subsys->max_qid - 1) << 16));
break; break;
case NVME_FEAT_KATO: case NVME_FEAT_KATO:
val32 = le32_to_cpu(req->cmd->common.cdw10[1]); status = nvmet_set_feat_kato(req);
req->sq->ctrl->kato = DIV_ROUND_UP(val32, 1000);
nvmet_set_result(req, req->sq->ctrl->kato);
break; break;
case NVME_FEAT_ASYNC_EVENT: case NVME_FEAT_ASYNC_EVENT:
val32 = le32_to_cpu(req->cmd->common.cdw10[1]); status = nvmet_set_feat_async_event(req, NVMET_AEN_CFG_ALL);
if (val32 & ~NVMET_AEN_CFG_ALL) {
status = NVME_SC_INVALID_FIELD | NVME_SC_DNR;
break;
}
WRITE_ONCE(req->sq->ctrl->aen_enabled, val32);
nvmet_set_result(req, val32);
break; break;
case NVME_FEAT_HOST_ID: case NVME_FEAT_HOST_ID:
status = NVME_SC_CMD_SEQ_ERROR | NVME_SC_DNR; status = NVME_SC_CMD_SEQ_ERROR | NVME_SC_DNR;
...@@ -648,6 +662,16 @@ static u16 nvmet_get_feat_write_protect(struct nvmet_req *req) ...@@ -648,6 +662,16 @@ static u16 nvmet_get_feat_write_protect(struct nvmet_req *req)
return 0; return 0;
} }
void nvmet_get_feat_kato(struct nvmet_req *req)
{
nvmet_set_result(req, req->sq->ctrl->kato * 1000);
}
void nvmet_get_feat_async_event(struct nvmet_req *req)
{
nvmet_set_result(req, READ_ONCE(req->sq->ctrl->aen_enabled));
}
static void nvmet_execute_get_features(struct nvmet_req *req) static void nvmet_execute_get_features(struct nvmet_req *req)
{ {
struct nvmet_subsys *subsys = req->sq->ctrl->subsys; struct nvmet_subsys *subsys = req->sq->ctrl->subsys;
...@@ -677,7 +701,7 @@ static void nvmet_execute_get_features(struct nvmet_req *req) ...@@ -677,7 +701,7 @@ static void nvmet_execute_get_features(struct nvmet_req *req)
break; break;
#endif #endif
case NVME_FEAT_ASYNC_EVENT: case NVME_FEAT_ASYNC_EVENT:
nvmet_set_result(req, READ_ONCE(req->sq->ctrl->aen_enabled)); nvmet_get_feat_async_event(req);
break; break;
case NVME_FEAT_VOLATILE_WC: case NVME_FEAT_VOLATILE_WC:
nvmet_set_result(req, 1); nvmet_set_result(req, 1);
...@@ -687,7 +711,7 @@ static void nvmet_execute_get_features(struct nvmet_req *req) ...@@ -687,7 +711,7 @@ static void nvmet_execute_get_features(struct nvmet_req *req)
(subsys->max_qid-1) | ((subsys->max_qid-1) << 16)); (subsys->max_qid-1) | ((subsys->max_qid-1) << 16));
break; break;
case NVME_FEAT_KATO: case NVME_FEAT_KATO:
nvmet_set_result(req, req->sq->ctrl->kato * 1000); nvmet_get_feat_kato(req);
break; break;
case NVME_FEAT_HOST_ID: case NVME_FEAT_HOST_ID:
/* need 128-bit host identifier flag */ /* need 128-bit host identifier flag */
...@@ -710,7 +734,7 @@ static void nvmet_execute_get_features(struct nvmet_req *req) ...@@ -710,7 +734,7 @@ static void nvmet_execute_get_features(struct nvmet_req *req)
nvmet_req_complete(req, status); nvmet_req_complete(req, status);
} }
static void nvmet_execute_async_event(struct nvmet_req *req) void nvmet_execute_async_event(struct nvmet_req *req)
{ {
struct nvmet_ctrl *ctrl = req->sq->ctrl; struct nvmet_ctrl *ctrl = req->sq->ctrl;
......
...@@ -357,6 +357,12 @@ static inline bool nvmet_aen_bit_disabled(struct nvmet_ctrl *ctrl, u32 bn) ...@@ -357,6 +357,12 @@ static inline bool nvmet_aen_bit_disabled(struct nvmet_ctrl *ctrl, u32 bn)
return test_and_set_bit(bn, &ctrl->aen_masked); return test_and_set_bit(bn, &ctrl->aen_masked);
} }
void nvmet_get_feat_kato(struct nvmet_req *req);
void nvmet_get_feat_async_event(struct nvmet_req *req);
u16 nvmet_set_feat_kato(struct nvmet_req *req);
u16 nvmet_set_feat_async_event(struct nvmet_req *req, u32 mask);
void nvmet_execute_async_event(struct nvmet_req *req);
u16 nvmet_parse_connect_cmd(struct nvmet_req *req); u16 nvmet_parse_connect_cmd(struct nvmet_req *req);
u16 nvmet_bdev_parse_io_cmd(struct nvmet_req *req); u16 nvmet_bdev_parse_io_cmd(struct nvmet_req *req);
u16 nvmet_file_parse_io_cmd(struct nvmet_req *req); u16 nvmet_file_parse_io_cmd(struct nvmet_req *req);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment