| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ApplicationThreadDeframerListener.java | 35 void runOnTransportThread(Runnable r); in runOnTransportThread() method
51 transportExecutor.runOnTransportThread( in bytesRead()
70 transportExecutor.runOnTransportThread( in deframerClosed()
81 transportExecutor.runOnTransportThread( in deframeFailed()
|
| D | MigratingThreadDeframer.java | 119 transportExecutor.runOnTransportThread(new Runnable() { in runWhereAppropriate()
143 transportExecutor.runOnTransportThread(new Runnable() { in request()
|
| D | AbstractStream.java | 240 runOnTransportThread(new RequestRunnable()); in requestMessagesFromDeframer()
|
| /external/grpc-grpc-java/servlet/src/main/java/io/grpc/servlet/ |
| D | ServletAdapter.java | 154 stream.transportState().runOnTransportThread(stream.transportState()::onStreamAllocated); in doPost()
230 stream.transportState().runOnTransportThread( in onTimeout()
246 stream.transportState().runOnTransportThread( in onError()
292 stream.transportState().runOnTransportThread( in onDataAvailable()
303 stream.transportState().runOnTransportThread(() -> in onAllDataRead()
317 stream.transportState().runOnTransportThread( in onError()
|
| D | ServletServerStream.java | 145 public void runOnTransportThread(Runnable r) { in runOnTransportThread() method in ServletServerStream.ServletTransportState
213 transportState.runOnTransportThread( in onError()
298 transportState.runOnTransportThread(() -> transportState.transportReportStatus(status)); in cancel()
302 transportState.runOnTransportThread(() -> { in cancel()
|
| D | AsyncServletOutputStreamWriter.java | 107 transportState.runOnTransportThread(() -> transportState.onSentBytes(numBytes)); in AsyncServletOutputStreamWriter()
116 transportState.runOnTransportThread( in AsyncServletOutputStreamWriter()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ApplicationThreadDeframerTest.java | 179 public void runOnTransportThread(Runnable r) { in runOnTransportThread() method in ApplicationThreadDeframerTest.TransportExecutor
|
| D | AbstractServerStreamTest.java | 433 public void runOnTransportThread(Runnable r) { in runOnTransportThread() method in AbstractServerStreamTest.AbstractServerStreamBase.TransportState
|
| D | Http2ClientStreamTransportStateTest.java | 367 public void runOnTransportThread(Runnable r) { in runOnTransportThread() method in Http2ClientStreamTransportStateTest.BaseTransportState
|
| D | AbstractClientStreamTest.java | 583 public void runOnTransportThread(Runnable r) { in runOnTransportThread() method in AbstractClientStreamTest.BaseTransportState
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 176 public void runOnTransportThread(final Runnable r) { in runOnTransportThread() method in NettyServerStream.TransportState
|
| D | NettyClientStream.java | 310 public void runOnTransportThread(final Runnable r) { in runOnTransportThread() method in NettyClientStream.TransportState
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpServerStream.java | 201 public void runOnTransportThread(final Runnable r) { in runOnTransportThread() method in OkHttpServerStream.TransportState
|
| D | OkHttpClientStream.java | 302 public void runOnTransportThread(final Runnable r) { in runOnTransportThread() method in OkHttpClientStream.TransportState
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 304 public void runOnTransportThread(final Runnable r) { in runOnTransportThread() method in CronetClientStream.TransportState
|