Home
last modified time | relevance | path

Searched refs:statsTraceCtx (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java73 private final StatsTraceContext statsTraceCtx = StatsTraceContext.NOOP; 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 …]
DMessageDeframerTest.java93 private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); field in MessageDeframerTest.WithAndWithoutFullStreamCompressionTests
97 DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, transportTracer);
192 DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, transportTracer); in endOfStreamWithInvalidGzipBlockShouldNotifyDeframerClosedWithPartialMessage()
286 statsTraceCtx, transportTracer); in compressed()
330 private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer});
336 new MessageDeframer.SizeEnforcingInputStream(in, 4, statsTraceCtx);
349 new MessageDeframer.SizeEnforcingInputStream(in, 3, statsTraceCtx);
362 new MessageDeframer.SizeEnforcingInputStream(in, 2, statsTraceCtx);
379 new MessageDeframer.SizeEnforcingInputStream(in, 4, statsTraceCtx);
393 new MessageDeframer.SizeEnforcingInputStream(in, 3, statsTraceCtx);
[all …]
DMessageFramerTest.java65 private StatsTraceContext statsTraceCtx; field in MessageFramerTest
73 statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); in setUp()
74 framer = new MessageFramer(sink, allocator, statsTraceCtx); in setUp()
139 framer = new MessageFramer(sink, allocator, statsTraceCtx); in payloadSplitBetweenSinks()
155 framer = new MessageFramer(sink, allocator, statsTraceCtx); in frameHeaderSplitBetweenSinks()
203 framer = new MessageFramer(sink, allocator, statsTraceCtx); in largerFrameSize()
224 framer = new MessageFramer(sink, allocator, statsTraceCtx); in largerFrameSizeUnknownLength()
252 framer = new MessageFramer(sink, allocator, statsTraceCtx) in compressed()
278 framer = new MessageFramer(sink, allocator, statsTraceCtx)
303 framer = new MessageFramer(sink, allocator, statsTraceCtx)
[all …]
DServerImplTest.java413 StatsTraceContext statsTraceCtx = in methodNotFound() local
416 when(stream.statsTraceContext()).thenReturn(statsTraceCtx); in methodNotFound()
441 StatsTraceContext statsTraceCtx = in decompressorNotFound() local
444 when(stream.statsTraceContext()).thenReturn(statsTraceCtx); in decompressorNotFound()
495 StatsTraceContext statsTraceCtx = in basicExchangeHelper() local
497 when(stream.statsTraceContext()).thenReturn(statsTraceCtx); in basicExchangeHelper()
701 StatsTraceContext statsTraceCtx = in interceptors() local
703 when(stream.statsTraceContext()).thenReturn(statsTraceCtx); in interceptors()
746 StatsTraceContext statsTraceCtx = in exceptionInStartCallPropagatesToStream() local
748 when(stream.statsTraceContext()).thenReturn(statsTraceCtx); in exceptionInStartCallPropagatesToStream()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerStream.java80 private final StatsTraceContext statsTraceCtx; field in AbstractServerStream
85 WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx) { in AbstractServerStream() argument
86 this.statsTraceCtx = Preconditions.checkNotNull(statsTraceCtx, "statsTraceCtx"); in AbstractServerStream()
87 framer = new MessageFramer(this, bufferAllocator, statsTraceCtx); in AbstractServerStream()
181 return statsTraceCtx; in statsTraceContext()
192 private final StatsTraceContext statsTraceCtx; field in AbstractServerStream.TransportState
204 StatsTraceContext statsTraceCtx, in TransportState() argument
208 statsTraceCtx, in TransportState()
210 this.statsTraceCtx = Preconditions.checkNotNull(statsTraceCtx, "statsTraceCtx"); in TransportState()
335 statsTraceCtx.streamClosed(newStatus); in closeListener()
[all …]
DAbstractClientStream.java109 StatsTraceContext statsTraceCtx, in AbstractClientStream() argument
117 framer = new MessageFramer(this, bufferAllocator, statsTraceCtx); in AbstractClientStream()
120 framer = new GetFramer(headers, statsTraceCtx); in AbstractClientStream()
214 private final StatsTraceContext statsTraceCtx; field in AbstractClientStream.TransportState
236 StatsTraceContext statsTraceCtx, in TransportState() argument
238 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
239 this.statsTraceCtx = checkNotNull(statsTraceCtx, "statsTraceCtx"); in TransportState()
298 statsTraceCtx.clientInboundHeaders(); in inboundHeadersReceived()
451 statsTraceCtx.streamClosed(status); in closeListener()
463 private final StatsTraceContext statsTraceCtx; field in AbstractClientStream.GetFramer
[all …]
DMessageDeframer.java90 private final StatsTraceContext statsTraceCtx; field in MessageDeframer
121 StatsTraceContext statsTraceCtx, in MessageDeframer() argument
126 this.statsTraceCtx = checkNotNull(statsTraceCtx, "statsTraceCtx"); in MessageDeframer()
357 statsTraceCtx.inboundWireSize(deflatedBytesRead); in readRequiredBytes()
360 statsTraceCtx.inboundWireSize(totalBytesRead); in readRequiredBytes()
391 statsTraceCtx.inboundMessage(currentMessageSeqNo); in processHeader()
404 statsTraceCtx.inboundMessageRead(currentMessageSeqNo, inboundBodyWireSize, -1); in processBody()
416 statsTraceCtx.inboundUncompressedSize(nextFrame.readableBytes()); in getUncompressedBody()
432 unlimitedStream, maxInboundMessageSize, statsTraceCtx); in getCompressedBody()
444 private final StatsTraceContext statsTraceCtx; field in MessageDeframer.SizeEnforcingInputStream
[all …]
DAbstractStream.java113 private final StatsTraceContext statsTraceCtx; field in AbstractStream.TransportState
137 StatsTraceContext statsTraceCtx, in TransportState() argument
139 this.statsTraceCtx = checkNotNull(statsTraceCtx, "statsTraceCtx"); in TransportState()
145 statsTraceCtx, in TransportState()
212 return statsTraceCtx; in getStatsTraceContext()
DMessageFramer.java80 private final StatsTraceContext statsTraceCtx; field in MessageFramer
96 Sink sink, WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx) { in MessageFramer() argument
99 this.statsTraceCtx = checkNotNull(statsTraceCtx, "statsTraceCtx"); in MessageFramer()
131 statsTraceCtx.outboundMessage(currentMessageSeqNo); in writePayload()
159 statsTraceCtx.outboundUncompressedSize(written); in writePayload()
160 statsTraceCtx.outboundWireSize(currentMessageWireSize); in writePayload()
161 statsTraceCtx.outboundMessageSent(currentMessageSeqNo, currentMessageWireSize, written); in writePayload()
DServerImpl.java433 final StatsTraceContext statsTraceCtx = Preconditions.checkNotNull( in streamCreated() local
436 final Context.CancellableContext context = createContext(stream, headers, statsTraceCtx); in streamCreated()
480 listener = startCall(stream, methodName, method, headers, context, statsTraceCtx); in streamCreated()
499 final ServerStream stream, Metadata headers, StatsTraceContext statsTraceCtx) { in createContext() argument
502 Context baseContext = statsTraceCtx.serverFilterContext(rootContext); in createContext()
530 Context.CancellableContext context, StatsTraceContext statsTraceCtx) { in startCall() argument
532 statsTraceCtx.serverCallStarted( in startCall()
DHttp2ClientStreamTransportState.java69 StatsTraceContext statsTraceCtx, in Http2ClientStreamTransportState() argument
71 super(maxMessageSize, statsTraceCtx, transportTracer); in Http2ClientStreamTransportState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java148 final StatsTraceContext statsTraceCtx =
153 statsTraceCtx.clientOutboundHeaders();
154 statsTraceCtx.streamClosed(capturedStatus);
300 final StatsTraceContext statsTraceCtx;
319 statsTraceCtx = StatsTraceContext.newServerContext(
366 clientStream.statsTraceCtx.streamClosed(clientNotifyStatus);
382 statsTraceCtx.outboundMessage(outboundSeqNo);
383 statsTraceCtx.outboundMessageSent(outboundSeqNo, -1, -1);
384 clientStream.statsTraceCtx.inboundMessage(outboundSeqNo);
385 clientStream.statsTraceCtx.inboundMessageRead(outboundSeqNo, -1, -1);
[all …]
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java55 private final StatsTraceContext statsTraceCtx; field in OkHttpClientStream
75 StatsTraceContext statsTraceCtx, in OkHttpClientStream() argument
79 statsTraceCtx, in OkHttpClientStream()
83 this.statsTraceCtx = checkNotNull(statsTraceCtx, "statsTraceCtx"); in OkHttpClientStream()
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow, in OkHttpClientStream()
208 StatsTraceContext statsTraceCtx, in TransportState() argument
213 super(maxMessageSize, statsTraceCtx, OkHttpClientStream.this.getTransportTracer()); in TransportState()
229 statsTraceCtx.clientOutboundHeaders(); in start()
DOkHttpClientTransport.java338 StatsTraceContext statsTraceCtx = StatsTraceContext.newClientContext(callOptions, headers); in newStream() local
349 statsTraceCtx, in newStream()
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientStream.java68 private final StatsTraceContext statsTraceCtx; field in CronetClientStream
94 StatsTraceContext statsTraceCtx, in CronetClientStream() argument
98 new CronetWritableBufferAllocator(), statsTraceCtx, transportTracer, headers, in CronetClientStream()
102 this.statsTraceCtx = Preconditions.checkNotNull(statsTraceCtx, "statsTraceCtx"); in CronetClientStream()
112 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, transportTracer); in CronetClientStream()
230 int maxMessageSize, StatsTraceContext statsTraceCtx, Object lock, in TransportState() argument
232 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
429 statsTraceCtx.clientOutboundHeaders(); in onWriteCompleted()
DCronetClientTransport.java119 final StatsTraceContext statsTraceCtx = in newStream() local
124 alwaysUsePut, method, statsTraceCtx, callOptions, transportTracer); in newStream()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerStream.java59 StatsTraceContext statsTraceCtx, in NettyServerStream() argument
61 super(new NettyWritableBufferAllocator(channel.alloc()), statsTraceCtx); in NettyServerStream()
166 StatsTraceContext statsTraceCtx, in TransportState() argument
168 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
DNettyClientStream.java72 StatsTraceContext statsTraceCtx, in NettyClientStream() argument
76 statsTraceCtx, in NettyClientStream()
221 StatsTraceContext statsTraceCtx, in TransportState() argument
223 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
DNettyClientTransport.java157 StatsTraceContext statsTraceCtx = StatsTraceContext.newClientContext(callOptions, headers); in newStream() local
163 statsTraceCtx, in newStream()
176 statsTraceCtx, in newStream()
DNettyServerHandler.java419 StatsTraceContext statsTraceCtx = in onHeadersRead() local
427 statsTraceCtx, in onHeadersRead()
435 statsTraceCtx, in onHeadersRead()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java286 StatsTraceContext statsTraceCtx = StatsTraceContext.NOOP; in createStream() local
289 handler, channel.eventLoop(), http2Stream, DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, in createStream()
292 "test-authority", statsTraceCtx, transportTracer); in createStream()
DNettyServerHandlerTest.java235 StatsTraceContext statsTraceCtx = stream.statsTraceContext(); in streamTracerCreated() local
236 List<StreamTracer> tracers = statsTraceCtx.getTracersForTest(); in streamTracerCreated()