Home
last modified time | relevance | path

Searched refs:CLIENT_MULTI (Results 1 – 12 of 12) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dmulti.c77 c->flags &= ~(CLIENT_MULTI|CLIENT_DIRTY_CAS|CLIENT_DIRTY_EXEC); in discardTransaction()
84 if (c->flags & CLIENT_MULTI) in flagTransaction()
89 if (c->flags & CLIENT_MULTI) { in multiCommand()
93 c->flags |= CLIENT_MULTI; in multiCommand()
98 if (!(c->flags & CLIENT_MULTI)) { in discardCommand()
124 if (!(c->flags & CLIENT_MULTI)) { in execCommand()
342 if (c->flags & CLIENT_MULTI) { in watchCommand()
H A Dt_list.c733 if (c->flags & CLIENT_MULTI) { in blockingPopGenericCommand()
759 if (c->flags & CLIENT_MULTI) { in brpoplpushCommand()
H A Dnetworking.c1135 if (!(c->flags & CLIENT_MULTI) && prevcmd != askingCommand) in resetClient()
1471 if (c->flags & CLIENT_MASTER && !(c->flags & CLIENT_MULTI)) { in processInputBuffer()
1659 if (client->flags & CLIENT_MULTI) *p++ = 'x'; in catClientInfoString()
1687 (client->flags & CLIENT_MULTI) ? client->mstate.count : -1, in catClientInfoString()
H A Dscripting.c362 if (server.lua_multi_emitted || (server.lua_caller->flags & CLIENT_MULTI)) { in luaRedisGenericCommand()
363 c->flags |= CLIENT_MULTI; in luaRedisGenericCommand()
365 c->flags &= ~CLIENT_MULTI; in luaRedisGenericCommand()
559 !(server.lua_caller->flags & CLIENT_MULTI) && in luaRedisGenericCommand()
H A Daof.c817 if (fakeClient->flags & CLIENT_MULTI && in loadAppendOnlyFile()
843 if (fakeClient->flags & CLIENT_MULTI) { in loadAppendOnlyFile()
H A Dreplication.c2181 if (c->flags & CLIENT_MULTI) discardTransaction(c); in replicationCacheMaster()
2454 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
H A Dmodule.c1302 if (ctx->client->flags & (CLIENT_MULTI|CLIENT_LUA)) return; in moduleReplicateMultiIfNeeded()
1447 if (ctx->client->flags & CLIENT_MULTI) in RM_GetContextFlags()
3609 int ismulti = c->flags & CLIENT_MULTI; in RM_BlockClient()
H A Dserver.c2636 (c->flags & CLIENT_MULTI && c->cmd->proc != execCommand))) { in processCommand()
2732 if (c->flags & CLIENT_MULTI && in processCommand()
H A Dserver.h232 #define CLIENT_MULTI (1<<3) /* This client is in a MULTI context */ macro
H A Dt_stream.c1543 if (c->flags & CLIENT_MULTI) { in xreadCommand()
H A Dt_zset.c3290 if (c->flags & CLIENT_MULTI) { in blockingGenericZpopCommand()
H A Dcluster.c5476 if (!(c->flags & CLIENT_MULTI)) return myself; in getNodeByQuery()