]> git.saurik.com Git - redis.git/blobdiff - src/redis.c
DEBUG FLUSHCACHE needs to wait that everything was synched on disk
[redis.git] / src / redis.c
index 2fd3ee39e3c8843f1f5e56c991e195c11b8aaf10..603b377faf3888c437cee2d62d2f7f2ee4b47e36 100644 (file)
@@ -583,7 +583,7 @@ int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
     if ((server.maxidletime && !(loops % 100)) || server.bpop_blocked_clients)
         closeTimedoutClients();
 
-    /* Check if a background saving or AOF rewrite in progress terminated */
+    /* Check if a background saving or AOF rewrite in progress terminated. */
     if (server.bgsavechildpid != -1 || server.bgrewritechildpid != -1) {
         int statloc;
         pid_t pid;
@@ -601,6 +601,7 @@ int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
             }
             updateDictResizePolicy();
         }
+    } else if (server.bgsavethread != (pthread_t) -1) {
         if (server.bgsavethread != (pthread_t) -1) {
             int state;
 
@@ -608,10 +609,11 @@ int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
             state = server.bgsavethread_state;
             pthread_mutex_unlock(&server.bgsavethread_mutex);
 
-            if (state == REDIS_BGSAVE_DONE_OK || state == REDIS_BGSAVE_DONE_ERR)
+            if (state == REDIS_BGSAVE_THREAD_DONE_OK ||
+                state == REDIS_BGSAVE_THREAD_DONE_ERR)
             {
                 backgroundSaveDoneHandler(
-                    (state == REDIS_BGSAVE_DONE_OK) ? 0 : 1, 0);
+                    (state == REDIS_BGSAVE_THREAD_DONE_OK) ? 0 : 1, 0);
             }
         }
     } else if (!server.ds_enabled) {
@@ -1298,6 +1300,19 @@ sds genRedisInfoString(void) {
             eta
         );
     }
+
+    info = sdscat(info,"allocation_stats:");
+    for (j = 0; j <= ZMALLOC_MAX_ALLOC_STAT; j++) {
+        size_t count = zmalloc_allocations_for_size(j);
+        if (count) {
+            if (info[sdslen(info)-1] != ':') info = sdscatlen(info,",",1);
+            info = sdscatprintf(info,"%s%d=%zu",
+                (j == ZMALLOC_MAX_ALLOC_STAT) ? ">=" : "",
+                j,count);
+        }
+    }
+    info = sdscat(info,"\r\n");
+
     for (j = 0; j < server.dbnum; j++) {
         long long keys, vkeys;