| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | RetriableStreamTest.java | 160 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata metadata) { in newSubstream()
193 ClientStream mockStream1 = mock(ClientStream.class); in retry_everythingDrained()
194 ClientStream mockStream2 = mock(ClientStream.class); in retry_everythingDrained()
195 ClientStream mockStream3 = mock(ClientStream.class); in retry_everythingDrained()
343 ClientStream mockStream1 = mock(ClientStream.class); in headersRead_cancel()
364 ClientStream mockStream1 = mock(ClientStream.class); in retry_headersRead_cancel()
375 ClientStream mockStream2 = mock(ClientStream.class); in retry_headersRead_cancel()
399 ClientStream mockStream1 = mock(ClientStream.class); in headersRead_closed()
423 ClientStream mockStream1 = mock(ClientStream.class); in retry_headersRead_closed()
434 ClientStream mockStream2 = mock(ClientStream.class); in retry_headersRead_closed()
[all …]
|
| D | DelayedClientTransportTest.java | 74 @Mock private ClientStream mockRealStream;
75 @Mock private ClientStream mockRealStream2;
124 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in streamStartThenAssignTransport()
143 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in newStreamThenAssignTransportThenShutdown()
170 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in assignTransportThenShutdownThenNewStream()
182 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in assignTransportThenShutdownNowThenNewStream()
190 ClientStream stream = delayedTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in cancelStreamWithoutSetTransport()
199 ClientStream stream = delayedTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in startThenCancelStreamWithoutSetTransport()
210 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in newStreamThenShutdownTransportThenAssignTransport()
243 ClientStream stream = delayedTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in newStreamThenShutdownTransportThenCancelStream()
[all …]
|
| D | ForwardingClientStreamTest.java | 42 private ClientStream mock = mock(ClientStream.class);
45 protected ClientStream delegate() {
53 ClientStream.class, in allMethodsForwarded()
|
| D | FailingClientStreamTest.java | 42 ClientStream stream = new FailingClientStream(status); in processedRpcProgressPopulatedToListener()
52 ClientStream stream = new FailingClientStream(status, RpcProgress.DROPPED); in droppedRpcProgressPopulatedToListener()
|
| D | ManagedChannelImplTest.java | 431 ClientStream mockStream = mock(ClientStream.class); in subtestCallsAndShutdown()
432 ClientStream mockStream2 = mock(ClientStream.class); in subtestCallsAndShutdown()
626 ClientStream mockStream = mock(ClientStream.class); in callOptionsExecutor()
878 .thenReturn(mock(ClientStream.class)); in firstResolvedServerFailedToConnect()
1427 doAnswer(new Answer<ClientStream>() { in informationPropagatedToNewStreamAndCallCredentials()
1429 public ClientStream answer(InvocationOnMock in) throws Throwable { in informationPropagatedToNewStreamAndCallCredentials()
1431 return mock(ClientStream.class); in informationPropagatedToNewStreamAndCallCredentials()
1491 ClientStream mockStream = mock(ClientStream.class); in pickerReturnsStreamTracer_noDelay()
1524 ClientStream mockStream = mock(ClientStream.class); in pickerReturnsStreamTracer_delayed()
1857 ClientStream mockStream = mock(ClientStream.class); in idleMode_resetsDelayedTransportPicker()
[all …]
|
| D | GrpcUtilTest.java | 246 ClientStream stream = transport in getTransportFromPickResult_errorPickResult_failFast()
262 ClientStream stream = transport in getTransportFromPickResult_dropPickResult_waitForReady()
278 ClientStream stream = transport in getTransportFromPickResult_dropPickResult_failFast()
|
| D | CallCredentialsApplyingTest.java | 66 private ClientStream mockStream;
209 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in applyMetadata_inline()
282 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in noCreds()
|
| D | FailingClientTransportTest.java | 44 ClientStream stream = transport in newStreamStart()
|
| D | TestUtils.java | 81 .thenReturn(mock(ClientStream.class)); in captureTransports()
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 47 if err := x.ClientStream.SendMsg(in); err != nil { return nil, err }
48 if err := x.ClientStream.CloseSend(); err != nil { return nil, err }
54 grpc.ClientStream
58 grpc.ClientStream anonMember
63 if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err }
78 grpc.ClientStream
82 grpc.ClientStream anonMember
86 return x.ClientStream.SendMsg(m)
90 if err := x.ClientStream.CloseSend(); err != nil { return nil, err }
92 if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err }
[all …]
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 222 if err := x.ClientStream.SendMsg(in); err != nil {
225 if err := x.ClientStream.CloseSend(); err != nil {
233 grpc.ClientStream
237 grpc.ClientStream anonMember
242 if err := x.ClientStream.RecvMsg(m); err != nil {
260 grpc.ClientStream
264 grpc.ClientStream anonMember
268 return x.ClientStream.SendMsg(m)
272 if err := x.ClientStream.CloseSend(); err != nil {
276 if err := x.ClientStream.RecvMsg(m); err != nil {
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MetadataApplierImpl.java | 45 private ClientStream returnedStream;
67 ClientStream realStream; in apply()
84 private void finalizeWith(ClientStream stream) { in finalizeWith()
104 ClientStream returnStream() { in returnStream()
|
| D | DelayedStream.java | 42 class DelayedStream implements ClientStream {
51 private ClientStream realStream;
103 final void setStream(ClientStream stream) { in setStream()
362 ClientStream getRealStream() { in getRealStream()
|
| D | ForwardingClientStream.java | 27 abstract class ForwardingClientStream implements ClientStream {
28 protected abstract ClientStream delegate(); in delegate()
|
| D | ClientStream.java | 30 public interface ClientStream extends Stream { interface
|
| D | ClientTransport.java | 52 ClientStream newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions); in newStream()
|
| D | NoopClientStream.java | 30 public class NoopClientStream implements ClientStream {
|
| D | DelayedClientTransport.java | 131 public final ClientStream newStream( in newStream()
355 ClientStream realStream; in createRealStream()
|
| D | ManagedChannelImpl.java | 526 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata newHeaders) {
936 Collection<ClientStream> uncommittedRetriableStreams = new HashSet<ClientStream>();
963 Collection<ClientStream> streams; in onShutdownNow()
969 for (ClientStream stream : streams) { in onShutdownNow()
999 uncommittedRetriableStreams = new HashSet<ClientStream>(); in remove()
|
| D | FailingClientTransport.java | 47 public ClientStream newStream( in newStream()
|
| D | ForwardingConnectionClientTransport.java | 47 public ClientStream newStream( in newStream()
|
| /external/grpc-grpc/test/cpp/util/ |
| D | proto_reflection_descriptor_database.h | 83 ClientStream; typedef
91 const std::shared_ptr<ClientStream> GetStream();
97 std::shared_ptr<ClientStream> stream_;
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 58 import io.grpc.internal.ClientStream;
252 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in frameAfterRstStreamShouldNotBreakClientChannel()
370 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in openStreamPreventsTermination()
422 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsClientStream()
459 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsServerStream()
513 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in ping_duringShutdown()
557 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in newStream_duringShutdown()
565 ClientStream stream2 = client.newStream(methodDescriptor, new Metadata(), callOptions); in newStream_duringShutdown()
601 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in newStream_afterTermination()
620 ClientStream stream1 = client.newStream(methodDescriptor, new Metadata(), callOptions); in transportInUse_normalClose()
[all …]
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | interceptor.go | 34 …Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error)
39 …amDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error)
|
| D | stream.go | 83 type ClientStream interface { interface
119 …m(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
133 …ntext, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
137 … desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
|