grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

netty: remove redundant variable references

This commit is contained in:
Steve Rao 2019-11-06 09:48:51 +08:00 committed by ZHANG Dapeng
parent 40bcab5d12
commit 1adf403bb1
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java
View File

@ -114,8 +114,7 @@ final class ProtocolNegotiators {
public ChannelHandler newHandler(GrpcHttp2ConnectionHandler handler) { public ChannelHandler newHandler(GrpcHttp2ConnectionHandler handler) {
ChannelHandler gnh = new GrpcNegotiationHandler(handler); ChannelHandler gnh = new GrpcNegotiationHandler(handler);
ChannelHandler sth = new ServerTlsHandler(gnh, sslContext); ChannelHandler sth = new ServerTlsHandler(gnh, sslContext);
ChannelHandler wauh = new WaitUntilActiveHandler(sth); return new WaitUntilActiveHandler(sth);
return wauh;
} }
@Override @Override
@ -195,9 +194,8 @@ final class ProtocolNegotiators {
@Override @Override
public ChannelHandler newHandler(GrpcHttp2ConnectionHandler http2Handler) { public ChannelHandler newHandler(GrpcHttp2ConnectionHandler http2Handler) {
ChannelHandler protocolNegotiationHandler = negotiator.newHandler(http2Handler); ChannelHandler protocolNegotiationHandler = negotiator.newHandler(http2Handler);
ChannelHandler ppnh = new ProxyProtocolNegotiationHandler( return new ProxyProtocolNegotiationHandler(
proxyAddress, proxyUsername, proxyPassword, protocolNegotiationHandler); proxyAddress, proxyUsername, proxyPassword, protocolNegotiationHandler);
return ppnh;
} }
@Override @Override
@ -276,8 +274,7 @@ final class ProtocolNegotiators {
public ChannelHandler newHandler(GrpcHttp2ConnectionHandler grpcHandler) { public ChannelHandler newHandler(GrpcHttp2ConnectionHandler grpcHandler) {
ChannelHandler gnh = new GrpcNegotiationHandler(grpcHandler); ChannelHandler gnh = new GrpcNegotiationHandler(grpcHandler);
ChannelHandler cth = new ClientTlsHandler(gnh, sslContext, grpcHandler.getAuthority()); ChannelHandler cth = new ClientTlsHandler(gnh, sslContext, grpcHandler.getAuthority());
WaitUntilActiveHandler wuah = new WaitUntilActiveHandler(cth); return new WaitUntilActiveHandler(cth);
return wuah;
} }
@Override @Override
@ -405,8 +402,7 @@ final class ProtocolNegotiators {
public ChannelHandler newHandler(GrpcHttp2ConnectionHandler grpcHandler) { public ChannelHandler newHandler(GrpcHttp2ConnectionHandler grpcHandler) {
ChannelHandler upgradeHandler = ChannelHandler upgradeHandler =
new Http2UpgradeAndGrpcHandler(grpcHandler.getAuthority(), grpcHandler); new Http2UpgradeAndGrpcHandler(grpcHandler.getAuthority(), grpcHandler);
ChannelHandler wuah = new WaitUntilActiveHandler(upgradeHandler); return new WaitUntilActiveHandler(upgradeHandler);
return wuah;
} }
@Override @Override