| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpWritableBufferAllocatorTest.java | 21 import io.grpc.internal.WritableBuffer;
43 WritableBuffer buffer = allocator().allocate(4096); in testCapacity()
50 WritableBuffer buffer = allocator().allocate(1024 * 1025); in testInitialCapacityHasMaximum()
57 WritableBuffer buffer = allocator().allocate(4097); in testIsExactBelowMaxCapacity()
|
| D | OkHttpWritableBufferTest.java | 19 import io.grpc.internal.WritableBuffer;
40 protected WritableBuffer buffer() { in buffer()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyWritableBufferAllocatorTest.java | 21 import io.grpc.internal.WritableBuffer;
45 WritableBuffer buffer = allocator().allocate(100); in testCapacityHasMinimum()
52 WritableBuffer buffer = allocator().allocate(9000); in testCapacityIsExactAboveMinimum()
60 WritableBuffer buffer = allocator().allocate(1024 * 1025); in testCapacityIsCappedAtMaximum()
|
| D | NettyWritableBufferTest.java | 19 import io.grpc.internal.WritableBuffer;
47 protected WritableBuffer buffer() { in buffer()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MessageFramer.java | 61 @Nullable WritableBuffer frame, in deliverFrame()
74 private WritableBuffer buffer;
240 WritableBuffer writeableHeader = bufferAllocator.allocate(HEADER_LENGTH); in writeBufferChain()
255 List<WritableBuffer> bufferList = bufferChain.bufferList; in writeBufferChain()
348 WritableBuffer buf = buffer; in commitToSink()
384 private final List<WritableBuffer> bufferList = new ArrayList<>();
385 private WritableBuffer current;
427 for (WritableBuffer writableBuffer : bufferList) { in readableBytes()
|
| D | WritableBufferAllocator.java | 29 WritableBuffer allocate(int capacityHint); in allocate()
|
| D | WritableBuffer.java | 24 public interface WritableBuffer { interface
|
| D | AbstractServerStream.java | 53 void writeFrame(@Nullable WritableBuffer frame, boolean flush, int numMessages); in writeFrame()
119 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame()
|
| D | AbstractClientStream.java | 77 @Nullable WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); in writeFrame()
182 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetWritableBufferAllocatorTest.java | 21 import io.grpc.internal.WritableBuffer;
32 WritableBuffer buffer = allocator.allocate(1000); in testAllocate()
40 WritableBuffer buffer = allocator.allocate(1024 * 1024 * 1024); in testAllocateLargeBuffer()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetWritableBufferAllocator.java | 19 import io.grpc.internal.WritableBuffer;
37 public WritableBuffer allocate(int capacityHint) { in allocate()
|
| D | CronetWritableBuffer.java | 20 import io.grpc.internal.WritableBuffer;
23 class CronetWritableBuffer implements WritableBuffer {
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpWritableBufferAllocator.java | 19 import io.grpc.internal.WritableBuffer;
47 public WritableBuffer allocate(int capacityHint) { in allocate()
|
| D | OkHttpWritableBuffer.java | 19 import io.grpc.internal.WritableBuffer;
22 class OkHttpWritableBuffer implements WritableBuffer {
|
| D | OkHttpClientStream.java | 32 import io.grpc.internal.WritableBuffer;
150 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in writeFrame()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | WritableBufferAllocatorTestBase.java | 35 WritableBuffer buffer1 = allocator().allocate(100); in testBuffersAreDifferent()
36 WritableBuffer buffer2 = allocator().allocate(100); in testBuffersAreDifferent()
|
| D | MessageFramerTest.java | 332 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {
356 private static WritableBuffer toWriteBuffer(byte[] data) {
360 private static WritableBuffer toWriteBufferWithMinSize(byte[] data, int minFrameSize) {
397 static class ByteWritableBuffer implements WritableBuffer {
465 public WritableBuffer allocate(int capacityHint) {
|
| D | AbstractServerStreamTest.java | 62 public WritableBuffer allocate(int capacityHint) {
274 .writeFrame(any(WritableBuffer.class), any(Boolean.class), any(Integer.class)); in writeMessage_ignoreIfFramerClosed()
284 verify(sink).writeFrame(any(WritableBuffer.class), eq(true), eq(1)); in writeMessage()
|
| D | ByteWritableBufferTest.java | 32 protected WritableBuffer buffer() { in buffer()
|
| D | WritableBufferTestBase.java | 36 protected abstract WritableBuffer buffer(); in buffer()
|
| D | AbstractClientStreamTest.java | 94 public WritableBuffer allocate(int capacityHint) {
399 any(WritableBuffer.class), any(Boolean.class), any(Boolean.class), any(Integer.class)); in getRequest()
521 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) {} in writeFrame()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyWritableBufferAllocator.java | 19 import io.grpc.internal.WritableBuffer;
49 public WritableBuffer allocate(int capacityHint) { in allocate()
|
| D | NettyWritableBuffer.java | 19 import io.grpc.internal.WritableBuffer;
25 class NettyWritableBuffer implements WritableBuffer {
|
| D | NettyServerStream.java | 28 import io.grpc.internal.WritableBuffer;
116 public void writeFrame(WritableBuffer frame, boolean flush, final int numMessages) { in writeFrame()
|
| D | NettyClientStream.java | 36 import io.grpc.internal.WritableBuffer;
161 WritableBuffer frame, boolean endOfStream, boolean flush, final int numMessages) { in writeFrame()
|