Lines Matching refs:fds
1209 int fds[6] = {-1, -1, -1, -1, -1, -1}; in aofCreatePipes() local
1212 if (pipe(fds) == -1) goto error; /* parent -> children data. */ in aofCreatePipes()
1213 if (pipe(fds+2) == -1) goto error; /* children -> parent ack. */ in aofCreatePipes()
1214 if (pipe(fds+4) == -1) goto error; /* children -> parent ack. */ 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()
1218 …if (aeCreateFileEvent(server.el, fds[2], AE_READABLE, aofChildPipeReadable, NULL) == AE_ERR) goto … 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()
1232 for (j = 0; j < 6; j++) if(fds[j] != -1) close(fds[j]); in aofCreatePipes()