| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | Http2ClientStreamTransportStateTest.java | 109 state.transportDataReceived(ReadableBuffers.empty(), true); in transportHeadersReceived_noHttpStatus()
124 state.transportDataReceived(ReadableBuffers.empty(), true); in transportHeadersReceived_wrongContentType_200()
140 state.transportDataReceived(ReadableBuffers.empty(), true); in transportHeadersReceived_wrongContentType_401()
182 state.transportDataReceived(ReadableBuffers.empty(), true); in transportHeadersReceived_twice()
202 state.transportDataReceived(ReadableBuffers.empty(), true); in transportHeadersReceived_unknownAndTwiceLogsSecondHeaders()
215 state.transportDataReceived(ReadableBuffers.wrap(testString.getBytes(US_ASCII)), true); in transportDataReceived_noHeaderReceived()
230 state.transportDataReceived(ReadableBuffers.wrap(testString.getBytes(US_ASCII)), true); in transportDataReceived_debugData()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientStreamTest.java | 310 stream().transportState().transportDataReceived(Unpooled.buffer(100).writeZero(100), false); in invalidInboundHeadersCancelStream()
312 stream().transportState().transportDataReceived(Unpooled.buffer(1000).writeZero(1000), false); in invalidInboundHeadersCancelStream()
347 stream().transportState().transportDataReceived(Unpooled.copiedBuffer(MESSAGE, UTF_8), true); in nonGrpcResponseShouldSetStatus()
360 stream().transportState().transportDataReceived(simpleGrpcFrame(), false); in deframedDataAfterCancelShouldBeIgnored()
361 stream().transportState().transportDataReceived(simpleGrpcFrame(), false); in deframedDataAfterCancelShouldBeIgnored()
397 stream().transportState().transportDataReceived(simpleGrpcFrame(), true); in dataFrameWithEosShouldDeframeAndThenFail()
|
| D | NettyStreamTestBase.java | 126 .transportDataReceived(messageFrame(MESSAGE), false); in inboundMessageShouldCallListener()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientStream.java | 304 void transportDataReceived(ByteBuf frame, boolean endOfStream) { in transportDataReceived() method in NettyClientStream.TransportState
305 transportDataReceived(new NettyReadableBuffer(frame.retain()), endOfStream); in transportDataReceived()
|
| D | NettyClientHandler.java | 355 stream.transportDataReceived(data, endOfStream); in onDataRead()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 289 private void transportDataReceived(ByteBuffer buffer, boolean endOfStream) { in transportDataReceived() method in CronetClientStream.TransportState
291 super.transportDataReceived(ReadableBuffers.wrap(buffer), endOfStream); in transportDataReceived()
409 state.transportDataReceived(buffer, false); in onReadCompleted()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 309 public void transportDataReceived(okio.Buffer frame, boolean endOfStream) { in transportDataReceived() method in OkHttpClientStream.TransportState
323 super.transportDataReceived(new OkHttpReadableBuffer(frame), endOfStream); in transportDataReceived()
|
| D | OkHttpClientTransport.java | 1019 stream.transportState().transportDataReceived(buf, inFinished); in data()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | Http2ClientStreamTransportState.java | 129 protected void transportDataReceived(ReadableBuffer frame, boolean endOfStream) { in transportDataReceived() method in Http2ClientStreamTransportState
|