Commit 54d92f24 authored by Lam Pham-Sy's avatar Lam Pham-Sy
Browse files

distinguish between request and response pdu

parent 51b3edb1

lib/kinetic.js

+2 −1
Original line number Diff line number Diff line
@@ -1632,7 +1632,8 @@ function parsePDU(socket, callback) { 
                const pdu = new PDU(

                    Buffer.concat([header, rawData], HEADER_SZ + protobufSize));

                let error;

                if (pdu.getMessageType() !== ops.NOOP) {

                if (pdu.getCommand().status &&

                    pdu.getMessageType() !== ops.NOOP) {

                    error = (pdu.getStatusCode() === errors.SUCCESS) ? null :

                        pdu.getErrorMessage();

                }