Lines Matching refs:master

760             if (server.masterhost && server.master) replicationSendAck();  in replconfCommand()
969 server.master = createClient(fd); in replicationCreateMasterClient()
970 server.master->flags |= CLIENT_MASTER; in replicationCreateMasterClient()
971 server.master->authenticated = 1; in replicationCreateMasterClient()
973 server.master->reploff = server.repl_master_initial_offset; in replicationCreateMasterClient()
974 memcpy(server.master->replrunid, server.repl_master_runid, in replicationCreateMasterClient()
978 if (server.master->reploff == -1) in replicationCreateMasterClient()
979 server.master->flags |= CLIENT_PRE_PSYNC; in replicationCreateMasterClient()
1730 if (server.master) freeClient(server.master); in replicationSetMaster()
1746 if (server.master) { in replicationUnsetMaster()
1752 server.master_repl_offset = server.master->reploff; in replicationUnsetMaster()
1755 freeClient(server.master); in replicationUnsetMaster()
1765 server.master = NULL; in replicationHandleMasterDisconnection()
1868 addReplyLongLong(c,server.master ? server.master->reploff : -1); in roleCommand()
1876 client *c = server.master; in replicationSendAck()
1909 serverAssert(server.master != NULL && server.cached_master == NULL); in replicationCacheMaster()
1917 server.cached_master = server.master; in replicationCacheMaster()
1949 server.master = server.cached_master; in replicationResurrectCachedMaster()
1951 server.master->fd = newfd; in replicationResurrectCachedMaster()
1952 server.master->flags &= ~(CLIENT_CLOSE_AFTER_REPLY|CLIENT_CLOSE_ASAP); in replicationResurrectCachedMaster()
1953 server.master->authenticated = 1; in replicationResurrectCachedMaster()
1954 server.master->lastinteraction = server.unixtime; in replicationResurrectCachedMaster()
1958 listAddNodeTail(server.clients,server.master); in replicationResurrectCachedMaster()
1960 readQueryFromClient, server.master)) { in replicationResurrectCachedMaster()
1962 freeClientAsync(server.master); /* Close ASAP. */ in replicationResurrectCachedMaster()
1967 if (clientHasPendingReplies(server.master)) { in replicationResurrectCachedMaster()
1969 sendReplyToClient, server.master)) { in replicationResurrectCachedMaster()
1971 freeClientAsync(server.master); /* Close ASAP. */ in replicationResurrectCachedMaster()
2219 if (server.master) { in replicationGetSlaveOffset()
2220 offset = server.master->reploff; in replicationGetSlaveOffset()
2259 (time(NULL)-server.master->lastinteraction) > server.repl_timeout) in replicationCron()
2262 freeClient(server.master); in replicationCron()
2277 if (server.masterhost && server.master && in replicationCron()
2278 !(server.master->flags & CLIENT_PRE_PSYNC)) in replicationCron()