From 971eddaa1257625a5a5744704e28fbeec94ded1e Mon Sep 17 00:00:00 2001 From: Shelikhoo Date: Thu, 11 Mar 2021 15:02:31 +0000 Subject: [PATCH] fix applied wrong name, and wrong varible name --- transport/internet/grpc/hub.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/transport/internet/grpc/hub.go b/transport/internet/grpc/hub.go index b65bbd31f..c93081c68 100644 --- a/transport/internet/grpc/hub.go +++ b/transport/internet/grpc/hub.go @@ -43,7 +43,7 @@ func (l Listener) Addr() net.Addr { } func Listen(ctx context.Context, address net.Address, port net.Port, settings *internet.MemoryStreamConfig, handler internet.ConnHandler) (internet.Listener, error) { - httpSettings := settings.ProtocolSettings.(*Config) + grpcSettings := settings.ProtocolSettings.(*Config) var listener *Listener if port == net.Port(0) { // unix listener = &Listener{ @@ -52,7 +52,7 @@ func Listen(ctx context.Context, address net.Address, port net.Port, settings *i Name: address.Domain(), Net: "unix", }, - config: httpSettings, + config: grpcSettings, } } else { // tcp listener = &Listener{ @@ -61,7 +61,7 @@ func Listen(ctx context.Context, address net.Address, port net.Port, settings *i IP: address.IP(), Port: int(port), }, - config: httpSettings, + config: grpcSettings, } } @@ -108,7 +108,7 @@ func Listen(ctx context.Context, address net.Address, port net.Port, settings *i } } - encoding.RegisterGunServiceServerX(s, listener, config.ServerName) + encoding.RegisterGunServiceServerX(s, listener, grpcSettings.ServiceName) if err = s.Serve(streamListener); err != nil { newError("Listener for grpc ended").Base(err).WriteToLog()