Lines Matching refs:flags
278 if (c->flags & CLIENT_LUA) { in replicationFeedMonitors()
280 } else if (c->flags & CLIENT_UNIX_SOCKET) { in replicationFeedMonitors()
400 if (!(slave->flags & CLIENT_PRE_PSYNC)) { in replicationSetupSlaveForFullResync()
458 c->flags |= CLIENT_SLAVE; in masterTryPartialResynchronization()
533 slave->flags &= ~CLIENT_SLAVE; in startBgsaveForReplication()
537 slave->flags |= CLIENT_CLOSE_AFTER_REPLY; in startBgsaveForReplication()
566 if (c->flags & CLIENT_SLAVE) return; in syncCommand()
613 c->flags |= CLIENT_PRE_PSYNC; in syncCommand()
625 c->flags |= CLIENT_SLAVE; in syncCommand()
744 if (!(c->flags & CLIENT_SLAVE)) return; in replconfCommand()
970 server.master->flags |= CLIENT_MASTER; in replicationCreateMasterClient()
979 server.master->flags |= CLIENT_PRE_PSYNC; in replicationCreateMasterClient()
1181 char *sendSynchronousCommand(int flags, int fd, ...) { in sendSynchronousCommand() argument
1185 if (flags & SYNC_CMD_WRITE) { in sendSynchronousCommand()
1213 if (flags & SYNC_CMD_READ) { in sendSynchronousCommand()
1879 c->flags |= CLIENT_MASTER_FORCE_REPLY; in replicationSendAck()
1884 c->flags &= ~CLIENT_MASTER_FORCE_REPLY; in replicationSendAck()
1937 server.cached_master->flags &= ~CLIENT_MASTER; in replicationDiscardCachedMaster()
1952 server.master->flags &= ~(CLIENT_CLOSE_AFTER_REPLY|CLIENT_CLOSE_ASAP); in replicationResurrectCachedMaster()
2150 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
2278 !(server.master->flags & CLIENT_PRE_PSYNC)) in replicationCron()
2327 if (slave->flags & CLIENT_PRE_PSYNC) continue; in replicationCron()