MCPcopy
hub / github.com/grpc/grpc-go / getStream

Method getStream

internal/transport/http2_client.go:1141–1146  ·  view source on GitHub ↗
(f http2.Frame)

Source from the content-addressed store, hash-verified

1139}
1140
1141func (t *http2Client) getStream(f http2.Frame) *ClientStream {
1142 t.mu.Lock()
1143 s := t.activeStreams[f.Header().StreamID]
1144 t.mu.Unlock()
1145 return s
1146}
1147
1148// adjustWindow sends out extra window update over the initial window size
1149// of stream if the application is requesting data larger in size than

Callers 3

handleDataMethod · 0.95
handleRSTStreamMethod · 0.95
operateHeadersMethod · 0.95

Calls 3

HeaderMethod · 0.65
LockMethod · 0.45
UnlockMethod · 0.45

Tested by

no test coverage detected