fix(protocol): drop request when connection lost after writing to kernel buffer

Author: fenying

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes Logs
 
+## v3.0.4
+
+- fix(protocol): drop request when connection lost after writing to kernel buffer.
+
 ## v3.0.3
 
 - fix(command): Return keys in `HMGET` command correctly.

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@litert/redis",
-  "version": "3.0.3",
+  "version": "3.0.4",
   "description": "A redis protocol implement for Node.js.",
   "main": "./lib/index.js",
   "scripts": {

package.json

@@ -548,6 +548,8 @@ export class ProtocolClient
 
         return this._unifyAsync(async (callback) => {
 
+            const execQueue = this._executingQueue;
+
             this._checkQueueSize();
 
             const data = this._encoder.encodeCommand(cmd, args);
@@ -559,7 +561,13 @@ export class ProtocolClient
 
             await this._write2Socket(data);
 
-            this._executingQueue.push(handle);
+            if (execQueue !== this._executingQueue) {
+
+                handle.callback(new E.E_CONN_LOST());
+                return;
+            }
+
+            execQueue.push(handle);
 
             if (this._cfg.commandTimeout > 0) {