Lines Matching refs:client
43 void putSlaveOnline(client *slave);
52 char *replicationGetSlaveName(client *c) { in replicationGetSlaveName()
209 client *slave = ln->value; in replicationFeedSlaves()
249 client *slave = ln->value; in replicationFeedSlaves()
268 void replicationFeedMonitors(client *c, list *monitors, int dictid, robj **argv, int argc) { in replicationFeedMonitors()
301 client *monitor = ln->value; in replicationFeedMonitors()
309 long long addReplyReplicationBacklog(client *c, long long offset) { in addReplyReplicationBacklog()
387 int replicationSetupSlaveForFullResync(client *slave, long long offset) { in replicationSetupSlaveForFullResync()
416 int masterTryPartialResynchronization(client *c) { in masterTryPartialResynchronization()
530 client *slave = ln->value; in startBgsaveForReplication()
548 client *slave = ln->value; in startBgsaveForReplication()
564 void syncCommand(client *c) { in syncCommand()
635 client *slave; in syncCommand()
706 void replconfCommand(client *c) { in replconfCommand()
783 void putSlaveOnline(client *slave) { in putSlaveOnline()
799 client *slave = privdata; in sendBulkToSlave()
876 client *slave = ln->value; in updateSlavesWaitingBgsave()
1773 void slaveofCommand(client *c) { in slaveofCommand()
1787 sds client = catClientInfoString(sdsempty(),c); in slaveofCommand() local
1789 client); in slaveofCommand()
1790 sdsfree(client); in slaveofCommand()
1808 sds client = catClientInfoString(sdsempty(),c); in slaveofCommand() local
1810 server.masterhost, server.masterport, client); in slaveofCommand()
1811 sdsfree(client); in slaveofCommand()
1819 void roleCommand(client *c) { in roleCommand()
1832 client *slave = ln->value; in roleCommand()
1876 client *c = server.master; in replicationSendAck()
1908 void replicationCacheMaster(client *c) { in replicationCacheMaster()
1991 client *slave = ln->value; in refreshGoodSlavesCount()
2127 client *slave = ln->value; in replicationCountAcksByOffset()
2137 void waitCommand(client *c) { in waitCommand()
2172 void unblockClientWaitingReplicas(client *c) { in unblockClientWaitingReplicas()
2189 client *c = ln->value; in processClientsWaitingReplicas()
2305 client *slave = ln->value; in replicationCron()
2324 client *slave = ln->value; in replicationCron()
2378 client *slave = ln->value; in replicationCron()