| 1163 | } |
| 1164 | |
| 1165 | void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) { |
| 1166 | int cfd, max = MAX_ACCEPTS_PER_CALL; |
| 1167 | UNUSED(el); |
| 1168 | UNUSED(mask); |
| 1169 | UNUSED(privdata); |
| 1170 | |
| 1171 | while(max--) { |
| 1172 | cfd = anetUnixAccept(server.neterr, fd); |
| 1173 | if (cfd == ANET_ERR) { |
| 1174 | if (errno != EWOULDBLOCK) |
| 1175 | serverLog(LL_WARNING, |
| 1176 | "Accepting client connection: %s", server.neterr); |
| 1177 | return; |
| 1178 | } |
| 1179 | anetCloexec(cfd); |
| 1180 | serverLog(LL_VERBOSE,"Accepted connection to %s", server.unixsocket); |
| 1181 | acceptCommonHandler(connCreateAcceptedSocket(cfd),CLIENT_UNIX_SOCKET,NULL); |
| 1182 | } |
| 1183 | } |
| 1184 | |
| 1185 | void freeClientOriginalArgv(client *c) { |
| 1186 | /* We didn't rewrite this client */ |
nothing calls this directly
no test coverage detected