FLUSHALL / FLUSHDB for diskstore implemented

[redis.git] / src / redis.c

diff --git a/src/redis.c b/src/redis.c
index 65cf3ace9c045b1fbcffa6347aba51f37dc87626..c567710eb2311694a9b92eba4a47a11fc4280bdd 100644 (file)
--- a/src/redis.c
+++ b/src/redis.c
@@ -778,6 +778,7 @@ void initServerConfig() {
     server.list_max_ziplist_value = REDIS_LIST_MAX_ZIPLIST_VALUE;
     server.set_max_intset_entries = REDIS_SET_MAX_INTSET_ENTRIES;
     server.shutdown_asap = 0;
+    server.cache_flush_delay = 0;
 
     updateLRUClock();
     resetServerSaveParams();
@@ -826,8 +827,7 @@ void initServer() {
     server.slaves = listCreate();
     server.monitors = listCreate();
     server.unblocked_clients = listCreate();
-    server.cache_flush_queue = listCreate();
-    server.cache_flush_delay = 0;
+    server.cache_io_queue = listCreate();
 
     createSharedObjects();
     server.el = aeCreateEventLoop();
@@ -857,6 +857,7 @@ void initServer() {
         if (server.ds_enabled) {
             server.db[j].io_keys = dictCreate(&keylistDictType,NULL);
             server.db[j].io_negcache = dictCreate(&setDictType,NULL);
+            server.db[j].io_queued = dictCreate(&setDictType,NULL);
         }
         server.db[j].id = j;
     }