Home
last modified time | relevance | path

Searched refs:fds (Results 1 – 8 of 8) sorted by relevance

/redis-3.2.3/src/
H A Drio.c205 retval = write(r->io.fdset.fds[j],p+nwritten,count-nwritten); in rioFdsetWrite()
266 void rioInitWithFdset(rio *r, int *fds, int numfds) { in rioInitWithFdset() argument
270 r->io.fdset.fds = zmalloc(sizeof(int)*numfds); in rioInitWithFdset()
272 memcpy(r->io.fdset.fds,fds,sizeof(int)*numfds); in rioInitWithFdset()
281 zfree(r->io.fdset.fds); in rioFreeFdset()
H A Daof.c1209 int fds[6] = {-1, -1, -1, -1, -1, -1}; in aofCreatePipes() local
1212 if (pipe(fds) == -1) goto error; /* parent -> children data. */ in aofCreatePipes()
1216 if (anetNonBlock(NULL,fds[0]) != ANET_OK) goto error; in aofCreatePipes()
1217 if (anetNonBlock(NULL,fds[1]) != ANET_OK) goto error; in aofCreatePipes()
1220 server.aof_pipe_write_data_to_child = fds[1]; in aofCreatePipes()
1221 server.aof_pipe_read_data_from_parent = fds[0]; in aofCreatePipes()
1222 server.aof_pipe_write_ack_to_parent = fds[3]; in aofCreatePipes()
1223 server.aof_pipe_read_ack_from_child = fds[2]; in aofCreatePipes()
1224 server.aof_pipe_write_ack_to_child = fds[5]; in aofCreatePipes()
1225 server.aof_pipe_read_ack_from_parent = fds[4]; in aofCreatePipes()
[all …]
H A Drio.h78 int *fds; /* File descriptors. */ member
129 void rioInitWithFdset(rio *r, int *fds, int numfds);
H A Drdb.c1580 int *fds; in rdbSaveToSlavesSockets() local
1600 fds = zmalloc(sizeof(int)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
1613 fds[numfds++] = slave->fd; in rdbSaveToSlavesSockets()
1630 rioInitWithFdset(&slave_sockets,fds,numfds); in rdbSaveToSlavesSockets()
1631 zfree(fds); in rdbSaveToSlavesSockets()
1726 zfree(fds); in rdbSaveToSlavesSockets()
H A Dserver.c1771 int listenToPort(int port, int *fds, int *count) { in listenToPort() argument
1781 fds[*count] = anetTcp6Server(server.neterr,port,NULL, in listenToPort()
1783 if (fds[*count] != ANET_ERR) { in listenToPort()
1784 anetNonBlock(NULL,fds[*count]); in listenToPort()
1788 fds[*count] = anetTcpServer(server.neterr,port,NULL, in listenToPort()
1790 if (fds[*count] != ANET_ERR) { in listenToPort()
1791 anetNonBlock(NULL,fds[*count]); in listenToPort()
1801 fds[*count] = anetTcp6Server(server.neterr,port,server.bindaddr[j], in listenToPort()
1805 fds[*count] = anetTcpServer(server.neterr,port,server.bindaddr[j], in listenToPort()
1808 if (fds[*count] == ANET_ERR) { in listenToPort()
[all …]
H A Dserver.h1136 int listenToPort(int port, int *fds, int *count);
/redis-3.2.3/deps/hiredis/
H A DCHANGELOG.md7 * Use poll(2) instead of select(2) to support large fds (>= 1024).
/redis-3.2.3/deps/jemalloc/
H A DChangeLog503 "swap.prezeroed", "swap.nfds", and "swap.fds" mallctls.