summaryrefslogtreecommitdiff
path: root/plugin/business/pangu-http/src/pangu_web_cache.cpp
diff options
context:
space:
mode:
authorzhengchao <[email protected]>2018-11-14 16:00:07 +0800
committerzhengchao <[email protected]>2018-11-14 16:03:36 +0800
commiteed9ebcadb81a28b23c99ec2637b0bb63679cc7e (patch)
tree36b4a50e01508b94e8407faf1dbcc9cc06e80880 /plugin/business/pangu-http/src/pangu_web_cache.cpp
parent6bcd2cb9a69e220f883f5843b1aa24f5a650ada9 (diff)
调整cache key的输出格式
Diffstat (limited to 'plugin/business/pangu-http/src/pangu_web_cache.cpp')
-rw-r--r--plugin/business/pangu-http/src/pangu_web_cache.cpp11
1 files changed, 4 insertions, 7 deletions
diff --git a/plugin/business/pangu-http/src/pangu_web_cache.cpp b/plugin/business/pangu-http/src/pangu_web_cache.cpp
index fc0e187..e0ccb48 100644
--- a/plugin/business/pangu-http/src/pangu_web_cache.cpp
+++ b/plugin/business/pangu-http/src/pangu_web_cache.cpp
@@ -88,7 +88,6 @@ struct cache_bloom
double error_rate;
char filename[TFE_PATH_MAX];
counting_bloom_t *bloom;
- void * ref_logger;
};
struct cache_handle
{
@@ -597,7 +596,6 @@ static void cache_key_bloom_gc_cb(evutil_socket_t fd, short what, void * arg)
new_bloom=new_counting_bloom(p_bloom->size, p_bloom->error_rate, p_bloom->filename);
free_counting_bloom(p_bloom->bloom);
p_bloom->bloom=new_bloom;
- TFE_LOG_DEBUG(p_bloom->ref_logger, "Bloom filter %d:%s resets.", p_bloom->thread_id, p_bloom->filename);
return;
}
@@ -633,7 +631,6 @@ struct cache_handle* create_web_cache_handle(const char* profile_path, const cha
p_bloom->thread_id=i;
p_bloom->size=cache->cache_key_bloom_size;
p_bloom->error_rate=0.01;
- p_bloom->ref_logger=logger;
snprintf(p_bloom->filename, sizeof(p_bloom->filename), "/tmp/pangu_cache_blooms.%02d", i);
p_bloom->bloom=new_counting_bloom(p_bloom->size, p_bloom->error_rate, p_bloom->filename);
if(p_bloom->bloom==NULL)
@@ -650,6 +647,7 @@ struct cache_handle* create_web_cache_handle(const char* profile_path, const cha
goto error_out;
}
}
+
MESA_load_profile_int_def(profile_path, section, "get_concurrency_max", &temp, 1000*1000);
cache->get_concurrency_max=temp;
MESA_load_profile_int_def(profile_path, section, "put_concurrency_max", &(temp), 1000*1000);
@@ -672,7 +670,7 @@ struct cache_handle* create_web_cache_handle(const char* profile_path, const cha
cache->default_cache_policy.pinning_time_sec=0;
cache->default_cache_policy.inactive_time_sec=0;
cache->default_cache_policy.max_cache_size=0;
- cache->default_cache_policy.max_cache_obj_size=1024*1024*1024;//<1GB
+ cache->default_cache_policy.max_cache_obj_size=1024*1024*1024;//<1GB by default
if(cache->cache_policy_enabled)
{
@@ -682,8 +680,7 @@ struct cache_handle* create_web_cache_handle(const char* profile_path, const cha
cache->cache_param_idx=Maat_rule_get_ex_new_index(feather, "PXY_CACHE_COMPILE",
cache_param_new, cache_param_free, cache_param_dup,
0, cache);
- cache->ref_feather=feather;
- TFE_LOG_INFO(logger, "Cache Policy Enabled.");
+ cache->ref_feather=feather;
}
cache_stat_init(cache);
return cache;
@@ -1009,7 +1006,7 @@ enum cache_pending_result web_cache_async_pending(struct cache_handle* handle, u
{
_mid->cache_key=get_cache_key(request, &(param->key_descr));
}
- TFE_LOG_DEBUG(handle->logger, "cache policy %d matched: url=%s alt-key=%s",
+ TFE_LOG_DEBUG(handle->logger, "cache policy %d matched: url=%s alternative key=%s",
cache_policy.config_id,
request->req_spec.url,
_mid->cache_key!=NULL?_mid->cache_key:"null");