Lines Matching refs:flags
928 !(c->flags & CLIENT_SLAVE) && /* no timeout for slaves */ in clientsCronHandleTimeout()
929 !(c->flags & CLIENT_MASTER) && /* no timeout for masters */ in clientsCronHandleTimeout()
930 !(c->flags & CLIENT_BLOCKED) && /* no timeout for BLPOP */ in clientsCronHandleTimeout()
931 !(c->flags & CLIENT_PUBSUB) && /* no timeout for Pub/Sub clients */ in clientsCronHandleTimeout()
937 } else if (c->flags & CLIENT_BLOCKED) { in clientsCronHandleTimeout()
1626 int restartServer(int flags, mstime_t delay) { in restartServer() argument
1634 if (flags & RESTART_SERVER_CONFIG_REWRITE && in restartServer()
1639 if (flags & RESTART_SERVER_GRACEFULLY && in restartServer()
2006 case 'w': c->flags |= CMD_WRITE; break; in populateCommandTable()
2007 case 'r': c->flags |= CMD_READONLY; break; in populateCommandTable()
2008 case 'm': c->flags |= CMD_DENYOOM; break; in populateCommandTable()
2009 case 'a': c->flags |= CMD_ADMIN; break; in populateCommandTable()
2010 case 'p': c->flags |= CMD_PUBSUB; break; in populateCommandTable()
2011 case 's': c->flags |= CMD_NOSCRIPT; break; in populateCommandTable()
2012 case 'R': c->flags |= CMD_RANDOM; break; in populateCommandTable()
2013 case 'S': c->flags |= CMD_SORT_FOR_SCRIPT; break; in populateCommandTable()
2014 case 'l': c->flags |= CMD_LOADING; break; in populateCommandTable()
2015 case 't': c->flags |= CMD_STALE; break; in populateCommandTable()
2016 case 'M': c->flags |= CMD_SKIP_MONITOR; break; in populateCommandTable()
2017 case 'k': c->flags |= CMD_ASKING; break; in populateCommandTable()
2018 case 'F': c->flags |= CMD_FAST; break; in populateCommandTable()
2122 int flags) in propagate() argument
2124 if (server.aof_state != AOF_OFF && flags & PROPAGATE_AOF) in propagate()
2126 if (flags & PROPAGATE_REPL) in propagate()
2161 void forceCommandPropagation(client *c, int flags) { in forceCommandPropagation() argument
2162 if (flags & PROPAGATE_REPL) c->flags |= CLIENT_FORCE_REPL; in forceCommandPropagation()
2163 if (flags & PROPAGATE_AOF) c->flags |= CLIENT_FORCE_AOF; in forceCommandPropagation()
2170 c->flags |= CLIENT_PREVENT_PROP; in preventCommandPropagation()
2175 c->flags |= CLIENT_PREVENT_AOF_PROP; in preventCommandAOF()
2180 c->flags |= CLIENT_PREVENT_REPL_PROP; in preventCommandReplication()
2220 void call(client *c, int flags) { in call() argument
2222 int client_old_flags = c->flags; in call()
2228 !(c->cmd->flags & (CMD_SKIP_MONITOR|CMD_ADMIN))) in call()
2235 c->flags &= ~(CLIENT_FORCE_AOF|CLIENT_FORCE_REPL|CLIENT_PREVENT_PROP); in call()
2248 if (server.loading && c->flags & CLIENT_LUA) in call()
2249 flags &= ~(CMD_CALL_SLOWLOG | CMD_CALL_STATS); in call()
2254 if (c->flags & CLIENT_LUA && server.lua_caller) { in call()
2255 if (c->flags & CLIENT_FORCE_REPL) in call()
2256 server.lua_caller->flags |= CLIENT_FORCE_REPL; in call()
2257 if (c->flags & CLIENT_FORCE_AOF) in call()
2258 server.lua_caller->flags |= CLIENT_FORCE_AOF; in call()
2263 if (flags & CMD_CALL_SLOWLOG && c->cmd->proc != execCommand) { in call()
2264 char *latency_event = (c->cmd->flags & CMD_FAST) ? in call()
2269 if (flags & CMD_CALL_STATS) { in call()
2275 if (flags & CMD_CALL_PROPAGATE && in call()
2276 (c->flags & CLIENT_PREVENT_PROP) != CLIENT_PREVENT_PROP) in call()
2286 if (c->flags & CLIENT_FORCE_REPL) propagate_flags |= PROPAGATE_REPL; in call()
2287 if (c->flags & CLIENT_FORCE_AOF) propagate_flags |= PROPAGATE_AOF; in call()
2292 if (c->flags & CLIENT_PREVENT_REPL_PROP || in call()
2293 !(flags & CMD_CALL_PROPAGATE_REPL)) in call()
2295 if (c->flags & CLIENT_PREVENT_AOF_PROP || in call()
2296 !(flags & CMD_CALL_PROPAGATE_AOF)) in call()
2307 c->flags &= ~(CLIENT_FORCE_AOF|CLIENT_FORCE_REPL|CLIENT_PREVENT_PROP); in call()
2308 c->flags |= client_old_flags & in call()
2318 if (flags & CMD_CALL_PROPAGATE) { in call()
2323 if (!(flags&CMD_CALL_PROPAGATE_AOF)) target &= ~PROPAGATE_AOF; in call()
2324 if (!(flags&CMD_CALL_PROPAGATE_REPL)) target &= ~PROPAGATE_REPL; in call()
2349 c->flags |= CLIENT_CLOSE_AFTER_REPLY; in processCommand()
2382 !(c->flags & CLIENT_MASTER) && in processCommand()
2383 !(c->flags & CLIENT_LUA && in processCommand()
2384 server.lua_caller->flags & CLIENT_MASTER) && in processCommand()
2416 if ((c->cmd->flags & CMD_DENYOOM) && retval == C_ERR) { in processCommand()
2430 (c->cmd->flags & CMD_WRITE || in processCommand()
2449 c->cmd->flags & CMD_WRITE && in processCommand()
2460 !(c->flags & CLIENT_MASTER) && in processCommand()
2461 c->cmd->flags & CMD_WRITE) in processCommand()
2468 if (c->flags & CLIENT_PUBSUB && in processCommand()
2482 !(c->cmd->flags & CMD_STALE)) in processCommand()
2491 if (server.loading && !(c->cmd->flags & CMD_LOADING)) { in processCommand()
2513 if (c->flags & CLIENT_MULTI && in processCommand()
2545 int prepareForShutdown(int flags) { in prepareForShutdown() argument
2546 int save = flags & SHUTDOWN_SAVE; in prepareForShutdown()
2547 int nosave = flags & SHUTDOWN_NOSAVE; in prepareForShutdown()
2680 if (c->flags & CLIENT_PUBSUB) { in pingCommand()
2712 if (cmd->flags & f) { in addReplyCommandFlag()
3313 if (c->flags & CLIENT_SLAVE) return; in monitorCommand()
3315 c->flags |= (CLIENT_SLAVE|CLIENT_MONITOR); in monitorCommand()