|
@ -160,6 +160,7 @@ module.exports = class RPC { |
|
|
const req = this._dequeue(m.tid) |
|
|
const req = this._dequeue(m.tid) |
|
|
|
|
|
|
|
|
if (req === null) return |
|
|
if (req === null) return |
|
|
|
|
|
if (m.id && (req.to.port !== from.port || req.to.host !== from.host)) m.id = null |
|
|
|
|
|
|
|
|
// decrement the inflight window as this is an "ack"
|
|
|
// decrement the inflight window as this is an "ack"
|
|
|
if (this._win[this._w] > 0) this._win[this._w]-- |
|
|
if (this._win[this._w] > 0) this._win[this._w]-- |
|
|