]>
Commit | Line | Data |
---|---|---|
e2641e09 | 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 */ | |
297e77c6 | 58 | argv = sdssplitargs(line,&argc); |
e2641e09 | 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]); | |
df50d707 | 69 | if (server.port < 0 || server.port > 65535) { |
e2641e09 | 70 | err = "Invalid port"; goto loaderr; |
71 | } | |
72 | } else if (!strcasecmp(argv[0],"bind") && argc == 2) { | |
73 | server.bindaddr = zstrdup(argv[1]); | |
5d10923f PN |
74 | } else if (!strcasecmp(argv[0],"unixsocket") && argc == 2) { |
75 | server.unixsocket = zstrdup(argv[1]); | |
e2641e09 | 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 | } | |
e1a586ee JH |
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 | } | |
e2641e09 | 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); | |
165346ca | 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; | |
5402c426 | 175 | } else if (!strcasecmp(argv[1],"noeviction")) { |
176 | server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION; | |
165346ca | 177 | } else { |
178 | err = "Invalid maxmemory policy"; | |
179 | goto loaderr; | |
180 | } | |
a3687929 | 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 | } | |
e2641e09 | 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]); | |
4ebfc455 | 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 | } | |
a510cb0c PN |
197 | } else if (!strcasecmp(argv[0],"glueoutputbuf")) { |
198 | redisLog(REDIS_WARNING, "Deprecated configuration directive: \"%s\"", argv[0]); | |
e2641e09 | 199 | } else if (!strcasecmp(argv[0],"rdbcompression") && argc == 2) { |
200 | if ((server.rdbcompression = yesnotoi(argv[1])) == -1) { | |
201 | err = "argument must be 'yes' or 'no'"; goto loaderr; | |
202 | } | |
203 | } else if (!strcasecmp(argv[0],"activerehashing") && argc == 2) { | |
204 | if ((server.activerehashing = yesnotoi(argv[1])) == -1) { | |
205 | err = "argument must be 'yes' or 'no'"; goto loaderr; | |
206 | } | |
207 | } else if (!strcasecmp(argv[0],"daemonize") && argc == 2) { | |
208 | if ((server.daemonize = yesnotoi(argv[1])) == -1) { | |
209 | err = "argument must be 'yes' or 'no'"; goto loaderr; | |
210 | } | |
211 | } else if (!strcasecmp(argv[0],"appendonly") && argc == 2) { | |
212 | if ((server.appendonly = yesnotoi(argv[1])) == -1) { | |
213 | err = "argument must be 'yes' or 'no'"; goto loaderr; | |
214 | } | |
215 | } else if (!strcasecmp(argv[0],"appendfilename") && argc == 2) { | |
216 | zfree(server.appendfilename); | |
217 | server.appendfilename = zstrdup(argv[1]); | |
218 | } else if (!strcasecmp(argv[0],"no-appendfsync-on-rewrite") | |
219 | && argc == 2) { | |
220 | if ((server.no_appendfsync_on_rewrite= yesnotoi(argv[1])) == -1) { | |
221 | err = "argument must be 'yes' or 'no'"; goto loaderr; | |
222 | } | |
223 | } else if (!strcasecmp(argv[0],"appendfsync") && argc == 2) { | |
224 | if (!strcasecmp(argv[1],"no")) { | |
225 | server.appendfsync = APPENDFSYNC_NO; | |
226 | } else if (!strcasecmp(argv[1],"always")) { | |
227 | server.appendfsync = APPENDFSYNC_ALWAYS; | |
228 | } else if (!strcasecmp(argv[1],"everysec")) { | |
229 | server.appendfsync = APPENDFSYNC_EVERYSEC; | |
230 | } else { | |
231 | err = "argument must be 'no', 'always' or 'everysec'"; | |
232 | goto loaderr; | |
233 | } | |
b333e239 | 234 | } else if (!strcasecmp(argv[0],"auto-aof-rewrite-percentage") && |
235 | argc == 2) | |
236 | { | |
4ff34b6a | 237 | server.auto_aofrewrite_perc = atoi(argv[1]); |
b333e239 | 238 | if (server.auto_aofrewrite_perc < 0) { |
239 | err = "Invalid negative percentage for AOF auto rewrite"; | |
240 | goto loaderr; | |
241 | } | |
242 | } else if (!strcasecmp(argv[0],"auto-aof-rewrite-min-size") && | |
243 | argc == 2) | |
244 | { | |
245 | server.auto_aofrewrite_min_size = memtoll(argv[1],NULL); | |
e2641e09 | 246 | } else if (!strcasecmp(argv[0],"requirepass") && argc == 2) { |
247 | server.requirepass = zstrdup(argv[1]); | |
248 | } else if (!strcasecmp(argv[0],"pidfile") && argc == 2) { | |
249 | zfree(server.pidfile); | |
250 | server.pidfile = zstrdup(argv[1]); | |
251 | } else if (!strcasecmp(argv[0],"dbfilename") && argc == 2) { | |
252 | zfree(server.dbfilename); | |
253 | server.dbfilename = zstrdup(argv[1]); | |
16d77878 | 254 | } else if (!strcasecmp(argv[0],"diskstore-enabled") && argc == 2) { |
255 | if ((server.ds_enabled = yesnotoi(argv[1])) == -1) { | |
e2641e09 | 256 | err = "argument must be 'yes' or 'no'"; goto loaderr; |
257 | } | |
16d77878 | 258 | } else if (!strcasecmp(argv[0],"diskstore-path") && argc == 2) { |
4ab98823 | 259 | sdsfree(server.ds_path); |
260 | server.ds_path = sdsnew(argv[1]); | |
16d77878 | 261 | } else if (!strcasecmp(argv[0],"cache-max-memory") && argc == 2) { |
262 | server.cache_max_memory = memtoll(argv[1],NULL); | |
82ef6ebf | 263 | } else if (!strcasecmp(argv[0],"cache-flush-delay") && argc == 2) { |
264 | server.cache_flush_delay = atoi(argv[1]); | |
265 | if (server.cache_flush_delay < 0) server.cache_flush_delay = 0; | |
8d3e063a | 266 | } else if (!strcasecmp(argv[0],"hash-max-zipmap-entries") && argc == 2) { |
e2641e09 | 267 | server.hash_max_zipmap_entries = memtoll(argv[1], NULL); |
8d3e063a | 268 | } else if (!strcasecmp(argv[0],"hash-max-zipmap-value") && argc == 2) { |
e2641e09 | 269 | server.hash_max_zipmap_value = memtoll(argv[1], NULL); |
270 | } else if (!strcasecmp(argv[0],"list-max-ziplist-entries") && argc == 2){ | |
271 | server.list_max_ziplist_entries = memtoll(argv[1], NULL); | |
8d3e063a | 272 | } else if (!strcasecmp(argv[0],"list-max-ziplist-value") && argc == 2) { |
e2641e09 | 273 | server.list_max_ziplist_value = memtoll(argv[1], NULL); |
8d3e063a | 274 | } else if (!strcasecmp(argv[0],"set-max-intset-entries") && argc == 2) { |
96ffb2fe | 275 | server.set_max_intset_entries = memtoll(argv[1], NULL); |
3ea204e1 PN |
276 | } else if (!strcasecmp(argv[0],"zset-max-ziplist-entries") && argc == 2) { |
277 | server.zset_max_ziplist_entries = memtoll(argv[1], NULL); | |
278 | } else if (!strcasecmp(argv[0],"zset-max-ziplist-value") && argc == 2) { | |
279 | server.zset_max_ziplist_value = memtoll(argv[1], NULL); | |
8d3e063a | 280 | } else if (!strcasecmp(argv[0],"rename-command") && argc == 3) { |
281 | struct redisCommand *cmd = lookupCommand(argv[1]); | |
282 | int retval; | |
283 | ||
284 | if (!cmd) { | |
285 | err = "No such command in rename-command"; | |
286 | goto loaderr; | |
287 | } | |
288 | ||
289 | /* If the target command name is the emtpy string we just | |
290 | * remove it from the command table. */ | |
291 | retval = dictDelete(server.commands, argv[1]); | |
292 | redisAssert(retval == DICT_OK); | |
293 | ||
294 | /* Otherwise we re-add the command under a different name. */ | |
295 | if (sdslen(argv[2]) != 0) { | |
296 | sds copy = sdsdup(argv[2]); | |
297 | ||
298 | retval = dictAdd(server.commands, copy, cmd); | |
299 | if (retval != DICT_OK) { | |
300 | sdsfree(copy); | |
301 | err = "Target command name already exists"; goto loaderr; | |
302 | } | |
303 | } | |
ecc91094 | 304 | } else if (!strcasecmp(argv[0],"cluster-enabled") && argc == 2) { |
305 | if ((server.cluster_enabled = yesnotoi(argv[1])) == -1) { | |
306 | err = "argument must be 'yes' or 'no'"; goto loaderr; | |
307 | } | |
1793752d | 308 | } else if (!strcasecmp(argv[0],"cluster-config-file") && argc == 2) { |
309 | zfree(server.cluster.configfile); | |
310 | server.cluster.configfile = zstrdup(argv[1]); | |
e2641e09 | 311 | } else { |
312 | err = "Bad directive or wrong number of arguments"; goto loaderr; | |
313 | } | |
314 | for (j = 0; j < argc; j++) | |
315 | sdsfree(argv[j]); | |
316 | zfree(argv); | |
317 | sdsfree(line); | |
318 | } | |
319 | if (fp != stdin) fclose(fp); | |
320 | return; | |
321 | ||
322 | loaderr: | |
323 | fprintf(stderr, "\n*** FATAL CONFIG FILE ERROR ***\n"); | |
324 | fprintf(stderr, "Reading the configuration file, at line %d\n", linenum); | |
325 | fprintf(stderr, ">>> '%s'\n", line); | |
326 | fprintf(stderr, "%s\n", err); | |
327 | exit(1); | |
328 | } | |
329 | ||
330 | /*----------------------------------------------------------------------------- | |
331 | * CONFIG command for remote configuration | |
332 | *----------------------------------------------------------------------------*/ | |
333 | ||
334 | void configSetCommand(redisClient *c) { | |
a375b077 | 335 | robj *o; |
e2641e09 | 336 | long long ll; |
a375b077 PN |
337 | redisAssert(c->argv[2]->encoding == REDIS_ENCODING_RAW); |
338 | redisAssert(c->argv[3]->encoding == REDIS_ENCODING_RAW); | |
339 | o = c->argv[3]; | |
e2641e09 | 340 | |
341 | if (!strcasecmp(c->argv[2]->ptr,"dbfilename")) { | |
342 | zfree(server.dbfilename); | |
343 | server.dbfilename = zstrdup(o->ptr); | |
344 | } else if (!strcasecmp(c->argv[2]->ptr,"requirepass")) { | |
345 | zfree(server.requirepass); | |
346 | server.requirepass = zstrdup(o->ptr); | |
347 | } else if (!strcasecmp(c->argv[2]->ptr,"masterauth")) { | |
348 | zfree(server.masterauth); | |
349 | server.masterauth = zstrdup(o->ptr); | |
350 | } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory")) { | |
351 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || | |
352 | ll < 0) goto badfmt; | |
353 | server.maxmemory = ll; | |
b4f2e412 | 354 | if (server.maxmemory) freeMemoryIfNeeded(); |
165346ca | 355 | } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-policy")) { |
356 | if (!strcasecmp(o->ptr,"volatile-lru")) { | |
357 | server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_LRU; | |
358 | } else if (!strcasecmp(o->ptr,"volatile-random")) { | |
359 | server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_RANDOM; | |
360 | } else if (!strcasecmp(o->ptr,"volatile-ttl")) { | |
361 | server.maxmemory_policy = REDIS_MAXMEMORY_VOLATILE_TTL; | |
362 | } else if (!strcasecmp(o->ptr,"allkeys-lru")) { | |
363 | server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_LRU; | |
364 | } else if (!strcasecmp(o->ptr,"allkeys-random")) { | |
365 | server.maxmemory_policy = REDIS_MAXMEMORY_ALLKEYS_RANDOM; | |
5402c426 | 366 | } else if (!strcasecmp(o->ptr,"noeviction")) { |
367 | server.maxmemory_policy = REDIS_MAXMEMORY_NO_EVICTION; | |
165346ca | 368 | } else { |
369 | goto badfmt; | |
370 | } | |
a3687929 | 371 | } else if (!strcasecmp(c->argv[2]->ptr,"maxmemory-samples")) { |
372 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || | |
373 | ll <= 0) goto badfmt; | |
374 | server.maxmemory_samples = ll; | |
e2641e09 | 375 | } else if (!strcasecmp(c->argv[2]->ptr,"timeout")) { |
376 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || | |
377 | ll < 0 || ll > LONG_MAX) goto badfmt; | |
378 | server.maxidletime = ll; | |
379 | } else if (!strcasecmp(c->argv[2]->ptr,"appendfsync")) { | |
380 | if (!strcasecmp(o->ptr,"no")) { | |
381 | server.appendfsync = APPENDFSYNC_NO; | |
382 | } else if (!strcasecmp(o->ptr,"everysec")) { | |
383 | server.appendfsync = APPENDFSYNC_EVERYSEC; | |
384 | } else if (!strcasecmp(o->ptr,"always")) { | |
385 | server.appendfsync = APPENDFSYNC_ALWAYS; | |
386 | } else { | |
387 | goto badfmt; | |
388 | } | |
389 | } else if (!strcasecmp(c->argv[2]->ptr,"no-appendfsync-on-rewrite")) { | |
390 | int yn = yesnotoi(o->ptr); | |
391 | ||
392 | if (yn == -1) goto badfmt; | |
393 | server.no_appendfsync_on_rewrite = yn; | |
394 | } else if (!strcasecmp(c->argv[2]->ptr,"appendonly")) { | |
395 | int old = server.appendonly; | |
396 | int new = yesnotoi(o->ptr); | |
397 | ||
398 | if (new == -1) goto badfmt; | |
399 | if (old != new) { | |
400 | if (new == 0) { | |
401 | stopAppendOnly(); | |
402 | } else { | |
403 | if (startAppendOnly() == REDIS_ERR) { | |
3ab20376 PN |
404 | addReplyError(c, |
405 | "Unable to turn on AOF. Check server logs."); | |
e2641e09 | 406 | return; |
407 | } | |
408 | } | |
409 | } | |
0ec93220 | 410 | } else if (!strcasecmp(c->argv[2]->ptr,"auto-aof-rewrite-percentage")) { |
411 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
412 | server.auto_aofrewrite_perc = ll; | |
413 | } else if (!strcasecmp(c->argv[2]->ptr,"auto-aof-rewrite-min-size")) { | |
414 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
415 | server.auto_aofrewrite_min_size = ll; | |
e2641e09 | 416 | } else if (!strcasecmp(c->argv[2]->ptr,"save")) { |
417 | int vlen, j; | |
418 | sds *v = sdssplitlen(o->ptr,sdslen(o->ptr)," ",1,&vlen); | |
419 | ||
420 | /* Perform sanity check before setting the new config: | |
421 | * - Even number of args | |
422 | * - Seconds >= 1, changes >= 0 */ | |
423 | if (vlen & 1) { | |
424 | sdsfreesplitres(v,vlen); | |
425 | goto badfmt; | |
426 | } | |
427 | for (j = 0; j < vlen; j++) { | |
428 | char *eptr; | |
429 | long val; | |
430 | ||
431 | val = strtoll(v[j], &eptr, 10); | |
432 | if (eptr[0] != '\0' || | |
433 | ((j & 1) == 0 && val < 1) || | |
434 | ((j & 1) == 1 && val < 0)) { | |
435 | sdsfreesplitres(v,vlen); | |
436 | goto badfmt; | |
437 | } | |
438 | } | |
439 | /* Finally set the new config */ | |
440 | resetServerSaveParams(); | |
441 | for (j = 0; j < vlen; j += 2) { | |
442 | time_t seconds; | |
443 | int changes; | |
444 | ||
445 | seconds = strtoll(v[j],NULL,10); | |
446 | changes = strtoll(v[j+1],NULL,10); | |
447 | appendServerSaveParams(seconds, changes); | |
448 | } | |
449 | sdsfreesplitres(v,vlen); | |
4ebfc455 | 450 | } else if (!strcasecmp(c->argv[2]->ptr,"slave-serve-stale-data")) { |
451 | int yn = yesnotoi(o->ptr); | |
452 | ||
453 | if (yn == -1) goto badfmt; | |
454 | server.repl_serve_stale_data = yn; | |
21cda08b | 455 | } else if (!strcasecmp(c->argv[2]->ptr,"dir")) { |
456 | if (chdir((char*)o->ptr) == -1) { | |
457 | addReplyErrorFormat(c,"Changing directory: %s", strerror(errno)); | |
458 | return; | |
459 | } | |
465b4189 | 460 | } else if (!strcasecmp(c->argv[2]->ptr,"hash-max-zipmap-entries")) { |
461 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
462 | server.hash_max_zipmap_entries = ll; | |
463 | } else if (!strcasecmp(c->argv[2]->ptr,"hash-max-zipmap-value")) { | |
464 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
465 | server.hash_max_zipmap_value = ll; | |
466 | } else if (!strcasecmp(c->argv[2]->ptr,"list-max-ziplist-entries")) { | |
467 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
468 | server.list_max_ziplist_entries = ll; | |
469 | } else if (!strcasecmp(c->argv[2]->ptr,"list-max-ziplist-value")) { | |
470 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
471 | server.list_max_ziplist_value = ll; | |
472 | } else if (!strcasecmp(c->argv[2]->ptr,"set-max-intset-entries")) { | |
473 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
474 | server.set_max_intset_entries = ll; | |
3ea204e1 PN |
475 | } else if (!strcasecmp(c->argv[2]->ptr,"zset-max-ziplist-entries")) { |
476 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
477 | server.zset_max_ziplist_entries = ll; | |
478 | } else if (!strcasecmp(c->argv[2]->ptr,"zset-max-ziplist-value")) { | |
479 | if (getLongLongFromObject(o,&ll) == REDIS_ERR || ll < 0) goto badfmt; | |
480 | server.zset_max_ziplist_value = ll; | |
e2641e09 | 481 | } else { |
3ab20376 PN |
482 | addReplyErrorFormat(c,"Unsupported CONFIG parameter: %s", |
483 | (char*)c->argv[2]->ptr); | |
e2641e09 | 484 | return; |
485 | } | |
e2641e09 | 486 | addReply(c,shared.ok); |
487 | return; | |
488 | ||
489 | badfmt: /* Bad format errors */ | |
3ab20376 | 490 | addReplyErrorFormat(c,"Invalid argument '%s' for CONFIG SET '%s'", |
e2641e09 | 491 | (char*)o->ptr, |
3ab20376 | 492 | (char*)c->argv[2]->ptr); |
e2641e09 | 493 | } |
494 | ||
495 | void configGetCommand(redisClient *c) { | |
a375b077 | 496 | robj *o = c->argv[2]; |
b301c1fc | 497 | void *replylen = addDeferredMultiBulkLength(c); |
e2641e09 | 498 | char *pattern = o->ptr; |
a3687929 | 499 | char buf[128]; |
e2641e09 | 500 | int matches = 0; |
a375b077 | 501 | redisAssert(o->encoding == REDIS_ENCODING_RAW); |
e2641e09 | 502 | |
21cda08b | 503 | if (stringmatch(pattern,"dir",0)) { |
504 | char buf[1024]; | |
505 | ||
21cda08b | 506 | addReplyBulkCString(c,"dir"); |
09d2abdc | 507 | if (getcwd(buf,sizeof(buf)) == NULL) { |
508 | buf[0] = '\0'; | |
509 | } else { | |
510 | addReplyBulkCString(c,buf); | |
511 | } | |
21cda08b | 512 | matches++; |
513 | } | |
e2641e09 | 514 | if (stringmatch(pattern,"dbfilename",0)) { |
515 | addReplyBulkCString(c,"dbfilename"); | |
516 | addReplyBulkCString(c,server.dbfilename); | |
517 | matches++; | |
518 | } | |
519 | if (stringmatch(pattern,"requirepass",0)) { | |
520 | addReplyBulkCString(c,"requirepass"); | |
521 | addReplyBulkCString(c,server.requirepass); | |
522 | matches++; | |
523 | } | |
524 | if (stringmatch(pattern,"masterauth",0)) { | |
525 | addReplyBulkCString(c,"masterauth"); | |
526 | addReplyBulkCString(c,server.masterauth); | |
527 | matches++; | |
528 | } | |
529 | if (stringmatch(pattern,"maxmemory",0)) { | |
a3687929 | 530 | ll2string(buf,sizeof(buf),server.maxmemory); |
e2641e09 | 531 | addReplyBulkCString(c,"maxmemory"); |
532 | addReplyBulkCString(c,buf); | |
533 | matches++; | |
534 | } | |
165346ca | 535 | if (stringmatch(pattern,"maxmemory-policy",0)) { |
536 | char *s; | |
537 | ||
538 | switch(server.maxmemory_policy) { | |
539 | case REDIS_MAXMEMORY_VOLATILE_LRU: s = "volatile-lru"; break; | |
540 | case REDIS_MAXMEMORY_VOLATILE_TTL: s = "volatile-ttl"; break; | |
541 | case REDIS_MAXMEMORY_VOLATILE_RANDOM: s = "volatile-random"; break; | |
542 | case REDIS_MAXMEMORY_ALLKEYS_LRU: s = "allkeys-lru"; break; | |
543 | case REDIS_MAXMEMORY_ALLKEYS_RANDOM: s = "allkeys-random"; break; | |
5402c426 | 544 | case REDIS_MAXMEMORY_NO_EVICTION: s = "noeviction"; break; |
165346ca | 545 | default: s = "unknown"; break; /* too harmless to panic */ |
546 | } | |
547 | addReplyBulkCString(c,"maxmemory-policy"); | |
548 | addReplyBulkCString(c,s); | |
549 | matches++; | |
550 | } | |
a3687929 | 551 | if (stringmatch(pattern,"maxmemory-samples",0)) { |
552 | ll2string(buf,sizeof(buf),server.maxmemory_samples); | |
553 | addReplyBulkCString(c,"maxmemory-samples"); | |
554 | addReplyBulkCString(c,buf); | |
555 | matches++; | |
556 | } | |
e2641e09 | 557 | if (stringmatch(pattern,"timeout",0)) { |
a3687929 | 558 | ll2string(buf,sizeof(buf),server.maxidletime); |
e2641e09 | 559 | addReplyBulkCString(c,"timeout"); |
560 | addReplyBulkCString(c,buf); | |
561 | matches++; | |
562 | } | |
563 | if (stringmatch(pattern,"appendonly",0)) { | |
564 | addReplyBulkCString(c,"appendonly"); | |
565 | addReplyBulkCString(c,server.appendonly ? "yes" : "no"); | |
566 | matches++; | |
567 | } | |
568 | if (stringmatch(pattern,"no-appendfsync-on-rewrite",0)) { | |
569 | addReplyBulkCString(c,"no-appendfsync-on-rewrite"); | |
570 | addReplyBulkCString(c,server.no_appendfsync_on_rewrite ? "yes" : "no"); | |
571 | matches++; | |
572 | } | |
573 | if (stringmatch(pattern,"appendfsync",0)) { | |
574 | char *policy; | |
575 | ||
576 | switch(server.appendfsync) { | |
577 | case APPENDFSYNC_NO: policy = "no"; break; | |
578 | case APPENDFSYNC_EVERYSEC: policy = "everysec"; break; | |
579 | case APPENDFSYNC_ALWAYS: policy = "always"; break; | |
580 | default: policy = "unknown"; break; /* too harmless to panic */ | |
581 | } | |
582 | addReplyBulkCString(c,"appendfsync"); | |
583 | addReplyBulkCString(c,policy); | |
584 | matches++; | |
585 | } | |
586 | if (stringmatch(pattern,"save",0)) { | |
587 | sds buf = sdsempty(); | |
588 | int j; | |
589 | ||
590 | for (j = 0; j < server.saveparamslen; j++) { | |
591 | buf = sdscatprintf(buf,"%ld %d", | |
592 | server.saveparams[j].seconds, | |
593 | server.saveparams[j].changes); | |
594 | if (j != server.saveparamslen-1) | |
595 | buf = sdscatlen(buf," ",1); | |
596 | } | |
597 | addReplyBulkCString(c,"save"); | |
598 | addReplyBulkCString(c,buf); | |
599 | sdsfree(buf); | |
600 | matches++; | |
601 | } | |
0ec93220 | 602 | if (stringmatch(pattern,"auto-aof-rewrite-percentage",0)) { |
603 | addReplyBulkCString(c,"auto-aof-rewrite-percentage"); | |
604 | addReplyBulkLongLong(c,server.auto_aofrewrite_perc); | |
605 | matches++; | |
606 | } | |
607 | if (stringmatch(pattern,"auto-aof-rewrite-min-size",0)) { | |
608 | addReplyBulkCString(c,"auto-aof-rewrite-min-size"); | |
609 | addReplyBulkLongLong(c,server.auto_aofrewrite_min_size); | |
610 | matches++; | |
611 | } | |
4ebfc455 | 612 | if (stringmatch(pattern,"slave-serve-stale-data",0)) { |
613 | addReplyBulkCString(c,"slave-serve-stale-data"); | |
614 | addReplyBulkCString(c,server.repl_serve_stale_data ? "yes" : "no"); | |
615 | matches++; | |
616 | } | |
465b4189 | 617 | if (stringmatch(pattern,"hash-max-zipmap-entries",0)) { |
618 | addReplyBulkCString(c,"hash-max-zipmap-entries"); | |
619 | addReplyBulkLongLong(c,server.hash_max_zipmap_entries); | |
620 | matches++; | |
621 | } | |
622 | if (stringmatch(pattern,"hash-max-zipmap-value",0)) { | |
623 | addReplyBulkCString(c,"hash-max-zipmap-value"); | |
624 | addReplyBulkLongLong(c,server.hash_max_zipmap_value); | |
625 | matches++; | |
626 | } | |
627 | if (stringmatch(pattern,"list-max-ziplist-entries",0)) { | |
628 | addReplyBulkCString(c,"list-max-ziplist-entries"); | |
629 | addReplyBulkLongLong(c,server.list_max_ziplist_entries); | |
630 | matches++; | |
631 | } | |
632 | if (stringmatch(pattern,"list-max-ziplist-value",0)) { | |
633 | addReplyBulkCString(c,"list-max-ziplist-value"); | |
634 | addReplyBulkLongLong(c,server.list_max_ziplist_value); | |
635 | matches++; | |
636 | } | |
637 | if (stringmatch(pattern,"set-max-intset-entries",0)) { | |
638 | addReplyBulkCString(c,"set-max-intset-entries"); | |
639 | addReplyBulkLongLong(c,server.set_max_intset_entries); | |
640 | matches++; | |
641 | } | |
3ea204e1 PN |
642 | if (stringmatch(pattern,"zset-max-ziplist-entries",0)) { |
643 | addReplyBulkCString(c,"zset-max-ziplist-entries"); | |
644 | addReplyBulkLongLong(c,server.zset_max_ziplist_entries); | |
645 | matches++; | |
646 | } | |
647 | if (stringmatch(pattern,"zset-max-ziplist-value",0)) { | |
648 | addReplyBulkCString(c,"zset-max-ziplist-value"); | |
649 | addReplyBulkLongLong(c,server.zset_max_ziplist_value); | |
650 | matches++; | |
651 | } | |
b301c1fc | 652 | setDeferredMultiBulkLength(c,replylen,matches*2); |
e2641e09 | 653 | } |
654 | ||
655 | void configCommand(redisClient *c) { | |
656 | if (!strcasecmp(c->argv[1]->ptr,"set")) { | |
657 | if (c->argc != 4) goto badarity; | |
658 | configSetCommand(c); | |
659 | } else if (!strcasecmp(c->argv[1]->ptr,"get")) { | |
660 | if (c->argc != 3) goto badarity; | |
661 | configGetCommand(c); | |
662 | } else if (!strcasecmp(c->argv[1]->ptr,"resetstat")) { | |
663 | if (c->argc != 2) goto badarity; | |
9f8ded8c | 664 | server.stat_keyspace_hits = 0; |
665 | server.stat_keyspace_misses = 0; | |
e2641e09 | 666 | server.stat_numcommands = 0; |
667 | server.stat_numconnections = 0; | |
668 | server.stat_expiredkeys = 0; | |
d7ed7fd2 | 669 | resetCommandTableStats(); |
e2641e09 | 670 | addReply(c,shared.ok); |
671 | } else { | |
3ab20376 PN |
672 | addReplyError(c, |
673 | "CONFIG subcommand must be one of GET, SET, RESETSTAT"); | |
e2641e09 | 674 | } |
675 | return; | |
676 | ||
677 | badarity: | |
3ab20376 PN |
678 | addReplyErrorFormat(c,"Wrong number of arguments for CONFIG %s", |
679 | (char*) c->argv[1]->ptr); | |
e2641e09 | 680 | } |