Searched refs:outboundFlow (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 70 OutboundFlowController outboundFlow, in OkHttpClientStream() argument
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow, in OkHttpClientStream()
202 private final OutboundFlowController outboundFlow; field in OkHttpClientStream.TransportState
211 OutboundFlowController outboundFlow, in TransportState() argument
216 this.outboundFlow = outboundFlow; in TransportState()
235 outboundFlow.data(data.endOfStream, id, data.buffer, false); in start()
241 outboundFlow.flush(); in start()
373 outboundFlow.data(endOfStream, id(), buffer, flush); in sendBuffer()
|
| D | OkHttpClientTransport.java | 145 private OutboundFlowController outboundFlow; field in OkHttpClientTransport
276 long remote = outboundFlow == null ? -1 : outboundFlow.windowUpdate(null, 0); in initTransportTracer()
344 outboundFlow, in newStream()
425 outboundFlow = new OutboundFlowController(this, frameWriter); in start()
1084 outboundWindowSizeIncreased = outboundFlow.initialOutboundWindowSize(initialWindowSize); in settings()
1098 outboundFlow.writeStreams(); in settings()
1179 outboundFlow.windowUpdate(null, (int) delta); in windowUpdate()
1185 outboundFlow.windowUpdate(stream, (int) delta); in windowUpdate()
|