Lines Matching refs:querybuf
115 c->querybuf = sdsempty(); in createClient()
880 sdsfree(c->querybuf); in freeClient()
882 c->querybuf = NULL; in freeClient()
1190 newline = strchr(c->querybuf+c->qb_pos,'\n'); in processInlineBuffer()
1194 if (sdslen(c->querybuf)-c->qb_pos > PROTO_INLINE_MAX_SIZE) { in processInlineBuffer()
1202 if (newline && newline != c->querybuf+c->qb_pos && *(newline-1) == '\r') in processInlineBuffer()
1206 querylen = newline-(c->querybuf+c->qb_pos); in processInlineBuffer()
1207 aux = sdsnewlen(c->querybuf+c->qb_pos,querylen); in processInlineBuffer()
1253 if (sdslen(c->querybuf)-c->qb_pos < PROTO_DUMP_LEN) { in setProtocolError()
1254 … snprintf(buf,sizeof(buf),"Query buffer during protocol error: '%s'", c->querybuf+c->qb_pos); in setProtocolError()
1256 …OTO_DUMP_LEN/2, c->querybuf+c->qb_pos, sdslen(c->querybuf)-c->qb_pos-PROTO_DUMP_LEN, PROTO_DUMP_LE… in setProtocolError()
1295 newline = strchr(c->querybuf+c->qb_pos,'\r'); in processMultibulkBuffer()
1297 if (sdslen(c->querybuf)-c->qb_pos > PROTO_INLINE_MAX_SIZE) { in processMultibulkBuffer()
1305 if (newline-(c->querybuf+c->qb_pos) > (ssize_t)(sdslen(c->querybuf)-c->qb_pos-2)) in processMultibulkBuffer()
1310 serverAssertWithInfo(c,NULL,c->querybuf[c->qb_pos] == '*'); in processMultibulkBuffer()
1311 ok = string2ll(c->querybuf+1+c->qb_pos,newline-(c->querybuf+1+c->qb_pos),&ll); in processMultibulkBuffer()
1318 c->qb_pos = (newline-c->querybuf)+2; in processMultibulkBuffer()
1333 newline = strchr(c->querybuf+c->qb_pos,'\r'); in processMultibulkBuffer()
1335 if (sdslen(c->querybuf)-c->qb_pos > PROTO_INLINE_MAX_SIZE) { in processMultibulkBuffer()
1345 if (newline-(c->querybuf+c->qb_pos) > (ssize_t)(sdslen(c->querybuf)-c->qb_pos-2)) in processMultibulkBuffer()
1348 if (c->querybuf[c->qb_pos] != '$') { in processMultibulkBuffer()
1351 c->querybuf[c->qb_pos]); in processMultibulkBuffer()
1356 ok = string2ll(c->querybuf+c->qb_pos+1,newline-(c->querybuf+c->qb_pos+1),&ll); in processMultibulkBuffer()
1363 c->qb_pos = newline-c->querybuf+2; in processMultibulkBuffer()
1374 if (sdslen(c->querybuf)-c->qb_pos <= (size_t)ll+2) { in processMultibulkBuffer()
1375 sdsrange(c->querybuf,c->qb_pos,-1); in processMultibulkBuffer()
1379 c->querybuf = sdsMakeRoomFor(c->querybuf,ll+2); in processMultibulkBuffer()
1386 if (sdslen(c->querybuf)-c->qb_pos < (size_t)(c->bulklen+2)) { in processMultibulkBuffer()
1395 sdslen(c->querybuf) == (size_t)(c->bulklen+2)) in processMultibulkBuffer()
1397 c->argv[c->argc++] = createObject(OBJ_STRING,c->querybuf); in processMultibulkBuffer()
1398 sdsIncrLen(c->querybuf,-2); /* remove CRLF */ in processMultibulkBuffer()
1401 c->querybuf = sdsnewlen(SDS_NOINIT,c->bulklen+2); in processMultibulkBuffer()
1402 sdsclear(c->querybuf); in processMultibulkBuffer()
1405 createStringObject(c->querybuf+c->qb_pos,c->bulklen); in processMultibulkBuffer()
1428 while(c->qb_pos < sdslen(c->querybuf)) { in processInputBuffer()
1450 if (c->querybuf[c->qb_pos] == '*') { in processInputBuffer()
1473 c->reploff = c->read_reploff - sdslen(c->querybuf) + c->qb_pos; in processInputBuffer()
1492 sdsrange(c->querybuf,c->qb_pos,-1); in processInputBuffer()
1535 ssize_t remaining = (size_t)(c->bulklen+2)-sdslen(c->querybuf); in readQueryFromClient()
1542 qblen = sdslen(c->querybuf); in readQueryFromClient()
1544 c->querybuf = sdsMakeRoomFor(c->querybuf, readlen); in readQueryFromClient()
1545 nread = read(fd, c->querybuf+qblen, readlen); in readQueryFromClient()
1563 c->querybuf+qblen,nread); in readQueryFromClient()
1566 sdsIncrLen(c->querybuf,nread); in readQueryFromClient()
1570 if (sdslen(c->querybuf) > server.client_max_querybuf_len) { in readQueryFromClient()
1573 bytes = sdscatrepr(bytes,c->querybuf,64); in readQueryFromClient()
1602 if (sdslen(c->querybuf) > bib) bib = sdslen(c->querybuf); in getClientsMaxBuffers()
1688 (unsigned long long) sdslen(client->querybuf), in catClientInfoString()
1689 (unsigned long long) sdsavail(client->querybuf), in catClientInfoString()