Browse Source

fix applied wrong name, and wrong varible name

Shelikhoo 4 years ago
parent
commit
971eddaa12
1 changed files with 4 additions and 4 deletions
  1. 4 4
      transport/internet/grpc/hub.go

+ 4 - 4
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) {
 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
 	var listener *Listener
 	if port == net.Port(0) { // unix
 	if port == net.Port(0) { // unix
 		listener = &Listener{
 		listener = &Listener{
@@ -52,7 +52,7 @@ func Listen(ctx context.Context, address net.Address, port net.Port, settings *i
 				Name: address.Domain(),
 				Name: address.Domain(),
 				Net:  "unix",
 				Net:  "unix",
 			},
 			},
-			config: httpSettings,
+			config: grpcSettings,
 		}
 		}
 	} else { // tcp
 	} else { // tcp
 		listener = &Listener{
 		listener = &Listener{
@@ -61,7 +61,7 @@ func Listen(ctx context.Context, address net.Address, port net.Port, settings *i
 				IP:   address.IP(),
 				IP:   address.IP(),
 				Port: int(port),
 				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 {
 		if err = s.Serve(streamListener); err != nil {
 			newError("Listener for grpc ended").Base(err).WriteToLog()
 			newError("Listener for grpc ended").Base(err).WriteToLog()