better handling of non blocking connect on redis-benchmark: EPIPE on read does not...

diff --git a/TODO b/TODO
index 7d3974019d49b1ac206433aea5d0bda37f2e4b61..23ec0422b022bb73ee92629239be0931959dc224 100644 (file)
--- a/TODO
+++ b/TODO
@@ -48,6 +48,7 @@ SHORT/LONG TERM RANDOM TODO ITEMS
 Most of this can be seen just as proposals, the fact they are in this list
 it's not a guarantee they'll ever get implemented ;)
 
 Most of this can be seen just as proposals, the fact they are in this list
 it's not a guarantee they'll ever get implemented ;)
 

+* Give errors when incrementing a key that does not look like an integer, when providing as a sorted set score something can't be parsed as a double, and so forth.

 * Move dict.c from hash table to skip list, in order to avoid the blocking resize operation needed for the hash table.
 * FORK command (fork()s executing the commands received by the current
   client in the new process). Hint: large SORTs can use more cores,
 * Move dict.c from hash table to skip list, in order to avoid the blocking resize operation needed for the hash table.
 * FORK command (fork()s executing the commands received by the current
   client in the new process). Hint: large SORTs can use more cores,

diff --git a/benchmark.c b/benchmark.c
index fd949ea30ba90d6093c73b1c2d6d5f0f7845e024..2984efe4139c9fc6740a3f7cdfbfd1ab4310d23b 100644 (file)
--- a/benchmark.c
+++ b/benchmark.c
@@ -322,7 +322,8 @@ static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask)
         int len = sdslen(c->obuf) - c->written;
         int nwritten = write(c->fd, ptr, len);
         if (nwritten == -1) {
         int len = sdslen(c->obuf) - c->written;
         int nwritten = write(c->fd, ptr, len);
         if (nwritten == -1) {

-            fprintf(stderr, "Writing to socket: %s\n", strerror(errno));
+            if (errno != EPIPE)
+                fprintf(stderr, "Writing to socket: %s\n", strerror(errno));

             freeClient(c);
             return;
         }
             freeClient(c);
             return;
         }