41 char *redisProtocolToLuaType_Int(lua_State *lua, char *reply);
42 char *redisProtocolToLuaType_Bulk(lua_State *lua, char *reply);
43 char *redisProtocolToLuaType_Status(lua_State *lua, char *reply);
44 char *redisProtocolToLuaType_Error(lua_State *lua, char *reply);
45 char *redisProtocolToLuaType_MultiBulk(lua_State *lua, char *reply);
54 void ldbLogRedisReply(char *reply);
127 char *redisProtocolToLuaType(lua_State *lua, char* reply) {  in redisProtocolToLuaType()  argument
128     char *p = reply;  in redisProtocolToLuaType()
131     case ':': p = redisProtocolToLuaType_Int(lua,reply); break;  in redisProtocolToLuaType()
132     case '$': p = redisProtocolToLuaType_Bulk(lua,reply); break;  in redisProtocolToLuaType()
133     case '+': p = redisProtocolToLuaType_Status(lua,reply); break;  in redisProtocolToLuaType()
134     case '-': p = redisProtocolToLuaType_Error(lua,reply); break;  in redisProtocolToLuaType()
135     case '*': p = redisProtocolToLuaType_MultiBulk(lua,reply); break;  in redisProtocolToLuaType()
140 char *redisProtocolToLuaType_Int(lua_State *lua, char *reply) {  in redisProtocolToLuaType_Int()  argument
141     char *p = strchr(reply+1,'\r');  in redisProtocolToLuaType_Int()
144     string2ll(reply+1,p-reply-1,&value);  in redisProtocolToLuaType_Int()
149 char *redisProtocolToLuaType_Bulk(lua_State *lua, char *reply) {  in redisProtocolToLuaType_Bulk()  argument
150     char *p = strchr(reply+1,'\r');  in redisProtocolToLuaType_Bulk()
153     string2ll(reply+1,p-reply-1,&bulklen);  in redisProtocolToLuaType_Bulk()
163 char *redisProtocolToLuaType_Status(lua_State *lua, char *reply) {  in redisProtocolToLuaType_Status()  argument
164     char *p = strchr(reply+1,'\r');  in redisProtocolToLuaType_Status()
168     lua_pushlstring(lua,reply+1,p-reply-1);  in redisProtocolToLuaType_Status()
173 char *redisProtocolToLuaType_Error(lua_State *lua, char *reply) {  in redisProtocolToLuaType_Error()  argument
174     char *p = strchr(reply+1,'\r');  in redisProtocolToLuaType_Error()
178     lua_pushlstring(lua,reply+1,p-reply-1);  in redisProtocolToLuaType_Error()
183 char *redisProtocolToLuaType_MultiBulk(lua_State *lua, char *reply) {  in redisProtocolToLuaType_MultiBulk()  argument
184     char *p = strchr(reply+1,'\r');  in redisProtocolToLuaType_MultiBulk()
188     string2ll(reply+1,p-reply-1,&mbulklen);  in redisProtocolToLuaType_MultiBulk()
352     sds reply;  in luaRedisGenericCommand()  local
581     if (listLength(c->reply) == 0 && c->bufpos < PROTO_REPLY_CHUNK_BYTES) {  in luaRedisGenericCommand()
586         reply = c->buf;  in luaRedisGenericCommand()
589         reply = sdsnewlen(c->buf,c->bufpos);  in luaRedisGenericCommand()
591         while(listLength(c->reply)) {  in luaRedisGenericCommand()
592             clientReplyBlock *o = listNodeValue(listFirst(c->reply));  in luaRedisGenericCommand()
594             reply = sdscatlen(reply,o->buf,o->used);  in luaRedisGenericCommand()
595             listDelNode(c->reply,listFirst(c->reply));  in luaRedisGenericCommand()
598     if (raise_error && reply[0] != '-') raise_error = 0;  in luaRedisGenericCommand()
599     redisProtocolToLuaType(lua,reply);  in luaRedisGenericCommand()
603         ldbLogRedisReply(reply);  in luaRedisGenericCommand()
609         (reply[0] == '*' && reply[1] != '-')) {  in luaRedisGenericCommand()
612     if (reply != c->buf) sdsfree(reply);  in luaRedisGenericCommand()
2019 char *ldbRedisProtocolToHuman_Int(sds *o, char *reply);
2020 char *ldbRedisProtocolToHuman_Bulk(sds *o, char *reply);
2021 char *ldbRedisProtocolToHuman_Status(sds *o, char *reply);
2022 char *ldbRedisProtocolToHuman_MultiBulk(sds *o, char *reply);
2029 char *ldbRedisProtocolToHuman(sds *o, char *reply) {  in ldbRedisProtocolToHuman()  argument
2030     char *p = reply;  in ldbRedisProtocolToHuman()
2032     case ':': p = ldbRedisProtocolToHuman_Int(o,reply); break;  in ldbRedisProtocolToHuman()
2033     case '$': p = ldbRedisProtocolToHuman_Bulk(o,reply); break;  in ldbRedisProtocolToHuman()
2034     case '+': p = ldbRedisProtocolToHuman_Status(o,reply); break;  in ldbRedisProtocolToHuman()
2035     case '-': p = ldbRedisProtocolToHuman_Status(o,reply); break;  in ldbRedisProtocolToHuman()
2036     case '*': p = ldbRedisProtocolToHuman_MultiBulk(o,reply); break;  in ldbRedisProtocolToHuman()
2044 char *ldbRedisProtocolToHuman_Int(sds *o, char *reply) {  in ldbRedisProtocolToHuman_Int()  argument
2045     char *p = strchr(reply+1,'\r');  in ldbRedisProtocolToHuman_Int()
2046     *o = sdscatlen(*o,reply+1,p-reply-1);  in ldbRedisProtocolToHuman_Int()
2050 char *ldbRedisProtocolToHuman_Bulk(sds *o, char *reply) {  in ldbRedisProtocolToHuman_Bulk()  argument
2051     char *p = strchr(reply+1,'\r');  in ldbRedisProtocolToHuman_Bulk()
2054     string2ll(reply+1,p-reply-1,&bulklen);  in ldbRedisProtocolToHuman_Bulk()
2064 char *ldbRedisProtocolToHuman_Status(sds *o, char *reply) {  in ldbRedisProtocolToHuman_Status()  argument
2065     char *p = strchr(reply+1,'\r');  in ldbRedisProtocolToHuman_Status()
2067     *o = sdscatrepr(*o,reply,p-reply);  in ldbRedisProtocolToHuman_Status()
2071 char *ldbRedisProtocolToHuman_MultiBulk(sds *o, char *reply) {  in ldbRedisProtocolToHuman_MultiBulk()  argument
2072     char *p = strchr(reply+1,'\r');  in ldbRedisProtocolToHuman_MultiBulk()
2076     string2ll(reply+1,p-reply-1,&mbulklen);  in ldbRedisProtocolToHuman_MultiBulk()
2094 void ldbLogRedisReply(char *reply) {  in ldbLogRedisReply()  argument
2096     ldbRedisProtocolToHuman(&log,reply);  in ldbLogRedisReply()