| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 370 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in openStreamPreventsTermination() local
372 clientStream.start(clientStreamListener); in openStreamPreventsTermination()
398 clientStream.halfClose(); in openStreamPreventsTermination()
406 clientStream.cancel(Status.CANCELLED); in openStreamPreventsTermination()
422 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsClientStream() local
424 clientStream.start(clientStreamListener); in shutdownNowKillsClientStream()
459 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsServerStream() local
461 clientStream.start(clientStreamListener); in shutdownNowKillsServerStream()
687 ClientStream clientStream = client.newStream(methodDescriptor, clientHeaders, callOptions); in basicStream() local
692 clientStream.start(clientStreamListener); in basicStream()
[all …]
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 78 CronetClientStream clientStream; field in CronetClientStreamTest
108 clientStream = in setUp()
123 callback.setStream(clientStream); in setUp()
128 clientStream.start(clientListener); in setUp()
166 clientStream.abstractClientStreamSink().writeFrame(buffers[i], false, i == 2 || i == 4, 1); in write()
191 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in write()
263 clientStream.request(1); in read()
268 clientStream.request(1); in read()
290 clientStream.abstractClientStreamSink().writeFrame(writableBuffer, false, true, 1); in streamSucceeded()
298 clientStream.request(2); in streamSucceeded()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 160 return new InProcessStream(method, headers, callOptions, authority).clientStream;
213 stream.clientStream.cancel(reason);
270 private final InProcessClientStream clientStream;
282 this.clientStream = new InProcessClientStream(callOptions, headers);
329 clientStream.setListener(serverStreamListener);
334 boolean onReady = clientStream.serverRequested(numMessages);
366 clientStream.statsTraceCtx.streamClosed(clientNotifyStatus);
384 clientStream.statsTraceCtx.inboundMessage(outboundSeqNo);
385 clientStream.statsTraceCtx.inboundMessageRead(outboundSeqNo, -1, -1);
412 clientStream.statsTraceCtx.clientInboundHeaders();
[all …]
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 342 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onHeadersRead()
354 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onDataRead()
366 NettyClientStream.TransportState stream = clientStream(connection().stream(streamId)); in onRstStreamRead()
407 NettyClientStream.TransportState clientStream = clientStream(stream); in channelInactive()
408 if (clientStream != null) { in channelInactive()
409 clientStream.transportReportStatus( in channelInactive()
463 NettyClientStream.TransportState stream = clientStream(connection().stream(http2Ex.streamId())); in onStreamError()
654 NettyClientStream.TransportState clientStream = clientStream(stream); in forcefulClose()
655 if (clientStream != null) { in forcefulClose()
656 clientStream.transportReportStatus(msg.getStatus(), true, new Metadata()); in forcefulClose()
[all …]
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | stream.go | 294 cs := &clientStream{
336 type clientStream struct { struct
360 cs *clientStream
381 func (cs *clientStream) Context() context.Context { argument
386 func (cs *clientStream) Header() (metadata.MD, error) { argument
396 func (cs *clientStream) Trailer() metadata.MD { argument
401 func (cs *clientStream) SendMsg(m interface{}) (err error) { argument
406 func (cs *clientStream) RecvMsg(m interface{}) (err error) { argument
411 func (cs *clientStream) CloseSend() error { argument
416 func (cs *clientStream) finish(err error) { argument
|
| D | call.go | 74 cs := csInt.(*clientStream)
|
| D | rpc_util.go | 158 stream *clientStream
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 122 final CronetClientStream clientStream = new CronetClientStream( in newStream() field in CronetClientTransport.StartCallback
130 clientStream.transportState().transportReportStatus(goAwayStatus, true, new Metadata()); in newStream()
132 startStream(clientStream); in newStream()
140 return new StartCallback().clientStream; in newStream()
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | transport.go | 166 streams map[uint32]*clientStream // client-initiated
190 type clientStream struct { struct
244 func (cs *clientStream) awaitRequestCancel(req *http.Request) { argument
251 func (cs *clientStream) cancelStream() { argument
266 func (cs *clientStream) checkResetOrDone() error { argument
277 func (cs *clientStream) getStartedWrite() bool { argument
284 func (cs *clientStream) abortRequestBodyWrite(err error) { argument
542 streams: make(map[uint32]*clientStream),
1031 func (cs *clientStream) writeRequestBody(body io.Reader, bodyCloser io.Closer) (err error) { argument
1139 func (cs *clientStream) awaitFlowControl(maxBytes int) (taken int32, err error) { argument
[all …]
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 354 void streamReadyToStart(OkHttpClientStream clientStream) { in streamReadyToStart() argument
356 clientStream.transportState().transportReportStatus( in streamReadyToStart()
359 pendingStreams.add(clientStream); in streamReadyToStart()
362 startStream(clientStream); in streamReadyToStart()
|