grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

grpc-js: Discard buffer tracker entry when RetryingCall ends

This commit is contained in:
Michael Lumish 2023-01-03 09:53:00 -08:00
parent c9f8f93a74
commit c62d41623b
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
packages/grpc-js/src/retrying-call.ts
View File

@ -202,6 +202,15 @@ export class RetryingCall implements Call {
private reportStatus(statusObject: StatusObject) { private reportStatus(statusObject: StatusObject) {
this.trace('ended with status: code=' + statusObject.code + ' details="' + statusObject.details + '"'); this.trace('ended with status: code=' + statusObject.code + ' details="' + statusObject.details + '"');
this.bufferTracker.freeAll(this.callNumber);
for (let i = 0; i < this.writeBuffer.length; i++) {
if (this.writeBuffer[i].entryType === 'MESSAGE') {
this.writeBuffer[i] = {
entryType: 'FREED',
allocated: false
};
}
}
process.nextTick(() => { process.nextTick(() => {
this.listener?.onReceiveStatus(statusObject); this.listener?.onReceiveStatus(statusObject);
}); });