| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractClientStreamTest.java | 74 private final TransportTracer transportTracer = new TransportTracer(); field in AbstractClientStreamTest
104 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in cancel_doNotAcceptOk()
123 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in cancel_failsOnNull()
132 final BaseTransportState state = new BaseTransportState(statsTraceCtx, transportTracer); in cancel_notifiesOnlyOnce()
139 }, statsTraceCtx, transportTracer); in cancel_notifiesOnlyOnce()
151 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in startFailsOnNullListener()
161 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in cantCallStartTwice()
172 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in inboundDataReceived_failsOnNullFrame()
184 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in inboundHeadersReceived_notifiesListener()
195 new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer); in inboundHeadersReceived_failsIfStatusReported()
[all …]
|
| D | Http2ClientStreamTransportStateTest.java | 53 private TransportTracer transportTracer; field in Http2ClientStreamTransportStateTest
60 transportTracer = new TransportTracer(); in setUp()
75 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_notifiesListener()
89 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_doesntRequire200()
103 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_noHttpStatus()
118 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_wrongContentType_200()
134 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_wrongContentType_401()
151 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_handles_1xx()
173 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_twice()
192 BaseTransportState state = new BaseTransportState(transportTracer); in transportHeadersReceived_unknownAndTwiceLogsSecondHeaders()
[all …]
|
| D | MessageDeframerTest.java | 94 private TransportTracer transportTracer = new TransportTracer(); field in MessageDeframerTest.WithAndWithoutFullStreamCompressionTests
97 DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, transportTracer);
131 checkStats(tracer, transportTracer.getStats(), 2, 2); in simplePayload()
145 checkStats(tracer, transportTracer.getStats(), 1, 1, 2, 2); in smallCombinedPayloads()
158 checkStats(tracer, transportTracer.getStats(), 1, 1); in endOfStreamWithPayloadShouldNotifyEndOfStream()
172 checkStats(tracer, transportTracer.getStats()); in endOfStreamShouldNotifyEndOfStream()
183 checkStats(tracer, transportTracer.getStats()); in endOfStreamWithPartialMessageShouldNotifyDeframerClosedWithPartialMessage()
192 DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, transportTracer); in endOfStreamWithInvalidGzipBlockShouldNotifyDeframerClosedWithPartialMessage()
199 checkStats(tracer, transportTracer.getStats()); in endOfStreamWithInvalidGzipBlockShouldNotifyDeframerClosedWithPartialMessage()
218 transportTracer.getStats(), in payloadSplitBetweenBuffers()
[all …]
|
| D | AbstractServerStreamTest.java | 68 private TransportTracer transportTracer; field in AbstractServerStreamTest
74 transportTracer = new TransportTracer(); in setUp()
78 new AbstractServerStreamBase.TransportState(MAX_MESSAGE_SIZE, transportTracer)); in setUp()
378 protected TransportState(int maxMessageSize, TransportTracer transportTracer) { in TransportState() argument
379 super(maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportState()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractStream.java | 114 private final TransportTracer transportTracer; field in AbstractStream.TransportState
138 TransportTracer transportTracer) { in TransportState() argument
140 this.transportTracer = checkNotNull(transportTracer, "transportTracer"); in TransportState()
146 transportTracer); in TransportState()
289 return transportTracer;
|
| D | AbstractClientStream.java | 96 private final TransportTracer transportTracer; field in AbstractClientStream
110 TransportTracer transportTracer, in AbstractClientStream() argument
114 this.transportTracer = checkNotNull(transportTracer, "transportTracer"); in AbstractClientStream()
208 return transportTracer; in getTransportTracer()
237 TransportTracer transportTracer) { in TransportState() argument
238 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
|
| D | MessageDeframer.java | 91 private final TransportTracer transportTracer; field in MessageDeframer
122 TransportTracer transportTracer) { in MessageDeframer() argument
127 this.transportTracer = checkNotNull(transportTracer, "transportTracer"); in MessageDeframer()
392 transportTracer.reportMessageReceived(); in processHeader()
|
| D | Http2ClientStreamTransportState.java | 70 TransportTracer transportTracer) { in Http2ClientStreamTransportState() argument
71 super(maxMessageSize, statsTraceCtx, transportTracer); in Http2ClientStreamTransportState()
|
| D | AbstractServerStream.java | 205 TransportTracer transportTracer) { in TransportState() argument
209 Preconditions.checkNotNull(transportTracer, "transportTracer")); in TransportState()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 52 private final TransportTracer transportTracer; field in NettyServerStream
60 TransportTracer transportTracer) { in NettyServerStream() argument
67 this.transportTracer = checkNotNull(transportTracer, "transportTracer"); in NettyServerStream()
134 transportTracer.reportMessageSent(numMessages); in writeFrame()
167 TransportTracer transportTracer) { in TransportState() argument
168 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
|
| D | NettyClientTransport.java | 92 private final TransportTracer transportTracer; field in NettyClientTransport
101 Runnable tooManyPingsRunnable, TransportTracer transportTracer, Attributes eagAttributes) { in NettyClientTransport() argument
118 this.transportTracer = Preconditions.checkNotNull(transportTracer, "transportTracer"); in NettyClientTransport()
164 transportTracer) { in newStream()
177 transportTracer); in newStream()
199 transportTracer,
354 transportTracer.getStats(),
|
| D | NettyServerTransport.java | 78 private final TransportTracer transportTracer; field in NettyServerTransport
85 TransportTracer transportTracer, in NettyServerTransport() argument
102 this.transportTracer = Preconditions.checkNotNull(transportTracer, "transportTracer"); in NettyServerTransport()
233 transportTracer.getStats(), in getStatsHelper()
258 transportTracer, in createHandler()
|
| D | NettyServerHandler.java | 112 private final TransportTracer transportTracer; field in NettyServerHandler
136 TransportTracer transportTracer, in newHandler() argument
161 transportTracer, in newHandler()
182 TransportTracer transportTracer, in newHandler() argument
226 transportTracer, in newHandler()
240 TransportTracer transportTracer, in NettyServerHandler() argument
303 this.transportTracer = checkNotNull(transportTracer, "transportTracer"); in NettyServerHandler()
346 if (transportTracer != null) { in handlerAdded()
349 transportTracer.setFlowControlWindowReader(new TransportTracer.FlowControlReader() { in handlerAdded()
428 transportTracer); in onHeadersRead()
[all …]
|
| D | NettyClientHandler.java | 104 private final TransportTracer transportTracer; field in NettyClientHandler
119 TransportTracer transportTracer, in newHandler() argument
143 transportTracer, in newHandler()
159 TransportTracer transportTracer, in newHandler() argument
186 transportTracer.setFlowControlWindowReader(new TransportTracer.FlowControlReader() { in newHandler()
212 transportTracer, in newHandler()
225 TransportTracer transportTracer, in NettyClientHandler() argument
232 this.transportTracer = Preconditions.checkNotNull(transportTracer); in NettyClientHandler()
620 transportTracer.reportKeepAliveSent(); in sendPingFrame()
|
| D | NettyClientStream.java | 73 TransportTracer transportTracer) { in NettyClientStream() argument
77 transportTracer, in NettyClientStream()
222 TransportTracer transportTracer) { in TransportState() argument
223 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
|
| D | NettyChannelBuilder.java | 473 private final TransportTracer transportTracer; field in NettyChannelBuilder.NettyTransportFactory
481 TransportTracer transportTracer) { in NettyTransportFactory() argument
491 this.transportTracer = transportTracer; in NettyTransportFactory()
526 tooManyPingsRunnable, transportTracer, options.getEagAttributes()); in newClientTransport()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 173 transportTracer); in setUp()
517 transportTracer); in createIncrementsIdsForActualAndBufferdStreams()
526 transportTracer); in createIncrementsIdsForActualAndBufferdStreams()
558 assertEquals(0, transportTracer.getStats().keepAlivesSent); in ping()
560 assertEquals(1, transportTracer.getStats().keepAlivesSent); in ping()
564 assertEquals(1, transportTracer.getStats().keepAlivesSent); in ping()
594 assertEquals(1, transportTracer.getStats().keepAlivesSent); in ping()
596 assertEquals(2, transportTracer.getStats().keepAlivesSent); in ping()
613 assertEquals(1, transportTracer.getStats().keepAlivesSent); in ping_failsWhenChannelCloses()
622 assertEquals(0, transportTracer.getStats().keepAlivesSent); in oustandingUserPingShouldNotInteractWithDataPing()
[all …]
|
| D | NettyHandlerTestBase.java | 102 protected final TransportTracer transportTracer = new TransportTracer(); field in NettyHandlerTestBase
453 TransportStats transportStats = transportTracer.getStats(); in transportTracer_windowSizeDefault()
462 TransportStats transportStats = transportTracer.getStats(); in transportTracer_windowSize()
470 TransportStats before = transportTracer.getStats(); in transportTracer_windowUpdate_remote()
476 TransportStats after = transportTracer.getStats(); in transportTracer_windowUpdate_remote()
485 TransportStats before = transportTracer.getStats(); in transportTracer_windowUpdate_local()
494 TransportStats after = transportTracer.getStats(); in transportTracer_windowUpdate_local()
|
| D | NettyClientStreamTest.java | 103 private final TransportTracer transportTracer = new TransportTracer(); field in NettyClientStreamTest
420 transportTracer); in setHttp2StreamShouldNotifyReady()
450 transportTracer); in removeUserAgentFromApplicationHeaders()
479 transportTracer); in getRequestSentThroughHeader()
511 transportTracer); in createStream()
549 super(handler, channel.eventLoop(), maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 61 private final TransportTracer transportTracer; field in CronetClientTransport
88 TransportTracer transportTracer) { in CronetClientTransport() argument
96 this.transportTracer = Preconditions.checkNotNull(transportTracer, "transportTracer"); in CronetClientTransport()
124 alwaysUsePut, method, statsTraceCtx, callOptions, transportTracer); in newStream()
|
| D | CronetChannelBuilder.java | 210 private final TransportTracer transportTracer; field in CronetChannelBuilder.CronetTransportFactory
219 TransportTracer transportTracer) { in CronetTransportFactory() argument
227 this.transportTracer = Preconditions.checkNotNull(transportTracer, "transportTracer"); in CronetTransportFactory()
235 options.getUserAgent(), executor, maxMessageSize, alwaysUsePut, transportTracer); in newClientTransport()
|
| D | CronetClientStream.java | 96 TransportTracer transportTracer) { in CronetClientStream() argument
98 new CronetWritableBufferAllocator(), statsTraceCtx, transportTracer, headers, in CronetClientStream()
112 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, transportTracer); in CronetClientStream()
231 TransportTracer transportTracer) { in TransportState() argument
232 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 67 private final TransportTracer transportTracer = new TransportTracer(); field in OkHttpClientStreamTest
93 transportTracer); in setUp()
152 StatsTraceContext.NOOP, transportTracer); in start_userAgentRemoved()
167 StatsTraceContext.NOOP, transportTracer); in start_headerFieldOrder()
195 StatsTraceContext.NOOP, transportTracer); in getUnaryRequest()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 193 private final TransportTracer transportTracer; field in OkHttpClientTransport
210 TransportTracer transportTracer) { in OkHttpClientTransport() argument
227 this.transportTracer = Preconditions.checkNotNull(transportTracer); in OkHttpClientTransport()
247 TransportTracer transportTracer) { in OkHttpClientTransport() argument
265 this.transportTracer = Preconditions.checkNotNull(transportTracer, "transportTracer"); in OkHttpClientTransport()
271 transportTracer.setFlowControlWindowReader(new TransportTracer.FlowControlReader() { in initTransportTracer()
322 transportTracer.reportKeepAliveSent(); in ping()
350 transportTracer); in newStream()
930 transportTracer.getStats(), in getStats()
937 transportTracer.getStats(), in getStats()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 77 private final TransportTracer transportTracer = TransportTracer.getDefaultFactory().create(); field in CronetClientStreamTest
122 transportTracer); in setUp()
591 transportTracer); in addCronetRequestAnnotation_deprecated()
624 transportTracer); in withAnnotation()
662 transportTracer); in getUnaryRequest()
717 transportTracer); in idempotentMethod_usesHttpPut()
747 transportTracer); in alwaysUsePutOption_usesHttpPut()
785 transportTracer); in reservedHeadersStripped()
|