diff --git a/src/engine/engine_d2c.c b/src/engine/engine_d2c.c index 9f7351a..16cf800 100644 --- a/src/engine/engine_d2c.c +++ b/src/engine/engine_d2c.c @@ -1,5 +1,5 @@ /* - * Copyright(c) 2012-2021 Intel Corporation + * Copyright(c) 2012-2022 Intel Corporation * SPDX-License-Identifier: BSD-3-Clause */ #include "ocf/ocf.h" @@ -38,7 +38,6 @@ int ocf_io_d2c(struct ocf_request *req) OCF_DEBUG_TRACE(req->cache); - ocf_io_start(&req->ioi.io); /* Get OCF request - increase reference counter */ ocf_req_get(req); diff --git a/src/engine/engine_discard.c b/src/engine/engine_discard.c index 3860386..d3788ff 100644 --- a/src/engine/engine_discard.c +++ b/src/engine/engine_discard.c @@ -243,7 +243,6 @@ int ocf_discard(struct ocf_request *req) { OCF_DEBUG_TRACE(req->cache); - ocf_io_start(&req->ioi.io); if (req->rw == OCF_READ) { req->complete(req, -OCF_ERR_INVAL); diff --git a/src/engine/engine_fast.c b/src/engine/engine_fast.c index 91822f8..fc7e608 100644 --- a/src/engine/engine_fast.c +++ b/src/engine/engine_fast.c @@ -125,7 +125,6 @@ int ocf_read_fast(struct ocf_request *req) part_has_space = ocf_user_part_has_space(req); if (hit && part_has_space) { - ocf_io_start(&req->ioi.io); lock = ocf_req_async_lock_rd( ocf_cache_line_concurrency(req->cache), req, ocf_engine_on_resume); @@ -192,7 +191,6 @@ int ocf_write_fast(struct ocf_request *req) part_has_space = ocf_user_part_has_space(req); if (mapped && part_has_space) { - ocf_io_start(&req->ioi.io); lock = ocf_req_async_lock_wr( ocf_cache_line_concurrency(req->cache), req, ocf_engine_on_resume); diff --git a/src/engine/engine_pt.c b/src/engine/engine_pt.c index 8c5706d..d49faa9 100644 --- a/src/engine/engine_pt.c +++ b/src/engine/engine_pt.c @@ -102,7 +102,6 @@ int ocf_read_pt(struct ocf_request *req) OCF_DEBUG_TRACE(req->cache); - ocf_io_start(&req->ioi.io); /* Get OCF request - increase reference counter */ ocf_req_get(req); diff --git a/src/engine/engine_rd.c b/src/engine/engine_rd.c index 7d07dd0..52fd4d3 100644 --- a/src/engine/engine_rd.c +++ b/src/engine/engine_rd.c @@ -214,7 +214,6 @@ int ocf_read_generic(struct ocf_request *req) int lock = OCF_LOCK_NOT_ACQUIRED; struct ocf_cache *cache = req->cache; - ocf_io_start(&req->ioi.io); if (env_atomic_read(&cache->pending_read_misses_list_blocked)) { /* There are conditions to bypass IO */ diff --git a/src/engine/engine_wa.c b/src/engine/engine_wa.c index 2e68a0b..cb72d0e 100644 --- a/src/engine/engine_wa.c +++ b/src/engine/engine_wa.c @@ -18,7 +18,6 @@ int ocf_write_wa(struct ocf_request *req) { - ocf_io_start(&req->ioi.io); /* Get OCF request - increase reference counter */ ocf_req_get(req); diff --git a/src/engine/engine_wb.c b/src/engine/engine_wb.c index 15574ae..9343360 100644 --- a/src/engine/engine_wb.c +++ b/src/engine/engine_wb.c @@ -167,7 +167,6 @@ int ocf_write_wb(struct ocf_request *req) { int lock = OCF_LOCK_NOT_ACQUIRED; - ocf_io_start(&req->ioi.io); /* Not sure if we need this. */ ocf_req_get(req); diff --git a/src/engine/engine_wi.c b/src/engine/engine_wi.c index bc6def5..f5076d2 100644 --- a/src/engine/engine_wi.c +++ b/src/engine/engine_wi.c @@ -163,7 +163,6 @@ int ocf_write_wi(struct ocf_request *req) OCF_DEBUG_TRACE(req->cache); - ocf_io_start(&req->ioi.io); /* Get OCF request - increase reference counter */ ocf_req_get(req); diff --git a/src/engine/engine_wo.c b/src/engine/engine_wo.c index df056bf..513f747 100644 --- a/src/engine/engine_wo.c +++ b/src/engine/engine_wo.c @@ -207,7 +207,6 @@ int ocf_read_wo(struct ocf_request *req) OCF_DEBUG_TRACE(req->cache); - ocf_io_start(&req->ioi.io); /* Get OCF request - increase reference counter */ ocf_req_get(req); diff --git a/src/engine/engine_wt.c b/src/engine/engine_wt.c index c824999..95a2321 100644 --- a/src/engine/engine_wt.c +++ b/src/engine/engine_wt.c @@ -201,7 +201,6 @@ int ocf_write_wt(struct ocf_request *req) { int lock = OCF_LOCK_NOT_ACQUIRED; - ocf_io_start(&req->ioi.io); /* Get OCF request - increase reference counter */ ocf_req_get(req); diff --git a/src/ocf_io_priv.h b/src/ocf_io_priv.h index b26d5dd..1d56b6f 100644 --- a/src/ocf_io_priv.h +++ b/src/ocf_io_priv.h @@ -46,17 +46,6 @@ struct ocf_io *ocf_io_new(ocf_volume_t volume, ocf_queue_t queue, uint64_t addr, uint32_t bytes, uint32_t dir, uint32_t io_class, uint64_t flags); -static inline void ocf_io_start(struct ocf_io *io) -{ - /* - * We want to call start() callback only once, so after calling - * we set it to NULL to prevent multiple calls. - */ - if (io->start) { - io->start(io); - io->start = NULL; - } -} static inline void ocf_io_end(struct ocf_io *io, int error) {