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

Merge pull request #1463 from azban/azb-grpc-js-server-call-deadline-lazy-singleton 

grpc-js: clear noop server call deadline
This commit is contained in:
Michael Lumish 2020-06-08 15:06:22 -07:00 committed by GitHub
parent 066950a71b e3a50ff3ee
commit e90d0c2c0e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
packages/grpc-js/src/server-call.ts
View File

@ -341,15 +341,13 @@ export type Handler<RequestType, ResponseType> =
export type HandlerType = 'bidi' | 'clientStream' | 'serverStream' | 'unary'; export type HandlerType = 'bidi' | 'clientStream' | 'serverStream' | 'unary';
const noopTimer: NodeJS.Timer = setTimeout(() => {}, 0);
// Internal class that wraps the HTTP2 request. // Internal class that wraps the HTTP2 request.
export class Http2ServerCallStream< export class Http2ServerCallStream<
RequestType, RequestType,
ResponseType ResponseType
> extends EventEmitter { > extends EventEmitter {
cancelled = false; cancelled = false;
deadline: NodeJS.Timer = noopTimer; deadline: NodeJS.Timer = setTimeout(() => {}, 0);
private wantTrailers = false; private wantTrailers = false;
private metadataSent = false; private metadataSent = false;
private canPush = false; private canPush = false;
@ -389,6 +387,9 @@ export class Http2ServerCallStream<
if ('grpc.max_receive_message_length' in options) { if ('grpc.max_receive_message_length' in options) {
this.maxReceiveMessageSize = options['grpc.max_receive_message_length']!; this.maxReceiveMessageSize = options['grpc.max_receive_message_length']!;
} }
// Clear noop timer
clearTimeout(this.deadline);
} }
private checkCancelled(): boolean { private checkCancelled(): boolean {