Lines Matching refs:querybuf

90     c->querybuf = sdsempty();  in createClient()
813 sdsfree(c->querybuf); in freeClient()
814 c->querybuf = NULL; in freeClient()
1055 newline = strchr(c->querybuf,'\n'); in processInlineBuffer()
1059 if (sdslen(c->querybuf) > PROTO_INLINE_MAX_SIZE) { in processInlineBuffer()
1067 if (newline && newline != c->querybuf && *(newline-1) == '\r') in processInlineBuffer()
1071 querylen = newline-(c->querybuf); in processInlineBuffer()
1072 aux = sdsnewlen(c->querybuf,querylen); in processInlineBuffer()
1088 sdsrange(c->querybuf,querylen+2,-1); in processInlineBuffer()
1119 sdsrange(c->querybuf,pos,-1); in setProtocolError()
1132 newline = strchr(c->querybuf,'\r'); in processMultibulkBuffer()
1134 if (sdslen(c->querybuf) > PROTO_INLINE_MAX_SIZE) { in processMultibulkBuffer()
1142 if (newline-(c->querybuf) > ((signed)sdslen(c->querybuf)-2)) in processMultibulkBuffer()
1147 serverAssertWithInfo(c,NULL,c->querybuf[0] == '*'); in processMultibulkBuffer()
1148 ok = string2ll(c->querybuf+1,newline-(c->querybuf+1),&ll); in processMultibulkBuffer()
1155 pos = (newline-c->querybuf)+2; in processMultibulkBuffer()
1157 sdsrange(c->querybuf,pos,-1); in processMultibulkBuffer()
1172 newline = strchr(c->querybuf+pos,'\r'); in processMultibulkBuffer()
1174 if (sdslen(c->querybuf) > PROTO_INLINE_MAX_SIZE) { in processMultibulkBuffer()
1184 if (newline-(c->querybuf) > ((signed)sdslen(c->querybuf)-2)) in processMultibulkBuffer()
1187 if (c->querybuf[pos] != '$') { in processMultibulkBuffer()
1190 c->querybuf[pos]); in processMultibulkBuffer()
1195 ok = string2ll(c->querybuf+pos+1,newline-(c->querybuf+pos+1),&ll); in processMultibulkBuffer()
1202 pos += newline-(c->querybuf+pos)+2; in processMultibulkBuffer()
1210 sdsrange(c->querybuf,pos,-1); in processMultibulkBuffer()
1212 qblen = sdslen(c->querybuf); in processMultibulkBuffer()
1216 c->querybuf = sdsMakeRoomFor(c->querybuf,ll+2-qblen); in processMultibulkBuffer()
1222 if (sdslen(c->querybuf)-pos < (unsigned)(c->bulklen+2)) { in processMultibulkBuffer()
1231 (signed) sdslen(c->querybuf) == c->bulklen+2) in processMultibulkBuffer()
1233 c->argv[c->argc++] = createObject(OBJ_STRING,c->querybuf); in processMultibulkBuffer()
1234 sdsIncrLen(c->querybuf,-2); /* remove CRLF */ in processMultibulkBuffer()
1237 c->querybuf = sdsnewlen(NULL,c->bulklen+2); in processMultibulkBuffer()
1238 sdsclear(c->querybuf); in processMultibulkBuffer()
1242 createStringObject(c->querybuf+pos,c->bulklen); in processMultibulkBuffer()
1251 if (pos) sdsrange(c->querybuf,pos,-1); in processMultibulkBuffer()
1263 while(sdslen(c->querybuf)) { in processInputBuffer()
1277 if (c->querybuf[0] == '*') { in processInputBuffer()
1324 int remaining = (unsigned)(c->bulklen+2)-sdslen(c->querybuf); in readQueryFromClient()
1329 qblen = sdslen(c->querybuf); in readQueryFromClient()
1331 c->querybuf = sdsMakeRoomFor(c->querybuf, readlen); in readQueryFromClient()
1332 nread = read(fd, c->querybuf+qblen, readlen); in readQueryFromClient()
1347 sdsIncrLen(c->querybuf,nread); in readQueryFromClient()
1351 if (sdslen(c->querybuf) > server.client_max_querybuf_len) { in readQueryFromClient()
1354 bytes = sdscatrepr(bytes,c->querybuf,64); in readQueryFromClient()
1376 if (sdslen(c->querybuf) > bib) bib = sdslen(c->querybuf); in getClientsMaxBuffers()
1461 (unsigned long long) sdslen(client->querybuf), in catClientInfoString()
1462 (unsigned long long) sdsavail(client->querybuf), in catClientInfoString()