diff --git a/infrastructure/network/netadapter/server/grpcserver/grpc_connection.go b/infrastructure/network/netadapter/server/grpcserver/grpc_connection.go index dc57d40d0..588aac6a9 100644 --- a/infrastructure/network/netadapter/server/grpcserver/grpc_connection.go +++ b/infrastructure/network/netadapter/server/grpcserver/grpc_connection.go @@ -4,6 +4,8 @@ import ( "github.com/kaspanet/kaspad/infrastructure/network/netadapter/router" "github.com/kaspanet/kaspad/infrastructure/network/netadapter/server/grpcserver/protowire" "github.com/pkg/errors" + "google.golang.org/grpc/codes" + "google.golang.org/grpc/status" "net" "sync" "sync/atomic" @@ -62,7 +64,17 @@ func (c *gRPCConnection) Start(router *router.Router) { spawn("gRPCConnection.Start-connectionLoops", func() { err := c.connectionLoops() if err != nil { - log.Errorf("error from connectionLoops for %s: %s", c.address, err) + status, isStatus := status.FromError(err) + if isStatus { + switch status.Code() { + case codes.Canceled: + log.Debugf("connectionLoop canceled connection for %s: %s", c.address, err) + default: + log.Errorf("status error from connectionLoops for %s: %s", c.address, err) + } + } else { + log.Errorf("unknown error from connectionLoops for %s: %+v", c.address, err) + } } }) } diff --git a/util/panics/panics.go b/util/panics/panics.go index d24bdcef8..863f75d8a 100644 --- a/util/panics/panics.go +++ b/util/panics/panics.go @@ -70,9 +70,8 @@ func exit(log *logger.Logger, reason string, currentThreadStackTrace []byte, gor fmt.Fprintln(os.Stderr, "Couldn't exit gracefully.") case <-exitHandlerDone: } - fmt.Print("Exiting...") + fmt.Println("Exiting...") os.Exit(1) - fmt.Print("After os.Exit(1)") } func handleSpawnedFunction(log *logger.Logger, stackTrace []byte, spawnedFunctionName string, spawnedFunction func()) {