]> git.saurik.com Git - redis.git/blame_incremental - src/config.c
Sentinel: client reconfiguration script execution.
[redis.git] / src / config.c
... / ...
CommitLineData
1#include "redis.h"
2
3/*-----------------------------------------------------------------------------
4 * Config file parsing
5 *----------------------------------------------------------------------------*/
6
7int yesnotoi(char *s) {
8 if (!strcasecmp(s,"yes")) return 1;
9 else if (!strcasecmp(s,"no")) return 0;
10 else return -1;
11}
12
13void 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
20void resetServerSaveParams() {
21 zfree(server.saveparams);
22 server.saveparams = NULL;
23 server.saveparamslen = 0;
24}
25
26void loadServerConfigFromString(char *config) {
27 char *err = NULL;
28 int linenum = 0, totlines, i;
29 sds *lines;
30
31 lines = sdssplitlen(config,strlen(config),"\n",1,&totlines);
32
33 for (i = 0; i < totlines; i++) {
34 sds *argv;
35 int argc;
36
37 linenum = i+1;
38 lines[i] = sdstrim(lines[i]," \t\r\n");
39
40 /* Skip comments and blank lines*/
41 if (lines[i][0] == '#' || lines[i][0] == '\0') continue;
42
43 /* Split into arguments */
44 argv = sdssplitargs(lines[i],&argc);
45 sdstolower(argv[0]);
46
47 /* Execute config directives */
48 if (!strcasecmp(argv[0],"timeout") && argc == 2) {
49 server.maxidletime = atoi(argv[1]);
50 if (server.maxidletime < 0) {
51 err = "Invalid timeout value"; goto loaderr;
52 }
53 } else if (!strcasecmp(argv[0],"port") && argc == 2) {
54 server.port = atoi(argv[1]);
55 if (server.port < 0 || server.port > 65535) {
56 err = "Invalid port"; goto loaderr;
57 }
58 } else if (!strcasecmp(argv[0],"bind") && argc == 2) {
59 server.bindaddr = zstrdup(argv[1]);
60 } else if (!strcasecmp(argv[0],"unixsocket") && argc == 2) {
61 server.unixsocket = zstrdup(argv[1]);
62 } else if (!strcasecmp(argv[0],"unixsocketperm") && argc == 2) {
63 errno = 0;
64 server.unixsocketperm = (mode_t)strtol(argv[1], NULL, 8);
65 if (errno || server.unixsocketperm > 0777) {
66 err = "Invalid socket file permissions"; goto loaderr;
67 }
68 } else if (!strcasecmp(argv[0],"save")) {
69 if (argc == 3) {
70 int seconds = atoi(argv[1]);
71 int changes = atoi(argv[2]);
72 if (seconds < 1 || changes < 0) {
73 err = "Invalid save parameters"; goto loaderr;
74 }
75 appendServerSaveParams(seconds,changes);
76 } else if (argc == 2 && !strcasecmp(argv[1],"")) {
77 resetServerSaveParams();
78 }
79 } else if (!strcasecmp(argv[0],"dir") && argc == 2) {
80 if (chdir(argv[1]) == -1) {
81 redisLog(REDIS_WARNING,"Can't chdir to '%s': %s",
82 argv[1], strerror(errno));
83 exit(1);
84 }
85 } else if (!strcasecmp(argv[0],"loglevel") && argc == 2) {
86 if (!strcasecmp(argv[1],"debug")) server.verbosity = REDIS_DEBUG;
87 else if (!strcasecmp(argv[1],"verbose")) server.verbosity = REDIS_VERBOSE;
88 else if (!strcasecmp(argv[1],"notice")) server.verbosity = REDIS_NOTICE;
89 else if (!strcasecmp(argv[1],"warning")) server.verbosity = REDIS_WARNING;
90 else {
91 err = "Invalid log level. Must be one of debug, notice, warning";
92 goto loaderr;
93 }
94 } else if (!strcasecmp(argv[0],"logfile") && argc == 2) {
95 FILE *logfp;
96
97 server.logfile = zstrdup(argv[1]);
98 if (!strcasecmp(server.logfile,"stdout")) {
99 zfree(server.logfile);
100 server.logfile = NULL;
101 }
102 if (server.logfile) {
103 /* Test if we are able to open the file. The server will not
104 * be able to abort just for this problem later... */
105 logfp = fopen(server.logfile,"a");
106 if (logfp == NULL) {
107 err = sdscatprintf(sdsempty(),
108 "Can't open the log file: %s", strerror(errno));
109 goto loaderr;
110 }
111 fclose(logfp);
112 }
113 } else if (!strcasecmp(argv[0],"syslog-enabled") && argc == 2) {
114 if ((server.syslog_enabled = yesnotoi(argv[1])) == -1) {
115 err = "argument must be 'yes' or 'no'"; goto loaderr;
116 }
117 } else if (!strcasecmp(argv[0],"syslog-ident") && argc == 2) {
118 if (server.syslog_ident) zfree(server.syslog_ident);
119 server.syslog_ident = zstrdup(argv[1]);
120 } else if (!strcasecmp(argv[0],"syslog-facility") && argc == 2) {
121 struct {
122 const char *name;
123 const int value;
124 } validSyslogFacilities[] = {
125 {"user", LOG_USER},
126 {"local0", LOG_LOCAL0},
127 {"local1", LOG_LOCAL1},
128 {"local2", LOG_LOCAL2},
129 {"local3", LOG_LOCAL3},
130 {"local4", LOG_LOCAL4},
131 {"local5", LOG_LOCAL5},
132 {"local6", LOG_LOCAL6},
133 {"local7", LOG_LOCAL7},
134 {NULL, 0}
135 };
136 int i;
137
138 for (i = 0; validSyslogFacilities[i].name; i++) {
139 if (!strcasecmp(validSyslogFacilities[i].name, argv[1])) {
140 server.syslog_facility = validSyslogFacilities[i].value;
141 break;
142 }
143 }
144
145 if (!validSyslogFacilities[i].name) {
146 err = "Invalid log facility. Must be one of USER or between LOCAL0-LOCAL7";
147 goto loaderr;
148 }
149 } else if (!strcasecmp(argv[0],"databases") && argc == 2) {
150 server.dbnum = atoi(argv[1]);
151 if (server.dbnum < 1) {
152 err = "Invalid number of databases"; goto loaderr;
153 }
154 } else if (!strcasecmp(argv[0],"include") && argc == 2) {
155 loadServerConfig(argv[1],NULL);
156 } else if (!strcasecmp(argv[0],"maxclients") && argc == 2) {
157 server.maxclients = atoi(argv[1]);
158 if (server.maxclients < 1) {
159 err = "Invalid max clients limit"; goto loaderr;
160 }
161 } else if (!strcasecmp(argv[0],"maxmemory") && argc == 2) {
162 server.maxmemory = memtoll(argv[1],NULL);
163 } else if (!strcasecmp(argv[0],"maxmemory-policy") && argc == 2) {
164 if (!strcasecmp(argv[1],"volatile-lru")) {
165 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU;
166 } else if (!strcasecmp(argv[1],"volatile-random")) {
167 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM;
168 } else if (!strcasecmp(argv[1],"volatile-ttl")) {
169 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL;
170 } else if (!strcasecmp(argv[1],"allkeys-lru")) {
171 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU;
172 } else if (!strcasecmp(argv[1],"allkeys-random")) {
173 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM;
174 } else if (!strcasecmp(argv[1],"noeviction")) {
175 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION;
176 } else {
177 err = "Invalid maxmemory policy";
178 goto loaderr;
179 }
180 } else if (!strcasecmp(argv[0],"maxmemory-samples") && argc == 2) {
181 server.maxmemory_samples = atoi(argv[1]);
182 if (server.maxmemory_samples <= 0) {
183 err = "maxmemory-samples must be 1 or greater";
184 goto loaderr;
185 }
186 } else if (!strcasecmp(argv[0],"slaveof") && argc == 3) {
187 server.masterhost = sdsnew(argv[1]);
188 server.masterport = atoi(argv[2]);
189 server.repl_state = REDIS_REPL_CONNECT;
190 } else if (!strcasecmp(argv[0],"repl-ping-slave-period") && argc == 2) {
191 server.repl_ping_slave_period = atoi(argv[1]);
192 if (server.repl_ping_slave_period <= 0) {
193 err = "repl-ping-slave-period must be 1 or greater";
194 goto loaderr;
195 }
196 } else if (!strcasecmp(argv[0],"repl-timeout") && argc == 2) {
197 server.repl_timeout = atoi(argv[1]);
198 if (server.repl_timeout <= 0) {
199 err = "repl-timeout must be 1 or greater";
200 goto loaderr;
201 }
202 } else if (!strcasecmp(argv[0],"masterauth") && argc == 2) {
203 server.masterauth = zstrdup(argv[1]);
204 } else if (!strcasecmp(argv[0],"slave-serve-stale-data") && argc == 2) {
205 if ((server.repl_serve_stale_data = yesnotoi(argv[1])) == -1) {
206 err = "argument must be 'yes' or 'no'"; goto loaderr;
207 }
208 } else if (!strcasecmp(argv[0],"slave-read-only") && argc == 2) {
209 if ((server.repl_slave_ro = yesnotoi(argv[1])) == -1) {
210 err = "argument must be 'yes' or 'no'"; goto loaderr;
211 }
212 } else if (!strcasecmp(argv[0],"rdbcompression") && argc == 2) {
213 if ((server.rdb_compression = yesnotoi(argv[1])) == -1) {
214 err = "argument must be 'yes' or 'no'"; goto loaderr;
215 }
216 } else if (!strcasecmp(argv[0],"rdbchecksum") && argc == 2) {
217 if ((server.rdb_checksum = yesnotoi(argv[1])) == -1) {
218 err = "argument must be 'yes' or 'no'"; goto loaderr;
219 }
220 } else if (!strcasecmp(argv[0],"activerehashing") && argc == 2) {
221 if ((server.activerehashing = yesnotoi(argv[1])) == -1) {
222 err = "argument must be 'yes' or 'no'"; goto loaderr;
223 }
224 } else if (!strcasecmp(argv[0],"daemonize") && argc == 2) {
225 if ((server.daemonize = yesnotoi(argv[1])) == -1) {
226 err = "argument must be 'yes' or 'no'"; goto loaderr;
227 }
228 } else if (!strcasecmp(argv[0],"appendonly") && argc == 2) {
229 int yes;
230
231 if ((yes = yesnotoi(argv[1])) == -1) {
232 err = "argument must be 'yes' or 'no'"; goto loaderr;
233 }
234 server.aof_state = yes ? REDIS_AOF_ON : REDIS_AOF_OFF;
235 } else if (!strcasecmp(argv[0],"appendfilename") && argc == 2) {
236 zfree(server.aof_filename);
237 server.aof_filename = zstrdup(argv[1]);
238 } else if (!strcasecmp(argv[0],"no-appendfsync-on-rewrite")
239 && argc == 2) {
240 if ((server.aof_no_fsync_on_rewrite= yesnotoi(argv[1])) == -1) {
241 err = "argument must be 'yes' or 'no'"; goto loaderr;
242 }
243 } else if (!strcasecmp(argv[0],"appendfsync") && argc == 2) {
244 if (!strcasecmp(argv[1],"no")) {
245 server.aof_fsync = AOF_FSYNC_NO;
246 } else if (!strcasecmp(argv[1],"always")) {
247 server.aof_fsync = AOF_FSYNC_ALWAYS;
248 } else if (!strcasecmp(argv[1],"everysec")) {
249 server.aof_fsync = AOF_FSYNC_EVERYSEC;
250 } else {
251 err = "argument must be 'no', 'always' or 'everysec'";
252 goto loaderr;
253 }
254 } else if (!strcasecmp(argv[0],"auto-aof-rewrite-percentage") &&
255 argc == 2)
256 {
257 server.aof_rewrite_perc = atoi(argv[1]);
258 if (server.aof_rewrite_perc < 0) {
259 err = "Invalid negative percentage for AOF auto rewrite";
260 goto loaderr;
261 }
262 } else if (!strcasecmp(argv[0],"auto-aof-rewrite-min-size") &&
263 argc == 2)
264 {
265 server.aof_rewrite_min_size = memtoll(argv[1],NULL);
266 } else if (!strcasecmp(argv[0],"requirepass") && argc == 2) {
267 if (strlen(argv[1]) > REDIS_AUTHPASS_MAX_LEN) {
268 err = "Password is longer than REDIS_AUTHPASS_MAX_LEN";
269 goto loaderr;
270 }
271 server.requirepass = zstrdup(argv[1]);
272 } else if (!strcasecmp(argv[0],"pidfile") && argc == 2) {
273 zfree(server.pidfile);
274 server.pidfile = zstrdup(argv[1]);
275 } else if (!strcasecmp(argv[0],"dbfilename") && argc == 2) {
276 zfree(server.rdb_filename);
277 server.rdb_filename = zstrdup(argv[1]);
278 } else if (!strcasecmp(argv[0],"hash-max-ziplist-entries") && argc == 2) {
279 server.hash_max_ziplist_entries = memtoll(argv[1], NULL);
280 } else if (!strcasecmp(argv[0],"hash-max-ziplist-value") && argc == 2) {
281 server.hash_max_ziplist_value = memtoll(argv[1], NULL);
282 } else if (!strcasecmp(argv[0],"list-max-ziplist-entries") && argc == 2){
283 server.list_max_ziplist_entries = memtoll(argv[1], NULL);
284 } else if (!strcasecmp(argv[0],"list-max-ziplist-value") && argc == 2) {
285 server.list_max_ziplist_value = memtoll(argv[1], NULL);
286 } else if (!strcasecmp(argv[0],"set-max-intset-entries") && argc == 2) {
287 server.set_max_intset_entries = memtoll(argv[1], NULL);
288 } else if (!strcasecmp(argv[0],"zset-max-ziplist-entries") && argc == 2) {
289 server.zset_max_ziplist_entries = memtoll(argv[1], NULL);
290 } else if (!strcasecmp(argv[0],"zset-max-ziplist-value") && argc == 2) {
291 server.zset_max_ziplist_value = memtoll(argv[1], NULL);
292 } else if (!strcasecmp(argv[0],"rename-command") && argc == 3) {
293 struct redisCommand *cmd = lookupCommand(argv[1]);
294 int retval;
295
296 if (!cmd) {
297 err = "No such command in rename-command";
298 goto loaderr;
299 }
300
301 /* If the target command name is the emtpy string we just
302 * remove it from the command table. */
303 retval = dictDelete(server.commands, argv[1]);
304 redisAssert(retval == DICT_OK);
305
306 /* Otherwise we re-add the command under a different name. */
307 if (sdslen(argv[2]) != 0) {
308 sds copy = sdsdup(argv[2]);
309
310 retval = dictAdd(server.commands, copy, cmd);
311 if (retval != DICT_OK) {
312 sdsfree(copy);
313 err = "Target command name already exists"; goto loaderr;
314 }
315 }
316 } else if (!strcasecmp(argv[0],"cluster-enabled") && argc == 2) {
317 if ((server.cluster_enabled = yesnotoi(argv[1])) == -1) {
318 err = "argument must be 'yes' or 'no'"; goto loaderr;
319 }
320 } else if (!strcasecmp(argv[0],"cluster-config-file") && argc == 2) {
321 zfree(server.cluster.configfile);
322 server.cluster.configfile = zstrdup(argv[1]);
323 } else if (!strcasecmp(argv[0],"lua-time-limit") && argc == 2) {
324 server.lua_time_limit = strtoll(argv[1],NULL,10);
325 } else if (!strcasecmp(argv[0],"slowlog-log-slower-than") &&
326 argc == 2)
327 {
328 server.slowlog_log_slower_than = strtoll(argv[1],NULL,10);
329 } else if (!strcasecmp(argv[0],"slowlog-max-len") && argc == 2) {
330 server.slowlog_max_len = strtoll(argv[1],NULL,10);
331 } else if (!strcasecmp(argv[0],"client-output-buffer-limit") &&
332 argc == 5)
333 {
334 int class = getClientLimitClassByName(argv[1]);
335 unsigned long long hard, soft;
336 int soft_seconds;
337
338 if (class == -1) {
339 err = "Unrecognized client limit class";
340 goto loaderr;
341 }
342 hard = memtoll(argv[2],NULL);
343 soft = memtoll(argv[3],NULL);
344 soft_seconds = atoi(argv[4]);
345 if (soft_seconds < 0) {
346 err = "Negative number of seconds in soft limt is invalid";
347 goto loaderr;
348 }
349 server.client_obuf_limits[class].hard_limit_bytes = hard;
350 server.client_obuf_limits[class].soft_limit_bytes = soft;
351 server.client_obuf_limits[class].soft_limit_seconds = soft_seconds;
352 } else if (!strcasecmp(argv[0],"stop-writes-on-bgsave-error") &&
353 argc == 2) {
354 if ((server.stop_writes_on_bgsave_err = yesnotoi(argv[1])) == -1) {
355 err = "argument must be 'yes' or 'no'"; goto loaderr;
356 }
357 } else if (!strcasecmp(argv[0],"sentinel")) {
358 /* argc == 1 is handled by main() as we need to enter the sentinel
359 * mode ASAP. */
360 if (argc != 1) {
361 if (!server.sentinel_mode) {
362 err = "sentinel directive while not in sentinel mode";
363 goto loaderr;
364 }
365 err = sentinelHandleConfiguration(argv+1,argc-1);
366 if (err) goto loaderr;
367 }
368 } else {
369 err = "Bad directive or wrong number of arguments"; goto loaderr;
370 }
371 sdsfreesplitres(argv,argc);
372 }
373 sdsfreesplitres(lines,totlines);
374 return;
375
376loaderr:
377 fprintf(stderr, "\n*** FATAL CONFIG FILE ERROR ***\n");
378 fprintf(stderr, "Reading the configuration file, at line %d\n", linenum);
379 fprintf(stderr, ">>> '%s'\n", lines[i]);
380 fprintf(stderr, "%s\n", err);
381 exit(1);
382}
383
384/* Load the server configuration from the specified filename.
385 * The function appends the additional configuration directives stored
386 * in the 'options' string to the config file before loading.
387 *
388 * Both filename and options can be NULL, in such a case are considered
389 * emtpy. This way loadServerConfig can be used to just load a file or
390 * just load a string. */
391void loadServerConfig(char *filename, char *options) {
392 sds config = sdsempty();
393 char buf[REDIS_CONFIGLINE_MAX+1];
394
395 /* Load the file content */
396 if (filename) {
397 FILE *fp;
398
399 if (filename[0] == '-' && filename[1] == '\0') {
400 fp = stdin;
401 } else {
402 if ((fp = fopen(filename,"r")) == NULL) {
403 redisLog(REDIS_WARNING,
404 "Fatal error, can't open config file '%s'", filename);
405 exit(1);
406 }
407 }
408 while(fgets(buf,REDIS_CONFIGLINE_MAX+1,fp) != NULL)
409 config = sdscat(config,buf);
410 if (fp != stdin) fclose(fp);
411 }
412 /* Append the additional options */
413 if (options) {
414 config = sdscat(config,"\n");
415 config = sdscat(config,options);
416 }
417 loadServerConfigFromString(config);
418 sdsfree(config);
419}
420
421/*-----------------------------------------------------------------------------
422 * CONFIG command for remote configuration
423 *----------------------------------------------------------------------------*/
424
425void configSetCommand(redisClient *c) {
426 robj *o;
427 long long ll;
428 redisAssertWithInfo(c,c->argv[2],c->argv[2]->encoding == REDIS_ENCODING_RAW);
429 redisAssertWithInfo(c,c->argv[2],c->argv[3]->encoding == REDIS_ENCODING_RAW);
430 o = c->argv[3];
431
432 if (!strcasecmp(c->argv[2]->ptr,"dbfilename")) {
433 zfree(server.rdb_filename);
434 server.rdb_filename = zstrdup(o->ptr);
435 } else if (!strcasecmp(c->argv[2]->ptr,"requirepass")) {
436 if (sdslen(o->ptr) > REDIS_AUTHPASS_MAX_LEN) goto badfmt;
437 zfree(server.requirepass);
438 server.requirepass = ((char*)o->ptr)[0] ? zstrdup(o->ptr) : NULL;
439 } else if (!strcasecmp(c->argv[2]->ptr,"masterauth")) {
440 zfree(server.masterauth);
441 server.masterauth = zstrdup(o->ptr);
442 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory")) {
443 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
444 ll < 0) goto badfmt;
445 server.maxmemory = ll;
446 if (server.maxmemory) freeMemoryIfNeeded();
447 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-policy")) {
448 if (!strcasecmp(o->ptr,"volatile-lru")) {
449 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU;
450 } else if (!strcasecmp(o->ptr,"volatile-random")) {
451 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM;
452 } else if (!strcasecmp(o->ptr,"volatile-ttl")) {
453 server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL;
454 } else if (!strcasecmp(o->ptr,"allkeys-lru")) {
455 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU;
456 } else if (!strcasecmp(o->ptr,"allkeys-random")) {
457 server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM;
458 } else if (!strcasecmp(o->ptr,"noeviction")) {
459 server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION;
460 } else {
461 goto badfmt;
462 }
463 } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-samples")) {
464 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
465 ll <= 0) goto badfmt;
466 server.maxmemory_samples = ll;
467 } else if (!strcasecmp(c->argv[2]->ptr,"timeout")) {
468 if (getLongLongFromObject(o,&ll) == REDIS_ERR ||
469 ll < 0 || ll > LONG_MAX) goto badfmt;
470 server.maxidletime = ll;
471 } else if (!strcasecmp(c->argv[2]->ptr,"appendfsync")) {
472 if (!strcasecmp(o->ptr,"no")) {
473 server.aof_fsync = AOF_FSYNC_NO;
474 } else if (!strcasecmp(o->ptr,"everysec")) {
475 server.aof_fsync = AOF_FSYNC_EVERYSEC;
476 } else if (!strcasecmp(o->ptr,"always")) {
477 server.aof_fsync = AOF_FSYNC_ALWAYS;
478 } else {
479 goto badfmt;
480 }
481 } else if (!strcasecmp(c->argv[2]->ptr,"no-appendfsync-on-rewrite")) {
482 int yn = yesnotoi(o->ptr);
483
484 if (yn == -1) goto badfmt;
485 server.aof_no_fsync_on_rewrite = yn;
486 } else if (!strcasecmp(c->argv[2]->ptr,"appendonly")) {
487 int enable = yesnotoi(o->ptr);
488
489 if (enable == -1) goto badfmt;
490 if (enable == 0 && server.aof_state != REDIS_AOF_OFF) {
491 stopAppendOnly();
492 } else if (enable && server.aof_state == REDIS_AOF_OFF) {
493 if (startAppendOnly() == REDIS_ERR) {
494 addReplyError(c,
495 "Unable to turn on AOF. Check server logs.");
496 return;
497 }
498 }
499 } else if (!strcasecmp(c->argv[2]->ptr,"auto-aof-rewrite-percentage")) {
500 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
501 server.aof_rewrite_perc = ll;
502 } else if (!strcasecmp(c->argv[2]->ptr,"auto-aof-rewrite-min-size")) {
503 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
504 server.aof_rewrite_min_size = ll;
505 } else if (!strcasecmp(c->argv[2]->ptr,"save")) {
506 int vlen, j;
507 sds *v = sdssplitlen(o->ptr,sdslen(o->ptr)," ",1,&vlen);
508
509 /* Perform sanity check before setting the new config:
510 * - Even number of args
511 * - Seconds >= 1, changes >= 0 */
512 if (vlen & 1) {
513 sdsfreesplitres(v,vlen);
514 goto badfmt;
515 }
516 for (j = 0; j < vlen; j++) {
517 char *eptr;
518 long val;
519
520 val = strtoll(v[j], &eptr, 10);
521 if (eptr[0] != '\0' ||
522 ((j & 1) == 0 && val < 1) ||
523 ((j & 1) == 1 && val < 0)) {
524 sdsfreesplitres(v,vlen);
525 goto badfmt;
526 }
527 }
528 /* Finally set the new config */
529 resetServerSaveParams();
530 for (j = 0; j < vlen; j += 2) {
531 time_t seconds;
532 int changes;
533
534 seconds = strtoll(v[j],NULL,10);
535 changes = strtoll(v[j+1],NULL,10);
536 appendServerSaveParams(seconds, changes);
537 }
538 sdsfreesplitres(v,vlen);
539 } else if (!strcasecmp(c->argv[2]->ptr,"slave-serve-stale-data")) {
540 int yn = yesnotoi(o->ptr);
541
542 if (yn == -1) goto badfmt;
543 server.repl_serve_stale_data = yn;
544 } else if (!strcasecmp(c->argv[2]->ptr,"slave-read-only")) {
545 int yn = yesnotoi(o->ptr);
546
547 if (yn == -1) goto badfmt;
548 server.repl_slave_ro = yn;
549 } else if (!strcasecmp(c->argv[2]->ptr,"dir")) {
550 if (chdir((char*)o->ptr) == -1) {
551 addReplyErrorFormat(c,"Changing directory: %s", strerror(errno));
552 return;
553 }
554 } else if (!strcasecmp(c->argv[2]->ptr,"hash-max-ziplist-entries")) {
555 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
556 server.hash_max_ziplist_entries = ll;
557 } else if (!strcasecmp(c->argv[2]->ptr,"hash-max-ziplist-value")) {
558 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
559 server.hash_max_ziplist_value = ll;
560 } else if (!strcasecmp(c->argv[2]->ptr,"list-max-ziplist-entries")) {
561 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
562 server.list_max_ziplist_entries = ll;
563 } else if (!strcasecmp(c->argv[2]->ptr,"list-max-ziplist-value")) {
564 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
565 server.list_max_ziplist_value = ll;
566 } else if (!strcasecmp(c->argv[2]->ptr,"set-max-intset-entries")) {
567 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
568 server.set_max_intset_entries = ll;
569 } else if (!strcasecmp(c->argv[2]->ptr,"zset-max-ziplist-entries")) {
570 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
571 server.zset_max_ziplist_entries = ll;
572 } else if (!strcasecmp(c->argv[2]->ptr,"zset-max-ziplist-value")) {
573 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
574 server.zset_max_ziplist_value = ll;
575 } else if (!strcasecmp(c->argv[2]->ptr,"lua-time-limit")) {
576 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
577 server.lua_time_limit = ll;
578 } else if (!strcasecmp(c->argv[2]->ptr,"slowlog-log-slower-than")) {
579 if (getLongLongFromObject(o,&ll) == REDIS_ERR) goto badfmt;
580 server.slowlog_log_slower_than = ll;
581 } else if (!strcasecmp(c->argv[2]->ptr,"slowlog-max-len")) {
582 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
583 server.slowlog_max_len = (unsigned)ll;
584 } else if (!strcasecmp(c->argv[2]->ptr,"loglevel")) {
585 if (!strcasecmp(o->ptr,"warning")) {
586 server.verbosity = REDIS_WARNING;
587 } else if (!strcasecmp(o->ptr,"notice")) {
588 server.verbosity = REDIS_NOTICE;
589 } else if (!strcasecmp(o->ptr,"verbose")) {
590 server.verbosity = REDIS_VERBOSE;
591 } else if (!strcasecmp(o->ptr,"debug")) {
592 server.verbosity = REDIS_DEBUG;
593 } else {
594 goto badfmt;
595 }
596 } else if (!strcasecmp(c->argv[2]->ptr,"client-output-buffer-limit")) {
597 int vlen, j;
598 sds *v = sdssplitlen(o->ptr,sdslen(o->ptr)," ",1,&vlen);
599
600 /* We need a multiple of 4: <class> <hard> <soft> <soft_seconds> */
601 if (vlen % 4) {
602 sdsfreesplitres(v,vlen);
603 goto badfmt;
604 }
605
606 /* Sanity check of single arguments, so that we either refuse the
607 * whole configuration string or accept it all, even if a single
608 * error in a single client class is present. */
609 for (j = 0; j < vlen; j++) {
610 char *eptr;
611 long val;
612
613 if ((j % 4) == 0) {
614 if (getClientLimitClassByName(v[j]) == -1) {
615 sdsfreesplitres(v,vlen);
616 goto badfmt;
617 }
618 } else {
619 val = strtoll(v[j], &eptr, 10);
620 if (eptr[0] != '\0' || val < 0) {
621 sdsfreesplitres(v,vlen);
622 goto badfmt;
623 }
624 }
625 }
626 /* Finally set the new config */
627 for (j = 0; j < vlen; j += 4) {
628 int class;
629 unsigned long long hard, soft;
630 int soft_seconds;
631
632 class = getClientLimitClassByName(v[j]);
633 hard = strtoll(v[j+1],NULL,10);
634 soft = strtoll(v[j+2],NULL,10);
635 soft_seconds = strtoll(v[j+3],NULL,10);
636
637 server.client_obuf_limits[class].hard_limit_bytes = hard;
638 server.client_obuf_limits[class].soft_limit_bytes = soft;
639 server.client_obuf_limits[class].soft_limit_seconds = soft_seconds;
640 }
641 sdsfreesplitres(v,vlen);
642 } else if (!strcasecmp(c->argv[2]->ptr,"stop-writes-on-bgsave-error")) {
643 int yn = yesnotoi(o->ptr);
644
645 if (yn == -1) goto badfmt;
646 server.stop_writes_on_bgsave_err = yn;
647 } else if (!strcasecmp(c->argv[2]->ptr,"repl-ping-slave-period")) {
648 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll <= 0) goto badfmt;
649 server.repl_ping_slave_period = ll;
650 } else if (!strcasecmp(c->argv[2]->ptr,"repl-timeout")) {
651 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll <= 0) goto badfmt;
652 server.repl_timeout = ll;
653 } else if (!strcasecmp(c->argv[2]->ptr,"watchdog-period")) {
654 if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt;
655 if (ll)
656 enableWatchdog(ll);
657 else
658 disableWatchdog();
659 } else if (!strcasecmp(c->argv[2]->ptr,"rdbcompression")) {
660 int yn = yesnotoi(o->ptr);
661
662 if (yn == -1) goto badfmt;
663 server.rdb_compression = yn;
664 } else if (!strcasecmp(c->argv[2]->ptr,"rdbchecksum")) {
665 int yn = yesnotoi(o->ptr);
666
667 if (yn == -1) goto badfmt;
668 server.rdb_checksum = yn;
669 } else {
670 addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s",
671 (char*)c->argv[2]->ptr);
672 return;
673 }
674 addReply(c,shared.ok);
675 return;
676
677badfmt: /* Bad format errors */
678 addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'",
679 (char*)o->ptr,
680 (char*)c->argv[2]->ptr);
681}
682
683#define config_get_string_field(_name,_var) do { \
684 if (stringmatch(pattern,_name,0)) { \
685 addReplyBulkCString(c,_name); \
686 addReplyBulkCString(c,_var ? _var : ""); \
687 matches++; \
688 } \
689} while(0);
690
691#define config_get_bool_field(_name,_var) do { \
692 if (stringmatch(pattern,_name,0)) { \
693 addReplyBulkCString(c,_name); \
694 addReplyBulkCString(c,_var ? "yes" : "no"); \
695 matches++; \
696 } \
697} while(0);
698
699#define config_get_numerical_field(_name,_var) do { \
700 if (stringmatch(pattern,_name,0)) { \
701 ll2string(buf,sizeof(buf),_var); \
702 addReplyBulkCString(c,_name); \
703 addReplyBulkCString(c,buf); \
704 matches++; \
705 } \
706} while(0);
707
708void configGetCommand(redisClient *c) {
709 robj *o = c->argv[2];
710 void *replylen = addDeferredMultiBulkLength(c);
711 char *pattern = o->ptr;
712 char buf[128];
713 int matches = 0;
714 redisAssertWithInfo(c,o,o->encoding == REDIS_ENCODING_RAW);
715
716 /* String values */
717 config_get_string_field("dbfilename",server.rdb_filename);
718 config_get_string_field("requirepass",server.requirepass);
719 config_get_string_field("masterauth",server.requirepass);
720 config_get_string_field("bind",server.bindaddr);
721 config_get_string_field("unixsocket",server.unixsocket);
722 config_get_string_field("logfile",server.logfile);
723 config_get_string_field("pidfile",server.pidfile);
724
725 /* Numerical values */
726 config_get_numerical_field("maxmemory",server.maxmemory);
727 config_get_numerical_field("maxmemory-samples",server.maxmemory_samples);
728 config_get_numerical_field("timeout",server.maxidletime);
729 config_get_numerical_field("auto-aof-rewrite-percentage",
730 server.aof_rewrite_perc);
731 config_get_numerical_field("auto-aof-rewrite-min-size",
732 server.aof_rewrite_min_size);
733 config_get_numerical_field("hash-max-ziplist-entries",
734 server.hash_max_ziplist_entries);
735 config_get_numerical_field("hash-max-ziplist-value",
736 server.hash_max_ziplist_value);
737 config_get_numerical_field("list-max-ziplist-entries",
738 server.list_max_ziplist_entries);
739 config_get_numerical_field("list-max-ziplist-value",
740 server.list_max_ziplist_value);
741 config_get_numerical_field("set-max-intset-entries",
742 server.set_max_intset_entries);
743 config_get_numerical_field("zset-max-ziplist-entries",
744 server.zset_max_ziplist_entries);
745 config_get_numerical_field("zset-max-ziplist-value",
746 server.zset_max_ziplist_value);
747 config_get_numerical_field("lua-time-limit",server.lua_time_limit);
748 config_get_numerical_field("slowlog-log-slower-than",
749 server.slowlog_log_slower_than);
750 config_get_numerical_field("slowlog-max-len",
751 server.slowlog_max_len);
752 config_get_numerical_field("port",server.port);
753 config_get_numerical_field("databases",server.dbnum);
754 config_get_numerical_field("repl-ping-slave-period",server.repl_ping_slave_period);
755 config_get_numerical_field("repl-timeout",server.repl_timeout);
756 config_get_numerical_field("maxclients",server.maxclients);
757 config_get_numerical_field("watchdog-period",server.watchdog_period);
758
759 /* Bool (yes/no) values */
760 config_get_bool_field("no-appendfsync-on-rewrite",
761 server.aof_no_fsync_on_rewrite);
762 config_get_bool_field("slave-serve-stale-data",
763 server.repl_serve_stale_data);
764 config_get_bool_field("slave-read-only",
765 server.repl_slave_ro);
766 config_get_bool_field("stop-writes-on-bgsave-error",
767 server.stop_writes_on_bgsave_err);
768 config_get_bool_field("daemonize", server.daemonize);
769 config_get_bool_field("rdbcompression", server.rdb_compression);
770 config_get_bool_field("rdbchecksum", server.rdb_checksum);
771 config_get_bool_field("activerehashing", server.activerehashing);
772
773 /* Everything we can't handle with macros follows. */
774
775 if (stringmatch(pattern,"appendonly",0)) {
776 addReplyBulkCString(c,"appendonly");
777 addReplyBulkCString(c,server.aof_state == REDIS_AOF_OFF ? "no" : "yes");
778 matches++;
779 }
780 if (stringmatch(pattern,"dir",0)) {
781 char buf[1024];
782
783 if (getcwd(buf,sizeof(buf)) == NULL)
784 buf[0] = '\0';
785
786 addReplyBulkCString(c,"dir");
787 addReplyBulkCString(c,buf);
788 matches++;
789 }
790 if (stringmatch(pattern,"maxmemory-policy",0)) {
791 char *s;
792
793 switch(server.maxmemory_policy) {
794 case REDIS_MAXMEMORY_VOLATILE_LRU: s = "volatile-lru"; break;
795 case REDIS_MAXMEMORY_VOLATILE_TTL: s = "volatile-ttl"; break;
796 case REDIS_MAXMEMORY_VOLATILE_RANDOM: s = "volatile-random"; break;
797 case REDIS_MAXMEMORY_ALLKEYS_LRU: s = "allkeys-lru"; break;
798 case REDIS_MAXMEMORY_ALLKEYS_RANDOM: s = "allkeys-random"; break;
799 case REDIS_MAXMEMORY_NO_EVICTION: s = "noeviction"; break;
800 default: s = "unknown"; break; /* too harmless to panic */
801 }
802 addReplyBulkCString(c,"maxmemory-policy");
803 addReplyBulkCString(c,s);
804 matches++;
805 }
806 if (stringmatch(pattern,"appendfsync",0)) {
807 char *policy;
808
809 switch(server.aof_fsync) {
810 case AOF_FSYNC_NO: policy = "no"; break;
811 case AOF_FSYNC_EVERYSEC: policy = "everysec"; break;
812 case AOF_FSYNC_ALWAYS: policy = "always"; break;
813 default: policy = "unknown"; break; /* too harmless to panic */
814 }
815 addReplyBulkCString(c,"appendfsync");
816 addReplyBulkCString(c,policy);
817 matches++;
818 }
819 if (stringmatch(pattern,"save",0)) {
820 sds buf = sdsempty();
821 int j;
822
823 for (j = 0; j < server.saveparamslen; j++) {
824 buf = sdscatprintf(buf,"%ld %d",
825 server.saveparams[j].seconds,
826 server.saveparams[j].changes);
827 if (j != server.saveparamslen-1)
828 buf = sdscatlen(buf," ",1);
829 }
830 addReplyBulkCString(c,"save");
831 addReplyBulkCString(c,buf);
832 sdsfree(buf);
833 matches++;
834 }
835 if (stringmatch(pattern,"loglevel",0)) {
836 char *s;
837
838 switch(server.verbosity) {
839 case REDIS_WARNING: s = "warning"; break;
840 case REDIS_VERBOSE: s = "verbose"; break;
841 case REDIS_NOTICE: s = "notice"; break;
842 case REDIS_DEBUG: s = "debug"; break;
843 default: s = "unknown"; break; /* too harmless to panic */
844 }
845 addReplyBulkCString(c,"loglevel");
846 addReplyBulkCString(c,s);
847 matches++;
848 }
849 if (stringmatch(pattern,"client-output-buffer-limit",0)) {
850 sds buf = sdsempty();
851 int j;
852
853 for (j = 0; j < REDIS_CLIENT_LIMIT_NUM_CLASSES; j++) {
854 buf = sdscatprintf(buf,"%s %llu %llu %ld",
855 getClientLimitClassName(j),
856 server.client_obuf_limits[j].hard_limit_bytes,
857 server.client_obuf_limits[j].soft_limit_bytes,
858 (long) server.client_obuf_limits[j].soft_limit_seconds);
859 if (j != REDIS_CLIENT_LIMIT_NUM_CLASSES-1)
860 buf = sdscatlen(buf," ",1);
861 }
862 addReplyBulkCString(c,"client-output-buffer-limit");
863 addReplyBulkCString(c,buf);
864 sdsfree(buf);
865 matches++;
866 }
867 if (stringmatch(pattern,"unixsocketperm",0)) {
868 char buf[32];
869 snprintf(buf,sizeof(buf),"%o",server.unixsocketperm);
870 addReplyBulkCString(c,"unixsocketperm");
871 addReplyBulkCString(c,buf);
872 matches++;
873 }
874 if (stringmatch(pattern,"slaveof",0)) {
875 char buf[256];
876
877 addReplyBulkCString(c,"slaveof");
878 if (server.masterhost)
879 snprintf(buf,sizeof(buf),"%s %d",
880 server.masterhost, server.masterport);
881 else
882 buf[0] = '\0';
883 addReplyBulkCString(c,buf);
884 matches++;
885 }
886 setDeferredMultiBulkLength(c,replylen,matches*2);
887}
888
889void configCommand(redisClient *c) {
890 if (!strcasecmp(c->argv[1]->ptr,"set")) {
891 if (c->argc != 4) goto badarity;
892 configSetCommand(c);
893 } else if (!strcasecmp(c->argv[1]->ptr,"get")) {
894 if (c->argc != 3) goto badarity;
895 configGetCommand(c);
896 } else if (!strcasecmp(c->argv[1]->ptr,"resetstat")) {
897 if (c->argc != 2) goto badarity;
898 server.stat_keyspace_hits = 0;
899 server.stat_keyspace_misses = 0;
900 server.stat_numcommands = 0;
901 server.stat_numconnections = 0;
902 server.stat_expiredkeys = 0;
903 server.stat_rejected_conn = 0;
904 server.stat_fork_time = 0;
905 server.aof_delayed_fsync = 0;
906 resetCommandTableStats();
907 addReply(c,shared.ok);
908 } else {
909 addReplyError(c,
910 "CONFIG subcommand must be one of GET, SET, RESETSTAT");
911 }
912 return;
913
914badarity:
915 addReplyErrorFormat(c,"Wrong number of arguments for CONFIG %s",
916 (char*) c->argv[1]->ptr);
917}