Lines Matching refs:config
81 static struct config { struct
121 } config; argument
156 if (config.eval_ldb) return; in cliRefreshPrompt()
157 if (config.hostsocket != NULL) in cliRefreshPrompt()
158 len = snprintf(config.prompt,sizeof(config.prompt),"redis %s", in cliRefreshPrompt()
159 config.hostsocket); in cliRefreshPrompt()
161 len = anetFormatAddr(config.prompt, sizeof(config.prompt), in cliRefreshPrompt()
162 config.hostip, config.hostport); in cliRefreshPrompt()
164 if (config.dbnum != 0) in cliRefreshPrompt()
165 len += snprintf(config.prompt+len,sizeof(config.prompt)-len,"[%d]", in cliRefreshPrompt()
166 config.dbnum); in cliRefreshPrompt()
167 snprintf(config.prompt+len,sizeof(config.prompt)-len,"> "); in cliRefreshPrompt()
481 if (config.auth == NULL) return REDIS_OK; in cliAuth()
483 reply = redisCommand(context,"AUTH %s",config.auth); in cliAuth()
494 if (config.dbnum == 0) return REDIS_OK; in cliSelect()
496 reply = redisCommand(context,"SELECT %d",config.dbnum); in cliSelect()
514 if (config.hostsocket == NULL) { in cliConnect()
515 context = redisConnect(config.hostip,config.hostport); in cliConnect()
517 context = redisConnectUnix(config.hostsocket); in cliConnect()
522 if (config.hostsocket == NULL) in cliConnect()
523 fprintf(stderr,"%s:%d: %s\n",config.hostip,config.hostport,context->errstr); in cliConnect()
525 fprintf(stderr,"%s: %s\n",config.hostsocket,context->errstr); in cliConnect()
677 if (r->type == REDIS_REPLY_STATUS && config.eval_ldb) { in cliFormatReplyRaw()
684 config.enable_ldb_on_eval = 0; in cliFormatReplyRaw()
685 config.eval_ldb = 0; in cliFormatReplyRaw()
686 config.eval_ldb_end = 1; /* Signal the caller session ended. */ in cliFormatReplyRaw()
687 config.output = OUTPUT_STANDARD; in cliFormatReplyRaw()
701 if (i > 0) out = sdscat(out,config.mb_delim); in cliFormatReplyRaw()
757 if (config.shutdown) { in cliReadReply()
762 if (config.interactive) { in cliReadReply()
777 config.last_cmd_type = reply->type; in cliReadReply()
781 if (config.cluster_mode && reply->type == REDIS_REPLY_ERROR && in cliReadReply()
799 sdsfree(config.hostip); in cliReadReply()
800 config.hostip = sdsnew(p+1); in cliReadReply()
801 config.hostport = atoi(s+1); in cliReadReply()
802 if (config.interactive) in cliReadReply()
804 slot, config.hostip, config.hostport); in cliReadReply()
805 config.cluster_reissue_command = 1; in cliReadReply()
813 if (config.output == OUTPUT_RAW) { in cliReadReply()
816 } else if (config.output == OUTPUT_STANDARD) { in cliReadReply()
818 } else if (config.output == OUTPUT_CSV) { in cliReadReply()
835 if (!config.eval_ldb && /* In debugging mode, let's pass "help" to Redis. */ in cliSendCommand()
861 if (!strcasecmp(command,"shutdown")) config.shutdown = 1; in cliSendCommand()
862 if (!strcasecmp(command,"monitor")) config.monitor_mode = 1; in cliSendCommand()
864 !strcasecmp(command,"psubscribe")) config.pubsub_mode = 1; in cliSendCommand()
866 !strcasecmp(command,"psync")) config.slave_mode = 1; in cliSendCommand()
874 config.enable_ldb_on_eval = 1; in cliSendCommand()
876 config.enable_ldb_on_eval = 0; in cliSendCommand()
881 if (!strcasecmp(command,"eval") && config.enable_ldb_on_eval) { in cliSendCommand()
882 config.eval_ldb = 1; in cliSendCommand()
883 config.output = OUTPUT_RAW; in cliSendCommand()
893 while (config.monitor_mode) { in cliSendCommand()
898 if (config.pubsub_mode) { in cliSendCommand()
899 if (config.output != OUTPUT_RAW) in cliSendCommand()
906 if (config.slave_mode) { in cliSendCommand()
909 config.slave_mode = 0; in cliSendCommand()
919 … if (!strcasecmp(command,"select") && argc == 2 && config.last_cmd_type != REDIS_REPLY_ERROR) { in cliSendCommand()
920 config.dbnum = atoi(argv[1]); in cliSendCommand()
926 if (config.interval) usleep(config.interval); in cliSendCommand()
948 c = redisConnect(config.hostip,config.hostport); in reconnectingRedisCommand()
979 sdsfree(config.hostip); in parseOptions()
980 config.hostip = sdsnew(argv[++i]); in parseOptions()
986 config.stdinarg = 1; in parseOptions()
988 config.hostport = atoi(argv[++i]); in parseOptions()
990 config.hostsocket = argv[++i]; in parseOptions()
992 config.repeat = strtoll(argv[++i],NULL,10); in parseOptions()
995 config.interval = seconds*1000000; in parseOptions()
997 config.dbnum = atoi(argv[++i]); in parseOptions()
999 config.auth = argv[++i]; in parseOptions()
1001 config.output = OUTPUT_RAW; in parseOptions()
1003 config.output = OUTPUT_STANDARD; in parseOptions()
1005 config.output = OUTPUT_CSV; in parseOptions()
1007 config.latency_mode = 1; in parseOptions()
1009 config.latency_dist_mode = 1; in parseOptions()
1014 config.latency_mode = 1; in parseOptions()
1015 config.latency_history = 1; in parseOptions()
1017 config.lru_test_mode = 1; in parseOptions()
1018 config.lru_test_sample_size = strtoll(argv[++i],NULL,10); in parseOptions()
1020 config.slave_mode = 1; in parseOptions()
1022 config.stat_mode = 1; in parseOptions()
1024 config.scan_mode = 1; in parseOptions()
1026 config.pattern = argv[++i]; in parseOptions()
1028 config.intrinsic_latency_mode = 1; in parseOptions()
1029 config.intrinsic_latency_duration = atoi(argv[++i]); in parseOptions()
1031 config.getrdb_mode = 1; in parseOptions()
1032 config.rdb_filename = argv[++i]; in parseOptions()
1034 config.pipe_mode = 1; in parseOptions()
1036 config.pipe_timeout = atoi(argv[++i]); in parseOptions()
1038 config.bigkeys = 1; in parseOptions()
1040 config.eval = argv[++i]; in parseOptions()
1042 config.eval_ldb = 1; in parseOptions()
1043 config.output = OUTPUT_RAW; in parseOptions()
1045 config.eval_ldb = 1; in parseOptions()
1046 config.eval_ldb_sync = 1; in parseOptions()
1047 config.output = OUTPUT_RAW; in parseOptions()
1049 config.cluster_mode = 1; in parseOptions()
1051 sdsfree(config.mb_delim); in parseOptions()
1052 config.mb_delim = sdsnew(argv[++i]); in parseOptions()
1072 if (config.eval_ldb && config.eval == NULL) { in parseOptions()
1176 config.cluster_reissue_command = 0; in issueCommandRepeat()
1188 if (config.cluster_mode && config.cluster_reissue_command) { in issueCommandRepeat()
1198 return issueCommandRepeat(argc, argv, config.repeat); in issueCommand()
1208 if (config.eval_ldb && (strstr(line,"eval ") == line || in cliSplitArgs()
1269 config.interactive = 1; in repl()
1286 while((line = linenoise(context ? config.prompt : "not connected> ")) != NULL) { in repl()
1305 if (config.eval) { in repl()
1306 config.eval_ldb = 1; in repl()
1307 config.output = OUTPUT_RAW; in repl()
1313 sdsfree(config.hostip); in repl()
1314 config.hostip = sdsnew(argv[1]); in repl()
1315 config.hostport = atoi(argv[2]); in repl()
1335 if (config.eval_ldb_end) { in repl()
1336 config.eval_ldb_end = 0; in repl()
1339 config.eval_ldb_sync ? "" : in repl()
1360 if (config.stdinarg) { in noninteractive()
1384 if (config.eval_ldb) { in evalMode()
1399 fp = fopen(config.eval,"r"); in evalMode()
1402 "Can't open file '%s': %s\n", config.eval, strerror(errno)); in evalMode()
1411 if (config.eval_ldb) { in evalMode()
1413 config.eval_ldb_sync ? in evalMode()
1433 int eval_ldb = config.eval_ldb; /* Save it, may be reverteed. */ in evalMode()
1436 if (!config.eval_ldb) { in evalMode()
1444 strncpy(config.prompt,"lua debugger> ",sizeof(config.prompt)); in evalMode()
1467 config.interval ? config.interval/1000 : in latencyMode()
1495 if (config.latency_history && mstime()-history_start > history_interval) in latencyMode()
1573 config.interval ? config.interval/1000 : in latencyDistMode()
1690 int original_output = config.output; in slaveMode()
1709 config.output = OUTPUT_CSV; in slaveMode()
1711 config.output = original_output; in slaveMode()
1727 payload, config.rdb_filename); in getRDB()
1730 if (!strcmp(config.rdb_filename,"-")) { in getRDB()
1733 fd = open(config.rdb_filename, O_CREAT|O_WRONLY, 0644); in getRDB()
1735 fprintf(stderr, "Error opening '%s': %s\n", config.rdb_filename, in getRDB()
1906 if (eof && config.pipe_timeout > 0 && in pipeMode()
1907 time(NULL)-last_read_time > config.pipe_timeout) in pipeMode()
1910 config.pipe_timeout); in pipeMode()
2158 if(sampled && (sampled %100) == 0 && config.interval) { in findBigKeys()
2159 usleep(config.interval); in findBigKeys()
2344 usleep(config.interval); in statMode()
2357 if (config.pattern) in scanMode()
2359 cur,config.pattern); in scanMode()
2406 powerLawRand(1, config.lru_test_sample_size, 6.2)); in LRUTestGenKey()
2508 run_time = config.intrinsic_latency_duration*1000000; in intrinsicLatencyMode()
2549 config.hostip = sdsnew("127.0.0.1"); in main()
2550 config.hostport = 6379; in main()
2551 config.hostsocket = NULL; in main()
2552 config.repeat = 1; in main()
2553 config.interval = 0; in main()
2554 config.dbnum = 0; in main()
2555 config.interactive = 0; in main()
2556 config.shutdown = 0; in main()
2557 config.monitor_mode = 0; in main()
2558 config.pubsub_mode = 0; in main()
2559 config.latency_mode = 0; in main()
2560 config.latency_dist_mode = 0; in main()
2561 config.latency_history = 0; in main()
2562 config.lru_test_mode = 0; in main()
2563 config.lru_test_sample_size = 0; in main()
2564 config.cluster_mode = 0; in main()
2565 config.slave_mode = 0; in main()
2566 config.getrdb_mode = 0; in main()
2567 config.stat_mode = 0; in main()
2568 config.scan_mode = 0; in main()
2569 config.intrinsic_latency_mode = 0; in main()
2570 config.pattern = NULL; in main()
2571 config.rdb_filename = NULL; in main()
2572 config.pipe_mode = 0; in main()
2573 config.pipe_timeout = REDIS_CLI_DEFAULT_PIPE_TIMEOUT; in main()
2574 config.bigkeys = 0; in main()
2575 config.stdinarg = 0; in main()
2576 config.auth = NULL; in main()
2577 config.eval = NULL; in main()
2578 config.eval_ldb = 0; in main()
2579 config.eval_ldb_end = 0; in main()
2580 config.eval_ldb_sync = 0; in main()
2581 config.enable_ldb_on_eval = 0; in main()
2582 config.last_cmd_type = -1; in main()
2590 config.output = OUTPUT_RAW; in main()
2592 config.output = OUTPUT_STANDARD; in main()
2593 config.mb_delim = sdsnew("\n"); in main()
2605 if (config.latency_mode) { in main()
2611 if (config.latency_dist_mode) { in main()
2617 if (config.slave_mode) { in main()
2623 if (config.getrdb_mode) { in main()
2629 if (config.pipe_mode) { in main()
2635 if (config.bigkeys) { in main()
2641 if (config.stat_mode) { in main()
2643 if (config.interval == 0) config.interval = 1000000; in main()
2648 if (config.scan_mode) { in main()
2654 if (config.lru_test_mode) { in main()
2660 if (config.intrinsic_latency_mode) intrinsicLatencyMode(); in main()
2663 if (argc == 0 && !config.eval) { in main()
2675 if (config.eval) { in main()