fix cache memory leak

w22gb8 · Jun 11, 2017 · 1bf0063 · 1bf0063
1 parent f59edce
commit 1bf0063
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 0 deletions.
diff --git a/accessws/aw_server.c b/accessws/aw_server.c
@@ -20,6 +20,7 @@ static dict_t *backend_cache;
 static rpc_clt *listener;
 static nw_state *state_context;
 static nw_cache *privdata_cache;
+static nw_timer cache_timer;
 
 static rpc_clt *matchengine;
 static rpc_clt *marketprice;
@@ -988,6 +989,11 @@ static void cache_dict_val_free(void *val)
     free(val);
 }
 
+static void on_cache_timer(nw_timer *timer, void *privdata)
+{
+    dict_clear(backend_cache);
+}
+
 static int init_backend(void)
 {
     rpc_clt_type ct;
@@ -1026,6 +1032,9 @@ static int init_backend(void)
     if (backend_cache == NULL)
         return -__LINE__;
 
+    nw_timer_set(&cache_timer, 60, true, on_cache_timer, NULL);
+    nw_timer_start(&cache_timer);
+
     return 0;
 }
 

diff --git a/marketprice/mp_server.c b/marketprice/mp_server.c
@@ -9,6 +9,7 @@
 
 static rpc_svr *svr;
 static dict_t *dict_cache;
+static nw_timer cache_timer;
 
 struct cache_val {
     double      time;
@@ -415,6 +416,11 @@ static void cache_dict_val_free(void *val)
     free(val);
 }
 
+static void on_cache_timer(nw_timer *timer, void *privdata)
+{
+    dict_clear(dict_cache);
+}
+
 int init_server(void)
 {
     rpc_svr_type type;
@@ -442,6 +448,9 @@ int init_server(void)
     if (dict_cache == NULL)
         return -__LINE__;
 
+    nw_timer_set(&cache_timer, 60, true, on_cache_timer, NULL);
+    nw_timer_start(&cache_timer);
+
     return 0;
 }
 
diff --git a/matchengine/me_server.c b/matchengine/me_server.c
@@ -15,6 +15,7 @@
 
 static rpc_svr *svr;
 static dict_t *dict_cache;
+static nw_timer cache_timer;
 
 struct cache_val {
     double      time;
@@ -1031,6 +1032,11 @@ static void cache_dict_val_free(void *val)
     free(val);
 }
 
+static void on_cache_timer(nw_timer *timer, void *privdata)
+{
+    dict_clear(dict_cache);
+}
+
 int init_server(void)
 {
     rpc_svr_type type;
@@ -1058,6 +1064,9 @@ int init_server(void)
     if (dict_cache == NULL)
         return -__LINE__;
 
+    nw_timer_set(&cache_timer, 60, true, on_cache_timer, NULL);
+    nw_timer_start(&cache_timer);
+
     return 0;
 }