Searched refs:REDISMODULE_CTX_THREAD_SAFE (Results 1 – 3 of 3) sorted by relevance
149 #define REDISMODULE_CTX_THREAD_SAFE (1<<5) macro566 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()
166 #define REDISMODULE_CTX_THREAD_SAFE (1<<5) macro631 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()
173 #define REDISMODULE_CTX_THREAD_SAFE (1<<4) macro675 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()