Searched refs:querybuf (Results 1 – 5 of 5) sorted by relevance
90 c->querybuf = sdsempty(); in createClient()813 sdsfree(c->querybuf); in freeClient()814 c->querybuf = NULL; in freeClient()1142 if (newline-(c->querybuf) > ((signed)sdslen(c->querybuf)-2)) in processMultibulkBuffer()1148 ok = string2ll(c->querybuf+1,newline-(c->querybuf+1),&ll); in processMultibulkBuffer()1184 if (newline-(c->querybuf) > ((signed)sdslen(c->querybuf)-2)) in processMultibulkBuffer()1195 ok = string2ll(c->querybuf+pos+1,newline-(c->querybuf+pos+1),&ll); in processMultibulkBuffer()1216 c->querybuf = sdsMakeRoomFor(c->querybuf,ll+2-qblen); in processMultibulkBuffer()1263 while(sdslen(c->querybuf)) { in processInputBuffer()1331 c->querybuf = sdsMakeRoomFor(c->querybuf, readlen); in readQueryFromClient()[all …]
125 if (c->querybuf && sdslen(c->querybuf) > 0) { in processUnblockedClients()
573 c->querybuf = sdsempty(); in createFakeClient()603 sdsfree(c->querybuf); in freeFakeClient()
961 size_t querybuf_size = sdsAllocSize(c->querybuf); in clientsCronResizeQueryBuffer()972 if (sdsavail(c->querybuf) > 1024) { in clientsCronResizeQueryBuffer()973 c->querybuf = sdsRemoveFreeSpace(c->querybuf); in clientsCronResizeQueryBuffer()
571 sds querybuf; /* Buffer we use to accumulate client queries. */ member