Searched refs:querybuf (Results 1 – 9 of 9) sorted by relevance
115 c->querybuf = sdsempty(); in createClient()880 sdsfree(c->querybuf); in freeClient()882 c->querybuf = NULL; in freeClient()1305 if (newline-(c->querybuf+c->qb_pos) > (ssize_t)(sdslen(c->querybuf)-c->qb_pos-2)) in processMultibulkBuffer()1311 ok = string2ll(c->querybuf+1+c->qb_pos,newline-(c->querybuf+1+c->qb_pos),&ll); in processMultibulkBuffer()1345 if (newline-(c->querybuf+c->qb_pos) > (ssize_t)(sdslen(c->querybuf)-c->qb_pos-2)) in processMultibulkBuffer()1356 ok = string2ll(c->querybuf+c->qb_pos+1,newline-(c->querybuf+c->qb_pos+1),&ll); in processMultibulkBuffer()1379 c->querybuf = sdsMakeRoomFor(c->querybuf,ll+2); in processMultibulkBuffer()1542 qblen = sdslen(c->querybuf); in readQueryFromClient()1544 c->querybuf = sdsMakeRoomFor(c->querybuf, readlen); in readQueryFromClient()[all …]
128 if (c->querybuf && sdslen(c->querybuf) > 0) { in processUnblockedClients()
995 mem += sdsAllocSize(c->querybuf); in getMemoryOverheadData()1013 mem += sdsAllocSize(c->querybuf); in getMemoryOverheadData()
857 size_t querybuf_size = sdsAllocSize(c->querybuf); in clientsCronResizeQueryBuffer()869 if (sdsavail(c->querybuf) > 1024*4) { in clientsCronResizeQueryBuffer()870 c->querybuf = sdsRemoveFreeSpace(c->querybuf); in clientsCronResizeQueryBuffer()913 size_t in_usage = sdsAllocSize(c->querybuf); in clientsCronTrackExpansiveClients()
658 c->querybuf = sdsempty(); in createFakeClient()688 sdsfree(c->querybuf); in freeFakeClient()
2178 sdsclear(server.master->querybuf); in replicationCacheMaster()
720 sds querybuf; /* Buffer we use to accumulate client queries. */ member
259 sds querybuf;273 * `querybuf` accumulates the requests from the client, which are parsed by the Redis server accordi…
1781 pipeline: do not sdsrange querybuf unless all commands processed2433 Merge pull request #5084 from chendq8/pending-querybuf2441 Merge branch 'unstable' into pending-querybuf2459 limit the size of pending-querybuf in masterclient