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

networking.c minor optimization

Browse Source
This commit is contained in:
Oran Agra 2016-04-25 16:48:09 +03:00
parent f8909a2579
commit 7b52ef1da2
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/networking.c
View File

@ -1204,10 +1204,10 @@ int processMultibulkBuffer(client *c) {
{ {
c->argv[c->argc++] = createObject(OBJ_STRING,c->querybuf); c->argv[c->argc++] = createObject(OBJ_STRING,c->querybuf);
sdsIncrLen(c->querybuf,-2); /* remove CRLF */ sdsIncrLen(c->querybuf,-2); /* remove CRLF */
c->querybuf = sdsempty();
/* Assume that if we saw a fat argument we'll see another one /* Assume that if we saw a fat argument we'll see another one
* likely... */ * likely... */
c->querybuf = sdsMakeRoomFor(c->querybuf,c->bulklen+2); c->querybuf = sdsnewlen(NULL,c->bulklen+2);
sdsclear(c->querybuf);
pos = 0; pos = 0;
} else { } else {
c->argv[c->argc++] = c->argv[c->argc++] =
@ -1443,9 +1443,8 @@ sds getAllClientsInfoString(void) {
listNode *ln; listNode *ln;
listIter li; listIter li;
client *client; client *client;
sds o = sdsempty(); sds o = sdsnewlen(NULL,200*listLength(server.clients));
sdsclear(o);
o = sdsMakeRoomFor(o,200*listLength(server.clients));
listRewind(server.clients,&li); listRewind(server.clients,&li);
while ((ln = listNext(&li)) != NULL) { while ((ln = listNext(&li)) != NULL) {
client = listNodeValue(ln); client = listNodeValue(ln);
@ -1887,7 +1886,7 @@ int clientsArePaused(void) {
* and so forth. * and so forth.
* *
* It calls the event loop in order to process a few events. Specifically we * It calls the event loop in order to process a few events. Specifically we
* try to call the event loop for times as long as we receive acknowledge that * try to call the event loop 4 times as long as we receive acknowledge that
* some event was processed, in order to go forward with the accept, read, * some event was processed, in order to go forward with the accept, read,
* write, close sequence needed to serve a client. * write, close sequence needed to serve a client.
* *