Update for upstream API changes of the RedisX library

Smithsonian · Dec 14, 2024 · fa74b7c · fa74b7c
1 parent e9b7d09
commit fa74b7c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/smax-util.c b/src/smax-util.c
@@ -147,7 +147,7 @@ void smaxSetOrigin(XMeta *m, const char *origin) {
  */
 // cppcheck-suppress constParameterPointer
 // cppcheck-suppress constParameter
-void smaxTransmitErrorHandler(Redis *redis, enum redisx_channel channel, const char *op) {
+void smaxSocketErrorHandler(Redis *redis, enum redisx_channel channel, const char *op) {
   pthread_t tid;
 
   if(redis != smaxGetRedis()) {

diff --git a/src/smax.c b/src/smax.c
@@ -464,7 +464,7 @@ int smaxConnect() {
     smaxGetProgramID();
     xvprintf("SMA-X> program ID: %s\n", programID);
 
-    redisxSetTcpBuf(tcpBufSize);
+    redisxSetTcpBuf(redis, tcpBufSize);
 
     if(sentinel) redis = redisxInitSentinel(SMAX_SENTINEL_SERVICENAME, sentinel, nSentinel);
     else redis = redisxInit(server ? server : SMAX_DEFAULT_HOSTNAME);
@@ -480,7 +480,7 @@ int smaxConnect() {
     redisxSetPassword(redis, auth);
     redisxSelectDB(redis, dbIndex);
 
-    redisxSetTransmitErrorHandler(redis, smaxTransmitErrorHandler);
+    redisxSetSocketErrorHandler(redis, smaxSocketErrorHandler);
 
     smaxSetPipelineConsumer(smaxProcessPipedWritesAsync);
     smaxAddSubscriber(NULL, ProcessUpdateNotificationAsync);