bug fix

DiceDB · Dec 5, 2024 · 07ca2b7 · 07ca2b7
1 parent 3e15eca
commit 07ca2b7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/iothread/iothread.go b/internal/iothread/iothread.go
@@ -64,6 +64,7 @@ func (t *BaseIOThread) Start(ctx context.Context) error {
 			t.ioThreadReadChan <- data
 		case err := <-readErrChan:
 			slog.Debug("Read error in io-thread, connection closed possibly", slog.String("id", t.id), slog.Any("error", err))
+			t.ioThreadErrChan <- err
 			return err
 		case resp := <-t.ioThreadWriteChan:
 			err := t.ioHandler.Write(ctx, resp)