Home
last modified time | relevance | path

Searched refs:WriteBufferingAndExceptionHandler (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DWriteBufferingAndExceptionHandlerTest.java85 WriteBufferingAndExceptionHandler handler = in connectionFailuresPropagated()
86 new WriteBufferingAndExceptionHandler(new ChannelHandlerAdapter() {}); in connectionFailuresPropagated()
110 WriteBufferingAndExceptionHandler handler = in channelInactiveFailuresPropagated()
111 new WriteBufferingAndExceptionHandler(new ChannelHandlerAdapter() {}); in channelInactiveFailuresPropagated()
145 WriteBufferingAndExceptionHandler handler = in channelCloseFailuresPropagated()
146 new WriteBufferingAndExceptionHandler(new ChannelHandlerAdapter() {}); in channelCloseFailuresPropagated()
180 WriteBufferingAndExceptionHandler handler = in uncaughtExceptionFailuresPropagated()
181 new WriteBufferingAndExceptionHandler(new ChannelHandlerAdapter() {}); in uncaughtExceptionFailuresPropagated()
215 WriteBufferingAndExceptionHandler handler = in uncaughtException_closeAtMostOnce()
216 new WriteBufferingAndExceptionHandler(new ChannelDuplexHandler() { in uncaughtException_closeAtMostOnce()
[all …]
DProtocolNegotiatorsTest.java966 pipeline.addLast(new WriteBufferingAndExceptionHandler(handler)); in clientTlsHandler_closeDuringNegotiation()
1224 WriteBufferingAndExceptionHandler clientWbaeh = in clientTlsHandler_firesNegotiation()
1225 new WriteBufferingAndExceptionHandler(pn.newHandler(gh)); in clientTlsHandler_firesNegotiation()
1232 WriteBufferingAndExceptionHandler serverWbaeh = new WriteBufferingAndExceptionHandler(sh); in clientTlsHandler_firesNegotiation()
1302 WriteBufferingAndExceptionHandler wbaeh = new WriteBufferingAndExceptionHandler(ch); in plaintextUpgradeNegotiator()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DWriteBufferingAndExceptionHandler.java43 final class WriteBufferingAndExceptionHandler extends ChannelDuplexHandler { class
45 Logger.getLogger(WriteBufferingAndExceptionHandler.class.getName());
53 WriteBufferingAndExceptionHandler(ChannelHandler next) { in WriteBufferingAndExceptionHandler() method in WriteBufferingAndExceptionHandler
DNettyServerTransport.java147 ChannelHandler bufferingHandler = new WriteBufferingAndExceptionHandler(negotiationHandler); in start()
DNettyClientTransport.java257 ChannelHandler bufferingHandler = new WriteBufferingAndExceptionHandler(negotiationHandler);
DNettyClientHandler.java482 channel.pipeline().context(WriteBufferingAndExceptionHandler.class); in writeBufferingAndRemove()
486 ((WriteBufferingAndExceptionHandler) handlerCtx.handler()).writeBufferedAndRemove(handlerCtx); in writeBufferingAndRemove()