]> git.saurik.com Git - redis.git/blob - src/config.c
removed dup syslog-ident conditional
[redis.git] / src / config.c
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],"vm-enabled") && argc == 2) {
245 if ((server.vm_enabled = yesnotoi(argv[1])) == -1) {
246 err = "argument must be 'yes' or 'no'"; goto loaderr;
247 }
248 } else if (!strcasecmp(argv[0],"vm-swap-file") && argc == 2) {
249 zfree(server.vm_swap_file);
250 server.vm_swap_file = zstrdup(argv[1]);
251 } else if (!strcasecmp(argv[0],"vm-max-memory") && argc == 2) {
252 server.vm_max_memory = memtoll(argv[1],NULL);
253 } else if (!strcasecmp(argv[0],"vm-page-size") && argc == 2) {
254 server.vm_page_size = memtoll(argv[1], NULL);
255 } else if (!strcasecmp(argv[0],"vm-pages") && argc == 2) {
256 server.vm_pages = memtoll(argv[1], NULL);
257 } else if (!strcasecmp(argv[0],"vm-max-threads") && argc == 2) {
258 server.vm_max_threads = strtoll(argv[1], NULL, 10);
259 } else if (!strcasecmp(argv[0],"hash-max-zipmap-entries") && argc == 2) {
260 server.hash_max_zipmap_entries = memtoll(argv[1], NULL);
261 } else if (!strcasecmp(argv[0],"hash-max-zipmap-value") && argc == 2) {
262 server.hash_max_zipmap_value = memtoll(argv[1], NULL);
263 } else if (!strcasecmp(argv[0],"list-max-ziplist-entries") && argc == 2){
264 server.list_max_ziplist_entries = memtoll(argv[1], NULL);
265 } else if (!strcasecmp(argv[0],"list-max-ziplist-value") && argc == 2) {
266 server.list_max_ziplist_value = memtoll(argv[1], NULL);
267 } else if (!strcasecmp(argv[0],"set-max-intset-entries") && argc == 2) {
268 server.set_max_intset_entries = memtoll(argv[1], NULL);
269 } else if (!strcasecmp(argv[0],"rename-command") && argc == 3) {
270 struct redisCommand *cmd = lookupCommand(argv[1]);
271 int retval;
272
273 if (!cmd) {
274 err = "No such command in rename-command";
275 goto loaderr;
276 }
277
278 /* If the target command name is the emtpy string we just
279 * remove it from the command table. */
280 retval = dictDelete(server.commands, argv[1]);
281 redisAssert(retval == DICT_OK);
282
283 /* Otherwise we re-add the command under a different name. */
284 if (sdslen(argv[2]) != 0) {
285 sds copy = sdsdup(argv[2]);
286
287 retval = dictAdd(server.commands, copy, cmd);
288 if (retval != DICT_OK) {
289 sdsfree(copy);
290 err = "Target command name already exists"; goto loaderr;
291 }
292 }
293 } else {
294 err = "Bad directive or wrong number of arguments"; goto loaderr;
295 }
296 for (j = 0; j < argc; j++)
297 sdsfree(argv[j]);
298 zfree(argv);
299 sdsfree(line);
300 }
301 if (fp != stdin) fclose(fp);
302 return;
303
304 loaderr:
305 fprintf(stderr, "\n*** FATAL CONFIG FILE ERROR ***\n");
306 fprintf(stderr, "Reading the configuration file, at line %d\n", linenum);
307 fprintf(stderr, ">>> '%s'\n", line);
308 fprintf(stderr, "%s\n", err);
309 exit(1);
310 }
311
312 /*-----------------------------------------------------------------------------
313 * CONFIG command for remote configuration
314 *----------------------------------------------------------------------------*/
315
316 void configSetCommand(redisClient *c) {
317 robj *o;
318 long long ll;
319 redisAssert(c->argv[2]->encoding == REDIS_ENCODING_RAW);
320 redisAssert(c->argv[3]->encoding == REDIS_ENCODING_RAW);
321 o = c->argv[3];
322
323 if (!strcasecmp(c->argv[2]->ptr,"dbfilename")) {
324 zfree(server.dbfilename);
325 server.dbfilename = zstrdup(o->ptr);
326 } else if (!strcasecmp(c->argv[2]->ptr,"requirepass")) {
327 zfree(server.requirepass);
328 server.requirepass = zstrdup(o->ptr);
329 } else if (!strcasecmp(c->argv[2]->ptr,"masterauth")) {
330 zfree(server.masterauth);
331 server.masterauth = zstrdup(o->ptr);
332 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory")) {
333 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
334 ll < 0) goto badfmt;
335 server.maxmemory = ll;
336 if (server.maxmemory) freeMemoryIfNeeded();
337 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-policy")) {
338 if (!strcasecmp(o->ptr,"volatile-lru")) {
339 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU;
340 } else if (!strcasecmp(o->ptr,"volatile-random")) {
341 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM;
342 } else if (!strcasecmp(o->ptr,"volatile-ttl")) {
343 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL;
344 } else if (!strcasecmp(o->ptr,"allkeys-lru")) {
345 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU;
346 } else if (!strcasecmp(o->ptr,"allkeys-random")) {
347 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM;
348 } else if (!strcasecmp(o->ptr,"noeviction")) {
349 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION;
350 } else {
351 goto badfmt;
352 }
353 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-samples")) {
354 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
355 ll <= 0) goto badfmt;
356 server.maxmemory_samples = ll;
357 } else if (!strcasecmp(c->argv[2]->ptr,"timeout")) {
358 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
359 ll < 0 || ll > LONG_MAX) goto badfmt;
360 server.maxidletime = ll;
361 } else if (!strcasecmp(c->argv[2]->ptr,"appendfsync")) {
362 if (!strcasecmp(o->ptr,"no")) {
363 server.appendfsync = APPENDFSYNC_NO;
364 } else if (!strcasecmp(o->ptr,"everysec")) {
365 server.appendfsync = APPENDFSYNC_EVERYSEC;
366 } else if (!strcasecmp(o->ptr,"always")) {
367 server.appendfsync = APPENDFSYNC_ALWAYS;
368 } else {
369 goto badfmt;
370 }
371 } else if (!strcasecmp(c->argv[2]->ptr,"no-appendfsync-on-rewrite")) {
372 int yn = yesnotoi(o->ptr);
373
374 if (yn == -1) goto badfmt;
375 server.no_appendfsync_on_rewrite = yn;
376 } else if (!strcasecmp(c->argv[2]->ptr,"appendonly")) {
377 int old = server.appendonly;
378 int new = yesnotoi(o->ptr);
379
380 if (new == -1) goto badfmt;
381 if (old != new) {
382 if (new == 0) {
383 stopAppendOnly();
384 } else {
385 if (startAppendOnly() == REDIS_ERR) {
386 addReplyError(c,
387 "Unable to turn on AOF. Check server logs.");
388 return;
389 }
390 }
391 }
392 } else if (!strcasecmp(c->argv[2]->ptr,"save")) {
393 int vlen, j;
394 sds *v = sdssplitlen(o->ptr,sdslen(o->ptr)," ",1,&vlen);
395
396 /* Perform sanity check before setting the new config:
397 * - Even number of args
398 * - Seconds >= 1, changes >= 0 */
399 if (vlen & 1) {
400 sdsfreesplitres(v,vlen);
401 goto badfmt;
402 }
403 for (j = 0; j < vlen; j++) {
404 char *eptr;
405 long val;
406
407 val = strtoll(v[j], &eptr, 10);
408 if (eptr[0] != '\0' ||
409 ((j & 1) == 0 && val < 1) ||
410 ((j & 1) == 1 && val < 0)) {
411 sdsfreesplitres(v,vlen);
412 goto badfmt;
413 }
414 }
415 /* Finally set the new config */
416 resetServerSaveParams();
417 for (j = 0; j < vlen; j += 2) {
418 time_t seconds;
419 int changes;
420
421 seconds = strtoll(v[j],NULL,10);
422 changes = strtoll(v[j+1],NULL,10);
423 appendServerSaveParams(seconds, changes);
424 }
425 sdsfreesplitres(v,vlen);
426 } else if (!strcasecmp(c->argv[2]->ptr,"slave-serve-stale-data")) {
427 int yn = yesnotoi(o->ptr);
428
429 if (yn == -1) goto badfmt;
430 server.repl_serve_stale_data = yn;
431 } else {
432 addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s",
433 (char*)c->argv[2]->ptr);
434 return;
435 }
436 addReply(c,shared.ok);
437 return;
438
439 badfmt: /* Bad format errors */
440 addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'",
441 (char*)o->ptr,
442 (char*)c->argv[2]->ptr);
443 }
444
445 void configGetCommand(redisClient *c) {
446 robj *o = c->argv[2];
447 void *replylen = addDeferredMultiBulkLength(c);
448 char *pattern = o->ptr;
449 char buf[128];
450 int matches = 0;
451 redisAssert(o->encoding == REDIS_ENCODING_RAW);
452
453 if (stringmatch(pattern,"dbfilename",0)) {
454 addReplyBulkCString(c,"dbfilename");
455 addReplyBulkCString(c,server.dbfilename);
456 matches++;
457 }
458 if (stringmatch(pattern,"requirepass",0)) {
459 addReplyBulkCString(c,"requirepass");
460 addReplyBulkCString(c,server.requirepass);
461 matches++;
462 }
463 if (stringmatch(pattern,"masterauth",0)) {
464 addReplyBulkCString(c,"masterauth");
465 addReplyBulkCString(c,server.masterauth);
466 matches++;
467 }
468 if (stringmatch(pattern,"maxmemory",0)) {
469 ll2string(buf,sizeof(buf),server.maxmemory);
470 addReplyBulkCString(c,"maxmemory");
471 addReplyBulkCString(c,buf);
472 matches++;
473 }
474 if (stringmatch(pattern,"maxmemory-policy",0)) {
475 char *s;
476
477 switch(server.maxmemory_policy) {
478 case REDIS_MAXMEMORY_VOLATILE_LRU: s = "volatile-lru"; break;
479 case REDIS_MAXMEMORY_VOLATILE_TTL: s = "volatile-ttl"; break;
480 case REDIS_MAXMEMORY_VOLATILE_RANDOM: s = "volatile-random"; break;
481 case REDIS_MAXMEMORY_ALLKEYS_LRU: s = "allkeys-lru"; break;
482 case REDIS_MAXMEMORY_ALLKEYS_RANDOM: s = "allkeys-random"; break;
483 case REDIS_MAXMEMORY_NO_EVICTION: s = "noeviction"; break;
484 default: s = "unknown"; break; /* too harmless to panic */
485 }
486 addReplyBulkCString(c,"maxmemory-policy");
487 addReplyBulkCString(c,s);
488 matches++;
489 }
490 if (stringmatch(pattern,"maxmemory-samples",0)) {
491 ll2string(buf,sizeof(buf),server.maxmemory_samples);
492 addReplyBulkCString(c,"maxmemory-samples");
493 addReplyBulkCString(c,buf);
494 matches++;
495 }
496 if (stringmatch(pattern,"timeout",0)) {
497 ll2string(buf,sizeof(buf),server.maxidletime);
498 addReplyBulkCString(c,"timeout");
499 addReplyBulkCString(c,buf);
500 matches++;
501 }
502 if (stringmatch(pattern,"appendonly",0)) {
503 addReplyBulkCString(c,"appendonly");
504 addReplyBulkCString(c,server.appendonly ? "yes" : "no");
505 matches++;
506 }
507 if (stringmatch(pattern,"no-appendfsync-on-rewrite",0)) {
508 addReplyBulkCString(c,"no-appendfsync-on-rewrite");
509 addReplyBulkCString(c,server.no_appendfsync_on_rewrite ? "yes" : "no");
510 matches++;
511 }
512 if (stringmatch(pattern,"appendfsync",0)) {
513 char *policy;
514
515 switch(server.appendfsync) {
516 case APPENDFSYNC_NO: policy = "no"; break;
517 case APPENDFSYNC_EVERYSEC: policy = "everysec"; break;
518 case APPENDFSYNC_ALWAYS: policy = "always"; break;
519 default: policy = "unknown"; break; /* too harmless to panic */
520 }
521 addReplyBulkCString(c,"appendfsync");
522 addReplyBulkCString(c,policy);
523 matches++;
524 }
525 if (stringmatch(pattern,"save",0)) {
526 sds buf = sdsempty();
527 int j;
528
529 for (j = 0; j < server.saveparamslen; j++) {
530 buf = sdscatprintf(buf,"%ld %d",
531 server.saveparams[j].seconds,
532 server.saveparams[j].changes);
533 if (j != server.saveparamslen-1)
534 buf = sdscatlen(buf," ",1);
535 }
536 addReplyBulkCString(c,"save");
537 addReplyBulkCString(c,buf);
538 sdsfree(buf);
539 matches++;
540 }
541 if (stringmatch(pattern,"slave-serve-stale-data",0)) {
542 addReplyBulkCString(c,"slave-serve-stale-data");
543 addReplyBulkCString(c,server.repl_serve_stale_data ? "yes" : "no");
544 matches++;
545 }
546 setDeferredMultiBulkLength(c,replylen,matches*2);
547 }
548
549 void configCommand(redisClient *c) {
550 if (!strcasecmp(c->argv[1]->ptr,"set")) {
551 if (c->argc != 4) goto badarity;
552 configSetCommand(c);
553 } else if (!strcasecmp(c->argv[1]->ptr,"get")) {
554 if (c->argc != 3) goto badarity;
555 configGetCommand(c);
556 } else if (!strcasecmp(c->argv[1]->ptr,"resetstat")) {
557 if (c->argc != 2) goto badarity;
558 server.stat_keyspace_hits = 0;
559 server.stat_keyspace_misses = 0;
560 server.stat_numcommands = 0;
561 server.stat_numconnections = 0;
562 server.stat_expiredkeys = 0;
563 addReply(c,shared.ok);
564 } else {
565 addReplyError(c,
566 "CONFIG subcommand must be one of GET, SET, RESETSTAT");
567 }
568 return;
569
570 badarity:
571 addReplyErrorFormat(c,"Wrong number of arguments for CONFIG %s",
572 (char*) c->argv[1]->ptr);
573 }