Lines Matching refs:slave
1525 client *slave = ln->value; in backgroundSaveDoneHandlerSocket() local
1527 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) { in backgroundSaveDoneHandlerSocket()
1535 if (slave->id == ok_slaves[2*j+1]) { in backgroundSaveDoneHandlerSocket()
1543 replicationGetSlaveName(slave), in backgroundSaveDoneHandlerSocket()
1546 freeClient(slave); in backgroundSaveDoneHandlerSocket()
1550 replicationGetSlaveName(slave)); in backgroundSaveDoneHandlerSocket()
1552 anetNonBlock(NULL,slave->fd); in backgroundSaveDoneHandlerSocket()
1553 anetSendTimeout(NULL,slave->fd,0); in backgroundSaveDoneHandlerSocket()
1609 client *slave = ln->value; in rdbSaveToSlavesSockets() local
1611 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in rdbSaveToSlavesSockets()
1612 clientids[numfds] = slave->id; in rdbSaveToSlavesSockets()
1613 fds[numfds++] = slave->fd; in rdbSaveToSlavesSockets()
1614 replicationSetupSlaveForFullResync(slave,getPsyncInitialOffset()); in rdbSaveToSlavesSockets()
1618 anetBlock(NULL,slave->fd); in rdbSaveToSlavesSockets()
1619 anetSendTimeout(NULL,slave->fd,server.repl_timeout*1000); in rdbSaveToSlavesSockets()
1705 client *slave = ln->value; in rdbSaveToSlavesSockets() local
1709 if (slave->id == clientids[j]) { in rdbSaveToSlavesSockets()
1710 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in rdbSaveToSlavesSockets()