From: antirez <antirez@gmail.com>
Date: Tue, 2 Nov 2010 22:47:52 +0000 (+0100)
Subject: Merge remote branch 'pietern/unixsocket'
X-Git-Url: https://git.saurik.com/redis.git/commitdiff_plain/0a546fc01758f9a9f8b2113764c2cf963df6ef20

Merge remote branch 'pietern/unixsocket'
---

0a546fc01758f9a9f8b2113764c2cf963df6ef20
diff --cc src/networking.c
index 6181799a,d1c6a75a..d2eb2543
--- a/src/networking.c
+++ b/src/networking.c
@@@ -375,11 -360,47 +363,43 @@@ static void acceptCommonHandler(int fd
      server.stat_numconnections++;
  }
  
+ void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) {
+     int cport, cfd;
+     char cip[128];
+     REDIS_NOTUSED(el);
+     REDIS_NOTUSED(mask);
+     REDIS_NOTUSED(privdata);
+ 
+     cfd = anetTcpAccept(server.neterr, fd, cip, &cport);
+     if (cfd == AE_ERR) {
+         redisLog(REDIS_VERBOSE,"Accepting client connection: %s", server.neterr);
+         return;
+     }
+     redisLog(REDIS_VERBOSE,"Accepted %s:%d", cip, cport);
+     acceptCommonHandler(cfd);
+ }
+ 
+ void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) {
+     int cfd;
+     REDIS_NOTUSED(el);
+     REDIS_NOTUSED(mask);
+     REDIS_NOTUSED(privdata);
+ 
+     cfd = anetUnixAccept(server.neterr, fd);
+     if (cfd == AE_ERR) {
+         redisLog(REDIS_VERBOSE,"Accepting client connection: %s", server.neterr);
+         return;
+     }
+     redisLog(REDIS_VERBOSE,"Accepted connection to %s", server.unixsocket);
+     acceptCommonHandler(cfd);
+ }
+ 
+ 
  static void freeClientArgv(redisClient *c) {
      int j;
 -
      for (j = 0; j < c->argc; j++)
          decrRefCount(c->argv[j]);
 -    for (j = 0; j < c->mbargc; j++)
 -        decrRefCount(c->mbargv[j]);
      c->argc = 0;
 -    c->mbargc = 0;
  }
  
  void freeClient(redisClient *c) {
diff --cc src/redis.c
index 2cbfc689,50cf2f6c..f65901c7
--- a/src/redis.c
+++ b/src/redis.c
@@@ -824,12 -831,12 +839,14 @@@ void initServer() 
      server.stat_numconnections = 0;
      server.stat_expiredkeys = 0;
      server.stat_starttime = time(NULL);
 +    server.stat_keyspace_misses = 0;
 +    server.stat_keyspace_hits = 0;
      server.unixtime = time(NULL);
      aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL);
-     if (aeCreateFileEvent(server.el, server.fd, AE_READABLE,
-         acceptHandler, NULL) == AE_ERR) oom("creating file event");
+     if (server.ipfd > 0 && aeCreateFileEvent(server.el,server.ipfd,AE_READABLE,
+         acceptTcpHandler,NULL) == AE_ERR) oom("creating file event");
+     if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE,
+         acceptUnixHandler,NULL) == AE_ERR) oom("creating file event");
  
      if (server.appendonly) {
          server.appendfd = open(server.appendfilename,O_WRONLY|O_APPEND|O_CREAT,0644);