1 #include "redis.h" 2 3 /*----------------------------------------------------------------------------- 4 * Config file parsing 5 *----------------------------------------------------------------------------*/ 6 7 int yesnotoi(char *s) { 8 if (!strcasecmp(s,"yes")) return 1; 9 else if (!strcasecmp(s,"no")) return 0; 10 else return -1; 11 } 12 13 void appendServerSaveParams(time_t seconds, int changes) { 14 server.saveparams = zrealloc(server.saveparams,sizeof(struct saveparam)*(server.saveparamslen+1)); 15 server.saveparams[server.saveparamslen].seconds = seconds; 16 server.saveparams[server.saveparamslen].changes = changes; 17 server.saveparamslen++; 18 } 19 20 void resetServerSaveParams() { 21 zfree(server.saveparams); 22 server.saveparams = NULL; 23 server.saveparamslen = 0; 24 } 25 26 /* I agree, this is a very rudimental way to load a configuration... 27 will improve later if the config gets more complex */ 28 void loadServerConfig(char *filename) { 29 FILE *fp; 30 char buf[REDIS_CONFIGLINE_MAX+1], *err = NULL; 31 int linenum = 0; 32 sds line = NULL; 33 34 if (filename[0] == '-' && filename[1] == '\0') 35 fp = stdin; 36 else { 37 if ((fp = fopen(filename,"r")) == NULL) { 38 redisLog(REDIS_WARNING, "Fatal error, can't open config file '%s'", filename); 39 exit(1); 40 } 41 } 42 43 while(fgets(buf,REDIS_CONFIGLINE_MAX+1,fp) != NULL) { 44 sds *argv; 45 int argc, j; 46 47 linenum++; 48 line = sdsnew(buf); 49 line = sdstrim(line," \t\r\n"); 50 51 /* Skip comments and blank lines*/ 52 if (line[0] == '#' || line[0] == '\0') { 53 sdsfree(line); 54 continue; 55 } 56 57 /* Split into arguments */ 58 argv = sdssplitargs(line,&argc); 59 sdstolower(argv[0]); 60 61 /* Execute config directives */ 62 if (!strcasecmp(argv[0],"timeout") && argc == 2) { 63 server.maxidletime = atoi(argv[1]); 64 if (server.maxidletime < 0) { 65 err = "Invalid timeout value"; goto loaderr; 66 } 67 } else if (!strcasecmp(argv[0],"port") && argc == 2) { 68 server.port = atoi(argv[1]); 69 if (server.port < 1 || server.port > 65535) { 70 err = "Invalid port"; goto loaderr; 71 } 72 } else if (!strcasecmp(argv[0],"bind") && argc == 2) { 73 server.bindaddr = zstrdup(argv[1]); 74 } else if (!strcasecmp(argv[0],"unixsocket") && argc == 2) { 75 server.unixsocket = zstrdup(argv[1]); 76 } else if (!strcasecmp(argv[0],"save") && argc == 3) { 77 int seconds = atoi(argv[1]); 78 int changes = atoi(argv[2]); 79 if (seconds < 1 || changes < 0) { 80 err = "Invalid save parameters"; goto loaderr; 81 } 82 appendServerSaveParams(seconds,changes); 83 } else if (!strcasecmp(argv[0],"dir") && argc == 2) { 84 if (chdir(argv[1]) == -1) { 85 redisLog(REDIS_WARNING,"Can't chdir to '%s': %s", 86 argv[1], strerror(errno)); 87 exit(1); 88 } 89 } else if (!strcasecmp(argv[0],"loglevel") && argc == 2) { 90 if (!strcasecmp(argv[1],"debug")) server.verbosity = REDIS_DEBUG; 91 else if (!strcasecmp(argv[1],"verbose")) server.verbosity = REDIS_VERBOSE; 92 else if (!strcasecmp(argv[1],"notice")) server.verbosity = REDIS_NOTICE; 93 else if (!strcasecmp(argv[1],"warning")) server.verbosity = REDIS_WARNING; 94 else { 95 err = "Invalid log level. Must be one of debug, notice, warning"; 96 goto loaderr; 97 } 98 } else if (!strcasecmp(argv[0],"logfile") && argc == 2) { 99 FILE *logfp; 100 101 server.logfile = zstrdup(argv[1]); 102 if (!strcasecmp(server.logfile,"stdout")) { 103 zfree(server.logfile); 104 server.logfile = NULL; 105 } 106 if (server.logfile) { 107 /* Test if we are able to open the file. The server will not 108 * be able to abort just for this problem later... */ 109 logfp = fopen(server.logfile,"a"); 110 if (logfp == NULL) { 111 err = sdscatprintf(sdsempty(), 112 "Can't open the log file: %s", strerror(errno)); 113 goto loaderr; 114 } 115 fclose(logfp); 116 } 117 } else if (!strcasecmp(argv[0],"syslog-enabled") && argc == 2) { 118 if ((server.syslog_enabled = yesnotoi(argv[1])) == -1) { 119 err = "argument must be 'yes' or 'no'"; goto loaderr; 120 } 121 } else if (!strcasecmp(argv[0],"syslog-ident") && argc == 2) { 122 if (server.syslog_ident) zfree(server.syslog_ident); 123 server.syslog_ident = zstrdup(argv[1]); 124 } else if (!strcasecmp(argv[0],"syslog-facility") && argc == 2) { 125 struct { 126 const char *name; 127 const int value; 128 } validSyslogFacilities[] = { 129 {"user", LOG_USER}, 130 {"local0", LOG_LOCAL0}, 131 {"local1", LOG_LOCAL1}, 132 {"local2", LOG_LOCAL2}, 133 {"local3", LOG_LOCAL3}, 134 {"local4", LOG_LOCAL4}, 135 {"local5", LOG_LOCAL5}, 136 {"local6", LOG_LOCAL6}, 137 {"local7", LOG_LOCAL7}, 138 {NULL, 0} 139 }; 140 int i; 141 142 for (i = 0; validSyslogFacilities[i].name; i++) { 143 if (!strcasecmp(validSyslogFacilities[i].name, argv[1])) { 144 server.syslog_facility = validSyslogFacilities[i].value; 145 break; 146 } 147 } 148 149 if (!validSyslogFacilities[i].name) { 150 err = "Invalid log facility. Must be one of USER or between LOCAL0-LOCAL7"; 151 goto loaderr; 152 } 153 } else if (!strcasecmp(argv[0],"databases") && argc == 2) { 154 server.dbnum = atoi(argv[1]); 155 if (server.dbnum < 1) { 156 err = "Invalid number of databases"; goto loaderr; 157 } 158 } else if (!strcasecmp(argv[0],"include") && argc == 2) { 159 loadServerConfig(argv[1]); 160 } else if (!strcasecmp(argv[0],"maxclients") && argc == 2) { 161 server.maxclients = atoi(argv[1]); 162 } else if (!strcasecmp(argv[0],"maxmemory") && argc == 2) { 163 server.maxmemory = memtoll(argv[1],NULL); 164 } else if (!strcasecmp(argv[0],"maxmemory-policy") && argc == 2) { 165 if (!strcasecmp(argv[1],"volatile-lru")) { 166 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU; 167 } else if (!strcasecmp(argv[1],"volatile-random")) { 168 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM; 169 } else if (!strcasecmp(argv[1],"volatile-ttl")) { 170 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL; 171 } else if (!strcasecmp(argv[1],"allkeys-lru")) { 172 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU; 173 } else if (!strcasecmp(argv[1],"allkeys-random")) { 174 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM; 175 } else if (!strcasecmp(argv[1],"noeviction")) { 176 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION; 177 } else { 178 err = "Invalid maxmemory policy"; 179 goto loaderr; 180 } 181 } else if (!strcasecmp(argv[0],"maxmemory-samples") && argc == 2) { 182 server.maxmemory_samples = atoi(argv[1]); 183 if (server.maxmemory_samples <= 0) { 184 err = "maxmemory-samples must be 1 or greater"; 185 goto loaderr; 186 } 187 } else if (!strcasecmp(argv[0],"slaveof") && argc == 3) { 188 server.masterhost = sdsnew(argv[1]); 189 server.masterport = atoi(argv[2]); 190 server.replstate = REDIS_REPL_CONNECT; 191 } else if (!strcasecmp(argv[0],"masterauth") && argc == 2) { 192 server.masterauth = zstrdup(argv[1]); 193 } else if (!strcasecmp(argv[0],"slave-serve-stale-data") && argc == 2) { 194 if ((server.repl_serve_stale_data = yesnotoi(argv[1])) == -1) { 195 err = "argument must be 'yes' or 'no'"; goto loaderr; 196 } 197 } else if (!strcasecmp(argv[0],"glueoutputbuf") && argc == 2) { 198 if ((server.glueoutputbuf = yesnotoi(argv[1])) == -1) { 199 err = "argument must be 'yes' or 'no'"; goto loaderr; 200 } 201 } else if (!strcasecmp(argv[0],"rdbcompression") && argc == 2) { 202 if ((server.rdbcompression = yesnotoi(argv[1])) == -1) { 203 err = "argument must be 'yes' or 'no'"; goto loaderr; 204 } 205 } else if (!strcasecmp(argv[0],"activerehashing") && argc == 2) { 206 if ((server.activerehashing = yesnotoi(argv[1])) == -1) { 207 err = "argument must be 'yes' or 'no'"; goto loaderr; 208 } 209 } else if (!strcasecmp(argv[0],"daemonize") && argc == 2) { 210 if ((server.daemonize = yesnotoi(argv[1])) == -1) { 211 err = "argument must be 'yes' or 'no'"; goto loaderr; 212 } 213 } else if (!strcasecmp(argv[0],"appendonly") && argc == 2) { 214 if ((server.appendonly = yesnotoi(argv[1])) == -1) { 215 err = "argument must be 'yes' or 'no'"; goto loaderr; 216 } 217 } else if (!strcasecmp(argv[0],"appendfilename") && argc == 2) { 218 zfree(server.appendfilename); 219 server.appendfilename = zstrdup(argv[1]); 220 } else if (!strcasecmp(argv[0],"no-appendfsync-on-rewrite") 221 && argc == 2) { 222 if ((server.no_appendfsync_on_rewrite= yesnotoi(argv[1])) == -1) { 223 err = "argument must be 'yes' or 'no'"; goto loaderr; 224 } 225 } else if (!strcasecmp(argv[0],"appendfsync") && argc == 2) { 226 if (!strcasecmp(argv[1],"no")) { 227 server.appendfsync = APPENDFSYNC_NO; 228 } else if (!strcasecmp(argv[1],"always")) { 229 server.appendfsync = APPENDFSYNC_ALWAYS; 230 } else if (!strcasecmp(argv[1],"everysec")) { 231 server.appendfsync = APPENDFSYNC_EVERYSEC; 232 } else { 233 err = "argument must be 'no', 'always' or 'everysec'"; 234 goto loaderr; 235 } 236 } else if (!strcasecmp(argv[0],"requirepass") && argc == 2) { 237 server.requirepass = zstrdup(argv[1]); 238 } else if (!strcasecmp(argv[0],"pidfile") && argc == 2) { 239 zfree(server.pidfile); 240 server.pidfile = zstrdup(argv[1]); 241 } else if (!strcasecmp(argv[0],"dbfilename") && argc == 2) { 242 zfree(server.dbfilename); 243 server.dbfilename = zstrdup(argv[1]); 244 } else if (!strcasecmp(argv[0],"diskstore-enabled") && argc == 2) { 245 if ((server.ds_enabled = yesnotoi(argv[1])) == -1) { 246 err = "argument must be 'yes' or 'no'"; goto loaderr; 247 } 248 } else if (!strcasecmp(argv[0],"diskstore-path") && argc == 2) { 249 sdsfree(server.ds_path); 250 server.ds_path = sdsnew(argv[1]); 251 } else if (!strcasecmp(argv[0],"cache-max-memory") && argc == 2) { 252 server.cache_max_memory = memtoll(argv[1],NULL); 253 } else if (!strcasecmp(argv[0],"cache-flush-delay") && argc == 2) { 254 server.cache_flush_delay = atoi(argv[1]); 255 if (server.cache_flush_delay < 0) server.cache_flush_delay = 0; 256 } else if (!strcasecmp(argv[0],"hash-max-zipmap-entries") && argc == 2) { 257 server.hash_max_zipmap_entries = memtoll(argv[1], NULL); 258 } else if (!strcasecmp(argv[0],"hash-max-zipmap-value") && argc == 2) { 259 server.hash_max_zipmap_value = memtoll(argv[1], NULL); 260 } else if (!strcasecmp(argv[0],"list-max-ziplist-entries") && argc == 2){ 261 server.list_max_ziplist_entries = memtoll(argv[1], NULL); 262 } else if (!strcasecmp(argv[0],"list-max-ziplist-value") && argc == 2) { 263 server.list_max_ziplist_value = memtoll(argv[1], NULL); 264 } else if (!strcasecmp(argv[0],"set-max-intset-entries") && argc == 2) { 265 server.set_max_intset_entries = memtoll(argv[1], NULL); 266 } else if (!strcasecmp(argv[0],"rename-command") && argc == 3) { 267 struct redisCommand *cmd = lookupCommand(argv[1]); 268 int retval; 269 270 if (!cmd) { 271 err = "No such command in rename-command"; 272 goto loaderr; 273 } 274 275 /* If the target command name is the emtpy string we just 276 * remove it from the command table. */ 277 retval = dictDelete(server.commands, argv[1]); 278 redisAssert(retval == DICT_OK); 279 280 /* Otherwise we re-add the command under a different name. */ 281 if (sdslen(argv[2]) != 0) { 282 sds copy = sdsdup(argv[2]); 283 284 retval = dictAdd(server.commands, copy, cmd); 285 if (retval != DICT_OK) { 286 sdsfree(copy); 287 err = "Target command name already exists"; goto loaderr; 288 } 289 } 290 } else { 291 err = "Bad directive or wrong number of arguments"; goto loaderr; 292 } 293 for (j = 0; j < argc; j++) 294 sdsfree(argv[j]); 295 zfree(argv); 296 sdsfree(line); 297 } 298 if (fp != stdin) fclose(fp); 299 return; 300 301 loaderr: 302 fprintf(stderr, "\n*** FATAL CONFIG FILE ERROR ***\n"); 303 fprintf(stderr, "Reading the configuration file, at line %d\n", linenum); 304 fprintf(stderr, ">>> '%s'\n", line); 305 fprintf(stderr, "%s\n", err); 306 exit(1); 307 } 308 309 /*----------------------------------------------------------------------------- 310 * CONFIG command for remote configuration 311 *----------------------------------------------------------------------------*/ 312 313 void configSetCommand(redisClient *c) { 314 robj *o; 315 long long ll; 316 redisAssert(c->argv[2]->encoding == REDIS_ENCODING_RAW); 317 redisAssert(c->argv[3]->encoding == REDIS_ENCODING_RAW); 318 o = c->argv[3]; 319 320 if (!strcasecmp(c->argv[2]->ptr,"dbfilename")) { 321 zfree(server.dbfilename); 322 server.dbfilename = zstrdup(o->ptr); 323 } else if (!strcasecmp(c->argv[2]->ptr,"requirepass")) { 324 zfree(server.requirepass); 325 server.requirepass = zstrdup(o->ptr); 326 } else if (!strcasecmp(c->argv[2]->ptr,"masterauth")) { 327 zfree(server.masterauth); 328 server.masterauth = zstrdup(o->ptr); 329 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory")) { 330 if (getLongLongFromObject(o,&ll) == REDIS_ERR || 331 ll < 0) goto badfmt; 332 server.maxmemory = ll; 333 if (server.maxmemory) freeMemoryIfNeeded(); 334 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-policy")) { 335 if (!strcasecmp(o->ptr,"volatile-lru")) { 336 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU; 337 } else if (!strcasecmp(o->ptr,"volatile-random")) { 338 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM; 339 } else if (!strcasecmp(o->ptr,"volatile-ttl")) { 340 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL; 341 } else if (!strcasecmp(o->ptr,"allkeys-lru")) { 342 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU; 343 } else if (!strcasecmp(o->ptr,"allkeys-random")) { 344 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM; 345 } else if (!strcasecmp(o->ptr,"noeviction")) { 346 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION; 347 } else { 348 goto badfmt; 349 } 350 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-samples")) { 351 if (getLongLongFromObject(o,&ll) == REDIS_ERR || 352 ll <= 0) goto badfmt; 353 server.maxmemory_samples = ll; 354 } else if (!strcasecmp(c->argv[2]->ptr,"timeout")) { 355 if (getLongLongFromObject(o,&ll) == REDIS_ERR || 356 ll < 0 || ll > LONG_MAX) goto badfmt; 357 server.maxidletime = ll; 358 } else if (!strcasecmp(c->argv[2]->ptr,"appendfsync")) { 359 if (!strcasecmp(o->ptr,"no")) { 360 server.appendfsync = APPENDFSYNC_NO; 361 } else if (!strcasecmp(o->ptr,"everysec")) { 362 server.appendfsync = APPENDFSYNC_EVERYSEC; 363 } else if (!strcasecmp(o->ptr,"always")) { 364 server.appendfsync = APPENDFSYNC_ALWAYS; 365 } else { 366 goto badfmt; 367 } 368 } else if (!strcasecmp(c->argv[2]->ptr,"no-appendfsync-on-rewrite")) { 369 int yn = yesnotoi(o->ptr); 370 371 if (yn == -1) goto badfmt; 372 server.no_appendfsync_on_rewrite = yn; 373 } else if (!strcasecmp(c->argv[2]->ptr,"appendonly")) { 374 int old = server.appendonly; 375 int new = yesnotoi(o->ptr); 376 377 if (new == -1) goto badfmt; 378 if (old != new) { 379 if (new == 0) { 380 stopAppendOnly(); 381 } else { 382 if (startAppendOnly() == REDIS_ERR) { 383 addReplyError(c, 384 "Unable to turn on AOF. Check server logs."); 385 return; 386 } 387 } 388 } 389 } else if (!strcasecmp(c->argv[2]->ptr,"save")) { 390 int vlen, j; 391 sds *v = sdssplitlen(o->ptr,sdslen(o->ptr)," ",1,&vlen); 392 393 /* Perform sanity check before setting the new config: 394 * - Even number of args 395 * - Seconds >= 1, changes >= 0 */ 396 if (vlen & 1) { 397 sdsfreesplitres(v,vlen); 398 goto badfmt; 399 } 400 for (j = 0; j < vlen; j++) { 401 char *eptr; 402 long val; 403 404 val = strtoll(v[j], &eptr, 10); 405 if (eptr[0] != '\0' || 406 ((j & 1) == 0 && val < 1) || 407 ((j & 1) == 1 && val < 0)) { 408 sdsfreesplitres(v,vlen); 409 goto badfmt; 410 } 411 } 412 /* Finally set the new config */ 413 resetServerSaveParams(); 414 for (j = 0; j < vlen; j += 2) { 415 time_t seconds; 416 int changes; 417 418 seconds = strtoll(v[j],NULL,10); 419 changes = strtoll(v[j+1],NULL,10); 420 appendServerSaveParams(seconds, changes); 421 } 422 sdsfreesplitres(v,vlen); 423 } else if (!strcasecmp(c->argv[2]->ptr,"slave-serve-stale-data")) { 424 int yn = yesnotoi(o->ptr); 425 426 if (yn == -1) goto badfmt; 427 server.repl_serve_stale_data = yn; 428 } else { 429 addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s", 430 (char*)c->argv[2]->ptr); 431 return; 432 } 433 addReply(c,shared.ok); 434 return; 435 436 badfmt: /* Bad format errors */ 437 addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'", 438 (char*)o->ptr, 439 (char*)c->argv[2]->ptr); 440 } 441 442 void configGetCommand(redisClient *c) { 443 robj *o = c->argv[2]; 444 void *replylen = addDeferredMultiBulkLength(c); 445 char *pattern = o->ptr; 446 char buf[128]; 447 int matches = 0; 448 redisAssert(o->encoding == REDIS_ENCODING_RAW); 449 450 if (stringmatch(pattern,"dbfilename",0)) { 451 addReplyBulkCString(c,"dbfilename"); 452 addReplyBulkCString(c,server.dbfilename); 453 matches++; 454 } 455 if (stringmatch(pattern,"requirepass",0)) { 456 addReplyBulkCString(c,"requirepass"); 457 addReplyBulkCString(c,server.requirepass); 458 matches++; 459 } 460 if (stringmatch(pattern,"masterauth",0)) { 461 addReplyBulkCString(c,"masterauth"); 462 addReplyBulkCString(c,server.masterauth); 463 matches++; 464 } 465 if (stringmatch(pattern,"maxmemory",0)) { 466 ll2string(buf,sizeof(buf),server.maxmemory); 467 addReplyBulkCString(c,"maxmemory"); 468 addReplyBulkCString(c,buf); 469 matches++; 470 } 471 if (stringmatch(pattern,"maxmemory-policy",0)) { 472 char *s; 473 474 switch(server.maxmemory_policy) { 475 case REDIS_MAXMEMORY_VOLATILE_LRU: s = "volatile-lru"; break; 476 case REDIS_MAXMEMORY_VOLATILE_TTL: s = "volatile-ttl"; break; 477 case REDIS_MAXMEMORY_VOLATILE_RANDOM: s = "volatile-random"; break; 478 case REDIS_MAXMEMORY_ALLKEYS_LRU: s = "allkeys-lru"; break; 479 case REDIS_MAXMEMORY_ALLKEYS_RANDOM: s = "allkeys-random"; break; 480 case REDIS_MAXMEMORY_NO_EVICTION: s = "noeviction"; break; 481 default: s = "unknown"; break; /* too harmless to panic */ 482 } 483 addReplyBulkCString(c,"maxmemory-policy"); 484 addReplyBulkCString(c,s); 485 matches++; 486 } 487 if (stringmatch(pattern,"maxmemory-samples",0)) { 488 ll2string(buf,sizeof(buf),server.maxmemory_samples); 489 addReplyBulkCString(c,"maxmemory-samples"); 490 addReplyBulkCString(c,buf); 491 matches++; 492 } 493 if (stringmatch(pattern,"timeout",0)) { 494 ll2string(buf,sizeof(buf),server.maxidletime); 495 addReplyBulkCString(c,"timeout"); 496 addReplyBulkCString(c,buf); 497 matches++; 498 } 499 if (stringmatch(pattern,"appendonly",0)) { 500 addReplyBulkCString(c,"appendonly"); 501 addReplyBulkCString(c,server.appendonly ? "yes" : "no"); 502 matches++; 503 } 504 if (stringmatch(pattern,"no-appendfsync-on-rewrite",0)) { 505 addReplyBulkCString(c,"no-appendfsync-on-rewrite"); 506 addReplyBulkCString(c,server.no_appendfsync_on_rewrite ? "yes" : "no"); 507 matches++; 508 } 509 if (stringmatch(pattern,"appendfsync",0)) { 510 char *policy; 511 512 switch(server.appendfsync) { 513 case APPENDFSYNC_NO: policy = "no"; break; 514 case APPENDFSYNC_EVERYSEC: policy = "everysec"; break; 515 case APPENDFSYNC_ALWAYS: policy = "always"; break; 516 default: policy = "unknown"; break; /* too harmless to panic */ 517 } 518 addReplyBulkCString(c,"appendfsync"); 519 addReplyBulkCString(c,policy); 520 matches++; 521 } 522 if (stringmatch(pattern,"save",0)) { 523 sds buf = sdsempty(); 524 int j; 525 526 for (j = 0; j < server.saveparamslen; j++) { 527 buf = sdscatprintf(buf,"%ld %d", 528 server.saveparams[j].seconds, 529 server.saveparams[j].changes); 530 if (j != server.saveparamslen-1) 531 buf = sdscatlen(buf," ",1); 532 } 533 addReplyBulkCString(c,"save"); 534 addReplyBulkCString(c,buf); 535 sdsfree(buf); 536 matches++; 537 } 538 if (stringmatch(pattern,"slave-serve-stale-data",0)) { 539 addReplyBulkCString(c,"slave-serve-stale-data"); 540 addReplyBulkCString(c,server.repl_serve_stale_data ? "yes" : "no"); 541 matches++; 542 } 543 setDeferredMultiBulkLength(c,replylen,matches*2); 544 } 545 546 void configCommand(redisClient *c) { 547 if (!strcasecmp(c->argv[1]->ptr,"set")) { 548 if (c->argc != 4) goto badarity; 549 configSetCommand(c); 550 } else if (!strcasecmp(c->argv[1]->ptr,"get")) { 551 if (c->argc != 3) goto badarity; 552 configGetCommand(c); 553 } else if (!strcasecmp(c->argv[1]->ptr,"resetstat")) { 554 if (c->argc != 2) goto badarity; 555 server.stat_keyspace_hits = 0; 556 server.stat_keyspace_misses = 0; 557 server.stat_numcommands = 0; 558 server.stat_numconnections = 0; 559 server.stat_expiredkeys = 0; 560 addReply(c,shared.ok); 561 } else { 562 addReplyError(c, 563 "CONFIG subcommand must be one of GET, SET, RESETSTAT"); 564 } 565 return; 566 567 badarity: 568 addReplyErrorFormat(c,"Wrong number of arguments for CONFIG %s", 569 (char*) c->argv[1]->ptr); 570 } 571