update source to Ceph Pacific 16.2.2

[ceph.git] / ceph / src / spdk / ocf / src / promotion / promotion.c

diff --git a/ceph/src/spdk/ocf/src/promotion/promotion.c b/ceph/src/spdk/ocf/src/promotion/promotion.c
new file mode 100644 (file)
index 0000000..0ed7e96
--- /dev/null
+++ b/ceph/src/spdk/ocf/src/promotion/promotion.c
@@ -0,0 +1,174 @@
+/*
+ * Copyright(c) 2019 Intel Corporation
+ * SPDX-License-Identifier: BSD-3-Clause-Clear
+ */
+
+#include "../metadata/metadata.h"
+
+#include "promotion.h"
+#include "ops.h"
+#include "nhit/nhit.h"
+
+struct promotion_policy_ops ocf_promotion_policies[ocf_promotion_max] = {
+       [ocf_promotion_always] = {
+               .name = "always",
+       },
+       [ocf_promotion_nhit] = {
+               .name = "nhit",
+               .setup = nhit_setup,
+               .init = nhit_init,
+               .deinit = nhit_deinit,
+               .set_param = nhit_set_param,
+               .get_param = nhit_get_param,
+               .req_purge = nhit_req_purge,
+               .req_should_promote = nhit_req_should_promote,
+       },
+};
+
+ocf_error_t ocf_promotion_init(ocf_cache_t cache, ocf_promotion_t type)
+{
+       ocf_promotion_policy_t policy;
+       ocf_error_t result = 0;
+
+       ENV_BUG_ON(type >= ocf_promotion_max);
+
+       policy = env_vmalloc(sizeof(*policy));
+       if (!policy)
+               return -OCF_ERR_NO_MEM;
+
+       policy->type = type;
+       policy->owner = cache;
+       policy->config =
+               (void *)&cache->conf_meta->promotion[type].data;
+       cache->promotion_policy = policy;
+
+       if (ocf_promotion_policies[type].init)
+               result = ocf_promotion_policies[type].init(cache);
+
+       if (result) {
+               env_vfree(cache->promotion_policy);
+               cache->promotion_policy = NULL;
+               ocf_cache_log(cache, log_info,
+                               "Policy '%s' failed to initialize\n",
+                               ocf_promotion_policies[type].name);
+       } else {
+               ocf_cache_log(cache, log_info,
+                               "Policy '%s' initialized successfully\n",
+                               ocf_promotion_policies[type].name);
+       }
+
+       return result;
+}
+
+void ocf_promotion_deinit(ocf_promotion_policy_t policy)
+{
+       ocf_promotion_t type = policy->type;
+
+       ENV_BUG_ON(type >= ocf_promotion_max);
+
+       if (ocf_promotion_policies[type].deinit)
+               ocf_promotion_policies[type].deinit(policy);
+
+       env_vfree(policy);
+}
+
+ocf_error_t ocf_promotion_set_policy(ocf_promotion_policy_t policy,
+               ocf_promotion_t type)
+{
+       ocf_error_t result = 0;
+       ocf_cache_t cache = policy->owner;
+       ocf_promotion_t prev_policy;
+
+       if (type >= ocf_promotion_max)
+               return -OCF_ERR_INVAL;
+
+       prev_policy = cache->conf_meta->promotion_policy_type;
+
+       if (type == prev_policy) {
+               ocf_cache_log(cache, log_info, "Promotion policy '%s' is already set\n",
+                             ocf_promotion_policies[type].name);
+               return 0;
+       }
+
+       if (ocf_promotion_policies[prev_policy].deinit)
+               ocf_promotion_policies[prev_policy].deinit(policy);
+
+       cache->conf_meta->promotion_policy_type = type;
+       policy->type = type;
+
+       if (ocf_promotion_policies[type].init)
+               result = ocf_promotion_policies[type].init(cache);
+
+       if (result) {
+               ocf_cache_log(cache, log_err,
+                               "Error switching to new promotion policy\n");
+               ocf_cache_log(cache, log_err,
+                               "Falling back to 'always' promotion policy\n");
+               cache->conf_meta->promotion_policy_type = ocf_promotion_always;
+               policy->type = ocf_promotion_always;
+       } else {
+               ocf_cache_log(cache, log_info,
+                               "Switched to '%s' promotion policy\n",
+                               ocf_promotion_policies[type].name);
+       }
+
+       return result;
+}
+
+ocf_error_t ocf_promotion_set_param(ocf_cache_t cache, ocf_promotion_t type,
+               uint8_t param_id, uint32_t param_value)
+{
+       ocf_error_t result = -OCF_ERR_INVAL;
+
+       ENV_BUG_ON(type >= ocf_promotion_max);
+
+       if (ocf_promotion_policies[type].set_param) {
+               result = ocf_promotion_policies[type].set_param(cache, param_id,
+                               param_value);
+       }
+
+       return result;
+}
+
+ocf_error_t ocf_promotion_get_param(ocf_cache_t cache, ocf_promotion_t type,
+               uint8_t param_id, uint32_t *param_value)
+{
+       ocf_error_t result = -OCF_ERR_INVAL;
+
+       ENV_BUG_ON(type >= ocf_promotion_max);
+
+       if (ocf_promotion_policies[type].get_param) {
+               result = ocf_promotion_policies[type].get_param(cache, param_id,
+                               param_value);
+       }
+
+       return result;
+}
+
+void ocf_promotion_req_purge(ocf_promotion_policy_t policy,
+               struct ocf_request *req)
+{
+       ocf_promotion_t type = policy->type;
+
+       ENV_BUG_ON(type >= ocf_promotion_max);
+
+       if (ocf_promotion_policies[type].req_purge)
+               ocf_promotion_policies[type].req_purge(policy, req);
+}
+
+bool ocf_promotion_req_should_promote(ocf_promotion_policy_t policy,
+               struct ocf_request *req)
+{
+       ocf_promotion_t type = policy->type;
+       bool result = true;
+
+       ENV_BUG_ON(type >= ocf_promotion_max);
+
+       if (ocf_promotion_policies[type].req_should_promote) {
+               result = ocf_promotion_policies[type].req_should_promote(policy,
+                               req);
+       }
+
+       return result;
+}
+