zmalloc functions to get RSS and fragmentation refactored into two separated functions

[redis.git] / src / config.c

diff --git a/src/config.c b/src/config.c
index 73d3ae87b77fb97820c2cc2b0378d9c1fb9701de..db58a2360b4817f0576ae8e5e48b9230e9514698 100644 (file)
--- a/src/config.c
+++ b/src/config.c
@@ -138,6 +138,12 @@ void loadServerConfig(char *filename) {
                 err = "Invalid maxmemory policy";
                 goto loaderr;
             }
                 err = "Invalid maxmemory policy";
                 goto loaderr;
             }

+        } else if (!strcasecmp(argv[0],"maxmemory-samples") && argc == 2) {
+            server.maxmemory_samples = atoi(argv[1]);
+            if (server.maxmemory_samples <= 0) {
+                err = "maxmemory-samples must be 1 or greater";
+                goto loaderr;
+            }

         } else if (!strcasecmp(argv[0],"slaveof") && argc == 3) {
             server.masterhost = sdsnew(argv[1]);
             server.masterport = atoi(argv[2]);
         } else if (!strcasecmp(argv[0],"slaveof") && argc == 3) {
             server.masterhost = sdsnew(argv[1]);
             server.masterport = atoi(argv[2]);


@@ -240,8 +246,11 @@ loaderr:
  *----------------------------------------------------------------------------*/
 
 void configSetCommand(redisClient *c) {
  *----------------------------------------------------------------------------*/
 
 void configSetCommand(redisClient *c) {

-    robj *o = getDecodedObject(c->argv[3]);
+    robj *o;

     long long ll;
     long long ll;

+    redisAssert(c->argv[2]->encoding == REDIS_ENCODING_RAW);
+    redisAssert(c->argv[3]->encoding == REDIS_ENCODING_RAW);
+    o = c->argv[3];

 
     if (!strcasecmp(c->argv[2]->ptr,"dbfilename")) {
         zfree(server.dbfilename);
 
     if (!strcasecmp(c->argv[2]->ptr,"dbfilename")) {
         zfree(server.dbfilename);


@@ -271,6 +280,10 @@ void configSetCommand(redisClient *c) {
         } else {
             goto badfmt;
         }
         } else {
             goto badfmt;
         }

+    } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-samples")) {
+        if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
+            ll <= 0) goto badfmt;
+        server.maxmemory_samples = ll;

     } else if (!strcasecmp(c->argv[2]->ptr,"timeout")) {
         if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
             ll < 0 || ll > LONG_MAX) goto badfmt;
     } else if (!strcasecmp(c->argv[2]->ptr,"timeout")) {
         if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
             ll < 0 || ll > LONG_MAX) goto badfmt;


@@ -302,7 +315,6 @@ void configSetCommand(redisClient *c) {
                 if (startAppendOnly() == REDIS_ERR) {
                     addReplyError(c,
                         "Unable to turn on AOF. Check server logs.");
                 if (startAppendOnly() == REDIS_ERR) {
                     addReplyError(c,
                         "Unable to turn on AOF. Check server logs.");

-                    decrRefCount(o);

                     return;
                 }
             }
                     return;
                 }
             }


@@ -344,10 +356,8 @@ void configSetCommand(redisClient *c) {
     } else {
         addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s",
             (char*)c->argv[2]->ptr);
     } else {
         addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s",
             (char*)c->argv[2]->ptr);

-        decrRefCount(o);

         return;
     }
         return;
     }

-    decrRefCount(o);

     addReply(c,shared.ok);
     return;
 
     addReply(c,shared.ok);
     return;
 


@@ -355,14 +365,15 @@ badfmt: /* Bad format errors */
     addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'",
             (char*)o->ptr,
             (char*)c->argv[2]->ptr);
     addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'",
             (char*)o->ptr,
             (char*)c->argv[2]->ptr);

-    decrRefCount(o);

 }
 
 void configGetCommand(redisClient *c) {
 }
 
 void configGetCommand(redisClient *c) {

-    robj *o = getDecodedObject(c->argv[2]);
+    robj *o = c->argv[2];

     void *replylen = addDeferredMultiBulkLength(c);
     char *pattern = o->ptr;
     void *replylen = addDeferredMultiBulkLength(c);
     char *pattern = o->ptr;

+    char buf[128];

     int matches = 0;
     int matches = 0;

+    redisAssert(o->encoding == REDIS_ENCODING_RAW);

 
     if (stringmatch(pattern,"dbfilename",0)) {
         addReplyBulkCString(c,"dbfilename");
 
     if (stringmatch(pattern,"dbfilename",0)) {
         addReplyBulkCString(c,"dbfilename");


@@ -380,9 +391,7 @@ void configGetCommand(redisClient *c) {
         matches++;
     }
     if (stringmatch(pattern,"maxmemory",0)) {
         matches++;
     }
     if (stringmatch(pattern,"maxmemory",0)) {

-        char buf[128];
-
-        ll2string(buf,128,server.maxmemory);
+        ll2string(buf,sizeof(buf),server.maxmemory);

         addReplyBulkCString(c,"maxmemory");
         addReplyBulkCString(c,buf);
         matches++;
         addReplyBulkCString(c,"maxmemory");
         addReplyBulkCString(c,buf);
         matches++;


@@ -402,10 +411,14 @@ void configGetCommand(redisClient *c) {
         addReplyBulkCString(c,s);
         matches++;
     }
         addReplyBulkCString(c,s);
         matches++;
     }

+    if (stringmatch(pattern,"maxmemory-samples",0)) {
+        ll2string(buf,sizeof(buf),server.maxmemory_samples);
+        addReplyBulkCString(c,"maxmemory-samples");
+        addReplyBulkCString(c,buf);
+        matches++;
+    }

     if (stringmatch(pattern,"timeout",0)) {
     if (stringmatch(pattern,"timeout",0)) {

-        char buf[128];
-
-        ll2string(buf,128,server.maxidletime);
+        ll2string(buf,sizeof(buf),server.maxidletime);

         addReplyBulkCString(c,"timeout");
         addReplyBulkCString(c,buf);
         matches++;
         addReplyBulkCString(c,"timeout");
         addReplyBulkCString(c,buf);
         matches++;


@@ -449,7 +462,6 @@ void configGetCommand(redisClient *c) {
         sdsfree(buf);
         matches++;
     }
         sdsfree(buf);
         matches++;
     }

-    decrRefCount(o);

     setDeferredMultiBulkLength(c,replylen,matches*2);
 }
 
     setDeferredMultiBulkLength(c,replylen,matches*2);
 }
 


@@ -462,10 +474,11 @@ void configCommand(redisClient *c) {
         configGetCommand(c);
     } else if (!strcasecmp(c->argv[1]->ptr,"resetstat")) {
         if (c->argc != 2) goto badarity;
         configGetCommand(c);
     } else if (!strcasecmp(c->argv[1]->ptr,"resetstat")) {
         if (c->argc != 2) goto badarity;

+        server.stat_keyspace_hits = 0;
+        server.stat_keyspace_misses = 0;

         server.stat_numcommands = 0;
         server.stat_numconnections = 0;
         server.stat_expiredkeys = 0;
         server.stat_numcommands = 0;
         server.stat_numconnections = 0;
         server.stat_expiredkeys = 0;

-        server.stat_starttime = time(NULL);

         addReply(c,shared.ok);
     } else {
         addReplyError(c,
         addReply(c,shared.ok);
     } else {
         addReplyError(c,