fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-04 16:51:12 +00:00
Code Issues Projects Releases Wiki Activity

sdsIncrLen() / sdsMakeRoomFor() used to avoid copying to intermediate buffer while reading the client query.

Browse Source
This commit is contained in:
antirez 2011-11-02 16:52:45 +01:00
parent a54806ac6a
commit b8d743e181
1 changed files with 5 additions and 3 deletions

8
src/networking.c

@ -833,12 +833,14 @@ void processInputBuffer(redisClient *c) {
void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) { void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) {
redisClient *c = (redisClient*) privdata; redisClient *c = (redisClient*) privdata;
char buf[REDIS_IOBUF_LEN];
int nread; int nread;
size_t qblen;
REDIS_NOTUSED(el); REDIS_NOTUSED(el);
REDIS_NOTUSED(mask); REDIS_NOTUSED(mask);
nread = read(fd, buf, REDIS_IOBUF_LEN); qblen = sdslen(c->querybuf);
c->querybuf = sdsMakeRoomFor(c->querybuf, REDIS_IOBUF_LEN);
nread = read(fd, c->querybuf+qblen, REDIS_IOBUF_LEN);
if (nread == -1) { if (nread == -1) {
if (errno == EAGAIN) { if (errno == EAGAIN) {
nread = 0; nread = 0;
@ -853,7 +855,7 @@ void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) {
return; return;
} }
if (nread) { if (nread) {
c->querybuf = sdscatlen(c->querybuf,buf,nread); sdsIncrLen(c->querybuf,nread);
c->lastinteraction = time(NULL); c->lastinteraction = time(NULL);
} else { } else {
return; return;