diff options
author | Pavlo Yatsukhnenko <yatsukhnenko@gmail.com> | 2020-09-08 17:58:08 +0300 |
---|---|---|
committer | Pavlo Yatsukhnenko <yatsukhnenko@gmail.com> | 2020-09-08 17:58:08 +0300 |
commit | a8daaff87a055bb6b4fb8702151915f56e144649 (patch) | |
tree | 11956b226ac03299ee10ece9dee9a99608eb6354 /redis_session.c | |
parent | f5c6fb0a45fdcc46de4c2b524c3725786a8aa11a (diff) |
Issue #1782
Allow to specify stream context for rediscluster session handler.
Diffstat (limited to 'redis_session.c')
-rw-r--r-- | redis_session.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/redis_session.c b/redis_session.c index 0e72fd4f..4165fff8 100644 --- a/redis_session.c +++ b/redis_session.c @@ -854,7 +854,7 @@ static char *cluster_session_key(redisCluster *c, const char *key, int keylen, PS_OPEN_FUNC(rediscluster) { redisCluster *c; - zval z_conf, *zv; + zval z_conf, *zv, *context; HashTable *ht_conf, *ht_seeds; double timeout = 0, read_timeout = 0; int persistent = 0, failover = REDIS_FAILOVER_NONE; @@ -932,6 +932,10 @@ PS_OPEN_FUNC(rediscluster) { redis_sock_set_auth(c->flags, user, pass); + if ((context = REDIS_HASH_STR_FIND_TYPE_STATIC(ht_conf, "stream", IS_ARRAY)) != NULL) { + redis_sock_set_stream_context(c->flags, context); + } + /* First attempt to load from cache */ if (CLUSTER_CACHING_ENABLED()) { hash = cluster_hash_seeds(seeds, nseeds); |