| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractServerStream.java | 53 void writeFrame(@Nullable WritableBuffer frame, boolean flush, int numMessages); in writeFrame() argument
68 void request(int numMessages); in request() argument
105 public final void request(int numMessages) { in request() argument
106 abstractServerStreamSink().request(numMessages); in request()
119 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame() argument
122 abstractServerStreamSink().writeFrame(frame, endOfStream ? false : flush, numMessages); in deliverFrame()
|
| D | TransportTracer.java | 108 public void reportMessageSent(int numMessages) { in reportMessageSent() argument
109 if (numMessages == 0) { in reportMessageSent()
112 messagesSent += numMessages; in reportMessageSent()
|
| D | AbstractClientStream.java | 77 @Nullable WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages); in writeFrame() argument
84 void request(int numMessages); in request() argument
176 public final void request(int numMessages) { in request() argument
177 abstractClientStreamSink().request(numMessages); in request()
182 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in deliverFrame() argument
184 abstractClientStreamSink().writeFrame(frame, endOfStream, flush, numMessages); in deliverFrame()
|
| D | ForwardingClientStream.java | 31 public void request(int numMessages) { in request() argument
32 delegate().request(numMessages); in request()
|
| D | ApplicationThreadDeframer.java | 72 public void request(final int numMessages) { in request() argument
82 deframer.request(numMessages); in request()
|
| D | DelayedStream.java | 292 public void request(final int numMessages) { in request() argument
294 realStream.request(numMessages); in request()
299 realStream.request(numMessages); in request()
|
| D | AbstractStream.java | 203 public final void requestMessagesFromDeframer(final int numMessages) { in requestMessagesFromDeframer() argument
205 deframer.request(numMessages); in requestMessagesFromDeframer()
|
| D | MessageDeframer.java | 155 public void request(int numMessages) { in request() argument
156 checkArgument(numMessages > 0, "numMessages must be > 0"); in request()
160 pendingDeliveries += numMessages; in request()
|
| D | Deframer.java | 51 void request(int numMessages); in request() argument
|
| D | Stream.java | 36 void request(int numMessages); in request() argument
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 92 public void request(final int numMessages) { in request() argument
95 transportState().requestMessagesFromDeframer(numMessages); in request()
100 transportState().requestMessagesFromDeframer(numMessages); in request()
116 public void writeFrame(WritableBuffer frame, boolean flush, final int numMessages) { in writeFrame() argument
117 Preconditions.checkArgument(numMessages >= 0); in writeFrame()
134 transportTracer.reportMessageSent(numMessages); in writeFrame()
|
| D | NettyClientStream.java | 161 WritableBuffer frame, boolean endOfStream, boolean flush, final int numMessages) { in writeFrame() argument
162 Preconditions.checkArgument(numMessages >= 0); in writeFrame()
178 NettyClientStream.this.getTransportTracer().reportMessageSent(numMessages); in writeFrame()
189 public void request(final int numMessages) { in request() argument
192 transportState().requestMessagesFromDeframer(numMessages); in request()
197 transportState().requestMessagesFromDeframer(numMessages); in request()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 333 public void request(int numMessages) {
334 boolean onReady = clientStream.serverRequested(numMessages);
350 private synchronized boolean clientRequested(int numMessages) {
355 clientRequested += numMessages;
524 public void request(int numMessages) {
525 boolean onReady = serverStream.clientRequested(numMessages);
541 private synchronized boolean serverRequested(int numMessages) {
546 serverRequested += numMessages;
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingClientCall.java | 33 public void request(int numMessages) { in request() argument
34 delegate().request(numMessages); in request()
|
| D | PartialForwardingServerCall.java | 32 public void request(int numMessages) { in request() argument
33 delegate().request(numMessages); in request()
|
| /external/conscrypt/repackaged/benchmark-android/src/main/java/com/android/org/conscrypt/ |
| D | CaliperClientSocketBenchmark.java | 63 public final void time(int numMessages) throws Exception { in time() argument
64 benchmark.time(numMessages); in time()
|
| /external/conscrypt/benchmark-android/src/main/java/org/conscrypt/ |
| D | CaliperClientSocketBenchmark.java | 61 public final void time(int numMessages) throws Exception { in time() argument
62 benchmark.time(numMessages); in time()
|
| /external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/ |
| D | ClientAuthInterceptorTest.java | 187 private int numMessages; field in ClientAuthInterceptorTest.ClientCallRecorder
200 public void request(int numMessages) { in request() argument
201 this.numMessages = numMessages; in request()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 150 WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages) { in writeFrame() argument
164 getTransportTracer().reportMessageSent(numMessages); in writeFrame()
169 public void request(final int numMessages) { in request() argument
171 state.requestMessagesFromDeframer(numMessages); in request()
|
| /external/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| D | ClientSocketBenchmark.java | 115 void time(final int numMessages) throws Exception { in time() argument
119 while (bytesCounter.get() < numMessages) { in time()
|
| /external/conscrypt/repackaged/benchmark-base/src/main/java/com/android/org/conscrypt/ |
| D | ClientSocketBenchmark.java | 117 void time(final int numMessages) throws Exception { in time() argument
121 while (bytesCounter.get() < numMessages) { in time()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 255 public void request(int numMessages) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
256 requests.add(numMessages); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
316 public void request(int numMessages) { in callStreamObserverPropagatesFlowControlRequestsToCall()
317 requests.add(numMessages); in callStreamObserverPropagatesFlowControlRequestsToCall()
362 public void request(int numMessages) { in canCaptureInboundFlowControlForServerStreamingObserver()
363 requests.add(numMessages); in canCaptureInboundFlowControlForServerStreamingObserver()
|
| /external/conscrypt/repackaged/openjdk/src/test/java/com/android/org/conscrypt/ |
| D | ConscryptEngineTest.java | 247 final int numMessages = 100; in exchangeMessages() local
248 ByteBuffer[] encryptedBuffers = new ByteBuffer[numMessages]; in exchangeMessages()
249 for (int i = 0; i < numMessages; ++i) { in exchangeMessages()
258 assertEquals(MESSAGE_SIZE * numMessages, actualBytes.length); in exchangeMessages()
259 for (int i = 0; i < numMessages; ++i) { in exchangeMessages()
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | ConscryptEngineTest.java | 240 final int numMessages = 100; in exchangeMessages() local
241 ByteBuffer[] encryptedBuffers = new ByteBuffer[numMessages]; in exchangeMessages()
242 for (int i = 0; i < numMessages; ++i) { in exchangeMessages()
251 assertEquals(MESSAGE_SIZE * numMessages, actualBytes.length); in exchangeMessages()
252 for (int i = 0; i < numMessages; ++i) { in exchangeMessages()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 143 public void request(final int numMessages) {
147 SerializingServerCall.super.request(numMessages);
|