fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 17:10:50 +00:00
Code Issues Projects Releases Wiki Activity

LFU: change lfu* parameters to int

Browse Source
This commit is contained in:
zhaozhao.zz 2017-10-13 11:09:48 +08:00 committed by antirez
parent dfc42ec447
commit 53cea97204
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/evict.c
View File

@ -334,7 +334,7 @@ uint8_t LFULogIncr(uint8_t counter) {
unsigned long LFUDecrAndReturn(robj *o) { unsigned long LFUDecrAndReturn(robj *o) {
unsigned long ldt = o->lru >> 8; unsigned long ldt = o->lru >> 8;
unsigned long counter = o->lru & 255; unsigned long counter = o->lru & 255;
if (LFUTimeElapsed(ldt) >= server.lfu_decay_time && counter) { if (LFUTimeElapsed(ldt) >= (unsigned long)server.lfu_decay_time && counter) {
if (counter > LFU_INIT_VAL*2) { if (counter > LFU_INIT_VAL*2) {
counter /= 2; counter /= 2;
if (counter < LFU_INIT_VAL*2) counter = LFU_INIT_VAL*2; if (counter < LFU_INIT_VAL*2) counter = LFU_INIT_VAL*2;

4
src/server.h
View File

@ -1118,8 +1118,8 @@ struct redisServer {
unsigned long long maxmemory; /* Max number of memory bytes to use */ unsigned long long maxmemory; /* Max number of memory bytes to use */
int maxmemory_policy; /* Policy for key eviction */ int maxmemory_policy; /* Policy for key eviction */
int maxmemory_samples; /* Pricision of random sampling */ int maxmemory_samples; /* Pricision of random sampling */
unsigned int lfu_log_factor; /* LFU logarithmic counter factor. */ int lfu_log_factor; /* LFU logarithmic counter factor. */
unsigned int lfu_decay_time; /* LFU counter decay factor. */ int lfu_decay_time; /* LFU counter decay factor. */
/* Blocked clients */ /* Blocked clients */
unsigned int bpop_blocked_clients; /* Number of clients blocked by lists */ unsigned int bpop_blocked_clients; /* Number of clients blocked by lists */
list *unblocked_clients; /* list of clients to unblock before next loop */ list *unblocked_clients; /* list of clients to unblock before next loop */