Home
last modified time | relevance | path

Searched refs:newStream (Results 1 – 25 of 43) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java111 when(mockRealTransport.newStream(same(method), same(headers), same(callOptions))) in setUp()
113 when(mockRealTransport2.newStream(same(method2), same(headers2), same(callOptions2))) in setUp()
124 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in streamStartThenAssignTransport()
134 verify(mockRealTransport).newStream(same(method), same(headers), same(callOptions)); in streamStartThenAssignTransport()
143 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in newStreamThenAssignTransportThenShutdown()
152 verify(mockRealTransport).newStream(same(method), same(headers), same(callOptions)); in newStreamThenAssignTransportThenShutdown()
170 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in assignTransportThenShutdownThenNewStream()
173 verify(mockRealTransport, never()).newStream( in assignTransportThenShutdownThenNewStream()
182 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in assignTransportThenShutdownNowThenNewStream()
185 verify(mockRealTransport, never()).newStream( in assignTransportThenShutdownNowThenNewStream()
[all …]
DCallCredentials2ApplyingTest.java111 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class))) in setUp()
127 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_base()
148 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_transportSetSecurityLevel()
168 transport.newStream(method, origHeaders, in parameterPropagation_callOptionsSetAuthority()
189 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in credentialThrows()
191 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
211 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in applyMetadata_inline()
213 verify(mockTransport).newStream(method, origHeaders, callOptions); in applyMetadata_inline()
234 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in fail_inline()
236 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in fail_inline()
[all …]
DCallCredentialsApplyingTest.java110 when(mockTransport.newStream(same(method), any(Metadata.class), any(CallOptions.class))) in setUp()
126 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_base()
146 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_overrideByTransport()
167 transport.newStream(method, origHeaders, in parameterPropagation_overrideByCallOptions()
188 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in credentialThrows()
190 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
211 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in applyMetadata_inline()
213 verify(mockTransport).newStream(method, origHeaders, callOptions); in applyMetadata_inline()
235 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in fail_inline()
237 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in fail_inline()
[all …]
DManagedChannelImplTest.java445 when(mockTransport.newStream(same(method), same(headers), same(CallOptions.DEFAULT))) in subtestCallsAndShutdown()
447 when(mockTransport.newStream(same(method), same(headers2), same(CallOptions.DEFAULT))) in subtestCallsAndShutdown()
465 .newStream(same(method), same(headers), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
470 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
471 verify(mockTransport).newStream(same(method), same(headers2), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
516 verify(mockTransport).newStream(same(method), same(headers), same(CallOptions.DEFAULT)); in subtestCallsAndShutdown()
645 when(mockTransport.newStream(same(method), same(headers), any(CallOptions.class))) in callOptionsExecutor()
655 verify(mockTransport).newStream(same(method), same(headers), same(options)); in callOptionsExecutor()
875 when(goodTransportInfo.transport.newStream( in firstResolvedServerFailedToConnect()
889 verify(goodTransportInfo.transport).newStream(same(method), same(headers), in firstResolvedServerFailedToConnect()
[all …]
DGrpcUtilTest.java247 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in getTransportFromPickResult_errorPickResult_failFast()
263 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in getTransportFromPickResult_dropPickResult_waitForReady()
279 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in getTransportFromPickResult_dropPickResult_failFast()
DFailingClientTransportTest.java45 .newStream(TestMethodDescriptors.voidMethod(), new Metadata(), CallOptions.DEFAULT); in newStreamStart()
DTestUtils.java79 when(mockTransport.newStream( in captureTransports()
DClientCallImplTest.java132 when(transport.newStream( in setUp()
287 verify(transport).newStream(eq(method), metadataCaptor.capture(), same(baseCallOptions)); in advertisedEncodingsAreSent()
328 verify(transport).newStream(same(method), same(metadata), same(callOptions)); in callOptionsPropagatedToTransport()
669 .newStream(any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class)); in deadlineExceededBeforeCallStarted()
/external/antlr/tool/src/test/java/org/antlr/test/
DTestTreeNodeStream.java41 public TreeNodeStream newStream(Object t) { in newStream() method in TestTreeNodeStream
52 TreeNodeStream stream = newStream(t); in testSingleNode()
69 TreeNodeStream stream = newStream(t); in test4Nodes()
92 TreeNodeStream stream = newStream(root); in testList()
109 TreeNodeStream stream = newStream(root); in testFlatList()
124 TreeNodeStream stream = newStream(root); in testListWithOneNode()
138 TreeNodeStream stream = newStream(t); in testAoverB()
155 TreeNodeStream stream = newStream(t); in testLT()
183 TreeNodeStream stream = newStream(r0); in testMarkRewindEntire()
214 TreeNodeStream stream = newStream(r0); in testMarkRewindInMiddle()
[all …]
DTestBufferedTreeNodeStream.java43 public TreeNodeStream newStream(Object t) { in newStream() method in TestBufferedTreeNodeStream
66 TreeNodeStream stream = newStream(r0); in testSeek()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java251 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in maxMessageSizeShouldBeEnforced()
277 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameThrowIoException()
281 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameThrowIoException()
311 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameThrowsError()
332 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in nextFrameReturnFalse()
350 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in readMessages()
400 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in invalidInboundHeadersCancelStream()
424 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in invalidInboundTrailersPropagateToMetadata()
444 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in readStatus()
458 clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in receiveReset()
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3ConnectionTest.java74 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true); in clientCreatesStreamAndServerReplies()
105 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, false); in headersOnlyStreamIsClosedAfterReplyHeaders()
125 connection.newStream(headerEntries("b", "banana"), false, true); in clientCreatesStreamAndServerRepliesWithFin()
424 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, false);
469 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
512 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
558 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
604 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
632 FramedStream stream = connection.newStream(headerEntries("c", "cola"), true, true);
704 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
[all …]
DHttp2ConnectionTest.java131 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
192 FramedStream stream1 = connection.newStream(headerEntries("a", "android"), true, true);
193 FramedStream stream2 = connection.newStream(headerEntries("b", "banana"), true, true);
208 connection.newStream(headerEntries("c", "cola"), true, true);
255 FramedStream stream = connection.newStream(headerEntries("b", "banana"), false, true);
296 FramedStream client = connection.newStream(headerEntries("b", "banana"), false, true);
318 FramedStream client = connection.newStream(headerEntries("b", "banana"), true, true);
347 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
388 FramedStream client = connection.newStream(headerEntries("b", "banana"), false, true);
412 connection.newStream(headerEntries("b", "banana"), false, true);
[all …]
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java252 ClientStream stream = client.newStream(methodDescriptor, new Metadata(), callOptions); in frameAfterRstStreamShouldNotBreakClientChannel()
275 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/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingConnectionClientTransport.java47 public ClientStream newStream( in newStream() method in ForwardingConnectionClientTransport
49 return delegate().newStream(method, headers, callOptions); in newStream()
DCallCredentialsApplyingTransportFactory.java76 public ClientStream newStream( in newStream() method in CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport
99 return delegate.newStream(method, headers, callOptions); in newStream()
DDelayedClientTransport.java131 public final ClientStream newStream( in newStream() method in DelayedClientTransport
153 return transport.newStream( in newStream()
358 realStream = transport.newStream( in createRealStream()
DClientTransport.java52 ClientStream newStream(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions); in newStream() method
DFailingClientTransport.java47 public ClientStream newStream( in newStream() method in FailingClientTransport
DMetadataApplierImpl.java70 realStream = transport.newStream(method, origHeaders, callOptions); in apply()
DGrpcUtil.java680 public ClientStream newStream( in getTransportFromPickResult()
682 return transport.newStream( in getTransportFromPickResult()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFramedConnection.java236 return newStream(associatedStreamId, requestHeaders, out, false); in pushStream()
247 public FramedStream newStream(List<Header> requestHeaders, boolean out, boolean in) in newStream() method in FramedConnection
249 return newStream(0, requestHeaders, out, in); in newStream()
252 private FramedStream newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, in newStream() method in FramedConnection
668 newStream = new FramedStream(streamId, FramedConnection.this, outFinished, in headers()
671 streams.put(streamId, newStream); in headers()
675 listener.onStream(newStream); in headers()
679 newStream.close(ErrorCode.PROTOCOL_ERROR); in headers()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFramedConnection.java238 return newStream(associatedStreamId, requestHeaders, out, false); in pushStream()
249 public FramedStream newStream(List<Header> requestHeaders, boolean out, boolean in) in newStream() method in FramedConnection
251 return newStream(0, requestHeaders, out, in); in newStream()
254 private FramedStream newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, in newStream() method in FramedConnection
673 newStream = new FramedStream(streamId, FramedConnection.this, outFinished, in headers()
676 streams.put(streamId, newStream); in headers()
680 listener.onStream(newStream); in headers()
684 newStream.close(ErrorCode.PROTOCOL_ERROR); in headers()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetChannelBuilderTest.java65 CronetClientStream stream = transport.newStream(method, new Metadata(), CallOptions.DEFAULT); in alwaysUsePutTrue_cronetStreamIsIdempotent()
79 CronetClientStream stream = transport.newStream(method, new Metadata(), CallOptions.DEFAULT); in alwaysUsePut_defaultsToFalse()
DCronetClientTransportTest.java93 transport.newStream(descriptor, new Metadata(), CallOptions.DEFAULT); in shutdownTransport()
95 transport.newStream(descriptor, new Metadata(), CallOptions.DEFAULT); in shutdownTransport()

12