mirror of
https://github.com/fluencelabs/redis
synced 2025-03-19 17:10:50 +00:00
redis-cli INFO output format is now raw again
This commit is contained in:
parent
0ce7679849
commit
f40b035d7b
219
redis-cli.c
219
redis-cli.c
@ -56,120 +56,125 @@ static struct config {
|
|||||||
int interactive;
|
int interactive;
|
||||||
int monitor_mode;
|
int monitor_mode;
|
||||||
int pubsub_mode;
|
int pubsub_mode;
|
||||||
|
int raw_output;
|
||||||
char *auth;
|
char *auth;
|
||||||
} config;
|
} config;
|
||||||
|
|
||||||
struct redisCommand {
|
struct redisCommand {
|
||||||
char *name;
|
char *name;
|
||||||
int arity;
|
int arity;
|
||||||
|
int flags;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
#define CMDFLAG_NONE 0
|
||||||
|
#define CMDFLAG_RAWOUTPUT 1
|
||||||
|
|
||||||
static struct redisCommand cmdTable[] = {
|
static struct redisCommand cmdTable[] = {
|
||||||
{"auth",2},
|
{"auth",2,CMDFLAG_NONE},
|
||||||
{"get",2},
|
{"get",2,CMDFLAG_NONE},
|
||||||
{"set",3},
|
{"set",3,CMDFLAG_NONE},
|
||||||
{"setnx",3},
|
{"setnx",3,CMDFLAG_NONE},
|
||||||
{"setex",4},
|
{"setex",4,CMDFLAG_NONE},
|
||||||
{"append",3},
|
{"append",3,CMDFLAG_NONE},
|
||||||
{"substr",4},
|
{"substr",4,CMDFLAG_NONE},
|
||||||
{"del",-2},
|
{"del",-2,CMDFLAG_NONE},
|
||||||
{"exists",2},
|
{"exists",2,CMDFLAG_NONE},
|
||||||
{"incr",2},
|
{"incr",2,CMDFLAG_NONE},
|
||||||
{"decr",2},
|
{"decr",2,CMDFLAG_NONE},
|
||||||
{"rpush",3},
|
{"rpush",3,CMDFLAG_NONE},
|
||||||
{"lpush",3},
|
{"lpush",3,CMDFLAG_NONE},
|
||||||
{"rpop",2},
|
{"rpop",2,CMDFLAG_NONE},
|
||||||
{"lpop",2},
|
{"lpop",2,CMDFLAG_NONE},
|
||||||
{"brpop",-3},
|
{"brpop",-3,CMDFLAG_NONE},
|
||||||
{"blpop",-3},
|
{"blpop",-3,CMDFLAG_NONE},
|
||||||
{"llen",2},
|
{"llen",2,CMDFLAG_NONE},
|
||||||
{"lindex",3},
|
{"lindex",3,CMDFLAG_NONE},
|
||||||
{"lset",4},
|
{"lset",4,CMDFLAG_NONE},
|
||||||
{"lrange",4},
|
{"lrange",4,CMDFLAG_NONE},
|
||||||
{"ltrim",4},
|
{"ltrim",4,CMDFLAG_NONE},
|
||||||
{"lrem",4},
|
{"lrem",4,CMDFLAG_NONE},
|
||||||
{"rpoplpush",3},
|
{"rpoplpush",3,CMDFLAG_NONE},
|
||||||
{"sadd",3},
|
{"sadd",3,CMDFLAG_NONE},
|
||||||
{"srem",3},
|
{"srem",3,CMDFLAG_NONE},
|
||||||
{"smove",4},
|
{"smove",4,CMDFLAG_NONE},
|
||||||
{"sismember",3},
|
{"sismember",3,CMDFLAG_NONE},
|
||||||
{"scard",2},
|
{"scard",2,CMDFLAG_NONE},
|
||||||
{"spop",2},
|
{"spop",2,CMDFLAG_NONE},
|
||||||
{"srandmember",2},
|
{"srandmember",2,CMDFLAG_NONE},
|
||||||
{"sinter",-2},
|
{"sinter",-2,CMDFLAG_NONE},
|
||||||
{"sinterstore",-3},
|
{"sinterstore",-3,CMDFLAG_NONE},
|
||||||
{"sunion",-2},
|
{"sunion",-2,CMDFLAG_NONE},
|
||||||
{"sunionstore",-3},
|
{"sunionstore",-3,CMDFLAG_NONE},
|
||||||
{"sdiff",-2},
|
{"sdiff",-2,CMDFLAG_NONE},
|
||||||
{"sdiffstore",-3},
|
{"sdiffstore",-3,CMDFLAG_NONE},
|
||||||
{"smembers",2},
|
{"smembers",2,CMDFLAG_NONE},
|
||||||
{"zadd",4},
|
{"zadd",4,CMDFLAG_NONE},
|
||||||
{"zincrby",4},
|
{"zincrby",4,CMDFLAG_NONE},
|
||||||
{"zrem",3},
|
{"zrem",3,CMDFLAG_NONE},
|
||||||
{"zremrangebyscore",4},
|
{"zremrangebyscore",4,CMDFLAG_NONE},
|
||||||
{"zmerge",-3},
|
{"zmerge",-3,CMDFLAG_NONE},
|
||||||
{"zmergeweighed",-4},
|
{"zmergeweighed",-4,CMDFLAG_NONE},
|
||||||
{"zrange",-4},
|
{"zrange",-4,CMDFLAG_NONE},
|
||||||
{"zrank",3},
|
{"zrank",3,CMDFLAG_NONE},
|
||||||
{"zrevrank",3},
|
{"zrevrank",3,CMDFLAG_NONE},
|
||||||
{"zrangebyscore",-4},
|
{"zrangebyscore",-4,CMDFLAG_NONE},
|
||||||
{"zcount",4},
|
{"zcount",4,CMDFLAG_NONE},
|
||||||
{"zrevrange",-4},
|
{"zrevrange",-4,CMDFLAG_NONE},
|
||||||
{"zcard",2},
|
{"zcard",2,CMDFLAG_NONE},
|
||||||
{"zscore",3},
|
{"zscore",3,CMDFLAG_NONE},
|
||||||
{"incrby",3},
|
{"incrby",3,CMDFLAG_NONE},
|
||||||
{"decrby",3},
|
{"decrby",3,CMDFLAG_NONE},
|
||||||
{"getset",3},
|
{"getset",3,CMDFLAG_NONE},
|
||||||
{"randomkey",1},
|
{"randomkey",1,CMDFLAG_NONE},
|
||||||
{"select",2},
|
{"select",2,CMDFLAG_NONE},
|
||||||
{"move",3},
|
{"move",3,CMDFLAG_NONE},
|
||||||
{"rename",3},
|
{"rename",3,CMDFLAG_NONE},
|
||||||
{"renamenx",3},
|
{"renamenx",3,CMDFLAG_NONE},
|
||||||
{"keys",2},
|
{"keys",2,CMDFLAG_NONE},
|
||||||
{"dbsize",1},
|
{"dbsize",1,CMDFLAG_NONE},
|
||||||
{"ping",1},
|
{"ping",1,CMDFLAG_NONE},
|
||||||
{"echo",2},
|
{"echo",2,CMDFLAG_NONE},
|
||||||
{"save",1},
|
{"save",1,CMDFLAG_NONE},
|
||||||
{"bgsave",1},
|
{"bgsave",1,CMDFLAG_NONE},
|
||||||
{"rewriteaof",1},
|
{"rewriteaof",1,CMDFLAG_NONE},
|
||||||
{"bgrewriteaof",1},
|
{"bgrewriteaof",1,CMDFLAG_NONE},
|
||||||
{"shutdown",1},
|
{"shutdown",1,CMDFLAG_NONE},
|
||||||
{"lastsave",1},
|
{"lastsave",1,CMDFLAG_NONE},
|
||||||
{"type",2},
|
{"type",2,CMDFLAG_NONE},
|
||||||
{"flushdb",1},
|
{"flushdb",1,CMDFLAG_NONE},
|
||||||
{"flushall",1},
|
{"flushall",1,CMDFLAG_NONE},
|
||||||
{"sort",-2},
|
{"sort",-2,CMDFLAG_NONE},
|
||||||
{"info",1},
|
{"info",1,CMDFLAG_RAWOUTPUT},
|
||||||
{"mget",-2},
|
{"mget",-2,CMDFLAG_NONE},
|
||||||
{"expire",3},
|
{"expire",3,CMDFLAG_NONE},
|
||||||
{"expireat",3},
|
{"expireat",3,CMDFLAG_NONE},
|
||||||
{"ttl",2},
|
{"ttl",2,CMDFLAG_NONE},
|
||||||
{"slaveof",3},
|
{"slaveof",3,CMDFLAG_NONE},
|
||||||
{"debug",-2},
|
{"debug",-2,CMDFLAG_NONE},
|
||||||
{"mset",-3},
|
{"mset",-3,CMDFLAG_NONE},
|
||||||
{"msetnx",-3},
|
{"msetnx",-3,CMDFLAG_NONE},
|
||||||
{"monitor",1},
|
{"monitor",1,CMDFLAG_NONE},
|
||||||
{"multi",1},
|
{"multi",1,CMDFLAG_NONE},
|
||||||
{"exec",1},
|
{"exec",1,CMDFLAG_NONE},
|
||||||
{"discard",1},
|
{"discard",1,CMDFLAG_NONE},
|
||||||
{"hset",4},
|
{"hset",4,CMDFLAG_NONE},
|
||||||
{"hget",3},
|
{"hget",3,CMDFLAG_NONE},
|
||||||
{"hmset",-4},
|
{"hmset",-4,CMDFLAG_NONE},
|
||||||
{"hmget",-3},
|
{"hmget",-3,CMDFLAG_NONE},
|
||||||
{"hincrby",4},
|
{"hincrby",4,CMDFLAG_NONE},
|
||||||
{"hdel",3},
|
{"hdel",3,CMDFLAG_NONE},
|
||||||
{"hlen",2},
|
{"hlen",2,CMDFLAG_NONE},
|
||||||
{"hkeys",2},
|
{"hkeys",2,CMDFLAG_NONE},
|
||||||
{"hvals",2},
|
{"hvals",2,CMDFLAG_NONE},
|
||||||
{"hgetall",2},
|
{"hgetall",2,CMDFLAG_NONE},
|
||||||
{"hexists",3},
|
{"hexists",3,CMDFLAG_NONE},
|
||||||
{"config",-2},
|
{"config",-2,CMDFLAG_NONE},
|
||||||
{"subscribe",-2},
|
{"subscribe",-2,CMDFLAG_NONE},
|
||||||
{"unsubscribe",-1},
|
{"unsubscribe",-1,CMDFLAG_NONE},
|
||||||
{"psubscribe",-2},
|
{"psubscribe",-2,CMDFLAG_NONE},
|
||||||
{"punsubscribe",-1},
|
{"punsubscribe",-1,CMDFLAG_NONE},
|
||||||
{"publish",3},
|
{"publish",3,CMDFLAG_NONE},
|
||||||
{NULL,0}
|
{NULL,0,CMDFLAG_NONE}
|
||||||
};
|
};
|
||||||
|
|
||||||
static int cliReadReply(int fd);
|
static int cliReadReply(int fd);
|
||||||
@ -269,7 +274,7 @@ static int cliReadBulkReply(int fd) {
|
|||||||
reply = zmalloc(bulklen);
|
reply = zmalloc(bulklen);
|
||||||
anetRead(fd,reply,bulklen);
|
anetRead(fd,reply,bulklen);
|
||||||
anetRead(fd,crlf,2);
|
anetRead(fd,crlf,2);
|
||||||
if (!isatty(fileno(stdout))) {
|
if (config.raw_output || !isatty(fileno(stdout))) {
|
||||||
if (bulklen && fwrite(reply,bulklen,1,stdout) == 0) {
|
if (bulklen && fwrite(reply,bulklen,1,stdout) == 0) {
|
||||||
zfree(reply);
|
zfree(reply);
|
||||||
return 1;
|
return 1;
|
||||||
@ -354,6 +359,7 @@ static int cliSendCommand(int argc, char **argv, int repeat) {
|
|||||||
int fd, j, retval = 0;
|
int fd, j, retval = 0;
|
||||||
sds cmd;
|
sds cmd;
|
||||||
|
|
||||||
|
config.raw_output = (rc->flags & CMDFLAG_RAWOUTPUT);
|
||||||
if (!rc) {
|
if (!rc) {
|
||||||
fprintf(stderr,"Unknown command '%s'\n",argv[0]);
|
fprintf(stderr,"Unknown command '%s'\n",argv[0]);
|
||||||
return 1;
|
return 1;
|
||||||
@ -588,6 +594,7 @@ int main(int argc, char **argv) {
|
|||||||
config.interactive = 0;
|
config.interactive = 0;
|
||||||
config.monitor_mode = 0;
|
config.monitor_mode = 0;
|
||||||
config.pubsub_mode = 0;
|
config.pubsub_mode = 0;
|
||||||
|
config.raw_output = 0;
|
||||||
config.auth = NULL;
|
config.auth = NULL;
|
||||||
|
|
||||||
firstarg = parseOptions(argc,argv);
|
firstarg = parseOptions(argc,argv);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user