Searched refs:bufpos (Results 1 – 4 of 4) sorted by relevance
89 c->bufpos = 0; in createClient()214 size_t available = sizeof(c->buf)-c->bufpos; in _addReplyToBuffer()225 memcpy(c->buf+c->bufpos,s,len); in _addReplyToBuffer()226 c->bufpos+=len; in _addReplyToBuffer()604 memcpy(dst->buf,src->buf,src->bufpos); in copyClientOutputBuffer()605 dst->bufpos = src->bufpos; in copyClientOutputBuffer()612 return c->bufpos || listLength(c->reply); in clientHasPendingReplies()909 if (c->bufpos > 0) { in writeToClient()917 if ((int)c->sentlen == c->bufpos) { in writeToClient()918 c->bufpos = 0; in writeToClient()[all …]
558 if (listLength(c->reply) == 0 && c->bufpos < PROTO_REPLY_CHUNK_BYTES) { in luaRedisGenericCommand()562 c->buf[c->bufpos] = '\0'; in luaRedisGenericCommand()564 c->bufpos = 0; in luaRedisGenericCommand()566 reply = sdsnewlen(c->buf,c->bufpos); in luaRedisGenericCommand()567 c->bufpos = 0; in luaRedisGenericCommand()
577 c->bufpos = 0; in createFakeClient()702 serverAssert(fakeClient->bufpos == 0 && listLength(fakeClient->reply) == 0); in loadAppendOnlyFile()
614 int bufpos; member