Home
last modified time | relevance | path

Searched refs:numMessages (Results 1 – 25 of 54) sorted by relevance

123

/external/angle/src/tests/gl_tests/
DDebugTest.cpp231 GLint numMessages = 0; in TEST_P() local
232 glGetIntegerv(GL_DEBUG_LOGGED_MESSAGES, &numMessages); in TEST_P()
233 ASSERT_EQ(0, numMessages); in TEST_P()
255 GLint numMessages = 0; in TEST_P() local
256 glGetIntegerv(GL_DEBUG_LOGGED_MESSAGES, &numMessages); in TEST_P()
257 ASSERT_EQ(1, numMessages); in TEST_P()
280 glGetIntegerv(GL_DEBUG_LOGGED_MESSAGES, &numMessages); in TEST_P()
281 EXPECT_EQ(0, numMessages); in TEST_P()
305 GLint numMessages = 0; in TEST_P() local
306 glGetIntegerv(GL_DEBUG_LOGGED_MESSAGES, &numMessages); in TEST_P()
[all …]
DErrorMessages.cpp91 GLint numMessages = 0; in TEST_P() local
92 glGetIntegerv(GL_DEBUG_LOGGED_MESSAGES, &numMessages); in TEST_P()
93 EXPECT_EQ(0, numMessages); in TEST_P()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerStream.java53 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()
DTransportTracer.java108 public void reportMessageSent(int numMessages) { in reportMessageSent() argument
109 if (numMessages == 0) { in reportMessageSent()
112 messagesSent += numMessages; in reportMessageSent()
DAbstractClientStream.java77 @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()
DForwardingClientStream.java31 public void request(int numMessages) { in request() argument
32 delegate().request(numMessages); in request()
DApplicationThreadDeframer.java72 public void request(final int numMessages) { in request() argument
82 deframer.request(numMessages); in request()
DAbstractStream.java203 public final void requestMessagesFromDeframer(final int numMessages) { in requestMessagesFromDeframer() argument
205 deframer.request(numMessages); in requestMessagesFromDeframer()
DDelayedStream.java292 public void request(final int numMessages) { in request() argument
294 realStream.request(numMessages); in request()
299 realStream.request(numMessages); in request()
DDeframer.java51 void request(int numMessages); in request() argument
DStream.java36 void request(int numMessages); in request() argument
DMessageDeframer.java155 public void request(int numMessages) { in request() argument
156 checkArgument(numMessages > 0, "numMessages must be > 0"); in request()
160 pendingDeliveries += numMessages; in request()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerStream.java92 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()
DNettyClientStream.java161 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/
DPartialForwardingClientCall.java33 public void request(int numMessages) { in request() argument
34 delegate().request(numMessages); in request()
DPartialForwardingServerCall.java32 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/
DCaliperClientSocketBenchmark.java63 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/
DCaliperClientSocketBenchmark.java61 public final void time(int numMessages) throws Exception { in time() argument
62 benchmark.time(numMessages); in time()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java334 public void request(int numMessages) {
335 boolean onReady = clientStream.serverRequested(numMessages);
351 private synchronized boolean clientRequested(int numMessages) {
356 clientRequested += numMessages;
525 public void request(int numMessages) {
526 boolean onReady = serverStream.clientRequested(numMessages);
542 private synchronized boolean serverRequested(int numMessages) {
547 serverRequested += numMessages;
/external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/
DClientAuthInterceptorTest.java187 private int numMessages; field in ClientAuthInterceptorTest.ClientCallRecorder
200 public void request(int numMessages) { in request() argument
201 this.numMessages = numMessages; in request()
/external/conscrypt/benchmark-base/src/main/java/org/conscrypt/
DClientSocketBenchmark.java115 void time(final int numMessages) throws Exception { in time() argument
119 while (bytesCounter.get() < numMessages) { in time()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java150 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/repackaged/benchmark-base/src/main/java/com/android/org/conscrypt/
DClientSocketBenchmark.java117 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/
DClientCallsTest.java255 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/dagger2/java/dagger/grpc/server/
DProxyServerCallHandler.java167 public void request(int numMessages) { in request() argument
168 delegate.request(numMessages); in request()

123