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: Handle errors when trying to ping

This commit is contained in:
Michael Lumish 2022-08-08 13:05:26 -07:00
parent 586f7c6db9
commit 31d28b5f14
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/grpc-js/src/subchannel.ts
View File

@ -361,12 +361,21 @@ export class Subchannel {
this.handleDisconnect(); this.handleDisconnect();
}, this.keepaliveTimeoutMs); }, this.keepaliveTimeoutMs);
this.keepaliveTimeoutId.unref?.(); this.keepaliveTimeoutId.unref?.();
this.session!.ping( try {
(err: Error | null, duration: number, payload: Buffer) => { this.session!.ping(
this.keepaliveTrace('Received ping response'); (err: Error | null, duration: number, payload: Buffer) => {
clearTimeout(this.keepaliveTimeoutId); this.keepaliveTrace('Received ping response');
} clearTimeout(this.keepaliveTimeoutId);
); }
);
} catch (e) {
/* If we fail to send a ping, the connection is no longer functional, so
* we should discard it. */
this.transitionToState(
[ConnectivityState.READY],
ConnectivityState.TRANSIENT_FAILURE
);
}
} }
private startKeepalivePings() { private startKeepalivePings() {