Home
last modified time | relevance | path

Searched defs:clientStream (Results 1 – 7 of 7) sorted by relevance

/external/syzkaller/vendor/google.golang.org/grpc/
Dstream.go336 type clientStream struct { struct
337 opts []CallOption
338 c *callInfo
339 cc *ClientConn
340 desc *StreamDesc
342 codec baseCodec
343 cp Compressor
344 comp encoding.Compressor
346 cancel context.CancelFunc // cancels all attempts
348 sentLast bool // sent an end stream
[all …]
/external/syzkaller/vendor/golang.org/x/net/http2/
Dtransport.go190 type clientStream struct { struct
191 cc *ClientConn
192 req *http.Request
193 trace *clientTrace // or nil
194 ID uint32
195 resc chan resAndError
196 bufPipe pipe // buffered pipe with the flow-controlled response payload
197 startedWrite bool // started request body write; guarded by cc.mu
198 requestedGzip bool
199 on100 func() // optional code to run if get a 100 continue response
[all …]
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java370 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in openStreamPreventsTermination() local
422 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsClientStream() local
459 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsServerStream() local
687 ClientStream clientStream = client.newStream(methodDescriptor, clientHeaders, callOptions); in basicStream() local
834 ClientStream clientStream = client.newStream(methodDescriptor, clientHeaders, callOptions); in authorityPropagation() local
853 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in zeroMessageStream() local
889 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in earlyServerClose_withServerHeaders() local
924 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in earlyServerClose_noServerHeaders() local
968 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in earlyServerClose_serverFailure() local
999 final ClientStream clientStream = in earlyServerClose_serverFailure_withClientCancelOnListenerClosed() local
[all …]
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientTransport.java122 final CronetClientStream clientStream = new CronetClientStream( in newStream() field in CronetClientTransport.StartCallback
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientStreamTest.java78 CronetClientStream clientStream; field in CronetClientStreamTest
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientHandler.java715 private NettyClientStream.TransportState clientStream(Http2Stream stream) { in clientStream() method in NettyClientHandler
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java354 void streamReadyToStart(OkHttpClientStream clientStream) { in streamReadyToStart()