/*
 * Copyright(c) 2012-2018 Intel Corporation
 * SPDX-License-Identifier: BSD-3-Clause-Clear
 */
#include "ocf/ocf.h"
#include "../ocf_cache_priv.h"
#include "engine_d2c.h"
#include "engine_common.h"
#include "cache_engine.h"
#include "../ocf_request.h"
#include "../utils/utils_io.h"
#include "../metadata/metadata.h"

#define OCF_ENGINE_DEBUG_IO_NAME "d2c"
#include "engine_debug.h"

static void _ocf_d2c_completion(struct ocf_request *req, int error)
{
	ocf_core_t core = req->core;
	req->error = error;

	OCF_DEBUG_RQ(req, "Completion");

	if (req->error) {
		req->info.core_error = 1;
		if (req->rw == OCF_READ)
			env_atomic_inc(&core->counters->core_errors.read);
		else
			env_atomic_inc(&core->counters->core_errors.write);
	}

	/* Complete request */
	req->complete(req, req->error);

	/* Release OCF request */
	ocf_req_put(req);
}

int ocf_io_d2c(struct ocf_request *req)
{
	ocf_core_t core = req->core;

	OCF_DEBUG_TRACE(req->cache);

	ocf_io_start(req->io);

	/* Get OCF request - increase reference counter */
	ocf_req_get(req);

	ocf_submit_volume_req(&core->volume, req, _ocf_d2c_completion);

	ocf_engine_update_block_stats(req);

	if (req->rw == OCF_READ) {
		env_atomic64_inc(&core->counters->
			part_counters[req->part_id].read_reqs.pass_through);
	} else {
		env_atomic64_inc(&core->counters->
			part_counters[req->part_id].write_reqs.pass_through);
	}

	/* Put OCF request - decrease reference counter */
	ocf_req_put(req);

	return 0;

}