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 #2041 from nimf/http2-flowctrl-tracing 

HTTP/2 flow control tracing
This commit is contained in:
Michael Lumish 2022-02-10 10:10:36 -08:00 committed by GitHub
parent faa79fe19e da66707d3b
commit d57df93200
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
doc/environment_variables.md
View File

@ -37,6 +37,7 @@ can be set.
- `server_call` - Traces server handling of individual requests - `server_call` - Traces server handling of individual requests
- `subchannel` - Traces subchannel connectivity state and errors - `subchannel` - Traces subchannel connectivity state and errors
- `subchannel_refcount` - Traces subchannel refcount changes - `subchannel_refcount` - Traces subchannel refcount changes
- `subchannel_flowctrl` - Traces HTTP/2 flow control
The following tracers are added by the `@grpc/grpc-js-xds` library: The following tracers are added by the `@grpc/grpc-js-xds` library:
- `cds_balancer` - Traces the CDS load balancing policy - `cds_balancer` - Traces the CDS load balancing policy

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

@ -41,6 +41,7 @@ import { SubchannelRef, ChannelzTrace, ChannelzChildrenTracker, SubchannelInfo,
const clientVersion = require('../../package.json').version; const clientVersion = require('../../package.json').version;
const TRACER_NAME = 'subchannel'; const TRACER_NAME = 'subchannel';
const FLOW_CONTROL_TRACER_NAME = 'subchannel_flowctrl';
const MIN_CONNECT_TIMEOUT_MS = 20000; const MIN_CONNECT_TIMEOUT_MS = 20000;
const INITIAL_BACKOFF_MS = 1000; const INITIAL_BACKOFF_MS = 1000;
@ -324,6 +325,10 @@ export class Subchannel {
logging.trace(LogVerbosity.DEBUG, 'subchannel_refcount', '(' + this.channelzRef.id + ') ' + this.subchannelAddressString + ' ' + text); logging.trace(LogVerbosity.DEBUG, 'subchannel_refcount', '(' + this.channelzRef.id + ') ' + this.subchannelAddressString + ' ' + text);
} }
private flowControlTrace(text: string): void {
logging.trace(LogVerbosity.DEBUG, FLOW_CONTROL_TRACER_NAME, '(' + this.channelzRef.id + ') ' + this.subchannelAddressString + ' ' + text);
}
private handleBackoffTimer() { private handleBackoffTimer() {
if (this.continueConnecting) { if (this.continueConnecting) {
this.transitionToState( this.transitionToState(
@ -848,6 +853,12 @@ export class Subchannel {
' with headers\n' + ' with headers\n' +
headersString headersString
); );
this.flowControlTrace(
'local window size: ' +
this.session!.state.localWindowSize +
' remote window size: ' +
this.session!.state.remoteWindowSize
);
const streamSession = this.session; const streamSession = this.session;
let statsTracker: SubchannelCallStatsTracker; let statsTracker: SubchannelCallStatsTracker;
if (this.channelzEnabled) { if (this.channelzEnabled) {