Home
last modified time | relevance | path

Searched refs:getWriteQueue (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientStream.java81 this.writeQueue = state.handler.getWriteQueue(); in NettyClientStream()
270 handler.getWriteQueue().enqueue(new CancelClientStreamCommand(this, status), true); in http2ProcessingFailed()
285 handler.getWriteQueue().scheduleFlush(); in bytesRead()
296 handler.getWriteQueue().enqueue(new CancelClientStreamCommand(this, null), true); in transportHeadersReceived()
DNettyServerStream.java64 this.writeQueue = state.handler.getWriteQueue(); in NettyServerStream()
186 handler.getWriteQueue().scheduleFlush(); in bytesRead()
194 handler.getWriteQueue().enqueue(new CancelServerStreamCommand(this, status), true); in deframeFailed()
DNettyClientTransport.java145 handler.getWriteQueue().enqueue(new SendPingCommand(callback, executor), true) in ping()
283 handler.getWriteQueue().enqueue(new GracefulCloseCommand(reason), true);
291 handler.getWriteQueue().enqueue(new Runnable() {
DNettyClientHandler.java322 WriteQueue getWriteQueue() { in getWriteQueue() method in NettyClientHandler
DNettyServerHandler.java562 WriteQueue getWriteQueue() { in getWriteQueue() method in NettyServerHandler
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java285 when(handler.getWriteQueue()).thenReturn(writeQueue); in createStream()
DNettyClientStreamTest.java501 when(handler.getWriteQueue()).thenReturn(writeQueue); in createStream()
DNettyClientHandlerTest.java732 return handler().getWriteQueue(); in initWriteQueue()
DNettyServerHandlerTest.java1083 return handler().getWriteQueue(); in initWriteQueue()