59         anetPeerToString(c->fd,ip,sizeof(ip),NULL) != -1)  in replicationGetSlaveName()
403         if (write(slave->fd,buf,buflen) != buflen) {  in replicationSetupSlaveForFullResync()
467     if (write(c->fd,buf,buflen) != buflen) {  in masterTryPartialResynchronization()
623         anetDisableTcpNoDelay(NULL, c->fd); /* Non critical if it fails. */  in syncCommand()
787     if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE,  in putSlaveOnline()
798 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) {  in sendBulkToSlave()  argument
809         nwritten = write(fd,slave->replpreamble,sdslen(slave->replpreamble));  in sendBulkToSlave()
836     if ((nwritten = write(fd,buf,buflen)) == -1) {  in sendBulkToSlave()
849         aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE);  in sendBulkToSlave()
920                 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE);  in updateSlavesWaitingBgsave()
921 …      if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendBulkToSlave, slave) == AE_ERR) {  in updateSlavesWaitingBgsave()
968 void replicationCreateMasterClient(int fd) {  in replicationCreateMasterClient()  argument
969     server.master = createClient(fd);  in replicationCreateMasterClient()
984 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) {  in readSyncBulkPayload()  argument
1001         if (syncReadLine(fd,buf,1024,server.repl_syncio_timeout*1000) == -1) {  in readSyncBulkPayload()
1061     nread = read(fd,buf,readlen);  in readSyncBulkPayload()
1181 char *sendSynchronousCommand(int flags, int fd, ...) {  in sendSynchronousCommand()  argument
1189         va_start(ap,fd);  in sendSynchronousCommand()
1201         if (syncWrite(fd,cmd,sdslen(cmd),server.repl_syncio_timeout*1000)  in sendSynchronousCommand()
1216         if (syncReadLine(fd,buf,sizeof(buf),server.repl_syncio_timeout*1000)  in sendSynchronousCommand()
1280 int slaveTryPartialResynchronization(int fd, int read_reply) {  in slaveTryPartialResynchronization()  argument
1305         reply = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"PSYNC",psync_runid,psync_offset,NULL);  in slaveTryPartialResynchronization()
1309             aeDeleteFileEvent(server.el,fd,AE_READABLE);  in slaveTryPartialResynchronization()
1316     reply = sendSynchronousCommand(SYNC_CMD_READ,fd,NULL);  in slaveTryPartialResynchronization()
1324     aeDeleteFileEvent(server.el,fd,AE_READABLE);  in slaveTryPartialResynchronization()
1364         replicationResurrectCachedMaster(fd);  in slaveTryPartialResynchronization()
1386 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) {  in syncWithMaster()  argument
1398         close(fd);  in syncWithMaster()
1403     if (getsockopt(fd, SOL_SOCKET, SO_ERROR, &sockerr, &errlen) == -1)  in syncWithMaster()
1416         aeDeleteFileEvent(server.el,fd,AE_WRITABLE);  in syncWithMaster()
1420         err = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"PING",NULL);  in syncWithMaster()
1427         err = sendSynchronousCommand(SYNC_CMD_READ,fd,NULL);  in syncWithMaster()
1452             err = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"AUTH",server.masterauth,NULL);  in syncWithMaster()
1463         err = sendSynchronousCommand(SYNC_CMD_READ,fd,NULL);  in syncWithMaster()
1478         err = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"REPLCONF",  in syncWithMaster()
1489         err = sendSynchronousCommand(SYNC_CMD_READ,fd,NULL);  in syncWithMaster()
1510         err = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"REPLCONF",  in syncWithMaster()
1520         err = sendSynchronousCommand(SYNC_CMD_READ,fd,NULL);  in syncWithMaster()
1536         err = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"REPLCONF",  in syncWithMaster()
1546         err = sendSynchronousCommand(SYNC_CMD_READ,fd,NULL);  in syncWithMaster()
1563         if (slaveTryPartialResynchronization(fd,0) == PSYNC_WRITE_ERROR) {  in syncWithMaster()
1579     psync_result = slaveTryPartialResynchronization(fd,1);  in syncWithMaster()
1602         if (syncWrite(fd,"SYNC\r\n",6,server.repl_syncio_timeout*1000) == -1) {  in syncWithMaster()
1623     if (aeCreateFileEvent(server.el,fd, AE_READABLE,readSyncBulkPayload,NULL)  in syncWithMaster()
1628             strerror(errno),fd);  in syncWithMaster()
1642     aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE);  in syncWithMaster()
1643     close(fd);  in syncWithMaster()
1655     int fd;  in connectWithMaster()  local
1657     fd = anetTcpNonBlockBestEffortBindConnect(NULL,  in connectWithMaster()
1659     if (fd == -1) {  in connectWithMaster()
1665     if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) ==  in connectWithMaster()
1668         close(fd);  in connectWithMaster()
1674     server.repl_transfer_s = fd;  in connectWithMaster()
1684     int fd = server.repl_transfer_s;  in undoConnectWithMaster()  local
1686     aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE);  in undoConnectWithMaster()
1687     close(fd);  in undoConnectWithMaster()
1836                 if (anetPeerToString(slave->fd,ip,sizeof(ip),NULL) == -1)  in roleCommand()
1951     server.master->fd = newfd;  in replicationResurrectCachedMaster()
2311             if (write(slave->fd, "\n", 1) == -1) {  in replicationCron()