add net/http/pprof

.gitignore

@@ -0,0 +1,6 @@
+config.yaml
+.idea
+vendor
+config.*.yaml
+*.log
+*.log.*

cmd/height/fetcher.go

@@ -3,7 +3,10 @@ package height
 import (
 	"github.com/dubuqingfeng/stratum-server-monitor/manager"
 	"github.com/dubuqingfeng/stratum-server-monitor/utils"
+	log "github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
+	"net/http"
+	_ "net/http/pprof"
 	"time"
 )
 
@@ -19,6 +22,13 @@ func NewHeightFetcherCommand() *cobra.Command {
 func stratumServerHeightFetch(cmd *cobra.Command, args []string) {
 	utils.ConfigLocalFilesystemLogger("./logs/", "fetcher.log", 7*time.Hour*24, time.Second*20)
 	// Initialization storage
+	if utils.Config.Debug {
+		go func() {
+			if err := http.ListenAndServe("0.0.0.0:8080", nil); err != nil {
+				log.Error(err)
+			}
+		}()
+	}
 	ssManager := manager.Manager{}
 	ssManager.Run()
 	quit := make(chan bool)

fetchers/HeightFetcher.go

@@ -174,6 +174,7 @@ func (p *PoolHeightFetcher) handleNotifyRes(resp interface{}) {
 		p.SendNotification(notification)
 		log.WithField("endpoint", p.Address).Info(fmt.Sprintf("height: %d, old height: %d", height, p.Height))
 	}
+	// mutex
 	p.Height = height
 }
 

utils/configs.go

@@ -4,6 +4,7 @@ import "github.com/jinzhu/configor"
 
 var Config = struct {
 	Name                                   string `default:"app_name"`
+	Debug                                  bool
 	MonitorName                            string `default:"ss-monitor"`
 	StratumServerConfigDatabaseTablePrefix string
 	GlobalDatabase                         MySQLDB