Home
last modified time | relevance | path

Searched refs:REDISMODULE_CTX_THREAD_SAFE (Results 1 – 3 of 3) sorted by relevance

/dports/databases/redis5/redis-5.0.14/src/
H A Dmodule.c149 #define REDISMODULE_CTX_THREAD_SAFE (1<<5) macro
566 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) freeClient(ctx->client); in moduleFreeContext()
1133 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) { in moduleGetReplyClient()
1354 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) return; in moduleReplicateMultiIfNeeded()
1429 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) { in RM_Replicate()
4035 ctx->flags |= REDISMODULE_CTX_THREAD_SAFE; in RM_GetThreadSafeContext()
/dports/databases/redis6/redis-6.0.16/src/
H A Dmodule.c166 #define REDISMODULE_CTX_THREAD_SAFE (1<<5) macro
631 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) freeClient(ctx->client); in moduleFreeContext()
1348 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) { in moduleGetReplyClient()
1624 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) return; in moduleReplicateMultiIfNeeded()
1699 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) { in RM_Replicate()
4923 ctx->flags |= REDISMODULE_CTX_THREAD_SAFE; in RM_GetThreadSafeContext()
4946 new_ctx->flags |= REDISMODULE_CTX_THREAD_SAFE; in RM_GetDetachedThreadSafeContext()
/dports/databases/redis-devel/redis-0e5b813/src/
H A Dmodule.c173 #define REDISMODULE_CTX_THREAD_SAFE (1<<4) macro
675 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) freeClient(ctx->client); in moduleFreeContext()
1883 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) { in moduleGetReplyClient()
2342 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) return; in moduleReplicateMultiIfNeeded()
2418 if (ctx->flags & REDISMODULE_CTX_THREAD_SAFE) { in RM_Replicate()
6705 ctx->flags |= REDISMODULE_CTX_THREAD_SAFE; in RM_GetThreadSafeContext()
6731 new_ctx->flags |= REDISMODULE_CTX_THREAD_SAFE; in RM_GetDetachedThreadSafeContext()