@@ -157,7 +157,8 @@ Protocol.prototype._enqueue = function(sequence) {
157157 self . _emitPacket ( packet ) ;
158158 } )
159159 . on ( 'timeout' , function ( ) {
160- var err = new Error ( sequence . constructor . name + ' inactivity timeout' ) ;
160+ var sequenceId = sequence . _id || sequence . constructor . name ;
161+ var err = new Error ( sequenceId + ' inactivity timeout' ) ;
161162
162163 err . code = 'PROTOCOL_SEQUENCE_TIMEOUT' ;
163164 err . fatal = true ;
@@ -206,7 +207,8 @@ Protocol.prototype._enqueue = function(sequence) {
206207
207208Protocol . prototype . _validateEnqueue = function _validateEnqueue ( sequence ) {
208209 var err ;
209- var prefix = 'Cannot enqueue ' + sequence . constructor . name ;
210+ var sequenceId = sequence . _id || sequence . constructor . name ;
211+ var prefix = 'Cannot enqueue ' + sequenceId ;
210212
211213 if ( this . _fatalError ) {
212214 err = new Error ( prefix + ' after fatal error.' ) ;
@@ -253,7 +255,7 @@ Protocol.prototype._parsePacket = function() {
253255
254256 var Packet = this . _determinePacket ( sequence ) ;
255257 var packet = new Packet ( { protocol41 : this . _config . protocol41 } ) ;
256- var packetName = Packet . name ;
258+ var packetName = packet . _id || Packet . name ;
257259
258260 // Special case: Faster dispatch, and parsing done inside sequence
259261 if ( Packet === Packets . RowDataPacket ) {
@@ -447,7 +449,7 @@ Protocol.prototype._debugPacket = function(incoming, packet) {
447449 var direction = incoming
448450 ? '<--'
449451 : '-->' ;
450- var packetName = packet . constructor . name ;
452+ var packetName = packet . _id || packet . constructor . name ;
451453 var threadId = connection && connection . threadId !== null
452454 ? ' (' + connection . threadId + ')'
453455 : '' ;
0 commit comments