refactor: Optimize cache cleaning policy configuration flow #2

Merged
td-zhangshun merged 1 commits from fix-clearnig into v24.9-td 2025-04-24 05:17:26 +00:00

View File

@ -635,15 +635,13 @@ def start_cache(cache, load, force=False):
def configure_cache(cache): def configure_cache(cache):
if "cleaning_policy" in cache.params: if "cleaning_policy" in cache.params:
casadm.set_param(
"cleaning", cache_id=cache.cache_id, policy=cache.params["cleaning_policy"]
)
if cache.params["cleaning_policy"] == "acp" or cache.params["cleaning_policy"] == "alru": if cache.params["cleaning_policy"] == "acp" or cache.params["cleaning_policy"] == "alru":
casadm.set_param_cleaning_policy( casadm.set_param_cleaning_policy(
policy=cache.params["cleaning_policy"], cache_id=cache.cache_id, wake_up=cache.params["wake_up"], flush_max_buffers=cache.params["flush_max_buffers"] policy=cache.params["cleaning_policy"], cache_id=cache.cache_id, wake_up=cache.params["wake_up"], flush_max_buffers=cache.params["flush_max_buffers"]
) )
else:
casadm.set_param(
"cleaning", cache_id=cache.cache_id, policy=cache.params["cleaning_policy"]
)
if "promotion_policy" in cache.params: if "promotion_policy" in cache.params:
casadm.set_param( casadm.set_param(