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

Add more keepalive logging

This commit is contained in:
Michael Lumish 2020-08-27 12:47:53 -07:00
parent 197cc84e7a
commit 665632f480
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -28,7 +28,7 @@ import * as logging from './logging';
import { LogVerbosity } from './constants'; import { LogVerbosity } from './constants';
import { getProxiedConnection, ProxyConnectionResult } from './http_proxy'; import { getProxiedConnection, ProxyConnectionResult } from './http_proxy';
import * as net from 'net'; import * as net from 'net';
import { GrpcUri, parseUri, splitHostPort } from './uri-parser'; import { GrpcUri, parseUri, splitHostPort, uriToString } from './uri-parser';
import { ConnectionOptions } from 'tls'; import { ConnectionOptions } from 'tls';
import { FilterFactory, Filter } from './filter'; import { FilterFactory, Filter } from './filter';
@ -263,6 +263,7 @@ export class Subchannel {
} }
private sendPing() { private sendPing() {
logging.trace(LogVerbosity.DEBUG, 'keepalive', 'Sending ping to ' + this.subchannelAddressString);
this.keepaliveTimeoutId = setTimeout(() => { this.keepaliveTimeoutId = setTimeout(() => {
this.transitionToState([ConnectivityState.READY], ConnectivityState.IDLE); this.transitionToState([ConnectivityState.READY], ConnectivityState.IDLE);
}, this.keepaliveTimeoutMs); }, this.keepaliveTimeoutMs);
@ -405,14 +406,14 @@ export class Subchannel {
errorCode === http2.constants.NGHTTP2_ENHANCE_YOUR_CALM && errorCode === http2.constants.NGHTTP2_ENHANCE_YOUR_CALM &&
opaqueData.equals(tooManyPingsData) opaqueData.equals(tooManyPingsData)
) { ) {
logging.log(
LogVerbosity.ERROR,
`Connection to ${this.channelTarget} rejected by server because of excess pings`
);
this.keepaliveTimeMs = Math.min( this.keepaliveTimeMs = Math.min(
2 * this.keepaliveTimeMs, 2 * this.keepaliveTimeMs,
KEEPALIVE_MAX_TIME_MS KEEPALIVE_MAX_TIME_MS
); );
logging.log(
LogVerbosity.ERROR,
`Connection to ${uriToString(this.channelTarget)} at ${this.subchannelAddressString} rejected by server because of excess pings. Increasing ping interval to ${this.keepaliveTimeMs}`
);
} }
trace( trace(
this.subchannelAddressString + this.subchannelAddressString +
@ -689,7 +690,7 @@ export class Subchannel {
for (const header of Object.keys(headers)) { for (const header of Object.keys(headers)) {
headersString += '\t\t' + header + ': ' + headers[header] + '\n'; headersString += '\t\t' + header + ': ' + headers[header] + '\n';
} }
trace('Starting stream with headers\n' + headersString); logging.trace(LogVerbosity.DEBUG, 'call_stream', 'Starting stream on subchannel ' + this.subchannelAddressString + ' with headers\n' + headersString);
callStream.attachHttp2Stream(http2Stream, this, extraFilterFactory); callStream.attachHttp2Stream(http2Stream, this, extraFilterFactory);
} }