Home
last modified time | relevance | path

Searched refs:grpcHandler (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
DAltsProtocolNegotiator.java61 public Handler newHandler(GrpcHttp2ConnectionHandler grpcHandler) { in create()
63 grpcHandler, in create()
75 private final GrpcHttp2ConnectionHandler grpcHandler;
78 GrpcHttp2ConnectionHandler grpcHandler, ChannelHandler... negotiationhandlers) {
82 this.grpcHandler = grpcHandler;
104 if (grpcHandler != null) {
105 ctx.pipeline().addBefore(ctx.name(), null, grpcHandler);
122 grpcHandler.handleProtocolNegotiationCompleted(
DGoogleDefaultProtocolNegotiator.java44 public Handler newHandler(GrpcHttp2ConnectionHandler grpcHandler) { in newHandler() argument
45 if (grpcHandler.getEagAttributes().get(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY) != null in newHandler()
46 || grpcHandler.getEagAttributes().get(GrpcAttributes.ATTR_LB_PROVIDED_BACKEND) != null) { in newHandler()
47 return altsProtocolNegotiator.newHandler(grpcHandler); in newHandler()
49 return tlsProtocolNegotiator.newHandler(grpcHandler); in newHandler()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DProtocolNegotiatorsTest.java84 private GrpcHttp2ConnectionHandler grpcHandler = mock(GrpcHttp2ConnectionHandler.class); field in ProtocolNegotiatorsTest
111 ChannelHandler handler = new ServerTlsHandler(sslContext, grpcHandler); in tlsAdapter_exceptionClosesChannel()
123 ChannelHandler handler = new ServerTlsHandler(sslContext, grpcHandler); in tlsHandler_handlerAddedAddsSslHandler()
132 ChannelHandler handler = new ServerTlsHandler(sslContext, grpcHandler); in tlsHandler_userEventTriggeredNonSslEvent()
140 ChannelHandlerContext grpcHandlerCtx = pipeline.context(grpcHandler); in tlsHandler_userEventTriggeredNonSslEvent()
153 ChannelHandler handler = new ServerTlsHandler(sslContext, grpcHandler); in tlsHandler_userEventTriggeredSslEvent_unsupportedProtocol()
164 ChannelHandlerContext grpcHandlerCtx = pipeline.context(grpcHandler); in tlsHandler_userEventTriggeredSslEvent_unsupportedProtocol()
170 ChannelHandler handler = new ServerTlsHandler(sslContext, grpcHandler); in tlsHandler_userEventTriggeredSslEvent_handshakeFailure()
179 ChannelHandlerContext grpcHandlerCtx = pipeline.context(grpcHandler); in tlsHandler_userEventTriggeredSslEvent_handshakeFailure()
192 ChannelHandler handler = new ServerTlsHandler(sslContext, grpcHandler); in tlsHandler_userEventTriggeredSslEvent_supportedProtocolH2()
[all …]
DNettyClientTransportTest.java526 assertSame(eagAttributes, npn.grpcHandler.getEagAttributes()); in getEagAttributes_negotiatorHandler()
805 public NoopHandler(GrpcHttp2ConnectionHandler grpcHandler) {
806 super(grpcHandler);
816 GrpcHttp2ConnectionHandler grpcHandler;
820 public Handler newHandler(final GrpcHttp2ConnectionHandler grpcHandler) {
821 this.grpcHandler = grpcHandler;
822 return handler = new NoopHandler(grpcHandler);
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DProtocolNegotiators.java126 private final GrpcHttp2ConnectionHandler grpcHandler;
129 ServerTlsHandler(SslContext sslContext, GrpcHttp2ConnectionHandler grpcHandler) {
131 this.grpcHandler = grpcHandler;
156 grpcHandler.handleProtocolNegotiationCompleted(
163 ctx.pipeline().replace(this, null, grpcHandler);
620 private final GrpcHttp2ConnectionHandler grpcHandler;
623 ChannelHandler bootstrapHandler, GrpcHttp2ConnectionHandler grpcHandler) {
625 this.grpcHandler = grpcHandler;
645 ctx.pipeline().addBefore(ctx.name(), null, grpcHandler);
650 grpcHandler.handleProtocolNegotiationCompleted(
[all …]
DNettyServerTransport.java64 private NettyServerHandler grpcHandler; field in NettyServerTransport
121 grpcHandler = createHandler(listener, channelUnused); in start()
122 NettyHandlerSettings.setAutoWindow(grpcHandler); in start()
132 notifyTerminated(grpcHandler.connectionError()); in start()
141 ChannelHandler negotiationHandler = protocolNegotiator.newHandler(grpcHandler); in start()
237 grpcHandler == null ? null : grpcHandler.getSecurityInfo()); in getStatsHelper()
DProtocolNegotiator.java45 Handler newHandler(GrpcHttp2ConnectionHandler grpcHandler); in newHandler() argument
/external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
DAltsProtocolNegotiatorTest.java79 private final CapturingGrpcHttp2ConnectionHandler grpcHandler = capturingGrpcHandler(); field in AltsProtocolNegotiatorTest
150 handler = AltsProtocolNegotiator.create(handshakerFactory).newHandler(grpcHandler); in setup()
342 assertThat(grpcHandler.attrs.get(AltsProtocolNegotiator.getTsiPeerAttributeKey())) in peerPropagated()
344 assertThat(grpcHandler.attrs.get(AltsProtocolNegotiator.getAltsAuthContextAttributeKey())) in peerPropagated()
346 assertThat(grpcHandler.attrs.get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR).toString()) in peerPropagated()
348 assertThat(grpcHandler.attrs.get(CallCredentials.ATTR_SECURITY_LEVEL)) in peerPropagated()