summaryrefslogtreecommitdiff
path: root/test.c
diff options
context:
space:
mode:
authormichael-grunder <michael.grunder@gmail.com>2022-08-25 12:08:20 -0700
committermichael-grunder <michael.grunder@gmail.com>2022-08-26 10:14:47 -0700
commit6a3e96ad2149584e441b0e8a5827dc6c2624035b (patch)
tree04fd2496251b711109b73046270f1231a61eb662 /test.c
parente7afd998f9ce3e6dfaa5e6534f779cab6a1c5a7b (diff)
Maintain backward compatibiliy withour onConnect callback.
In f69fac7690fb22a7fc19dba61ef70e5f79ccb2e9, our async onConnect callback was improved to take a non-const redisAsyncContext allowing it to be reentrant. Unfortunately, this is a breaking change we can't make until hiredis v2.0.0. This commit creates a separate callback member and corresponding function that allows us to use the new functionality, while maintaining our existing API for legacy code. Fixes #1086
Diffstat (limited to 'test.c')
-rw-r--r--test.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/test.c b/test.c
index fccaca4..b901752 100644
--- a/test.c
+++ b/test.c
@@ -2008,7 +2008,7 @@ static redisAsyncContext *do_aconnect(struct config config, astest_no testno)
{
redisOptions options = {0};
memset(&astest, 0, sizeof(astest));
-
+
astest.testno = testno;
astest.connect_status = astest.disconnect_status = -2;
@@ -2039,7 +2039,7 @@ static redisAsyncContext *do_aconnect(struct config config, astest_no testno)
c->data = &astest;
c->dataCleanup = asCleanup;
redisPollAttach(c);
- redisAsyncSetConnectCallback(c, connectCallback);
+ redisAsyncSetConnectCallbackNC(c, connectCallback);
redisAsyncSetDisconnectCallback(c, disconnectCallback);
return c;
}
@@ -2058,7 +2058,7 @@ static void test_async_polling(struct config config) {
int status;
redisAsyncContext *c;
struct config defaultconfig = config;
-
+
test("Async connect: ");
c = do_aconnect(config, ASTEST_CONNECT);
assert(c);
@@ -2095,7 +2095,7 @@ static void test_async_polling(struct config config) {
test_cond(astest.connect_status == REDIS_ERR);
config = defaultconfig;
}
-
+
/* Test a ping/pong after connection */
test("Async PING/PONG: ");
c = do_aconnect(config, ASTEST_PINGPONG);