Debug request tracing

Signed-off-by: Michal Mielewczyk <[email protected]>

Author: mmichal10

src/engine/cache_engine.c

@@ -41,6 +41,9 @@ enum ocf_io_if_type {
 	OCF_IO_FAST_IF,
 	OCF_IO_FLUSH_IF,
 	OCF_IO_DISCARD_IF,
+	OCF_IO_REFRESH_IF,
+	OCF_IO_INVALIDATE_IF,
+	OCF_IO_RD_IF,
 	OCF_IO_PRIV_MAX_IF,
 };
 
@@ -108,6 +111,18 @@ static const struct ocf_io_if IO_IFS[OCF_IO_PRIV_MAX_IF] = {
 		},
 		.name = "Discard",
 	},
+	[OCF_IO_REFRESH_IF] = {
+		.cbs = { },
+		.name = "Refresh",
+	},
+	[OCF_IO_INVALIDATE_IF] = {
+		.cbs = { },
+		.name = "Invalidate",
+	},
+	[OCF_IO_RD_IF] = {
+		.cbs = { },
+		.name = "Read generic",
+	},
 };
 
 static const struct ocf_io_if *cache_mode_io_if_map[ocf_req_cache_mode_max] = {
@@ -118,8 +133,29 @@ static const struct ocf_io_if *cache_mode_io_if_map[ocf_req_cache_mode_max] = {
 	[ocf_req_cache_mode_wo] = &IO_IFS[OCF_IO_WO_IF],
 	[ocf_req_cache_mode_pt] = &IO_IFS[OCF_IO_PT_IF],
 	[ocf_req_cache_mode_fast] = &IO_IFS[OCF_IO_FAST_IF],
+	[ocf_req_refresh] = &IO_IFS[OCF_IO_REFRESH_IF],
+	[ocf_req_cache_mode_discard] = &IO_IFS[OCF_IO_DISCARD_IF],
+	[ocf_req_cache_mode_invalidate] = &IO_IFS[OCF_IO_INVALIDATE_IF],
+	[ocf_req_cache_mode_rd] = &IO_IFS[OCF_IO_RD_IF],
 };
 
+void ocf_debug_request_trace(struct ocf_request *req,
+		ocf_req_cache_mode_t engine, uint8_t info)
+{
+	uint8_t tmp = (uint8_t)engine;
+
+	ENV_BUG_ON(info > 0xf);
+	ENV_BUG_ON(engine > 0xf);
+
+	ENV_WARN_ON(req->engine_trace & 0xff00000000000000);
+
+	req->engine_trace <<= 4;
+	req->engine_trace |= engine;
+
+	req->engine_trace <<= 4;
+	req->engine_trace |= tmp;
+}
+
 const char *ocf_get_io_iface_name(ocf_req_cache_mode_t cache_mode)
 {
 	if (cache_mode == ocf_req_cache_mode_max)

src/engine/cache_engine.h

@@ -47,4 +47,7 @@ void ocf_engine_hndl_flush_req(struct ocf_request *req);
 
 void ocf_engine_hndl_discard_req(struct ocf_request *req);
 
+void ocf_debug_request_trace(struct ocf_request *req,
+		ocf_req_cache_mode_t engine, uint8_t info);
+
 #endif

src/engine/engine_common.c

@@ -599,6 +599,8 @@ static int _ocf_engine_refresh(struct ocf_request *req)
 {
 	int result;
 
+	ocf_debug_request_trace(req, ocf_req_refresh, 0);
+
 	/* Check under metadata RD lock */
 	ocf_hb_req_prot_lock_rd(req);
 

src/engine/engine_discard.c

@@ -211,6 +211,8 @@ int ocf_engine_discard(struct ocf_request *req)
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_discard, 0);
+
 	_ocf_discard_step(req);
 
 	/* Put OCF request - decrease reference counter */

src/engine/engine_fast.c

@@ -99,6 +99,8 @@ int ocf_read_fast(struct ocf_request *req)
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_fast, 0);
+
 	/* Set resume handler */
 	req->engine_handler = _ocf_read_fast_do;
 
@@ -165,6 +167,8 @@ int ocf_write_fast(struct ocf_request *req)
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_fast, 1);
+
 	/* Set resume handler */
 	req->engine_handler = ocf_write_wb_do;
 

src/engine/engine_inv.c

@@ -40,6 +40,8 @@ static int _ocf_invalidate_do(struct ocf_request *req)
 	ocf_purge_map_info(req);
 	ocf_hb_req_prot_unlock_wr(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_invalidate, 0);
+
 	if (ocf_volume_is_atomic(&cache->device->volume) &&
 			req->info.flush_metadata) {
 		/* Metadata flush IO */

src/engine/engine_pt.c

@@ -47,6 +47,8 @@ int ocf_read_pt_do(struct ocf_request *req)
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_pt, 0);
+
 	if (req->info.dirty_any) {
 		ocf_hb_req_prot_lock_rd(req);
 		/* Need to clean, start it */
@@ -97,10 +99,11 @@ int ocf_read_pt(struct ocf_request *req)
 
 	OCF_DEBUG_TRACE(req->cache);
 
-
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_pt, 1);
+
 	/* Set resume handler */
 	req->engine_handler = ocf_read_pt_do;
 

src/engine/engine_rd.c

@@ -183,6 +183,8 @@ int ocf_read_generic(struct ocf_request *req)
 	int lock = OCF_LOCK_NOT_ACQUIRED;
 	struct ocf_cache *cache = req->cache;
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_rd, 0);
+
 
 	if (env_atomic_read(&cache->pending_read_misses_list_blocked)) {
 		/* There are conditions to bypass IO */

src/engine/engine_wa.c

@@ -23,6 +23,8 @@ int ocf_write_wa(struct ocf_request *req)
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_wa, 0);
+
 	ocf_req_hash(req);
 
 	ocf_hb_req_prot_lock_rd(req); /*- Metadata RD access -----------------------*/

src/engine/engine_wb.c

@@ -127,6 +127,7 @@ int ocf_write_wb_do(struct ocf_request *req)
 	/* Get OCF request - increase reference counter */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_wb, 0);
 	/* Submit IO */
 	_ocf_write_wb_submit(req);
 
@@ -149,10 +150,11 @@ int ocf_write_wb(struct ocf_request *req)
 {
 	int lock = OCF_LOCK_NOT_ACQUIRED;
 
-
 	/* Not sure if we need this. */
 	ocf_req_get(req);
 
+	ocf_debug_request_trace(req, ocf_req_cache_mode_wb, 1);
+
 	/* Set resume handler */
 	req->engine_handler = ocf_write_wb_do;
 	req->engine_cbs = &_wb_engine_callbacks;