diff options
| author | Pavlo Yatsukhnenko <yatsukhnenko@gmail.com> | 2022-06-26 13:10:56 +0300 |
|---|---|---|
| committer | Pavlo Yatsukhnenko <yatsukhnenko@gmail.com> | 2022-06-28 18:18:38 +0300 |
| commit | 3c9e159c7e700a48aff29b83374039c3bdf1e909 (patch) | |
| tree | 2c3271ab868ca18b35e02afdd904d512474a8c62 /cluster_library.c | |
| parent | aaa4c91a7640d2fc0f3fea203dcc64d42a17b2cf (diff) | |
Refactor subscribe/unsubscribepubsub
Diffstat (limited to 'cluster_library.c')
| -rw-r--r-- | cluster_library.c | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/cluster_library.c b/cluster_library.c index 976cb889..2512f0fd 100644 --- a/cluster_library.c +++ b/cluster_library.c @@ -1857,8 +1857,8 @@ PHP_REDIS_API void cluster_sub_resp(INTERNAL_FUNCTION_PARAMETERS, redisCluster * // Set up our callback pointers zval z_ret, z_args[4]; - sctx->cb.retval = &z_ret; - sctx->cb.params = z_args; + sctx->cb.fci.retval = &z_ret; + sctx->cb.fci.params = z_args; /* We're in a subscribe loop */ c->subscribed_slot = c->cmd_slot; @@ -1911,12 +1911,10 @@ PHP_REDIS_API void cluster_sub_resp(INTERNAL_FUNCTION_PARAMETERS, redisCluster * } // Set arg count - sctx->cb.param_count = tab_idx; + sctx->cb.fci.param_count = tab_idx; // Execute our callback - if (zend_call_function(&(sctx->cb), &(sctx->cb_cache)) != - SUCCESS) - { + if (zend_call_function(&sctx->cb.fci, &sctx->cb.fci_cache) != SUCCESS) { break; } |