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

Handle 'too_many_pings' error from server

This commit is contained in:
murgatroid99 2019-11-06 14:28:44 -08:00
parent a7567f05cc
commit fef812b2c8
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -71,6 +71,8 @@ function uniformRandom(min: number, max: number) {
return Math.random() * (max - min) + min; return Math.random() * (max - min) + min;
} }
const tooManyPingsData: Buffer = Buffer.from('too_many_pings', 'ascii');
export class Subchannel { export class Subchannel {
/** /**
* The subchannel's current connectivity state. Invariant: `session` === `null` * The subchannel's current connectivity state. Invariant: `session` === `null`
@ -275,8 +277,14 @@ export class Subchannel {
); );
} }
}); });
session.once('goaway', () => { session.once('goaway', (errorCode: number, lastStreamID: number, opaqueData: Buffer) => {
if (this.session === session) { if (this.session === session) {
/* See the last paragraph of
* https://github.com/grpc/proposal/blob/master/A8-client-side-keepalive.md#basic-keepalive */
if (errorCode === http2.constants.NGHTTP2_ENHANCE_YOUR_CALM && opaqueData.equals(tooManyPingsData)) {
logging.log(LogVerbosity.ERROR, `Connection to ${this.channelTarget} rejected by server because of excess pings`);
this.keepaliveTimeMs *= 2;
}
this.transitionToState( this.transitionToState(
[ConnectivityState.CONNECTING, ConnectivityState.READY], [ConnectivityState.CONNECTING, ConnectivityState.READY],
ConnectivityState.IDLE ConnectivityState.IDLE