redis源码笔记－config
redis配置文件的头文件，有一些和平台有关的配置，在这里边进行设置。config.h
1 #ifndef __CONFIG_H
2 #define __CONFIG_H
3
4 #ifdef __APPLE__
5 #include
6 #endif
7
8 /* Define redis_fstat to fstat or fstat64() */
9 #if defined(__APPLE__) && !defined(MAC_OS_X_VERSION_10_6)
10 #define redis_fstat fstat64
11 #define redis_stat stat64
12 #else
13 #define redis_fstat fstat
14 #define redis_stat stat
15 #endif
16
17 /* Test for proc filesystem */
18 //proc filesystem是进程文件系统的意思，包含一个伪文件系统（启动时动态生成的文件系统），用于通过内核访问进程信息。这个文件系统通常挂载在/proc目录下，/proc不是真正的文件系统，仅占用内存空间
19 //redis在获取rss信息(zmalloc.c的zmalloc_get_rss函数)时，需要判断是否有proc filesystem。rss是Resident Set Size的缩写，表示进程占用被hold在内存的那一部分。
20 #ifdef __linux__
21 #define HAVE_PROCFS 1
22 #endif
23
24 /* Test for task_info() */
25 #if defined(__APPLE__)
26 #define HAVE_TASKINFO 1
27 #endif
28
29 //backtrace是指“A backtrace is a list of the function calls that are currently active in a thread. The usual way to inspect a backtrace of a program is to use an external debugger such as gdb. However, sometimes it is useful to obtain a backtrace programmatically from within a program, e.g., for the purposes of logging or diagnostics.”或者说，我们通常说的栈祯。在debug.c和redis.c中均有应用，具体到相关调用处再说明。
30 /* Test for backtrace() */
31 #if defined(__APPLE__) || defined(__linux__) || defined(__sun)
32 #define HAVE_BACKTRACE 1
33 #endif
34
35 //linux下使用epoll构建事件框架
36 /* Test for polling API */
37 #ifdef __linux__
38 #define HAVE_EPOLL 1
39 #endif
40
41 #if (defined(__APPLE__) && defined(MAC_OS_X_VERSION_10_6)) || defined(__FreeBSD__) || defined(__OpenBSD__) || defined (__NetBSD__)
42 #define HAVE_KQUEUE 1
43 #endif
44
45 //linux下使用fdatasync来flush硬盘。apue上讲过，fsync和fdatasync的区别是，fsync同时刷新文件的元数据（精确描述大家自己翻书吧）。redis使用fsync是为了将内存中的业务数据保存下来，具体rdb文件的元数据是否得到及时更新，并不是很重要，因此，如果在fdatasync可用的时候，使用更快的就是一个更明智的选择。
46 /* Define aof_fsync to fdatasync() in Linux and fsync() for all the rest */
47 #ifdef __linux__
48 #define aof_fsync fdatasync
49 #else
50 #define aof_fsync fsync
51 #endif
52
53 #endif
config.c 读取配置文件，以及和配置文件有关的client命令的执行函数，可谓又臭又长，看看就好。
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.seconds = seconds;
16 server.saveparams.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, *err = NULL;
31 int linenum = 0;
32 sds line = NULL;
33 int really_use_vm = 0;
34
35 if (filename == '-' && filename == '\0')
36 fp = stdin;
37 else {
38 if ((fp = fopen(filename,"r")) == NULL) {
39 redisLog(REDIS_WARNING, "Fatal error, can't open config file '%s'", filename);
40 exit(1);
41 }
42 }
43
44 while(fgets(buf,REDIS_CONFIGLINE_MAX+1,fp) != NULL) {
45 sds *argv;
46 int argc, j;
47
48 linenum++;
49 line = sdsnew(buf);
50 line = sdstrim(line," \t\r\n");
51
52 /* Skip comments and blank lines*/
53 if (line == '#' || line == '\0') {
54 sdsfree(line);
55 continue;
56 }
57
58 /* Split into arguments */
59 argv = sdssplitargs(line,&argc);
60 sdstolower(argv);
61
62 /* Execute config directives */
63 if (!strcasecmp(argv,"timeout") && argc == 2) {
64 server.maxidletime = atoi(argv);
65 if (server.maxidletime < 0) {
66 err = "Invalid timeout value"; goto loaderr;
67 }
68 } else if (!strcasecmp(argv,"port") && argc == 2) {
69 server.port = atoi(argv);
70 if (server.port < 0 || server.port > 65535) {
71 err = "Invalid port"; goto loaderr;
72 }
73 } else if (!strcasecmp(argv,"bind") && argc == 2) {
74 server.bindaddr = zstrdup(argv);
75 } else if (!strcasecmp(argv,"unixsocket") && argc == 2) {
76 server.unixsocket = zstrdup(argv);
77 } else if (!strcasecmp(argv,"unixsocketperm") && argc == 2) {
78 errno = 0;
79 server.unixsocketperm = (mode_t)strtol(argv, NULL, 8);
80 if (errno || server.unixsocketperm > 0777) {
81 err = "Invalid socket file permissions"; goto loaderr;
82 }
83 } else if (!strcasecmp(argv,"save") && argc == 3) {
84 int seconds = atoi(argv);
85 int changes = atoi(argv);
86 if (seconds < 1 || changes < 0) {
87 err = "Invalid save parameters"; goto loaderr;
88 }
89 appendServerSaveParams(seconds,changes);
90 } else if (!strcasecmp(argv,"dir") && argc == 2) {
91 if (chdir(argv) == -1) {
92 redisLog(REDIS_WARNING,"Can't chdir to '%s': %s",
93 argv, strerror(errno));
94 exit(1);
95 }
96 } else if (!strcasecmp(argv,"loglevel") && argc == 2) {
97 if (!strcasecmp(argv,"debug")) server.verbosity = REDIS_DEBUG;
98 else if (!strcasecmp(argv,"verbose")) server.verbosity = REDIS_VERBOSE;
99 else if (!strcasecmp(argv,"notice")) server.verbosity = REDIS_NOTICE;
100 else if (!strcasecmp(argv,"warning")) server.verbosity = REDIS_WARNING;
101 else {
102 err = "Invalid log level. Must be one of debug, notice, warning";
103 goto loaderr;
104 }
105 } else if (!strcasecmp(argv,"logfile") && argc == 2) {
106 FILE *logfp;
107
108 server.logfile = zstrdup(argv);
109 if (!strcasecmp(server.logfile,"stdout")) {
110 zfree(server.logfile);
111 server.logfile = NULL;
112 }
113 if (server.logfile) {
114 /* Test if we are able to open the file. The server will not
115 * be able to abort just for this problem later... */
116 logfp = fopen(server.logfile,"a");
117 if (logfp == NULL) {
118 err = sdscatprintf(sdsempty(),
119 "Can't open the log file: %s", strerror(errno));
120 goto loaderr;
121 }
122 fclose(logfp);
123 }
124 } else if (!strcasecmp(argv,"syslog-enabled") && argc == 2) {
125 if ((server.syslog_enabled = yesnotoi(argv)) == -1) {
126 err = "argument must be 'yes' or 'no'"; goto loaderr;
127 }
128 } else if (!strcasecmp(argv,"syslog-ident") && argc == 2) {
129 if (server.syslog_ident) zfree(server.syslog_ident);
130 server.syslog_ident = zstrdup(argv);
131 } else if (!strcasecmp(argv,"syslog-facility") && argc == 2) {
132 struct {
133 const char *name;
134 const int value;
135 } validSyslogFacilities[] = {
136 {"user", LOG_USER},
137 {"local0",LOG_LOCAL0},
138 {"local1",LOG_LOCAL1},
139 {"local2",LOG_LOCAL2},
140 {"local3",LOG_LOCAL3},
141 {"local4",LOG_LOCAL4},
142 {"local5",LOG_LOCAL5},
143 {"local6",LOG_LOCAL6},
144 {"local7",LOG_LOCAL7},
145 {NULL, 0}
146 };
147 int i;
148
149 for (i = 0; validSyslogFacilities.name; i++) {
150 if (!strcasecmp(validSyslogFacilities.name, argv)) {
151 server.syslog_facility = validSyslogFacilities.value;
152 break;
153 }
154 }
155
156 if (!validSyslogFacilities.name) {
157 err = "Invalid log facility. Must be one of USER or between LOCAL0-LOCAL7";
158 goto loaderr;
159 }
160 } else if (!strcasecmp(argv,"databases") && argc == 2) {
161 server.dbnum = atoi(argv);
162 if (server.dbnum < 1) {
163 err = "Invalid number of databases"; goto loaderr;
164 }
165 } else if (!strcasecmp(argv,"include") && argc == 2) {
166 loadServerConfig(argv);
167 } else if (!strcasecmp(argv,"maxclients") && argc == 2) {
168 server.maxclients = atoi(argv);
169 } else if (!strcasecmp(argv,"maxmemory") && argc == 2) {
170 server.maxmemory = memtoll(argv,NULL);
171 } else if (!strcasecmp(argv,"maxmemory-policy") && argc == 2) {
172 if (!strcasecmp(argv,"volatile-lru")) {
173 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU;
174 } else if (!strcasecmp(argv,"volatile-random")) {
175 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM;
176 } else if (!strcasecmp(argv,"volatile-ttl")) {
177 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL;
178 } else if (!strcasecmp(argv,"allkeys-lru")) {
179 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU;
180 } else if (!strcasecmp(argv,"allkeys-random")) {
181 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM;
182 } else if (!strcasecmp(argv,"noeviction")) {
183 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION;
184 } else {
185 err = "Invalid maxmemory policy";
186 goto loaderr;
187 }
188 } else if (!strcasecmp(argv,"maxmemory-samples") && argc == 2) {
189 server.maxmemory_samples = atoi(argv);
190 if (server.maxmemory_samples argv->encoding == REDIS_ENCODING_RAW);
373 redisAssert(c->argv->encoding == REDIS_ENCODING_RAW);
374 o = c->argv;
375
376 if (!strcasecmp(c->argv->ptr,"dbfilename")) {
377 zfree(server.dbfilename);
378 server.dbfilename = zstrdup(o->ptr);
379 } else if (!strcasecmp(c->argv->ptr,"requirepass")) {
380 zfree(server.requirepass);
381 server.requirepass = ((char*)o->ptr) ? zstrdup(o->ptr) : NULL;
382 } else if (!strcasecmp(c->argv->ptr,"masterauth")) {
383 zfree(server.masterauth);
384 server.masterauth = zstrdup(o->ptr);
385 } else if (!strcasecmp(c->argv->ptr,"maxmemory")) {
386 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
387 ll < 0) goto badfmt;
388 server.maxmemory = ll;
389 if (server.maxmemory) freeMemoryIfNeeded();
390 } else if (!strcasecmp(c->argv->ptr,"maxmemory-policy")) {
391 if (!strcasecmp(o->ptr,"volatile-lru")) {
392 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU;
393 } else if (!strcasecmp(o->ptr,"volatile-random")) {
394 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM;
395 } else if (!strcasecmp(o->ptr,"volatile-ttl")) {
396 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL;
397 } else if (!strcasecmp(o->ptr,"allkeys-lru")) {
398 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU;
399 } else if (!strcasecmp(o->ptr,"allkeys-random")) {
400 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM;
401 } else if (!strcasecmp(o->ptr,"noeviction")) {
402 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION;
403 } else {
404 goto badfmt;
405 }
406 } else if (!strcasecmp(c->argv->ptr,"maxmemory-samples")) {
407 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
408 ll argv->ptr,"timeout")) {
411 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
412 ll < 0 || ll > LONG_MAX) goto badfmt;
413 server.maxidletime = ll;
414 } else if (!strcasecmp(c->argv->ptr,"appendfsync")) {
415 if (!strcasecmp(o->ptr,"no")) {
416 server.appendfsync = APPENDFSYNC_NO;
417 } else if (!strcasecmp(o->ptr,"everysec")) {
418 server.appendfsync = APPENDFSYNC_EVERYSEC;
419 } else if (!strcasecmp(o->ptr,"always")) {
420 server.appendfsync = APPENDFSYNC_ALWAYS;
421 } else {
422 goto badfmt;
423 }
424 } else if (!strcasecmp(c->argv->ptr,"no-appendfsync-on-rewrite")) {
425 int yn = yesnotoi(o->ptr);
426
427 if (yn == -1) goto badfmt;
428 server.no_appendfsync_on_rewrite = yn;
429 } else if (!strcasecmp(c->argv->ptr,"appendonly")) {
430 int old = server.appendonly;
431 int new = yesnotoi(o->ptr);
432
433 if (new == -1) goto badfmt;
434 if (old != new) {
435 if (new == 0) {
436 stopAppendOnly();
437 } else {
438 if (startAppendOnly() == REDIS_ERR) {
439 addReplyError(c,
440 "Unable to turn on AOF. Check server logs.");
441 return;
442 }
443 }
444 }
445 } else if (!strcasecmp(c->argv->ptr,"auto-aof-rewrite-percentage")) {
446 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
447 server.auto_aofrewrite_perc = ll;
448 } else if (!strcasecmp(c->argv->ptr,"auto-aof-rewrite-min-size")) {
449 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
450 server.auto_aofrewrite_min_size = ll;
451 } else if (!strcasecmp(c->argv->ptr,"save")) {
452 int vlen, j;
453 sds *v = sdssplitlen(o->ptr,sdslen(o->ptr)," ",1,&vlen);
454
455 /* Perform sanity check before setting the new config:
456 * - Even number of args
457 * - Seconds >= 1, changes >= 0 */
458 if (vlen & 1) {
459 sdsfreesplitres(v,vlen);
460 goto badfmt;
461 }
462 for (j = 0; j < vlen; j++) {
463 char *eptr;
464 long val;
465
466 val = strtoll(v, &eptr, 10);
467 if (eptr != '\0' ||
468 ((j & 1) == 0 && val < 1) ||
469 ((j & 1) == 1 && val < 0)) {
470 sdsfreesplitres(v,vlen);
471 goto badfmt;
472 }
473 }
474 /* Finally set the new config */
475 resetServerSaveParams();
476 for (j = 0; j < vlen; j += 2) {
477 time_t seconds;
478 int changes;
479
480 seconds = strtoll(v,NULL,10);
481 changes = strtoll(v,NULL,10);
482 appendServerSaveParams(seconds, changes);
483 }
484 sdsfreesplitres(v,vlen);
485 } else if (!strcasecmp(c->argv->ptr,"slave-serve-stale-data")) {
486 int yn = yesnotoi(o->ptr);
487
488 if (yn == -1) goto badfmt;
489 server.repl_serve_stale_data = yn;
490 } else if (!strcasecmp(c->argv->ptr,"dir")) {
491 if (chdir((char*)o->ptr) == -1) {
492 addReplyErrorFormat(c,"Changing directory: %s", strerror(errno));
493 return;
494 }
495 } else if (!strcasecmp(c->argv->ptr,"hash-max-zipmap-entries")) {
496 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
497 server.hash_max_zipmap_entries = ll;
498 } else if (!strcasecmp(c->argv->ptr,"hash-max-zipmap-value")) {
499 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
500 server.hash_max_zipmap_value = ll;
501 } else if (!strcasecmp(c->argv->ptr,"list-max-ziplist-entries")) {
502 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
503 server.list_max_ziplist_entries = ll;
504 } else if (!strcasecmp(c->argv->ptr,"list-max-ziplist-value")) {
505 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
506 server.list_max_ziplist_value = ll;
507 } else if (!strcasecmp(c->argv->ptr,"set-max-intset-entries")) {
508 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
509 server.set_max_intset_entries = ll;
510 } else if (!strcasecmp(c->argv->ptr,"zset-max-ziplist-entries")) {
511 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
512 server.zset_max_ziplist_entries = ll;
513 } else if (!strcasecmp(c->argv->ptr,"zset-max-ziplist-value")) {
514 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
515 server.zset_max_ziplist_value = ll;
516 } else if (!strcasecmp(c->argv->ptr,"slowlog-log-slower-than")) {
517 if (getLongLongFromObject(o,&ll) == REDIS_ERR) goto badfmt;
518 server.slowlog_log_slower_than = ll;
519 } else if (!strcasecmp(c->argv->ptr,"slowlog-max-len")) {
520 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
521 server.slowlog_max_len = (unsigned)ll;
522 } else if (!strcasecmp(c->argv->ptr,"loglevel")) {
523 if (!strcasecmp(o->ptr,"warning")) {
524 server.verbosity = REDIS_WARNING;
525 } else if (!strcasecmp(o->ptr,"notice")) {
526 server.verbosity = REDIS_NOTICE;
527 } else if (!strcasecmp(o->ptr,"verbose")) {
528 server.verbosity = REDIS_VERBOSE;
529 } else if (!strcasecmp(o->ptr,"debug")) {
530 server.verbosity = REDIS_DEBUG;
531 } else {
532 goto badfmt;
533 }
534 } else {
535 addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s",
536 (char*)c->argv->ptr);
537 return;
538 }
539 addReply(c,shared.ok);
540 return;
541
542 badfmt: /* Bad format errors */
543 addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'",
544 (char*)o->ptr,
545 (char*)c->argv->ptr);
546 }
547
548 void configGetCommand(redisClient *c) {
549 robj *o = c->argv;
550 void *replylen = addDeferredMultiBulkLength(c);
551 char *pattern = o->ptr;
552 char buf;
553 int matches = 0;
554 redisAssert(o->encoding == REDIS_ENCODING_RAW);
555
556 if (stringmatch(pattern,"dir",0)) {
557 char buf;
558
559 if (getcwd(buf,sizeof(buf)) == NULL)
560 buf = '\0';
561
562 addReplyBulkCString(c,"dir");
563 addReplyBulkCString(c,buf);
564 matches++;
565 }
566 if (stringmatch(pattern,"dbfilename",0)) {
567 addReplyBulkCString(c,"dbfilename");
568 addReplyBulkCString(c,server.dbfilename);
569 matches++;
570 }
571 if (stringmatch(pattern,"requirepass",0)) {
572 addReplyBulkCString(c,"requirepass");
573 addReplyBulkCString(c,server.requirepass);
574 matches++;
575 }
576 if (stringmatch(pattern,"masterauth",0)) {
577 addReplyBulkCString(c,"masterauth");
578 addReplyBulkCString(c,server.masterauth);
579 matches++;
580 }
581 if (stringmatch(pattern,"maxmemory",0)) {
582 ll2string(buf,sizeof(buf),server.maxmemory);
583 addReplyBulkCString(c,"maxmemory");
584 addReplyBulkCString(c,buf);
585 matches++;
586 }
587 if (stringmatch(pattern,"maxmemory-policy",0)) {
588 char *s;
589
590 switch(server.maxmemory_policy) {
591 case REDIS_MAXMEMORY_VOLATILE_LRU: s = "volatile-lru"; break;
592 case REDIS_MAXMEMORY_VOLATILE_TTL: s = "volatile-ttl"; break;
593 case REDIS_MAXMEMORY_VOLATILE_RANDOM: s = "volatile-random"; break;
594 case REDIS_MAXMEMORY_ALLKEYS_LRU: s = "allkeys-lru"; break;
595 case REDIS_MAXMEMORY_ALLKEYS_RANDOM: s = "allkeys-random"; break;
596 case REDIS_MAXMEMORY_NO_EVICTION: s = "noeviction"; break;
597 default: s = "unknown"; break; /* too harmless to panic */
598 }
599 addReplyBulkCString(c,"maxmemory-policy");
600 addReplyBulkCString(c,s);
601 matches++;
602 }
603 if (stringmatch(pattern,"maxmemory-samples",0)) {
604 ll2string(buf,sizeof(buf),server.maxmemory_samples);
605 addReplyBulkCString(c,"maxmemory-samples");
606 addReplyBulkCString(c,buf);
607 matches++;
608 }
609 if (stringmatch(pattern,"timeout",0)) {
610 ll2string(buf,sizeof(buf),server.maxidletime);
611 addReplyBulkCString(c,"timeout");
612 addReplyBulkCString(c,buf);
613 matches++;
614 }
615 if (stringmatch(pattern,"appendonly",0)) {
616 addReplyBulkCString(c,"appendonly");
617 addReplyBulkCString(c,server.appendonly ? "yes" : "no");
618 matches++;
619 }
620 if (stringmatch(pattern,"no-appendfsync-on-rewrite",0)) {
621 addReplyBulkCString(c,"no-appendfsync-on-rewrite");
622 addReplyBulkCString(c,server.no_appendfsync_on_rewrite ? "yes" : "no");
623 matches++;
624 }
625 if (stringmatch(pattern,"appendfsync",0)) {
626 char *policy;
627
628 switch(server.appendfsync) {
629 case APPENDFSYNC_NO: policy = "no"; break;
630 case APPENDFSYNC_EVERYSEC: policy = "everysec"; break;
631 case APPENDFSYNC_ALWAYS: policy = "always"; break;
632 default: policy = "unknown"; break; /* too harmless to panic */
633 }
634 addReplyBulkCString(c,"appendfsync");
635 addReplyBulkCString(c,policy);
636 matches++;
637 }
638 if (stringmatch(pattern,"save",0)) {
639 sds buf = sdsempty();
640 int j;
641
642 for (j = 0; j < server.saveparamslen; j++) {
643 buf = sdscatprintf(buf,"%ld %d",
644 server.saveparams.seconds,
645 server.saveparams.changes);
646 if (j != server.saveparamslen-1)
647 buf = sdscatlen(buf," ",1);
648 }
649 addReplyBulkCString(c,"save");
650 addReplyBulkCString(c,buf);
651 sdsfree(buf);
652 matches++;
653 }
654 if (stringmatch(pattern,"auto-aof-rewrite-percentage",0)) {
655 addReplyBulkCString(c,"auto-aof-rewrite-percentage");
656 addReplyBulkLongLong(c,server.auto_aofrewrite_perc);
657 matches++;
658 }
659 if (stringmatch(pattern,"auto-aof-rewrite-min-size",0)) {
660 addReplyBulkCString(c,"auto-aof-rewrite-min-size");
661 addReplyBulkLongLong(c,server.auto_aofrewrite_min_size);
662 matches++;
663 }
664 if (stringmatch(pattern,"slave-serve-stale-data",0)) {
665 addReplyBulkCString(c,"slave-serve-stale-data");
666 addReplyBulkCString(c,server.repl_serve_stale_data ? "yes" : "no");
667 matches++;
668 }
669 if (stringmatch(pattern,"hash-max-zipmap-entries",0)) {
670 addReplyBulkCString(c,"hash-max-zipmap-entries");
671 addReplyBulkLongLong(c,server.hash_max_zipmap_entries);
672 matches++;
673 }
674 if (stringmatch(pattern,"hash-max-zipmap-value",0)) {
675 addReplyBulkCString(c,"hash-max-zipmap-value");
676 addReplyBulkLongLong(c,server.hash_max_zipmap_value);
677 matches++;
678 }
679 if (stringmatch(pattern,"list-max-ziplist-entries",0)) {
680 addReplyBulkCString(c,"list-max-ziplist-entries");
681 addReplyBulkLongLong(c,server.list_max_ziplist_entries);
682 matches++;
683 }
684 if (stringmatch(pattern,"list-max-ziplist-value",0)) {
685 addReplyBulkCString(c,"list-max-ziplist-value");
686 addReplyBulkLongLong(c,server.list_max_ziplist_value);
687 matches++;
688 }
689 if (stringmatch(pattern,"set-max-intset-entries",0)) {
690 addReplyBulkCString(c,"set-max-intset-entries");
691 addReplyBulkLongLong(c,server.set_max_intset_entries);
692 matches++;
693 }
694 if (stringmatch(pattern,"zset-max-ziplist-entries",0)) {
695 addReplyBulkCString(c,"zset-max-ziplist-entries");
696 addReplyBulkLongLong(c,server.zset_max_ziplist_entries);
697 matches++;
698 }
699 if (stringmatch(pattern,"zset-max-ziplist-value",0)) {
700 addReplyBulkCString(c,"zset-max-ziplist-value");
701 addReplyBulkLongLong(c,server.zset_max_ziplist_value);
702 matches++;
703 }
704 if (stringmatch(pattern,"slowlog-log-slower-than",0)) {
705 addReplyBulkCString(c,"slowlog-log-slower-than");
706 addReplyBulkLongLong(c,server.slowlog_log_slower_than);
707 matches++;
708 }
709 if (stringmatch(pattern,"slowlog-max-len",0)) {
710 addReplyBulkCString(c,"slowlog-max-len");
711 addReplyBulkLongLong(c,server.slowlog_max_len);
712 matches++;
713 }
714 if (stringmatch(pattern,"loglevel",0)) {
715 char *s;
716
717 switch(server.verbosity) {
718 case REDIS_WARNING: s = "warning"; break;
719 case REDIS_VERBOSE: s = "verbose"; break;
720 case REDIS_NOTICE: s = "notice"; break;
721 case REDIS_DEBUG: s = "debug"; break;
722 default: s = "unknown"; break; /* too harmless to panic */
723 }
724 addReplyBulkCString(c,"loglevel");
725 addReplyBulkCString(c,s);
726 matches++;
727 }
728 setDeferredMultiBulkLength(c,replylen,matches*2);
729 }
730
731 void configCommand(redisClient *c) {
732 if (!strcasecmp(c->argv->ptr,"set")) {
733 if (c->argc != 4) goto badarity;
734 configSetCommand(c);
735 } else if (!strcasecmp(c->argv->ptr,"get")) {
736 if (c->argc != 3) goto badarity;
737 configGetCommand(c);
738 } else if (!strcasecmp(c->argv->ptr,"resetstat")) {
739 if (c->argc != 2) goto badarity;
740 server.stat_keyspace_hits = 0;
741 server.stat_keyspace_misses = 0;
742 server.stat_numcommands = 0;
743 server.stat_numconnections = 0;
744 server.stat_expiredkeys = 0;
745 addReply(c,shared.ok);
746 } else {
747 addReplyError(c,
748 "CONFIG subcommand must be one of GET, SET, RESETSTAT");
749 }
750 return;
751
752 badarity:
753 addReplyErrorFormat(c,"Wrong number of arguments for CONFIG %s",
754 (char*) c->argv->ptr);
755 }
页:
[1]