Home
last modified time | relevance | path

Searched refs:CLIENT_MASTER (Results 1 – 9 of 9) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dnetworking.c222 if ((c->flags & CLIENT_MASTER) && in prepareClientToWrite()
370 char* to = c->flags & CLIENT_MASTER? "master": "replica"; in addReplyErrorLength()
371 char* from = c->flags & CLIENT_MASTER? "replica": "master"; in addReplyErrorLength()
862 if (server.master && c->flags & CLIENT_MASTER) { in freeClient()
928 if (c->flags & CLIENT_MASTER) replicationHandleMasterDisconnection(); in freeClient()
1439 if (server.lua_timedout && c->flags & CLIENT_MASTER) break; in processInputBuffer()
1504 if (!(c->flags & CLIENT_MASTER)) { in processInputBufferAndReplicate()
1558 } else if (c->flags & CLIENT_MASTER) { in readQueryFromClient()
1568 if (c->flags & CLIENT_MASTER) c->read_reploff += nread; in readQueryFromClient()
1657 if (client->flags & CLIENT_MASTER) *p++ = 'M'; in catClientInfoString()
[all …]
H A Dmulti.c148 !(c->flags & CLIENT_MASTER) && c->mstate.cmd_flags & CMD_WRITE) in execCommand()
H A Dscripting.c498 !(server.lua_caller->flags & CLIENT_MASTER)) in luaRedisGenericCommand()
539 !(server.lua_caller->flags & CLIENT_MASTER)) in luaRedisGenericCommand()
1524 } else if (server.lua_caller->flags & CLIENT_MASTER) { in scriptCommand()
H A Dserver.c825 !(c->flags & CLIENT_MASTER) && /* no timeout for masters */ in clientsCronHandleTimeout()
882 if (c->flags & CLIENT_MASTER) { in clientsCronResizeQueryBuffer()
2598 !(c->flags & CLIENT_MASTER) && in processCommand()
2600 server.lua_caller->flags & CLIENT_MASTER) && in processCommand()
2678 !(c->flags & CLIENT_MASTER) && in processCommand()
H A Dreplication.c1081 server.master->flags |= CLIENT_MASTER; in replicationCreateMasterClient()
2235 server.cached_master->flags &= ~CLIENT_MASTER; in replicationDiscardCachedMaster()
H A Ddb.c1086 if (c && writable_slave && !(c->flags & CLIENT_MASTER)) in setExpire()
H A Dmodule.c1450 if (ctx->client->flags & CLIENT_MASTER) in RM_GetContextFlags()
2789 if (server.cluster_enabled && !(ctx->client->flags & CLIENT_MASTER)) { in RM_Call()
H A Dserver.h230 #define CLIENT_MASTER (1<<1) /* This client is a master server */ macro
/f-stack/app/redis-5.0.5/
H A D00-RELEASENOTES1679 Make pending buffer processing safe for CLIENT_MASTER client.