From c466c18ab808b1cdb4a770ee9753fcedec727f80 Mon Sep 17 00:00:00 2001 From: simlecode <69969590+simlecode@users.noreply.github.com> Date: Fri, 28 Oct 2022 15:27:59 +0800 Subject: [PATCH] chore: shutdown server when receiving exit signal --- app/node/node.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/app/node/node.go b/app/node/node.go index da1e12ec9b..e6585cc56b 100644 --- a/app/node/node.go +++ b/app/node/node.go @@ -212,12 +212,9 @@ func (node *Node) Stop(ctx context.Context) { log.Infof("shutting down pay channel...") node.paychan.Stop() - // Stop market submodule - // node.market.Stop() - log.Infof("closing repository...") if err := node.repo.Close(); err != nil { - fmt.Printf("error closing repo: %s\n", err) + log.Warnf("error closing repo: %s", err) } log.Infof("flushing system logs...") @@ -302,10 +299,13 @@ func (node *Node) RunRPCAndWait(ctx context.Context, rootCmdDaemon *cmds.Command // todo: design an genterfull memguard.CatchSignal(func(signal os.Signal) { log.Infof("received signal(%s), venus will shutdown...", signal.String()) + log.Infof("shutting down server...") + if err := apiserv.Shutdown(ctx); err != nil { + log.Warnf("failed to shutdown server: %v", err) + } node.Stop(ctx) - log.Infof("venus shutdown gracefully ...") - _ = log.Sync() memguard.Purge() + log.Infof("venus shutdown gracefully ...") terminate <- nil }, syscall.SIGTERM, os.Interrupt)