/*
* Copyright(c) 2012-2021 Intel Corporation
* SPDX-License-Identifier: BSD-3-Clause-Clear
*/

#ifndef __CAS_CACHE_H__
#define __CAS_CACHE_H__

#include "ocf/ocf.h"
#include "ocf_env.h"

#include <cas_ioctl_codes.h>

#include "linux_kernel_version.h"
#include "layer_upgrade.h"
#include "control.h"
#include "layer_cache_management.h"
#include "service_ui_ioctl.h"
#include "utils/cas_cache_utils.h"
#include "volume/vol_blk_utils.h"
#include "classifier.h"
#include "context.h"
#include <linux/kallsyms.h>

#define CAS_KERN_EMERG KERN_EMERG OCF_PREFIX_SHORT
#define CAS_KERN_ALERT KERN_ALERT OCF_PREFIX_SHORT
#define CAS_KERN_CRIT KERN_CRIT OCF_PREFIX_SHORT
#define CAS_KERN_ERR KERN_ERR OCF_PREFIX_SHORT
#define CAS_KERN_WARNING KERN_WARNING OCF_PREFIX_SHORT
#define CAS_KERN_NOTICE KERN_NOTICE OCF_PREFIX_SHORT
#define CAS_KERN_INFO KERN_INFO OCF_PREFIX_SHORT
#define CAS_KERN_DEBUG KERN_DEBUG OCF_PREFIX_SHORT

#ifndef SECTOR_SHIFT
#define SECTOR_SHIFT 9
#endif

#ifndef SECTOR_SIZE
#define SECTOR_SIZE (1<<SECTOR_SHIFT)
#endif

#define MAX_LINES_PER_IO	16

/**
 * cache/core object types */
enum {
	BLOCK_DEVICE_VOLUME = 1,	/**< block device volume */
	ATOMIC_DEVICE_VOLUME,		/**< block device volume with atomic
					     metadata support */
/** \cond SKIP_IN_DOC */
	OBJECT_TYPE_MAX,
	NVME_CONTROLLER
/** \endcond */
};

struct cas_classifier;

struct cache_priv {
	uint64_t core_id_bitmap[DIV_ROUND_UP(OCF_CORE_MAX, 8*sizeof(uint64_t))];
	struct cas_classifier *classifier;
	struct _cache_mngt_stop_context *stop_context;
	atomic_t flush_interrupt_enabled;
	ocf_queue_t mngt_queue;
	void *attach_context;
	ocf_queue_t io_queues[];
};

extern ocf_ctx_t cas_ctx;

extern struct casdsk_functions_mapper casdisk_functions;

struct casdsk_functions_mapper {
	int (*casdsk_disk_detach)(struct casdsk_disk *dsk);
	int (*casdsk_exp_obj_destroy)(struct casdsk_disk *dsk);
	int (*casdsk_exp_obj_create)(struct casdsk_disk *dsk, const char *dev_name,
		struct module *owner, struct casdsk_exp_obj_ops *ops);
	void(*casdsk_exp_obj_free)(struct casdsk_disk *dsk);
	struct request_queue *(*casdsk_disk_get_queue)(struct casdsk_disk *dsk);
	void (*casdsk_store_config)(size_t n_blobs, struct casdsk_props_conf *blobs);
	struct block_device *(*casdsk_disk_get_blkdev)(struct casdsk_disk *dsk);
	struct request_queue *(*casdsk_exp_obj_get_queue)(struct casdsk_disk *dsk);
	uint32_t (*casdsk_get_version)(void);
	void (*casdsk_disk_close)(struct casdsk_disk *dsk);
	struct casdsk_disk *(*casdsk_disk_claim)(const char *path, void *private);
	int (*casdsk_exp_obj_unlock)(struct casdsk_disk *dsk);
	int (*casdsk_disk_set_pt)(struct casdsk_disk *dsk);
	size_t (*casdsk_get_stored_config)(struct casdsk_props_conf **blobs);
	struct gendisk *(*casdsk_disk_get_gendisk)(struct casdsk_disk *dsk);
	int (*casdsk_disk_attach) (struct casdsk_disk *dsk, struct module *owner,
		struct casdsk_exp_obj_ops *ops);
	int (*casdsk_disk_set_attached)(struct casdsk_disk *dsk);
	int (*casdsk_exp_obj_activate)(struct casdsk_disk *dsk);
	bool (*casdsk_exp_obj_activated)(struct casdsk_disk *ds);
	int (*casdsk_exp_obj_lock)(struct casdsk_disk *dsk);
	void (*casdsk_free_stored_config)(void);
	struct casdsk_disk *(*casdsk_disk_open)(const char *path, void *private);
	int (*casdsk_disk_clear_pt)(struct casdsk_disk *dsk);
	struct gendisk *(*casdsk_exp_obj_get_gendisk)(struct casdsk_disk *dsk);
};

static inline void cache_name_from_id(char *name, uint16_t id)
{
	int result;

	result = snprintf(name, OCF_CACHE_NAME_SIZE, "cache%d", id);
	ENV_BUG_ON(result >= OCF_CACHE_NAME_SIZE);
}

static inline void core_name_from_id(char *name, uint16_t id)
{
	int result;

	result = snprintf(name, OCF_CORE_NAME_SIZE, "core%d", id);
	ENV_BUG_ON(result >= OCF_CORE_NAME_SIZE);
}

static inline int cache_id_from_name(uint16_t *cache_id, const char *name)
{
	const char *id_str;
	long res;
	int result;

	if (strnlen(name, OCF_CACHE_NAME_SIZE) < sizeof("cache") - 1)
		return -EINVAL;

	id_str = name + sizeof("cache") - 1;

	result = kstrtol(id_str, 10, &res);

	if (!result)
		*cache_id = res;

	return result;
}

static inline int core_id_from_name(uint16_t *core_id, const char *name)
{
	const char *id_str;
	long res;
	int result;

	if (strnlen(name, OCF_CORE_NAME_SIZE) < sizeof("core") - 1)
		return -EINVAL;

	id_str = name + sizeof("core") - 1;

	result = kstrtol(id_str, 10, &res);

	if (!result)
		*core_id = res;

	return result;
}

static inline int mngt_get_cache_by_id(ocf_ctx_t ctx, uint16_t id,
		ocf_cache_t *cache)
{
	char cache_name[OCF_CACHE_NAME_SIZE];

	cache_name_from_id(cache_name, id);

	return ocf_mngt_cache_get_by_name(ctx, cache_name,
					OCF_CACHE_NAME_SIZE, cache);
}

static inline int get_core_by_id(ocf_cache_t cache, uint16_t id,
		ocf_core_t *core)
{
	char core_name[OCF_CORE_NAME_SIZE];

	core_name_from_id(core_name, id);

	return ocf_core_get_by_name(cache, core_name, OCF_CORE_NAME_SIZE, core);
}


#endif