src/redis.c

   1 /*
   2  * Copyright (c) 2009-2010, Salvatore Sanfilippo <antirez at gmail dot com>
   3  * All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms, with or without
   6  * modification, are permitted provided that the following conditions are met:
   7  *
   8  *   * Redistributions of source code must retain the above copyright notice,
   9  *     this list of conditions and the following disclaimer.
  10  *   * Redistributions in binary form must reproduce the above copyright
  11  *     notice, this list of conditions and the following disclaimer in the
  12  *     documentation and/or other materials provided with the distribution.
  13  *   * Neither the name of Redis nor the names of its contributors may be used
  14  *     to endorse or promote products derived from this software without
  15  *     specific prior written permission.
  16  *
  17  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  18  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  20  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  21  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  22  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  23  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  24  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  25  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  26  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  27  * POSSIBILITY OF SUCH DAMAGE.
  28  */
  29
  30 #include "redis.h"
  31
  32 #ifdef HAVE_BACKTRACE
  33 #include <execinfo.h>
  34 #include <ucontext.h>
  35 #endif /* HAVE_BACKTRACE */
  36
  37 #include <time.h>
  38 #include <signal.h>
  39 #include <sys/wait.h>
  40 #include <errno.h>
  41 #include <assert.h>
  42 #include <ctype.h>
  43 #include <stdarg.h>
  44 #include <arpa/inet.h>
  45 #include <sys/stat.h>
  46 #include <fcntl.h>
  47 #include <sys/time.h>
  48 #include <sys/resource.h>
  49 #include <sys/uio.h>
  50 #include <limits.h>
  51 #include <float.h>
  52 #include <math.h>
  53 #include <pthread.h>
  54 #include <sys/resource.h>
  55
  56 /* Our shared "common" objects */
  57
  58 struct sharedObjectsStruct shared;
  59
  60 /* Global vars that are actally used as constants. The following double
  61  * values are used for double on-disk serialization, and are initialized
  62  * at runtime to avoid strange compiler optimizations. */
  63
  64 double R_Zero, R_PosInf, R_NegInf, R_Nan;
  65
  66 /*================================= Globals ================================= */
  67
  68 /* Global vars */
  69 struct redisServer server; /* server global state */
  70 struct redisCommand *commandTable;
  71 struct redisCommand readonlyCommandTable[] = {
  72     {"get",getCommand,2,0,NULL,1,1,1},
  73     {"set",setCommand,3,REDIS_CMD_DENYOOM,NULL,0,0,0},
  74     {"setnx",setnxCommand,3,REDIS_CMD_DENYOOM,NULL,0,0,0},
  75     {"setex",setexCommand,4,REDIS_CMD_DENYOOM,NULL,0,0,0},
  76     {"append",appendCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
  77     {"strlen",strlenCommand,2,0,NULL,1,1,1},
  78     {"del",delCommand,-2,0,NULL,0,0,0},
  79     {"exists",existsCommand,2,0,NULL,1,1,1},
  80     {"setbit",setbitCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
  81     {"getbit",getbitCommand,3,0,NULL,1,1,1},
  82     {"setrange",setrangeCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
  83     {"getrange",getrangeCommand,4,0,NULL,1,1,1},
  84     {"substr",getrangeCommand,4,0,NULL,1,1,1},
  85     {"incr",incrCommand,2,REDIS_CMD_DENYOOM,NULL,1,1,1},
  86     {"decr",decrCommand,2,REDIS_CMD_DENYOOM,NULL,1,1,1},
  87     {"mget",mgetCommand,-2,0,NULL,1,-1,1},
  88     {"rpush",rpushCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
  89     {"lpush",lpushCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
  90     {"rpushx",rpushxCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
  91     {"lpushx",lpushxCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
  92     {"linsert",linsertCommand,5,REDIS_CMD_DENYOOM,NULL,1,1,1},
  93     {"rpop",rpopCommand,2,0,NULL,1,1,1},
  94     {"lpop",lpopCommand,2,0,NULL,1,1,1},
  95     {"brpop",brpopCommand,-3,0,NULL,1,1,1},
  96     {"brpoplpush",brpoplpushCommand,4,REDIS_CMD_DENYOOM,NULL,1,2,1},
  97     {"blpop",blpopCommand,-3,0,NULL,1,1,1},
  98     {"llen",llenCommand,2,0,NULL,1,1,1},
  99     {"lindex",lindexCommand,3,0,NULL,1,1,1},
 100     {"lset",lsetCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 101     {"lrange",lrangeCommand,4,0,NULL,1,1,1},
 102     {"ltrim",ltrimCommand,4,0,NULL,1,1,1},
 103     {"lrem",lremCommand,4,0,NULL,1,1,1},
 104     {"rpoplpush",rpoplpushCommand,3,REDIS_CMD_DENYOOM,NULL,1,2,1},
 105     {"sadd",saddCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
 106     {"srem",sremCommand,3,0,NULL,1,1,1},
 107     {"smove",smoveCommand,4,0,NULL,1,2,1},
 108     {"sismember",sismemberCommand,3,0,NULL,1,1,1},
 109     {"scard",scardCommand,2,0,NULL,1,1,1},
 110     {"spop",spopCommand,2,0,NULL,1,1,1},
 111     {"srandmember",srandmemberCommand,2,0,NULL,1,1,1},
 112     {"sinter",sinterCommand,-2,REDIS_CMD_DENYOOM,NULL,1,-1,1},
 113     {"sinterstore",sinterstoreCommand,-3,REDIS_CMD_DENYOOM,NULL,2,-1,1},
 114     {"sunion",sunionCommand,-2,REDIS_CMD_DENYOOM,NULL,1,-1,1},
 115     {"sunionstore",sunionstoreCommand,-3,REDIS_CMD_DENYOOM,NULL,2,-1,1},
 116     {"sdiff",sdiffCommand,-2,REDIS_CMD_DENYOOM,NULL,1,-1,1},
 117     {"sdiffstore",sdiffstoreCommand,-3,REDIS_CMD_DENYOOM,NULL,2,-1,1},
 118     {"smembers",sinterCommand,2,0,NULL,1,1,1},
 119     {"zadd",zaddCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 120     {"zincrby",zincrbyCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 121     {"zrem",zremCommand,3,0,NULL,1,1,1},
 122     {"zremrangebyscore",zremrangebyscoreCommand,4,0,NULL,1,1,1},
 123     {"zremrangebyrank",zremrangebyrankCommand,4,0,NULL,1,1,1},
 124     {"zunionstore",zunionstoreCommand,-4,REDIS_CMD_DENYOOM,zunionInterBlockClientOnSwappedKeys,0,0,0},
 125     {"zinterstore",zinterstoreCommand,-4,REDIS_CMD_DENYOOM,zunionInterBlockClientOnSwappedKeys,0,0,0},
 126     {"zrange",zrangeCommand,-4,0,NULL,1,1,1},
 127     {"zrangebyscore",zrangebyscoreCommand,-4,0,NULL,1,1,1},
 128     {"zrevrangebyscore",zrevrangebyscoreCommand,-4,0,NULL,1,1,1},
 129     {"zcount",zcountCommand,4,0,NULL,1,1,1},
 130     {"zrevrange",zrevrangeCommand,-4,0,NULL,1,1,1},
 131     {"zcard",zcardCommand,2,0,NULL,1,1,1},
 132     {"zscore",zscoreCommand,3,0,NULL,1,1,1},
 133     {"zrank",zrankCommand,3,0,NULL,1,1,1},
 134     {"zrevrank",zrevrankCommand,3,0,NULL,1,1,1},
 135     {"hset",hsetCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 136     {"hsetnx",hsetnxCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 137     {"hget",hgetCommand,3,0,NULL,1,1,1},
 138     {"hmset",hmsetCommand,-4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 139     {"hmget",hmgetCommand,-3,0,NULL,1,1,1},
 140     {"hincrby",hincrbyCommand,4,REDIS_CMD_DENYOOM,NULL,1,1,1},
 141     {"hdel",hdelCommand,3,0,NULL,1,1,1},
 142     {"hlen",hlenCommand,2,0,NULL,1,1,1},
 143     {"hkeys",hkeysCommand,2,0,NULL,1,1,1},
 144     {"hvals",hvalsCommand,2,0,NULL,1,1,1},
 145     {"hgetall",hgetallCommand,2,0,NULL,1,1,1},
 146     {"hexists",hexistsCommand,3,0,NULL,1,1,1},
 147     {"incrby",incrbyCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
 148     {"decrby",decrbyCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
 149     {"getset",getsetCommand,3,REDIS_CMD_DENYOOM,NULL,1,1,1},
 150     {"mset",msetCommand,-3,REDIS_CMD_DENYOOM,NULL,1,-1,2},
 151     {"msetnx",msetnxCommand,-3,REDIS_CMD_DENYOOM,NULL,1,-1,2},
 152     {"randomkey",randomkeyCommand,1,0,NULL,0,0,0},
 153     {"select",selectCommand,2,0,NULL,0,0,0},
 154     {"move",moveCommand,3,0,NULL,1,1,1},
 155     {"rename",renameCommand,3,0,NULL,1,1,1},
 156     {"renamenx",renamenxCommand,3,0,NULL,1,1,1},
 157     {"expire",expireCommand,3,0,NULL,0,0,0},
 158     {"expireat",expireatCommand,3,0,NULL,0,0,0},
 159     {"keys",keysCommand,2,0,NULL,0,0,0},
 160     {"dbsize",dbsizeCommand,1,0,NULL,0,0,0},
 161     {"auth",authCommand,2,0,NULL,0,0,0},
 162     {"ping",pingCommand,1,0,NULL,0,0,0},
 163     {"echo",echoCommand,2,0,NULL,0,0,0},
 164     {"save",saveCommand,1,0,NULL,0,0,0},
 165     {"bgsave",bgsaveCommand,1,0,NULL,0,0,0},
 166     {"bgrewriteaof",bgrewriteaofCommand,1,0,NULL,0,0,0},
 167     {"shutdown",shutdownCommand,1,0,NULL,0,0,0},
 168     {"lastsave",lastsaveCommand,1,0,NULL,0,0,0},
 169     {"type",typeCommand,2,0,NULL,1,1,1},
 170     {"multi",multiCommand,1,0,NULL,0,0,0},
 171     {"exec",execCommand,1,REDIS_CMD_DENYOOM,execBlockClientOnSwappedKeys,0,0,0},
 172     {"discard",discardCommand,1,0,NULL,0,0,0},
 173     {"sync",syncCommand,1,0,NULL,0,0,0},
 174     {"flushdb",flushdbCommand,1,0,NULL,0,0,0},
 175     {"flushall",flushallCommand,1,0,NULL,0,0,0},
 176     {"sort",sortCommand,-2,REDIS_CMD_DENYOOM,NULL,1,1,1},
 177     {"info",infoCommand,1,0,NULL,0,0,0},
 178     {"monitor",monitorCommand,1,0,NULL,0,0,0},
 179     {"ttl",ttlCommand,2,0,NULL,1,1,1},
 180     {"persist",persistCommand,2,0,NULL,1,1,1},
 181     {"slaveof",slaveofCommand,3,0,NULL,0,0,0},
 182     {"debug",debugCommand,-2,0,NULL,0,0,0},
 183     {"config",configCommand,-2,0,NULL,0,0,0},
 184     {"subscribe",subscribeCommand,-2,0,NULL,0,0,0},
 185     {"unsubscribe",unsubscribeCommand,-1,0,NULL,0,0,0},
 186     {"psubscribe",psubscribeCommand,-2,0,NULL,0,0,0},
 187     {"punsubscribe",punsubscribeCommand,-1,0,NULL,0,0,0},
 188     {"publish",publishCommand,3,REDIS_CMD_FORCE_REPLICATION,NULL,0,0,0},
 189     {"watch",watchCommand,-2,0,NULL,0,0,0},
 190     {"unwatch",unwatchCommand,1,0,NULL,0,0,0}
 191 };
 192
 193 /*============================ Utility functions ============================ */
 194
 195 void redisLog(int level, const char *fmt, ...) {
 196     const int syslogLevelMap[] = { LOG_DEBUG, LOG_INFO, LOG_NOTICE, LOG_WARNING };
 197     const char *c = ".-*#";
 198     time_t now = time(NULL);
 199     va_list ap;
 200     FILE *fp;
 201     char buf[64];
 202     char msg[REDIS_MAX_LOGMSG_LEN];
 203
 204     if (level < server.verbosity) return;
 205
 206     fp = (server.logfile == NULL) ? stdout : fopen(server.logfile,"a");
 207     if (!fp) return;
 208
 209     va_start(ap, fmt);
 210     vsnprintf(msg, sizeof(msg), fmt, ap);
 211     va_end(ap);
 212
 213     strftime(buf,sizeof(buf),"%d %b %H:%M:%S",localtime(&now));
 214     fprintf(fp,"[%d] %s %c %s\n",(int)getpid(),buf,c[level],msg);
 215     fflush(fp);
 216
 217     if (server.logfile) fclose(fp);
 218
 219     if (server.syslog_enabled) syslog(syslogLevelMap[level], "%s", msg);
 220 }
 221
 222 /* Redis generally does not try to recover from out of memory conditions
 223  * when allocating objects or strings, it is not clear if it will be possible
 224  * to report this condition to the client since the networking layer itself
 225  * is based on heap allocation for send buffers, so we simply abort.
 226  * At least the code will be simpler to read... */
 227 void oom(const char *msg) {
 228     redisLog(REDIS_WARNING, "%s: Out of memory\n",msg);
 229     sleep(1);
 230     abort();
 231 }
 232
 233 /*====================== Hash table type implementation  ==================== */
 234
 235 /* This is an hash table type that uses the SDS dynamic strings libary as
 236  * keys and radis objects as values (objects can hold SDS strings,
 237  * lists, sets). */
 238
 239 void dictVanillaFree(void *privdata, void *val)
 240 {
 241     DICT_NOTUSED(privdata);
 242     zfree(val);
 243 }
 244
 245 void dictListDestructor(void *privdata, void *val)
 246 {
 247     DICT_NOTUSED(privdata);
 248     listRelease((list*)val);
 249 }
 250
 251 int dictSdsKeyCompare(void *privdata, const void *key1,
 252         const void *key2)
 253 {
 254     int l1,l2;
 255     DICT_NOTUSED(privdata);
 256
 257     l1 = sdslen((sds)key1);
 258     l2 = sdslen((sds)key2);
 259     if (l1 != l2) return 0;
 260     return memcmp(key1, key2, l1) == 0;
 261 }
 262
 263 /* A case insensitive version used for the command lookup table. */
 264 int dictSdsKeyCaseCompare(void *privdata, const void *key1,
 265         const void *key2)
 266 {
 267     DICT_NOTUSED(privdata);
 268
 269     return strcasecmp(key1, key2) == 0;
 270 }
 271
 272 void dictRedisObjectDestructor(void *privdata, void *val)
 273 {
 274     DICT_NOTUSED(privdata);
 275
 276     if (val == NULL) return; /* Values of swapped out keys as set to NULL */
 277     decrRefCount(val);
 278 }
 279
 280 void dictSdsDestructor(void *privdata, void *val)
 281 {
 282     DICT_NOTUSED(privdata);
 283
 284     sdsfree(val);
 285 }
 286
 287 int dictObjKeyCompare(void *privdata, const void *key1,
 288         const void *key2)
 289 {
 290     const robj *o1 = key1, *o2 = key2;
 291     return dictSdsKeyCompare(privdata,o1->ptr,o2->ptr);
 292 }
 293
 294 unsigned int dictObjHash(const void *key) {
 295     const robj *o = key;
 296     return dictGenHashFunction(o->ptr, sdslen((sds)o->ptr));
 297 }
 298
 299 unsigned int dictSdsHash(const void *key) {
 300     return dictGenHashFunction((unsigned char*)key, sdslen((char*)key));
 301 }
 302
 303 unsigned int dictSdsCaseHash(const void *key) {
 304     return dictGenCaseHashFunction((unsigned char*)key, sdslen((char*)key));
 305 }
 306
 307 int dictEncObjKeyCompare(void *privdata, const void *key1,
 308         const void *key2)
 309 {
 310     robj *o1 = (robj*) key1, *o2 = (robj*) key2;
 311     int cmp;
 312
 313     if (o1->encoding == REDIS_ENCODING_INT &&
 314         o2->encoding == REDIS_ENCODING_INT)
 315             return o1->ptr == o2->ptr;
 316
 317     o1 = getDecodedObject(o1);
 318     o2 = getDecodedObject(o2);
 319     cmp = dictSdsKeyCompare(privdata,o1->ptr,o2->ptr);
 320     decrRefCount(o1);
 321     decrRefCount(o2);
 322     return cmp;
 323 }
 324
 325 unsigned int dictEncObjHash(const void *key) {
 326     robj *o = (robj*) key;
 327
 328     if (o->encoding == REDIS_ENCODING_RAW) {
 329         return dictGenHashFunction(o->ptr, sdslen((sds)o->ptr));
 330     } else {
 331         if (o->encoding == REDIS_ENCODING_INT) {
 332             char buf[32];
 333             int len;
 334
 335             len = ll2string(buf,32,(long)o->ptr);
 336             return dictGenHashFunction((unsigned char*)buf, len);
 337         } else {
 338             unsigned int hash;
 339
 340             o = getDecodedObject(o);
 341             hash = dictGenHashFunction(o->ptr, sdslen((sds)o->ptr));
 342             decrRefCount(o);
 343             return hash;
 344         }
 345     }
 346 }
 347
 348 /* Sets type and diskstore negative caching hash table */
 349 dictType setDictType = {
 350     dictEncObjHash,            /* hash function */
 351     NULL,                      /* key dup */
 352     NULL,                      /* val dup */
 353     dictEncObjKeyCompare,      /* key compare */
 354     dictRedisObjectDestructor, /* key destructor */
 355     NULL                       /* val destructor */
 356 };
 357
 358 /* Sorted sets hash (note: a skiplist is used in addition to the hash table) */
 359 dictType zsetDictType = {
 360     dictEncObjHash,            /* hash function */
 361     NULL,                      /* key dup */
 362     NULL,                      /* val dup */
 363     dictEncObjKeyCompare,      /* key compare */
 364     dictRedisObjectDestructor, /* key destructor */
 365     NULL                       /* val destructor */
 366 };
 367
 368 /* Db->dict, keys are sds strings, vals are Redis objects. */
 369 dictType dbDictType = {
 370     dictSdsHash,                /* hash function */
 371     NULL,                       /* key dup */
 372     NULL,                       /* val dup */
 373     dictSdsKeyCompare,          /* key compare */
 374     dictSdsDestructor,          /* key destructor */
 375     dictRedisObjectDestructor   /* val destructor */
 376 };
 377
 378 /* Db->expires */
 379 dictType keyptrDictType = {
 380     dictSdsHash,               /* hash function */
 381     NULL,                      /* key dup */
 382     NULL,                      /* val dup */
 383     dictSdsKeyCompare,         /* key compare */
 384     NULL,                      /* key destructor */
 385     NULL                       /* val destructor */
 386 };
 387
 388 /* Command table. sds string -> command struct pointer. */
 389 dictType commandTableDictType = {
 390     dictSdsCaseHash,           /* hash function */
 391     NULL,                      /* key dup */
 392     NULL,                      /* val dup */
 393     dictSdsKeyCaseCompare,     /* key compare */
 394     dictSdsDestructor,         /* key destructor */
 395     NULL                       /* val destructor */
 396 };
 397
 398 /* Hash type hash table (note that small hashes are represented with zimpaps) */
 399 dictType hashDictType = {
 400     dictEncObjHash,             /* hash function */
 401     NULL,                       /* key dup */
 402     NULL,                       /* val dup */
 403     dictEncObjKeyCompare,       /* key compare */
 404     dictRedisObjectDestructor,  /* key destructor */
 405     dictRedisObjectDestructor   /* val destructor */
 406 };
 407
 408 /* Keylist hash table type has unencoded redis objects as keys and
 409  * lists as values. It's used for blocking operations (BLPOP) and to
 410  * map swapped keys to a list of clients waiting for this keys to be loaded. */
 411 dictType keylistDictType = {
 412     dictObjHash,                /* hash function */
 413     NULL,                       /* key dup */
 414     NULL,                       /* val dup */
 415     dictObjKeyCompare,          /* key compare */
 416     dictRedisObjectDestructor,  /* key destructor */
 417     dictListDestructor          /* val destructor */
 418 };
 419
 420 int htNeedsResize(dict *dict) {
 421     long long size, used;
 422
 423     size = dictSlots(dict);
 424     used = dictSize(dict);
 425     return (size && used && size > DICT_HT_INITIAL_SIZE &&
 426             (used*100/size < REDIS_HT_MINFILL));
 427 }
 428
 429 /* If the percentage of used slots in the HT reaches REDIS_HT_MINFILL
 430  * we resize the hash table to save memory */
 431 void tryResizeHashTables(void) {
 432     int j;
 433
 434     for (j = 0; j < server.dbnum; j++) {
 435         if (htNeedsResize(server.db[j].dict))
 436             dictResize(server.db[j].dict);
 437         if (htNeedsResize(server.db[j].expires))
 438             dictResize(server.db[j].expires);
 439     }
 440 }
 441
 442 /* Our hash table implementation performs rehashing incrementally while
 443  * we write/read from the hash table. Still if the server is idle, the hash
 444  * table will use two tables for a long time. So we try to use 1 millisecond
 445  * of CPU time at every serverCron() loop in order to rehash some key. */
 446 void incrementallyRehash(void) {
 447     int j;
 448
 449     for (j = 0; j < server.dbnum; j++) {
 450         if (dictIsRehashing(server.db[j].dict)) {
 451             dictRehashMilliseconds(server.db[j].dict,1);
 452             break; /* already used our millisecond for this loop... */
 453         }
 454     }
 455 }
 456
 457 /* This function is called once a background process of some kind terminates,
 458  * as we want to avoid resizing the hash tables when there is a child in order
 459  * to play well with copy-on-write (otherwise when a resize happens lots of
 460  * memory pages are copied). The goal of this function is to update the ability
 461  * for dict.c to resize the hash tables accordingly to the fact we have o not
 462  * running childs. */
 463 void updateDictResizePolicy(void) {
 464     if (server.bgsavechildpid == -1 && server.bgrewritechildpid == -1)
 465         dictEnableResize();
 466     else
 467         dictDisableResize();
 468 }
 469
 470 /* ======================= Cron: called every 100 ms ======================== */
 471
 472 /* Try to expire a few timed out keys. The algorithm used is adaptive and
 473  * will use few CPU cycles if there are few expiring keys, otherwise
 474  * it will get more aggressive to avoid that too much memory is used by
 475  * keys that can be removed from the keyspace. */
 476 void activeExpireCycle(void) {
 477     int j;
 478
 479     for (j = 0; j < server.dbnum; j++) {
 480         int expired;
 481         redisDb *db = server.db+j;
 482
 483         /* Continue to expire if at the end of the cycle more than 25%
 484          * of the keys were expired. */
 485         do {
 486             long num = dictSize(db->expires);
 487             time_t now = time(NULL);
 488
 489             expired = 0;
 490             if (num > REDIS_EXPIRELOOKUPS_PER_CRON)
 491                 num = REDIS_EXPIRELOOKUPS_PER_CRON;
 492             while (num--) {
 493                 dictEntry *de;
 494                 time_t t;
 495
 496                 if ((de = dictGetRandomKey(db->expires)) == NULL) break;
 497                 t = (time_t) dictGetEntryVal(de);
 498                 if (now > t) {
 499                     sds key = dictGetEntryKey(de);
 500                     robj *keyobj = createStringObject(key,sdslen(key));
 501
 502                     propagateExpire(db,keyobj);
 503                     dbDelete(db,keyobj);
 504                     decrRefCount(keyobj);
 505                     expired++;
 506                     server.stat_expiredkeys++;
 507                 }
 508             }
 509         } while (expired > REDIS_EXPIRELOOKUPS_PER_CRON/4);
 510     }
 511 }
 512
 513 void updateLRUClock(void) {
 514     server.lruclock = (time(NULL)/REDIS_LRU_CLOCK_RESOLUTION) &
 515                                                 REDIS_LRU_CLOCK_MAX;
 516 }
 517
 518 int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
 519     int j, loops = server.cronloops++;
 520     REDIS_NOTUSED(eventLoop);
 521     REDIS_NOTUSED(id);
 522     REDIS_NOTUSED(clientData);
 523
 524     /* We take a cached value of the unix time in the global state because
 525      * with virtual memory and aging there is to store the current time
 526      * in objects at every object access, and accuracy is not needed.
 527      * To access a global var is faster than calling time(NULL) */
 528     server.unixtime = time(NULL);
 529     /* We have just 22 bits per object for LRU information.
 530      * So we use an (eventually wrapping) LRU clock with 10 seconds resolution.
 531      * 2^22 bits with 10 seconds resoluton is more or less 1.5 years.
 532      *
 533      * Note that even if this will wrap after 1.5 years it's not a problem,
 534      * everything will still work but just some object will appear younger
 535      * to Redis. But for this to happen a given object should never be touched
 536      * for 1.5 years.
 537      *
 538      * Note that you can change the resolution altering the
 539      * REDIS_LRU_CLOCK_RESOLUTION define.
 540      */
 541     updateLRUClock();
 542
 543     /* We received a SIGTERM, shutting down here in a safe way, as it is
 544      * not ok doing so inside the signal handler. */
 545     if (server.shutdown_asap) {
 546         if (prepareForShutdown() == REDIS_OK) exit(0);
 547         redisLog(REDIS_WARNING,"SIGTERM received but errors trying to shut down the server, check the logs for more information");
 548     }
 549
 550     /* Show some info about non-empty databases */
 551     for (j = 0; j < server.dbnum; j++) {
 552         long long size, used, vkeys;
 553
 554         size = dictSlots(server.db[j].dict);
 555         used = dictSize(server.db[j].dict);
 556         vkeys = dictSize(server.db[j].expires);
 557         if (!(loops % 50) && (used || vkeys)) {
 558             redisLog(REDIS_VERBOSE,"DB %d: %lld keys (%lld volatile) in %lld slots HT.",j,used,vkeys,size);
 559             /* dictPrintStats(server.dict); */
 560         }
 561     }
 562
 563     /* We don't want to resize the hash tables while a bacground saving
 564      * is in progress: the saving child is created using fork() that is
 565      * implemented with a copy-on-write semantic in most modern systems, so
 566      * if we resize the HT while there is the saving child at work actually
 567      * a lot of memory movements in the parent will cause a lot of pages
 568      * copied. */
 569     if (server.bgsavechildpid == -1 && server.bgrewritechildpid == -1) {
 570         if (!(loops % 10)) tryResizeHashTables();
 571         if (server.activerehashing) incrementallyRehash();
 572     }
 573
 574     /* Show information about connected clients */
 575     if (!(loops % 50)) {
 576         redisLog(REDIS_VERBOSE,"%d clients connected (%d slaves), %zu bytes in use",
 577             listLength(server.clients)-listLength(server.slaves),
 578             listLength(server.slaves),
 579             zmalloc_used_memory());
 580     }
 581
 582     /* Close connections of timedout clients */
 583     if ((server.maxidletime && !(loops % 100)) || server.bpop_blocked_clients)
 584         closeTimedoutClients();
 585
 586     /* Check if a background saving or AOF rewrite in progress terminated. */
 587     if (server.bgsavechildpid != -1 || server.bgrewritechildpid != -1) {
 588         int statloc;
 589         pid_t pid;
 590
 591         if ((pid = wait3(&statloc,WNOHANG,NULL)) != 0) {
 592             int exitcode = WEXITSTATUS(statloc);
 593             int bysignal = 0;
 594
 595             if (WIFSIGNALED(statloc)) bysignal = WTERMSIG(statloc);
 596
 597             if (pid == server.bgsavechildpid) {
 598                 backgroundSaveDoneHandler(exitcode,bysignal);
 599             } else {
 600                 backgroundRewriteDoneHandler(exitcode,bysignal);
 601             }
 602             updateDictResizePolicy();
 603         }
 604     } else if (server.bgsavethread != (pthread_t) -1) {
 605         if (server.bgsavethread != (pthread_t) -1) {
 606             int state;
 607
 608             pthread_mutex_lock(&server.bgsavethread_mutex);
 609             state = server.bgsavethread_state;
 610             pthread_mutex_unlock(&server.bgsavethread_mutex);
 611
 612             if (state == REDIS_BGSAVE_THREAD_DONE_OK ||
 613                 state == REDIS_BGSAVE_THREAD_DONE_ERR)
 614             {
 615                 backgroundSaveDoneHandler(
 616                     (state == REDIS_BGSAVE_THREAD_DONE_OK) ? 0 : 1, 0);
 617             }
 618         }
 619     } else if (!server.ds_enabled) {
 620         /* If there is not a background saving in progress check if
 621          * we have to save now */
 622          time_t now = time(NULL);
 623          for (j = 0; j < server.saveparamslen; j++) {
 624             struct saveparam *sp = server.saveparams+j;
 625
 626             if (server.dirty >= sp->changes &&
 627                 now-server.lastsave > sp->seconds) {
 628                 redisLog(REDIS_NOTICE,"%d changes in %d seconds. Saving...",
 629                     sp->changes, sp->seconds);
 630                 rdbSaveBackground(server.dbfilename);
 631                 break;
 632             }
 633          }
 634     }
 635
 636     /* Expire a few keys per cycle, only if this is a master.
 637      * On slaves we wait for DEL operations synthesized by the master
 638      * in order to guarantee a strict consistency. */
 639     if (server.masterhost == NULL) activeExpireCycle();
 640
 641     /* Remove a few cached objects from memory if we are over the
 642      * configured memory limit */
 643     if (server.ds_enabled) cacheCron();
 644
 645     /* Replication cron function -- used to reconnect to master and
 646      * to detect transfer failures. */
 647     if (!(loops % 10)) replicationCron();
 648
 649     return 100;
 650 }
 651
 652 /* This function gets called every time Redis is entering the
 653  * main loop of the event driven library, that is, before to sleep
 654  * for ready file descriptors. */
 655 void beforeSleep(struct aeEventLoop *eventLoop) {
 656     REDIS_NOTUSED(eventLoop);
 657     listNode *ln;
 658     redisClient *c;
 659
 660     /* Awake clients that got all the on disk keys they requested */
 661     if (server.ds_enabled && listLength(server.io_ready_clients)) {
 662         listIter li;
 663
 664         listRewind(server.io_ready_clients,&li);
 665         while((ln = listNext(&li))) {
 666             c = ln->value;
 667             struct redisCommand *cmd;
 668
 669             /* Resume the client. */
 670             listDelNode(server.io_ready_clients,ln);
 671             c->flags &= (~REDIS_IO_WAIT);
 672             server.cache_blocked_clients--;
 673             aeCreateFileEvent(server.el, c->fd, AE_READABLE,
 674                 readQueryFromClient, c);
 675             cmd = lookupCommand(c->argv[0]->ptr);
 676             redisAssert(cmd != NULL);
 677             call(c,cmd);
 678             resetClient(c);
 679             /* There may be more data to process in the input buffer. */
 680             if (c->querybuf && sdslen(c->querybuf) > 0)
 681                 processInputBuffer(c);
 682         }
 683     }
 684
 685     /* Try to process pending commands for clients that were just unblocked. */
 686     while (listLength(server.unblocked_clients)) {
 687         ln = listFirst(server.unblocked_clients);
 688         redisAssert(ln != NULL);
 689         c = ln->value;
 690         listDelNode(server.unblocked_clients,ln);
 691
 692         /* Process remaining data in the input buffer. */
 693         if (c->querybuf && sdslen(c->querybuf) > 0)
 694             processInputBuffer(c);
 695     }
 696
 697     /* Write the AOF buffer on disk */
 698     flushAppendOnlyFile();
 699 }
 700
 701 /* =========================== Server initialization ======================== */
 702
 703 void createSharedObjects(void) {
 704     int j;
 705
 706     shared.crlf = createObject(REDIS_STRING,sdsnew("\r\n"));
 707     shared.ok = createObject(REDIS_STRING,sdsnew("+OK\r\n"));
 708     shared.err = createObject(REDIS_STRING,sdsnew("-ERR\r\n"));
 709     shared.emptybulk = createObject(REDIS_STRING,sdsnew("$0\r\n\r\n"));
 710     shared.czero = createObject(REDIS_STRING,sdsnew(":0\r\n"));
 711     shared.cone = createObject(REDIS_STRING,sdsnew(":1\r\n"));
 712     shared.cnegone = createObject(REDIS_STRING,sdsnew(":-1\r\n"));
 713     shared.nullbulk = createObject(REDIS_STRING,sdsnew("$-1\r\n"));
 714     shared.nullmultibulk = createObject(REDIS_STRING,sdsnew("*-1\r\n"));
 715     shared.emptymultibulk = createObject(REDIS_STRING,sdsnew("*0\r\n"));
 716     shared.pong = createObject(REDIS_STRING,sdsnew("+PONG\r\n"));
 717     shared.queued = createObject(REDIS_STRING,sdsnew("+QUEUED\r\n"));
 718     shared.wrongtypeerr = createObject(REDIS_STRING,sdsnew(
 719         "-ERR Operation against a key holding the wrong kind of value\r\n"));
 720     shared.nokeyerr = createObject(REDIS_STRING,sdsnew(
 721         "-ERR no such key\r\n"));
 722     shared.syntaxerr = createObject(REDIS_STRING,sdsnew(
 723         "-ERR syntax error\r\n"));
 724     shared.sameobjecterr = createObject(REDIS_STRING,sdsnew(
 725         "-ERR source and destination objects are the same\r\n"));
 726     shared.outofrangeerr = createObject(REDIS_STRING,sdsnew(
 727         "-ERR index out of range\r\n"));
 728     shared.loadingerr = createObject(REDIS_STRING,sdsnew(
 729         "-LOADING Redis is loading the dataset in memory\r\n"));
 730     shared.space = createObject(REDIS_STRING,sdsnew(" "));
 731     shared.colon = createObject(REDIS_STRING,sdsnew(":"));
 732     shared.plus = createObject(REDIS_STRING,sdsnew("+"));
 733     shared.select0 = createStringObject("select 0\r\n",10);
 734     shared.select1 = createStringObject("select 1\r\n",10);
 735     shared.select2 = createStringObject("select 2\r\n",10);
 736     shared.select3 = createStringObject("select 3\r\n",10);
 737     shared.select4 = createStringObject("select 4\r\n",10);
 738     shared.select5 = createStringObject("select 5\r\n",10);
 739     shared.select6 = createStringObject("select 6\r\n",10);
 740     shared.select7 = createStringObject("select 7\r\n",10);
 741     shared.select8 = createStringObject("select 8\r\n",10);
 742     shared.select9 = createStringObject("select 9\r\n",10);
 743     shared.messagebulk = createStringObject("$7\r\nmessage\r\n",13);
 744     shared.pmessagebulk = createStringObject("$8\r\npmessage\r\n",14);
 745     shared.subscribebulk = createStringObject("$9\r\nsubscribe\r\n",15);
 746     shared.unsubscribebulk = createStringObject("$11\r\nunsubscribe\r\n",18);
 747     shared.psubscribebulk = createStringObject("$10\r\npsubscribe\r\n",17);
 748     shared.punsubscribebulk = createStringObject("$12\r\npunsubscribe\r\n",19);
 749     shared.mbulk3 = createStringObject("*3\r\n",4);
 750     shared.mbulk4 = createStringObject("*4\r\n",4);
 751     for (j = 0; j < REDIS_SHARED_INTEGERS; j++) {
 752         shared.integers[j] = createObject(REDIS_STRING,(void*)(long)j);
 753         shared.integers[j]->encoding = REDIS_ENCODING_INT;
 754     }
 755 }
 756
 757 void initServerConfig() {
 758     server.port = REDIS_SERVERPORT;
 759     server.bindaddr = NULL;
 760     server.unixsocket = NULL;
 761     server.ipfd = -1;
 762     server.sofd = -1;
 763     server.dbnum = REDIS_DEFAULT_DBNUM;
 764     server.verbosity = REDIS_VERBOSE;
 765     server.maxidletime = REDIS_MAXIDLETIME;
 766     server.saveparams = NULL;
 767     server.loading = 0;
 768     server.logfile = NULL; /* NULL = log on standard output */
 769     server.syslog_enabled = 0;
 770     server.syslog_ident = zstrdup("redis");
 771     server.syslog_facility = LOG_LOCAL0;
 772     server.daemonize = 0;
 773     server.appendonly = 0;
 774     server.appendfsync = APPENDFSYNC_EVERYSEC;
 775     server.no_appendfsync_on_rewrite = 0;
 776     server.lastfsync = time(NULL);
 777     server.appendfd = -1;
 778     server.appendseldb = -1; /* Make sure the first time will not match */
 779     server.pidfile = zstrdup("/var/run/redis.pid");
 780     server.dbfilename = zstrdup("dump.rdb");
 781     server.appendfilename = zstrdup("appendonly.aof");
 782     server.requirepass = NULL;
 783     server.rdbcompression = 1;
 784     server.activerehashing = 1;
 785     server.maxclients = 0;
 786     server.bpop_blocked_clients = 0;
 787     server.maxmemory = 0;
 788     server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU;
 789     server.maxmemory_samples = 3;
 790     server.ds_enabled = 0;
 791     server.ds_path = sdsnew("/tmp/redis.ds");
 792     server.cache_max_memory = 64LL*1024*1024; /* 64 MB of RAM */
 793     server.cache_blocked_clients = 0;
 794     server.hash_max_zipmap_entries = REDIS_HASH_MAX_ZIPMAP_ENTRIES;
 795     server.hash_max_zipmap_value = REDIS_HASH_MAX_ZIPMAP_VALUE;
 796     server.list_max_ziplist_entries = REDIS_LIST_MAX_ZIPLIST_ENTRIES;
 797     server.list_max_ziplist_value = REDIS_LIST_MAX_ZIPLIST_VALUE;
 798     server.set_max_intset_entries = REDIS_SET_MAX_INTSET_ENTRIES;
 799     server.shutdown_asap = 0;
 800     server.cache_flush_delay = 0;
 801
 802     updateLRUClock();
 803     resetServerSaveParams();
 804
 805     appendServerSaveParams(60*60,1);  /* save after 1 hour and 1 change */
 806     appendServerSaveParams(300,100);  /* save after 5 minutes and 100 changes */
 807     appendServerSaveParams(60,10000); /* save after 1 minute and 10000 changes */
 808     /* Replication related */
 809     server.isslave = 0;
 810     server.masterauth = NULL;
 811     server.masterhost = NULL;
 812     server.masterport = 6379;
 813     server.master = NULL;
 814     server.replstate = REDIS_REPL_NONE;
 815     server.repl_serve_stale_data = 1;
 816
 817     /* Double constants initialization */
 818     R_Zero = 0.0;
 819     R_PosInf = 1.0/R_Zero;
 820     R_NegInf = -1.0/R_Zero;
 821     R_Nan = R_Zero/R_Zero;
 822
 823     /* Command table -- we intiialize it here as it is part of the
 824      * initial configuration, since command names may be changed via
 825      * redis.conf using the rename-command directive. */
 826     server.commands = dictCreate(&commandTableDictType,NULL);
 827     populateCommandTable();
 828     server.delCommand = lookupCommandByCString("del");
 829     server.multiCommand = lookupCommandByCString("multi");
 830 }
 831
 832 void initServer() {
 833     int j;
 834
 835     signal(SIGHUP, SIG_IGN);
 836     signal(SIGPIPE, SIG_IGN);
 837     setupSigSegvAction();
 838
 839     if (server.syslog_enabled) {
 840         openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT,
 841             server.syslog_facility);
 842     }
 843
 844     server.mainthread = pthread_self();
 845     server.clients = listCreate();
 846     server.slaves = listCreate();
 847     server.monitors = listCreate();
 848     server.unblocked_clients = listCreate();
 849     server.cache_io_queue = listCreate();
 850
 851     createSharedObjects();
 852     server.el = aeCreateEventLoop();
 853     server.db = zmalloc(sizeof(redisDb)*server.dbnum);
 854     server.ipfd = anetTcpServer(server.neterr,server.port,server.bindaddr);
 855     if (server.ipfd == ANET_ERR) {
 856         redisLog(REDIS_WARNING, "Opening port: %s", server.neterr);
 857         exit(1);
 858     }
 859     if (server.unixsocket != NULL) {
 860         unlink(server.unixsocket); /* don't care if this fails */
 861         server.sofd = anetUnixServer(server.neterr,server.unixsocket);
 862         if (server.sofd == ANET_ERR) {
 863             redisLog(REDIS_WARNING, "Opening socket: %s", server.neterr);
 864             exit(1);
 865         }
 866     }
 867     if (server.ipfd < 0 && server.sofd < 0) {
 868         redisLog(REDIS_WARNING, "Configured to not listen anywhere, exiting.");
 869         exit(1);
 870     }
 871     for (j = 0; j < server.dbnum; j++) {
 872         server.db[j].dict = dictCreate(&dbDictType,NULL);
 873         server.db[j].expires = dictCreate(&keyptrDictType,NULL);
 874         server.db[j].blocking_keys = dictCreate(&keylistDictType,NULL);
 875         server.db[j].watched_keys = dictCreate(&keylistDictType,NULL);
 876         if (server.ds_enabled) {
 877             server.db[j].io_keys = dictCreate(&keylistDictType,NULL);
 878             server.db[j].io_negcache = dictCreate(&setDictType,NULL);
 879             server.db[j].io_queued = dictCreate(&setDictType,NULL);
 880         }
 881         server.db[j].id = j;
 882     }
 883     server.pubsub_channels = dictCreate(&keylistDictType,NULL);
 884     server.pubsub_patterns = listCreate();
 885     listSetFreeMethod(server.pubsub_patterns,freePubsubPattern);
 886     listSetMatchMethod(server.pubsub_patterns,listMatchPubsubPattern);
 887     server.cronloops = 0;
 888     server.bgsavechildpid = -1;
 889     server.bgrewritechildpid = -1;
 890     server.bgsavethread_state = REDIS_BGSAVE_THREAD_UNACTIVE;
 891     server.bgsavethread = (pthread_t) -1;
 892     server.bgrewritebuf = sdsempty();
 893     server.aofbuf = sdsempty();
 894     server.lastsave = time(NULL);
 895     server.dirty = 0;
 896     server.stat_numcommands = 0;
 897     server.stat_numconnections = 0;
 898     server.stat_expiredkeys = 0;
 899     server.stat_evictedkeys = 0;
 900     server.stat_starttime = time(NULL);
 901     server.stat_keyspace_misses = 0;
 902     server.stat_keyspace_hits = 0;
 903     server.unixtime = time(NULL);
 904     aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL);
 905     if (server.ipfd > 0 && aeCreateFileEvent(server.el,server.ipfd,AE_READABLE,
 906         acceptTcpHandler,NULL) == AE_ERR) oom("creating file event");
 907     if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE,
 908         acceptUnixHandler,NULL) == AE_ERR) oom("creating file event");
 909
 910     if (server.appendonly) {
 911         server.appendfd = open(server.appendfilename,O_WRONLY|O_APPEND|O_CREAT,0644);
 912         if (server.appendfd == -1) {
 913             redisLog(REDIS_WARNING, "Can't open the append-only file: %s",
 914                 strerror(errno));
 915             exit(1);
 916         }
 917     }
 918
 919     if (server.ds_enabled) dsInit();
 920 }
 921
 922 /* Populates the Redis Command Table starting from the hard coded list
 923  * we have on top of redis.c file. */
 924 void populateCommandTable(void) {
 925     int j;
 926     int numcommands = sizeof(readonlyCommandTable)/sizeof(struct redisCommand);
 927
 928     for (j = 0; j < numcommands; j++) {
 929         struct redisCommand *c = readonlyCommandTable+j;
 930         int retval;
 931
 932         retval = dictAdd(server.commands, sdsnew(c->name), c);
 933         assert(retval == DICT_OK);
 934     }
 935 }
 936
 937 /* ====================== Commands lookup and execution ===================== */
 938
 939 struct redisCommand *lookupCommand(sds name) {
 940     return dictFetchValue(server.commands, name);
 941 }
 942
 943 struct redisCommand *lookupCommandByCString(char *s) {
 944     struct redisCommand *cmd;
 945     sds name = sdsnew(s);
 946
 947     cmd = dictFetchValue(server.commands, name);
 948     sdsfree(name);
 949     return cmd;
 950 }
 951
 952 /* Call() is the core of Redis execution of a command */
 953 void call(redisClient *c, struct redisCommand *cmd) {
 954     long long dirty;
 955
 956     dirty = server.dirty;
 957     cmd->proc(c);
 958     dirty = server.dirty-dirty;
 959
 960     if (server.appendonly && dirty)
 961         feedAppendOnlyFile(cmd,c->db->id,c->argv,c->argc);
 962     if ((dirty || cmd->flags & REDIS_CMD_FORCE_REPLICATION) &&
 963         listLength(server.slaves))
 964         replicationFeedSlaves(server.slaves,c->db->id,c->argv,c->argc);
 965     if (listLength(server.monitors))
 966         replicationFeedMonitors(server.monitors,c->db->id,c->argv,c->argc);
 967     server.stat_numcommands++;
 968 }
 969
 970 /* If this function gets called we already read a whole
 971  * command, argments are in the client argv/argc fields.
 972  * processCommand() execute the command or prepare the
 973  * server for a bulk read from the client.
 974  *
 975  * If 1 is returned the client is still alive and valid and
 976  * and other operations can be performed by the caller. Otherwise
 977  * if 0 is returned the client was destroied (i.e. after QUIT). */
 978 int processCommand(redisClient *c) {
 979     struct redisCommand *cmd;
 980
 981     /* The QUIT command is handled separately. Normal command procs will
 982      * go through checking for replication and QUIT will cause trouble
 983      * when FORCE_REPLICATION is enabled and would be implemented in
 984      * a regular command proc. */
 985     if (!strcasecmp(c->argv[0]->ptr,"quit")) {
 986         addReply(c,shared.ok);
 987         c->flags |= REDIS_CLOSE_AFTER_REPLY;
 988         return REDIS_ERR;
 989     }
 990
 991     /* Now lookup the command and check ASAP about trivial error conditions
 992      * such wrong arity, bad command name and so forth. */
 993     cmd = lookupCommand(c->argv[0]->ptr);
 994     if (!cmd) {
 995         addReplyErrorFormat(c,"unknown command '%s'",
 996             (char*)c->argv[0]->ptr);
 997         return REDIS_OK;
 998     } else if ((cmd->arity > 0 && cmd->arity != c->argc) ||
 999                (c->argc < -cmd->arity)) {
1000         addReplyErrorFormat(c,"wrong number of arguments for '%s' command",
1001             cmd->name);
1002         return REDIS_OK;
1003     }
1004
1005     /* Check if the user is authenticated */
1006     if (server.requirepass && !c->authenticated && cmd->proc != authCommand) {
1007         addReplyError(c,"operation not permitted");
1008         return REDIS_OK;
1009     }
1010
1011     /* Handle the maxmemory directive.
1012      *
1013      * First we try to free some memory if possible (if there are volatile
1014      * keys in the dataset). If there are not the only thing we can do
1015      * is returning an error. */
1016     if (server.maxmemory) freeMemoryIfNeeded();
1017     if (server.maxmemory && (cmd->flags & REDIS_CMD_DENYOOM) &&
1018         zmalloc_used_memory() > server.maxmemory)
1019     {
1020         addReplyError(c,"command not allowed when used memory > 'maxmemory'");
1021         return REDIS_OK;
1022     }
1023
1024     /* Only allow SUBSCRIBE and UNSUBSCRIBE in the context of Pub/Sub */
1025     if ((dictSize(c->pubsub_channels) > 0 || listLength(c->pubsub_patterns) > 0)
1026         &&
1027         cmd->proc != subscribeCommand && cmd->proc != unsubscribeCommand &&
1028         cmd->proc != psubscribeCommand && cmd->proc != punsubscribeCommand) {
1029         addReplyError(c,"only (P)SUBSCRIBE / (P)UNSUBSCRIBE / QUIT allowed in this context");
1030         return REDIS_OK;
1031     }
1032
1033     /* Only allow INFO and SLAVEOF when slave-serve-stale-data is no and
1034      * we are a slave with a broken link with master. */
1035     if (server.masterhost && server.replstate != REDIS_REPL_CONNECTED &&
1036         server.repl_serve_stale_data == 0 &&
1037         cmd->proc != infoCommand && cmd->proc != slaveofCommand)
1038     {
1039         addReplyError(c,
1040             "link with MASTER is down and slave-serve-stale-data is set to no");
1041         return REDIS_OK;
1042     }
1043
1044     /* Loading DB? Return an error if the command is not INFO */
1045     if (server.loading && cmd->proc != infoCommand) {
1046         addReply(c, shared.loadingerr);
1047         return REDIS_OK;
1048     }
1049
1050     /* Exec the command */
1051     if (c->flags & REDIS_MULTI &&
1052         cmd->proc != execCommand && cmd->proc != discardCommand &&
1053         cmd->proc != multiCommand && cmd->proc != watchCommand)
1054     {
1055         queueMultiCommand(c,cmd);
1056         addReply(c,shared.queued);
1057     } else {
1058         if (server.ds_enabled && blockClientOnSwappedKeys(c,cmd))
1059             return REDIS_ERR;
1060         call(c,cmd);
1061     }
1062     return REDIS_OK;
1063 }
1064
1065 /*================================== Shutdown =============================== */
1066
1067 int prepareForShutdown() {
1068     redisLog(REDIS_WARNING,"User requested shutdown, saving DB...");
1069     /* Kill the saving child if there is a background saving in progress.
1070        We want to avoid race conditions, for instance our saving child may
1071        overwrite the synchronous saving did by SHUTDOWN. */
1072     if (server.bgsavechildpid != -1) {
1073         redisLog(REDIS_WARNING,"There is a live saving child. Killing it!");
1074         kill(server.bgsavechildpid,SIGKILL);
1075         rdbRemoveTempFile(server.bgsavechildpid);
1076     }
1077     if (server.ds_enabled) {
1078         /* FIXME: flush all objects on disk */
1079     } else if (server.appendonly) {
1080         /* Append only file: fsync() the AOF and exit */
1081         aof_fsync(server.appendfd);
1082     } else if (server.saveparamslen > 0) {
1083         /* Snapshotting. Perform a SYNC SAVE and exit */
1084         if (rdbSave(server.dbfilename) != REDIS_OK) {
1085             /* Ooops.. error saving! The best we can do is to continue
1086              * operating. Note that if there was a background saving process,
1087              * in the next cron() Redis will be notified that the background
1088              * saving aborted, handling special stuff like slaves pending for
1089              * synchronization... */
1090             redisLog(REDIS_WARNING,"Error trying to save the DB, can't exit");
1091             return REDIS_ERR;
1092         }
1093     } else {
1094         redisLog(REDIS_WARNING,"Not saving DB.");
1095     }
1096     if (server.daemonize) unlink(server.pidfile);
1097     redisLog(REDIS_WARNING,"Server exit now, bye bye...");
1098     return REDIS_OK;
1099 }
1100
1101 /*================================== Commands =============================== */
1102
1103 void authCommand(redisClient *c) {
1104     if (!server.requirepass || !strcmp(c->argv[1]->ptr, server.requirepass)) {
1105       c->authenticated = 1;
1106       addReply(c,shared.ok);
1107     } else {
1108       c->authenticated = 0;
1109       addReplyError(c,"invalid password");
1110     }
1111 }
1112
1113 void pingCommand(redisClient *c) {
1114     addReply(c,shared.pong);
1115 }
1116
1117 void echoCommand(redisClient *c) {
1118     addReplyBulk(c,c->argv[1]);
1119 }
1120
1121 /* Convert an amount of bytes into a human readable string in the form
1122  * of 100B, 2G, 100M, 4K, and so forth. */
1123 void bytesToHuman(char *s, unsigned long long n) {
1124     double d;
1125
1126     if (n < 1024) {
1127         /* Bytes */
1128         sprintf(s,"%lluB",n);
1129         return;
1130     } else if (n < (1024*1024)) {
1131         d = (double)n/(1024);
1132         sprintf(s,"%.2fK",d);
1133     } else if (n < (1024LL*1024*1024)) {
1134         d = (double)n/(1024*1024);
1135         sprintf(s,"%.2fM",d);
1136     } else if (n < (1024LL*1024*1024*1024)) {
1137         d = (double)n/(1024LL*1024*1024);
1138         sprintf(s,"%.2fG",d);
1139     }
1140 }
1141
1142 /* Create the string returned by the INFO command. This is decoupled
1143  * by the INFO command itself as we need to report the same information
1144  * on memory corruption problems. */
1145 sds genRedisInfoString(void) {
1146     sds info;
1147     time_t uptime = time(NULL)-server.stat_starttime;
1148     int j;
1149     char hmem[64];
1150     struct rusage self_ru, c_ru;
1151
1152     getrusage(RUSAGE_SELF, &self_ru);
1153     getrusage(RUSAGE_CHILDREN, &c_ru);
1154
1155     bytesToHuman(hmem,zmalloc_used_memory());
1156     info = sdscatprintf(sdsempty(),
1157         "redis_version:%s\r\n"
1158         "redis_git_sha1:%s\r\n"
1159         "redis_git_dirty:%d\r\n"
1160         "arch_bits:%s\r\n"
1161         "multiplexing_api:%s\r\n"
1162         "process_id:%ld\r\n"
1163         "uptime_in_seconds:%ld\r\n"
1164         "uptime_in_days:%ld\r\n"
1165         "lru_clock:%ld\r\n"
1166         "used_cpu_sys:%.2f\r\n"
1167         "used_cpu_user:%.2f\r\n"
1168         "used_cpu_sys_childrens:%.2f\r\n"
1169         "used_cpu_user_childrens:%.2f\r\n"
1170         "connected_clients:%d\r\n"
1171         "connected_slaves:%d\r\n"
1172         "blocked_clients:%d\r\n"
1173         "used_memory:%zu\r\n"
1174         "used_memory_human:%s\r\n"
1175         "used_memory_rss:%zu\r\n"
1176         "mem_fragmentation_ratio:%.2f\r\n"
1177         "use_tcmalloc:%d\r\n"
1178         "loading:%d\r\n"
1179         "aof_enabled:%d\r\n"
1180         "changes_since_last_save:%lld\r\n"
1181         "bgsave_in_progress:%d\r\n"
1182         "last_save_time:%ld\r\n"
1183         "bgrewriteaof_in_progress:%d\r\n"
1184         "total_connections_received:%lld\r\n"
1185         "total_commands_processed:%lld\r\n"
1186         "expired_keys:%lld\r\n"
1187         "evicted_keys:%lld\r\n"
1188         "keyspace_hits:%lld\r\n"
1189         "keyspace_misses:%lld\r\n"
1190         "hash_max_zipmap_entries:%zu\r\n"
1191         "hash_max_zipmap_value:%zu\r\n"
1192         "pubsub_channels:%ld\r\n"
1193         "pubsub_patterns:%u\r\n"
1194         "ds_enabled:%d\r\n"
1195         "role:%s\r\n"
1196         ,REDIS_VERSION,
1197         redisGitSHA1(),
1198         strtol(redisGitDirty(),NULL,10) > 0,
1199         (sizeof(long) == 8) ? "64" : "32",
1200         aeGetApiName(),
1201         (long) getpid(),
1202         uptime,
1203         uptime/(3600*24),
1204         (unsigned long) server.lruclock,
1205         (float)self_ru.ru_utime.tv_sec+(float)self_ru.ru_utime.tv_usec/1000000,
1206         (float)self_ru.ru_stime.tv_sec+(float)self_ru.ru_stime.tv_usec/1000000,
1207         (float)c_ru.ru_utime.tv_sec+(float)c_ru.ru_utime.tv_usec/1000000,
1208         (float)c_ru.ru_stime.tv_sec+(float)c_ru.ru_stime.tv_usec/1000000,
1209         listLength(server.clients)-listLength(server.slaves),
1210         listLength(server.slaves),
1211         server.bpop_blocked_clients,
1212         zmalloc_used_memory(),
1213         hmem,
1214         zmalloc_get_rss(),
1215         zmalloc_get_fragmentation_ratio(),
1216 #ifdef USE_TCMALLOC
1217         1,
1218 #else
1219         0,
1220 #endif
1221         server.loading,
1222         server.appendonly,
1223         server.dirty,
1224         server.bgsavechildpid != -1,
1225         server.lastsave,
1226         server.bgrewritechildpid != -1,
1227         server.stat_numconnections,
1228         server.stat_numcommands,
1229         server.stat_expiredkeys,
1230         server.stat_evictedkeys,
1231         server.stat_keyspace_hits,
1232         server.stat_keyspace_misses,
1233         server.hash_max_zipmap_entries,
1234         server.hash_max_zipmap_value,
1235         dictSize(server.pubsub_channels),
1236         listLength(server.pubsub_patterns),
1237         server.ds_enabled != 0,
1238         server.masterhost == NULL ? "master" : "slave"
1239     );
1240     if (server.masterhost) {
1241         info = sdscatprintf(info,
1242             "master_host:%s\r\n"
1243             "master_port:%d\r\n"
1244             "master_link_status:%s\r\n"
1245             "master_last_io_seconds_ago:%d\r\n"
1246             "master_sync_in_progress:%d\r\n"
1247             ,server.masterhost,
1248             server.masterport,
1249             (server.replstate == REDIS_REPL_CONNECTED) ?
1250                 "up" : "down",
1251             server.master ? ((int)(time(NULL)-server.master->lastinteraction)) : -1,
1252             server.replstate == REDIS_REPL_TRANSFER
1253         );
1254
1255         if (server.replstate == REDIS_REPL_TRANSFER) {
1256             info = sdscatprintf(info,
1257                 "master_sync_left_bytes:%ld\r\n"
1258                 "master_sync_last_io_seconds_ago:%d\r\n"
1259                 ,(long)server.repl_transfer_left,
1260                 (int)(time(NULL)-server.repl_transfer_lastio)
1261             );
1262         }
1263     }
1264     if (server.ds_enabled) {
1265         lockThreadedIO();
1266         info = sdscatprintf(info,
1267             "cache_max_memory:%llu\r\n"
1268             "cache_blocked_clients:%lu\r\n"
1269             ,(unsigned long long) server.cache_max_memory,
1270             (unsigned long) server.cache_blocked_clients
1271         );
1272         unlockThreadedIO();
1273     }
1274     if (server.loading) {
1275         double perc;
1276         time_t eta, elapsed;
1277         off_t remaining_bytes = server.loading_total_bytes-
1278                                 server.loading_loaded_bytes;
1279
1280         perc = ((double)server.loading_loaded_bytes /
1281                server.loading_total_bytes) * 100;
1282
1283         elapsed = time(NULL)-server.loading_start_time;
1284         if (elapsed == 0) {
1285             eta = 1; /* A fake 1 second figure if we don't have enough info */
1286         } else {
1287             eta = (elapsed*remaining_bytes)/server.loading_loaded_bytes;
1288         }
1289
1290         info = sdscatprintf(info,
1291             "loading_start_time:%ld\r\n"
1292             "loading_total_bytes:%llu\r\n"
1293             "loading_loaded_bytes:%llu\r\n"
1294             "loading_loaded_perc:%.2f\r\n"
1295             "loading_eta_seconds:%ld\r\n"
1296             ,(unsigned long) server.loading_start_time,
1297             (unsigned long long) server.loading_total_bytes,
1298             (unsigned long long) server.loading_loaded_bytes,
1299             perc,
1300             eta
1301         );
1302     }
1303
1304     info = sdscat(info,"allocation_stats:");
1305     for (j = 0; j <= ZMALLOC_MAX_ALLOC_STAT; j++) {
1306         size_t count = zmalloc_allocations_for_size(j);
1307         if (count) {
1308             if (info[sdslen(info)-1] != ':') info = sdscatlen(info,",",1);
1309             info = sdscatprintf(info,"%s%d=%zu",
1310                 (j == ZMALLOC_MAX_ALLOC_STAT) ? ">=" : "",
1311                 j,count);
1312         }
1313     }
1314     info = sdscat(info,"\r\n");
1315
1316     for (j = 0; j < server.dbnum; j++) {
1317         long long keys, vkeys;
1318
1319         keys = dictSize(server.db[j].dict);
1320         vkeys = dictSize(server.db[j].expires);
1321         if (keys || vkeys) {
1322             info = sdscatprintf(info, "db%d:keys=%lld,expires=%lld\r\n",
1323                 j, keys, vkeys);
1324         }
1325     }
1326     return info;
1327 }
1328
1329 void infoCommand(redisClient *c) {
1330     sds info = genRedisInfoString();
1331     addReplySds(c,sdscatprintf(sdsempty(),"$%lu\r\n",
1332         (unsigned long)sdslen(info)));
1333     addReplySds(c,info);
1334     addReply(c,shared.crlf);
1335 }
1336
1337 void monitorCommand(redisClient *c) {
1338     /* ignore MONITOR if aleady slave or in monitor mode */
1339     if (c->flags & REDIS_SLAVE) return;
1340
1341     c->flags |= (REDIS_SLAVE|REDIS_MONITOR);
1342     c->slaveseldb = 0;
1343     listAddNodeTail(server.monitors,c);
1344     addReply(c,shared.ok);
1345 }
1346
1347 /* ============================ Maxmemory directive  ======================== */
1348
1349 /* This function gets called when 'maxmemory' is set on the config file to limit
1350  * the max memory used by the server, and we are out of memory.
1351  * This function will try to, in order:
1352  *
1353  * - Free objects from the free list
1354  * - Try to remove keys with an EXPIRE set
1355  *
1356  * It is not possible to free enough memory to reach used-memory < maxmemory
1357  * the server will start refusing commands that will enlarge even more the
1358  * memory usage.
1359  */
1360 void freeMemoryIfNeeded(void) {
1361     /* Remove keys accordingly to the active policy as long as we are
1362      * over the memory limit. */
1363     if (server.maxmemory_policy == REDIS_MAXMEMORY_NO_EVICTION) return;
1364
1365     while (server.maxmemory && zmalloc_used_memory() > server.maxmemory) {
1366         int j, k, freed = 0;
1367
1368         for (j = 0; j < server.dbnum; j++) {
1369             long bestval = 0; /* just to prevent warning */
1370             sds bestkey = NULL;
1371             struct dictEntry *de;
1372             redisDb *db = server.db+j;
1373             dict *dict;
1374
1375             if (server.maxmemory_policy == REDIS_MAXMEMORY_ALLKEYS_LRU ||
1376                 server.maxmemory_policy == REDIS_MAXMEMORY_ALLKEYS_RANDOM)
1377             {
1378                 dict = server.db[j].dict;
1379             } else {
1380                 dict = server.db[j].expires;
1381             }
1382             if (dictSize(dict) == 0) continue;
1383
1384             /* volatile-random and allkeys-random policy */
1385             if (server.maxmemory_policy == REDIS_MAXMEMORY_ALLKEYS_RANDOM ||
1386                 server.maxmemory_policy == REDIS_MAXMEMORY_VOLATILE_RANDOM)
1387             {
1388                 de = dictGetRandomKey(dict);
1389                 bestkey = dictGetEntryKey(de);
1390             }
1391
1392             /* volatile-lru and allkeys-lru policy */
1393             else if (server.maxmemory_policy == REDIS_MAXMEMORY_ALLKEYS_LRU ||
1394                 server.maxmemory_policy == REDIS_MAXMEMORY_VOLATILE_LRU)
1395             {
1396                 for (k = 0; k < server.maxmemory_samples; k++) {
1397                     sds thiskey;
1398                     long thisval;
1399                     robj *o;
1400
1401                     de = dictGetRandomKey(dict);
1402                     thiskey = dictGetEntryKey(de);
1403                     /* When policy is volatile-lru we need an additonal lookup
1404                      * to locate the real key, as dict is set to db->expires. */
1405                     if (server.maxmemory_policy == REDIS_MAXMEMORY_VOLATILE_LRU)
1406                         de = dictFind(db->dict, thiskey);
1407                     o = dictGetEntryVal(de);
1408                     thisval = estimateObjectIdleTime(o);
1409
1410                     /* Higher idle time is better candidate for deletion */
1411                     if (bestkey == NULL || thisval > bestval) {
1412                         bestkey = thiskey;
1413                         bestval = thisval;
1414                     }
1415                 }
1416             }
1417
1418             /* volatile-ttl */
1419             else if (server.maxmemory_policy == REDIS_MAXMEMORY_VOLATILE_TTL) {
1420                 for (k = 0; k < server.maxmemory_samples; k++) {
1421                     sds thiskey;
1422                     long thisval;
1423
1424                     de = dictGetRandomKey(dict);
1425                     thiskey = dictGetEntryKey(de);
1426                     thisval = (long) dictGetEntryVal(de);
1427
1428                     /* Expire sooner (minor expire unix timestamp) is better
1429                      * candidate for deletion */
1430                     if (bestkey == NULL || thisval < bestval) {
1431                         bestkey = thiskey;
1432                         bestval = thisval;
1433                     }
1434                 }
1435             }
1436
1437             /* Finally remove the selected key. */
1438             if (bestkey) {
1439                 robj *keyobj = createStringObject(bestkey,sdslen(bestkey));
1440                 dbDelete(db,keyobj);
1441                 server.stat_evictedkeys++;
1442                 decrRefCount(keyobj);
1443                 freed++;
1444             }
1445         }
1446         if (!freed) return; /* nothing to free... */
1447     }
1448 }
1449
1450 /* =================================== Main! ================================ */
1451
1452 #ifdef __linux__
1453 int linuxOvercommitMemoryValue(void) {
1454     FILE *fp = fopen("/proc/sys/vm/overcommit_memory","r");
1455     char buf[64];
1456
1457     if (!fp) return -1;
1458     if (fgets(buf,64,fp) == NULL) {
1459         fclose(fp);
1460         return -1;
1461     }
1462     fclose(fp);
1463
1464     return atoi(buf);
1465 }
1466
1467 void linuxOvercommitMemoryWarning(void) {
1468     if (linuxOvercommitMemoryValue() == 0) {
1469         redisLog(REDIS_WARNING,"WARNING overcommit_memory is set to 0! Background save may fail under low memory condition. To fix this issue add 'vm.overcommit_memory = 1' to /etc/sysctl.conf and then reboot or run the command 'sysctl vm.overcommit_memory=1' for this to take effect.");
1470     }
1471 }
1472 #endif /* __linux__ */
1473
1474 void createPidFile(void) {
1475     /* Try to write the pid file in a best-effort way. */
1476     FILE *fp = fopen(server.pidfile,"w");
1477     if (fp) {
1478         fprintf(fp,"%d\n",(int)getpid());
1479         fclose(fp);
1480     }
1481 }
1482
1483 void daemonize(void) {
1484     int fd;
1485
1486     if (fork() != 0) exit(0); /* parent exits */
1487     setsid(); /* create a new session */
1488
1489     /* Every output goes to /dev/null. If Redis is daemonized but
1490      * the 'logfile' is set to 'stdout' in the configuration file
1491      * it will not log at all. */
1492     if ((fd = open("/dev/null", O_RDWR, 0)) != -1) {
1493         dup2(fd, STDIN_FILENO);
1494         dup2(fd, STDOUT_FILENO);
1495         dup2(fd, STDERR_FILENO);
1496         if (fd > STDERR_FILENO) close(fd);
1497     }
1498 }
1499
1500 void version() {
1501     printf("Redis server version %s (%s:%d)\n", REDIS_VERSION,
1502         redisGitSHA1(), atoi(redisGitDirty()) > 0);
1503     exit(0);
1504 }
1505
1506 void usage() {
1507     fprintf(stderr,"Usage: ./redis-server [/path/to/redis.conf]\n");
1508     fprintf(stderr,"       ./redis-server - (read config from stdin)\n");
1509     exit(1);
1510 }
1511
1512 int main(int argc, char **argv) {
1513     time_t start;
1514
1515     initServerConfig();
1516     if (argc == 2) {
1517         if (strcmp(argv[1], "-v") == 0 ||
1518             strcmp(argv[1], "--version") == 0) version();
1519         if (strcmp(argv[1], "--help") == 0) usage();
1520         resetServerSaveParams();
1521         loadServerConfig(argv[1]);
1522     } else if ((argc > 2)) {
1523         usage();
1524     } else {
1525         redisLog(REDIS_WARNING,"Warning: no config file specified, using the default config. In order to specify a config file use 'redis-server /path/to/redis.conf'");
1526     }
1527     if (server.daemonize) daemonize();
1528     initServer();
1529     if (server.daemonize) createPidFile();
1530     redisLog(REDIS_NOTICE,"Server started, Redis version " REDIS_VERSION);
1531 #ifdef __linux__
1532     linuxOvercommitMemoryWarning();
1533 #endif
1534     start = time(NULL);
1535     if (server.ds_enabled) {
1536         redisLog(REDIS_NOTICE,"DB not loaded (running with disk back end)");
1537     } else if (server.appendonly) {
1538         if (loadAppendOnlyFile(server.appendfilename) == REDIS_OK)
1539             redisLog(REDIS_NOTICE,"DB loaded from append only file: %ld seconds",time(NULL)-start);
1540     } else {
1541         if (rdbLoad(server.dbfilename) == REDIS_OK)
1542             redisLog(REDIS_NOTICE,"DB loaded from disk: %ld seconds",time(NULL)-start);
1543     }
1544     if (server.ipfd > 0)
1545         redisLog(REDIS_NOTICE,"The server is now ready to accept connections on port %d", server.port);
1546     if (server.sofd > 0)
1547         redisLog(REDIS_NOTICE,"The server is now ready to accept connections at %s", server.unixsocket);
1548     aeSetBeforeSleepProc(server.el,beforeSleep);
1549     aeMain(server.el);
1550     aeDeleteEventLoop(server.el);
1551     return 0;
1552 }
1553
1554 /* ============================= Backtrace support ========================= */
1555
1556 #ifdef HAVE_BACKTRACE
1557 void *getMcontextEip(ucontext_t *uc) {
1558 #if defined(__FreeBSD__)
1559     return (void*) uc->uc_mcontext.mc_eip;
1560 #elif defined(__dietlibc__)
1561     return (void*) uc->uc_mcontext.eip;
1562 #elif defined(__APPLE__) && !defined(MAC_OS_X_VERSION_10_6)
1563   #if __x86_64__
1564     return (void*) uc->uc_mcontext->__ss.__rip;
1565   #else
1566     return (void*) uc->uc_mcontext->__ss.__eip;
1567   #endif
1568 #elif defined(__APPLE__) && defined(MAC_OS_X_VERSION_10_6)
1569   #if defined(_STRUCT_X86_THREAD_STATE64) && !defined(__i386__)
1570     return (void*) uc->uc_mcontext->__ss.__rip;
1571   #else
1572     return (void*) uc->uc_mcontext->__ss.__eip;
1573   #endif
1574 #elif defined(__i386__)
1575     return (void*) uc->uc_mcontext.gregs[14]; /* Linux 32 */
1576 #elif defined(__X86_64__) || defined(__x86_64__)
1577     return (void*) uc->uc_mcontext.gregs[16]; /* Linux 64 */
1578 #elif defined(__ia64__) /* Linux IA64 */
1579     return (void*) uc->uc_mcontext.sc_ip;
1580 #else
1581     return NULL;
1582 #endif
1583 }
1584
1585 void segvHandler(int sig, siginfo_t *info, void *secret) {
1586     void *trace[100];
1587     char **messages = NULL;
1588     int i, trace_size = 0;
1589     ucontext_t *uc = (ucontext_t*) secret;
1590     sds infostring;
1591     struct sigaction act;
1592     REDIS_NOTUSED(info);
1593
1594     redisLog(REDIS_WARNING,
1595         "======= Ooops! Redis %s got signal: -%d- =======", REDIS_VERSION, sig);
1596     infostring = genRedisInfoString();
1597     redisLog(REDIS_WARNING, "%s",infostring);
1598     /* It's not safe to sdsfree() the returned string under memory
1599      * corruption conditions. Let it leak as we are going to abort */
1600
1601     trace_size = backtrace(trace, 100);
1602     /* overwrite sigaction with caller's address */
1603     if (getMcontextEip(uc) != NULL) {
1604         trace[1] = getMcontextEip(uc);
1605     }
1606     messages = backtrace_symbols(trace, trace_size);
1607
1608     for (i=1; i<trace_size; ++i)
1609         redisLog(REDIS_WARNING,"%s", messages[i]);
1610
1611     /* free(messages); Don't call free() with possibly corrupted memory. */
1612     if (server.daemonize) unlink(server.pidfile);
1613
1614     /* Make sure we exit with the right signal at the end. So for instance
1615      * the core will be dumped if enabled. */
1616     sigemptyset (&act.sa_mask);
1617     /* When the SA_SIGINFO flag is set in sa_flags then sa_sigaction
1618      * is used. Otherwise, sa_handler is used */
1619     act.sa_flags = SA_NODEFER | SA_ONSTACK | SA_RESETHAND;
1620     act.sa_handler = SIG_DFL;
1621     sigaction (sig, &act, NULL);
1622     kill(getpid(),sig);
1623 }
1624
1625 void sigtermHandler(int sig) {
1626     REDIS_NOTUSED(sig);
1627
1628     redisLog(REDIS_WARNING,"SIGTERM received, scheduling shutting down...");
1629     server.shutdown_asap = 1;
1630 }
1631
1632 void setupSigSegvAction(void) {
1633     struct sigaction act;
1634
1635     sigemptyset (&act.sa_mask);
1636     /* When the SA_SIGINFO flag is set in sa_flags then sa_sigaction
1637      * is used. Otherwise, sa_handler is used */
1638     act.sa_flags = SA_NODEFER | SA_ONSTACK | SA_RESETHAND | SA_SIGINFO;
1639     act.sa_sigaction = segvHandler;
1640     sigaction (SIGSEGV, &act, NULL);
1641     sigaction (SIGBUS, &act, NULL);
1642     sigaction (SIGFPE, &act, NULL);
1643     sigaction (SIGILL, &act, NULL);
1644     sigaction (SIGBUS, &act, NULL);
1645
1646     act.sa_flags = SA_NODEFER | SA_ONSTACK | SA_RESETHAND;
1647     act.sa_handler = sigtermHandler;
1648     sigaction (SIGTERM, &act, NULL);
1649     return;
1650 }
1651
1652 #else /* HAVE_BACKTRACE */
1653 void setupSigSegvAction(void) {
1654 }
1655 #endif /* HAVE_BACKTRACE */
1656
1657 /* The End */