"Connection is closed" during quit() when commandQueue has entries

[SiebelsTim]

Problem

await ioredis.quit() throws an Error when there are still items on the commandQueue.

Error: Connection is closed.
    at close (./node_modules/ioredis/built/redis/event_handler.js:189:25)
    at Socket.<anonymous> (./node_modules/ioredis/built/redis/event_handler.js:156:20)
    at Object.onceWrapper (node:events:622:26)
    at Socket.emit (node:events:507:28)
    at TCP.<anonymous> (node:net:346:12)

Version

ioredis 5.8.0

Context

We have code for a health check that connects and immediately disconnects using await ioredis.quit().

The issue occurs often since #2011. I assume the reason for this is, that we now have entries on the commandQueue immediately.

Workaround

The issue does not occur anymore when I set disableClientInfo to true.

Reason

Usually the commandQueue is empty and the connection terminates sucessfully. However, when the error occures, we have the following entries on the commandQueue

[
  {
    command: Command {
      name: 'client',
      inTransaction: false,
      isResolved: false,
      transformed: true,
      replyEncoding: 'utf8',
      errorStack: undefined,
      args: [Array],
      callback: undefined,
      resolve: [Function (anonymous)],
      reject: [Function (anonymous)],
      promise: [Promise]
    },
    stream: undefined,
    select: 0
  },
  {
    command: Command {
      name: 'quit',
      inTransaction: false,
      isResolved: false,
      transformed: true,
      replyEncoding: 'utf8',
      errorStack: undefined,
      args: [],
      callback: undefined,
      resolve: [Function (anonymous)],
      reject: [Function (anonymous)],
      promise: [Promise]
    },
    stream: undefined,
    select: 0
  }
] 

The closeHandler flushes the queue with an error (

ioredis/lib/redis/event_handler.ts

Line 227 in 8dad79f

self.flushQueue(new Error(CONNECTION_CLOSED_ERROR_MSG));

).
Thus, quit can only ever complete successfully if the queue is empty.

[SiebelsTim]

I think this is the same as #597

[PavelPashov]

Hey @SiebelsTim,

Thank you for creating such a detailed issue, I was able to reproduce it in some scenarios. It would be very helpful if you could share a code snippet that produces the error. In my case, the issue only occurs when another command is executed after redis.quit().

The flushQueue method rejects all queued commands with the provided error, in this case CONNECTION_CLOSED_ERROR_MSG:

while ((item = this.commandQueue.shift())) {
  item.command.reject(error);
}

The CLIENT SETINFO commands added in PR #2011 handle promise rejections with a no-operation handler:

self.client("SETINFO", "LIB-VER", version).catch(noop);

My current suspicion is that the CLIENT SETINFO commands introduce a condition that triggers the error during your health check. Running your code with the following environment variable will enable debug logs, which should help us understand the exact order of command execution:

DEBUG=ioredis:*

Additionally, here’s an example health check implementation where I wasn’t able to reproduce the issue:

const redis = new Redis();

try {
  await new Promise<void>((resolve, reject) => {
    const timeout = setTimeout(() => {
      redis.off('ready', onReady);
      redis.off('error', onError);
      reject(new Error('Client ready timeout after 5s'));
    }, 5000);

    const onReady = () => {
      clearTimeout(timeout);
      redis.off('error', onError);
      redis
        .ping()
        .then(() => resolve())
        .catch(reject);
    };

    const onError = (error: Error) => {
      clearTimeout(timeout);
      redis.off('ready', onReady);
      reject(error);
    };

    redis.once('ready', onReady);
    redis.once('error', onError);
  });

  console.log('Health check passed');
} catch (error) {
  console.error('Health check failed');
  console.error('Client error:', error);
} finally {
  await redis.quit();
}

[SiebelsTim]

Hi @PavelPashov,

I am very happy to hear back from you so quickly!

I setup a minimal reproduction example:

import Redis from "ioredis";

for (let i = 0; i < 100; i++) {
  const redis = new Redis({
    host: "localhost",
    port: 6379,
    username: "default",
    password: "",
    lazyConnect: true,
    // disableClientInfo: true, // disable to workaround the error
  });

  await redis.connect();
  await redis.quit();
}

The issue only happens sometimes, so you might need a few rounds of it. I accomplished this with the for loop.

I assume there should be no global side-effects, I don't know it though.

Due to the logging, it is harder to trigger the race condition. I've needed a few rounds with DEBUG='ioredis:*'.

Complete output

  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +1ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +5ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +2ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +3ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +1ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +1ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +1ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +1ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +1ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +1ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +1ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +1ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +0ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[localhost:6379]: wait -> wait +0ms
  ioredis:redis status[localhost:6379]: wait -> connecting +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
  ioredis:redis status[127.0.0.1:6379]: connecting -> connect +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> auth([ 'default', '' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> info([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: connect -> ready +1ms
  ioredis:connection set the client info +1ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-NAME', 'ioredis' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> client([ 'SETINFO', 'LIB-VER', '5.8.1' ]) +0ms
  ioredis:redis write command[127.0.0.1:6379]: 0 -> quit([]) +0ms
  ioredis:redis status[127.0.0.1:6379]: ready -> close +0ms
  ioredis:connection skip reconnecting since the connection is manually closed. +0ms
  ioredis:redis status[127.0.0.1:6379]: close -> end +0ms
/home/tim/Projects/tests/redis-repro-2025/node_modules/.pnpm/ioredis@5.8.1/node_modules/ioredis/built/redis/event_handler.js:189
        self.flushQueue(new Error(utils_1.CONNECTION_CLOSED_ERROR_MSG));
                        ^

Error: Connection is closed.
    at close (/home/tim/Projects/tests/redis-repro-2025/node_modules/.pnpm/ioredis@5.8.1/node_modules/ioredis/built/redis/event_handler.js:189:25)
    at Socket.<anonymous> (/home/tim/Projects/tests/redis-repro-2025/node_modules/.pnpm/ioredis@5.8.1/node_modules/ioredis/built/redis/event_handler.js:156:20)
    at Object.onceWrapper (node:events:622:26)
    at Socket.emit (node:events:507:28)
    at TCP.<anonymous> (node:net:346:12)

Node.js v24.3.0

[PavelPashov]

Hi @SiebelsTim, thank you for providing the example. Unfortunately, I was still unable to reproduce it properly even with this example. I have an idea what the culprit could be however, it's hard to verify it if I can't reproduce it. It's very helpful that you've also included the workaround for it. Let's see if anyone else experiences this issue.

[SiebelsTim]

Hi @PavelPashov,

I just realized that I can only reproduce this with DragonflyDB. Sorry I didn't immediately realize that this might affect the problem.

I can reproduce this when running DragonflyDB as such:

docker run -it -p6379:6379 docker.dragonflydb.io/dragonflydb/dragonfly

[PavelPashov]

Hey @SiebelsTim,

Thank you for the clarification. I was able to reproduce the issue immediately. It appears to be an existing, long-standing behavior, as I could trigger it by setting connectionName: "my-test-client" in the client options. I recommend continuing with the current workaround for the time being, as we investigate this further, since this issue has likely been present for some time and is only now more visible due to the CLIENT SETINFO commands.

[PavelPashov]

Hey @SiebelsTim, version 5.8.2 of ioredis has been released. When you have a moment, could you confirm if this update resolves the issue?

[SiebelsTim]

Hi @PavelPashov,

Yes, this seems to be fixed :) Thank you very much!