Skip to content
Snippets Groups Projects
Commit 1416c8d8 authored by Manuel Kieweg's avatar Manuel Kieweg
Browse files

Merge branch 'lint-clean' into 'develop'

remove %v and simplify if-statement

See merge request cocsn/gosdn!39
parents c0ae8170 a5691c40
Branches
Tags
2 merge requests!39remove %v and simplify if-statement,!18Develop
Pipeline #52237 passed
...@@ -9,10 +9,10 @@ package nucleus ...@@ -9,10 +9,10 @@ package nucleus
import ( import (
pb "code.fbi.h-da.de/cocsn/gosdn/cliInterface" pb "code.fbi.h-da.de/cocsn/gosdn/cliInterface"
"code.fbi.h-da.de/cocsn/gosdn/log"
"code.fbi.h-da.de/cocsn/gosdn/restconf/client/ciena" "code.fbi.h-da.de/cocsn/gosdn/restconf/client/ciena"
"context" "context"
"google.golang.org/grpc" "google.golang.org/grpc"
"code.fbi.h-da.de/cocsn/gosdn/log"
"net" "net"
) )
...@@ -23,12 +23,12 @@ type server struct { ...@@ -23,12 +23,12 @@ type server struct {
} }
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) { func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
log.Info("Received: %v", in.GetName()) log.Info("Received: ", in.GetName())
return &pb.HelloReply{Message: "Hello " + in.GetName(), GoSDNInfo: "goSDN in version: DEVELOP"}, nil return &pb.HelloReply{Message: "Hello " + in.GetName(), GoSDNInfo: "goSDN in version: DEVELOP"}, nil
} }
func (s *server) Shutdown(ctx context.Context, in *pb.ShutdownRequest) (*pb.ShutdownReply, error) { func (s *server) Shutdown(ctx context.Context, in *pb.ShutdownRequest) (*pb.ShutdownReply, error) {
log.Info("Shutdown Received: %v", in.GetName()) log.Info("Shutdown Received: ", in.GetName())
s.core.IsRunning <- false s.core.IsRunning <- false
return &pb.ShutdownReply{Message: "Shutdown " + in.GetName()}, nil return &pb.ShutdownReply{Message: "Shutdown " + in.GetName()}, nil
} }
...@@ -38,21 +38,21 @@ func getCLIGoing(core *Core) { ...@@ -38,21 +38,21 @@ func getCLIGoing(core *Core) {
// Boot-up the control interface for the cli // Boot-up the control interface for the cli
cliControlListener, err := net.Listen("tcp", core.config.CliSocket) cliControlListener, err := net.Listen("tcp", core.config.CliSocket)
if err != nil { if err != nil {
log.Fatal("failed to listen: %v", err) log.Fatal(err)
} }
cliControlServer := grpc.NewServer() cliControlServer := grpc.NewServer()
pb.RegisterGrpcCliServer(cliControlServer, &server{core: core}) pb.RegisterGrpcCliServer(cliControlServer, &server{core: core})
if err := cliControlServer.Serve(cliControlListener); err != nil { if err := cliControlServer.Serve(cliControlListener); err != nil {
log.Fatal("failed to serve: %v", err) log.Fatal(err)
} }
log.Info("Started: GetCLIGoing") log.Info("Started: GetCLIGoing")
} }
// SBI specific calls, by now TAPI only // SBI specific calls, by now TAPI only
func (s *server) TAPIGetEdge(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIReply, error) { func (s *server) TAPIGetEdge(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIReply, error) {
log.Info("Received: %v", in.GetName()) log.Info("Received: ", in.GetName())
if err := s.core.clients["ciena-mcp"].(*ciena.MCPClient).GetNodes(); err != nil { if err := s.core.clients["ciena-mcp"].(*ciena.MCPClient).GetNodes(); err != nil {
log.Error(err) log.Error(err)
return &pb.TAPIReply{Message: "TAPI error"}, nil return &pb.TAPIReply{Message: "TAPI error"}, nil
...@@ -61,7 +61,7 @@ func (s *server) TAPIGetEdge(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIR ...@@ -61,7 +61,7 @@ func (s *server) TAPIGetEdge(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIR
} }
func (s *server) TAPIGetEdgeNode(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIReply, error) { func (s *server) TAPIGetEdgeNode(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIReply, error) {
log.Info("Received: %v", in.GetName()) log.Info("Received: ", in.GetName())
if err := s.core.clients["ciena-mcp"].(*ciena.MCPClient).GetNodeEdgePoints(); err != nil { if err := s.core.clients["ciena-mcp"].(*ciena.MCPClient).GetNodeEdgePoints(); err != nil {
log.Error(err) log.Error(err)
return &pb.TAPIReply{Message: "TAPI error"}, nil return &pb.TAPIReply{Message: "TAPI error"}, nil
...@@ -70,7 +70,7 @@ func (s *server) TAPIGetEdgeNode(ctx context.Context, in *pb.TAPIRequest) (*pb.T ...@@ -70,7 +70,7 @@ func (s *server) TAPIGetEdgeNode(ctx context.Context, in *pb.TAPIRequest) (*pb.T
} }
func (s *server) TAPIGetLink(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIReply, error) { func (s *server) TAPIGetLink(ctx context.Context, in *pb.TAPIRequest) (*pb.TAPIReply, error) {
log.Info("Received: %v", in.GetName()) log.Info("Received: ", in.GetName())
if err := s.core.clients["ciena-mcp"].(*ciena.MCPClient).GetLinks(); err != nil { if err := s.core.clients["ciena-mcp"].(*ciena.MCPClient).GetLinks(); err != nil {
log.Error(err) log.Error(err)
return &pb.TAPIReply{Message: "TAPI error"}, nil return &pb.TAPIReply{Message: "TAPI error"}, nil
......
...@@ -62,7 +62,7 @@ func (c *Core) AttachDatabase() { ...@@ -62,7 +62,7 @@ func (c *Core) AttachDatabase() {
func (c *Core) Shutdown() { func (c *Core) Shutdown() {
stopIt := <- c.IsRunning stopIt := <- c.IsRunning
if(stopIt == false) { if !stopIt {
log.Debug("Shutdown() received action to shutdown") log.Debug("Shutdown() received action to shutdown")
}else { }else {
log.Debug("Shutdown() received something else.") log.Debug("Shutdown() received something else.")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment