Lines Matching refs:master

834             if (server.masterhost && server.master) replicationSendAck();  in replconfCommand()
1080 server.master = createClient(fd); in replicationCreateMasterClient()
1081 server.master->flags |= CLIENT_MASTER; in replicationCreateMasterClient()
1082 server.master->authenticated = 1; in replicationCreateMasterClient()
1083 server.master->reploff = server.master_initial_offset; in replicationCreateMasterClient()
1084 server.master->read_reploff = server.master->reploff; in replicationCreateMasterClient()
1085 memcpy(server.master->replid, server.master_replid, in replicationCreateMasterClient()
1089 if (server.master->reploff == -1) in replicationCreateMasterClient()
1090 server.master->flags |= CLIENT_PRE_PSYNC; in replicationCreateMasterClient()
1091 if (dbid != -1) selectDb(server.master,dbid); in replicationCreateMasterClient()
1309 memcpy(server.replid,server.master->replid,sizeof(server.replid)); in readSyncBulkPayload()
1310 server.master_repl_offset = server.master->reploff; in readSyncBulkPayload()
1964 if (server.master) { in replicationSetMaster()
1965 freeClient(server.master); in replicationSetMaster()
1989 if (server.master) freeClient(server.master); in replicationUnsetMaster()
2015 server.master = NULL; in replicationHandleMasterDisconnection()
2127 addReplyLongLong(c,server.master ? server.master->reploff : -1); in roleCommand()
2135 client *c = server.master; in replicationSendAck()
2168 serverAssert(server.master != NULL && server.cached_master == NULL); in replicationCacheMaster()
2178 sdsclear(server.master->querybuf); in replicationCacheMaster()
2179 sdsclear(server.master->pending_querybuf); in replicationCacheMaster()
2180 server.master->read_reploff = server.master->reploff; in replicationCacheMaster()
2190 server.cached_master = server.master; in replicationCacheMaster()
2220 memcpy(server.master->replid, server.replid, sizeof(server.replid)); in replicationCacheMasterUsingMyself()
2223 unlinkClient(server.master); in replicationCacheMasterUsingMyself()
2224 server.cached_master = server.master; in replicationCacheMasterUsingMyself()
2225 server.master = NULL; in replicationCacheMasterUsingMyself()
2247 server.master = server.cached_master; in replicationResurrectCachedMaster()
2249 server.master->fd = newfd; in replicationResurrectCachedMaster()
2250 server.master->flags &= ~(CLIENT_CLOSE_AFTER_REPLY|CLIENT_CLOSE_ASAP); in replicationResurrectCachedMaster()
2251 server.master->authenticated = 1; in replicationResurrectCachedMaster()
2252 server.master->lastinteraction = server.unixtime; in replicationResurrectCachedMaster()
2257 linkClient(server.master); in replicationResurrectCachedMaster()
2259 readQueryFromClient, server.master)) { in replicationResurrectCachedMaster()
2261 freeClientAsync(server.master); /* Close ASAP. */ in replicationResurrectCachedMaster()
2266 if (clientHasPendingReplies(server.master)) { in replicationResurrectCachedMaster()
2268 sendReplyToClient, server.master)) { in replicationResurrectCachedMaster()
2270 freeClientAsync(server.master); /* Close ASAP. */ in replicationResurrectCachedMaster()
2523 if (server.master) { in replicationGetSlaveOffset()
2524 offset = server.master->reploff; in replicationGetSlaveOffset()
2563 (time(NULL)-server.master->lastinteraction) > server.repl_timeout) in replicationCron()
2566 freeClient(server.master); in replicationCron()
2581 if (server.masterhost && server.master && in replicationCron()
2582 !(server.master->flags & CLIENT_PRE_PSYNC)) in replicationCron()