bugfix: repair init getty failed (#423)

* bugfix: repair init getty failed

pkg/client/client.go

@@ -20,13 +20,12 @@ package client
 import (
 	"sync"
 
-	"github.com/seata/seata-go/pkg/tm"
-
 	at "github.com/seata/seata-go/pkg/datasource/sql"
 	"github.com/seata/seata-go/pkg/integration"
 	"github.com/seata/seata-go/pkg/remoting/getty"
 	"github.com/seata/seata-go/pkg/remoting/processor/client"
 	"github.com/seata/seata-go/pkg/rm/tcc"
+	"github.com/seata/seata-go/pkg/tm"
 	"github.com/seata/seata-go/pkg/util/log"
 )
 
@@ -39,21 +38,18 @@ func Init() {
 func InitPath(configFilePath string) {
 	cfg := LoadPath(configFilePath)
 
-	initLog(cfg)
 	initRmClient(cfg)
 	initTmClient(cfg)
 }
 
 var (
 	onceInitTmClient sync.Once
 	onceInitRmClient sync.Once
-	onceInitLog      sync.Once
 )
 
 // InitTmClient init client tm client
 func initTmClient(cfg *Config) {
 	onceInitTmClient.Do(func() {
-		initRemoting(cfg)
 		tm.InitTm(cfg.ClientConfig.TmConfig)
 	})
 }
@@ -71,16 +67,11 @@ func initRemoting(cfg *Config) {
 // InitRmClient init client rm client
 func initRmClient(cfg *Config) {
 	onceInitRmClient.Do(func() {
+		log.Init()
+		initRemoting(cfg)
 		client.RegisterProcessor()
 		integration.Init()
 		tcc.InitTCC()
 		at.InitAT(cfg.ClientConfig.UndoConfig, cfg.AsyncWorkerConfig)
 	})
 }
-
-// initLog init log
-func initLog(cfg *Config) {
-	onceInitLog.Do(func() {
-		log.Init()
-	})
-}

pkg/remoting/getty/listener.go

@@ -36,7 +36,6 @@ var (
 )
 
 type gettyClientHandler struct {
-	conf           *SeataConfig
 	idGenerator    *atomic.Uint32
 	msgFutures     *sync.Map
 	mergeMsgMap    *sync.Map
@@ -48,7 +47,6 @@ func GetGettyClientHandlerInstance() *gettyClientHandler {
 	if clientHandler == nil {
 		onceClientHandler.Do(func() {
 			clientHandler = &gettyClientHandler{
-				conf:           getSeataConfig(),
 				idGenerator:    &atomic.Uint32{},
 				msgFutures:     &sync.Map{},
 				mergeMsgMap:    &sync.Map{},
@@ -63,11 +61,12 @@ func GetGettyClientHandlerInstance() *gettyClientHandler {
 func (g *gettyClientHandler) OnOpen(session getty.Session) error {
 	log.Infof("Open new getty session ")
 	g.sessionManager.registerSession(session)
+	conf := getSeataConfig()
 	go func() {
 		request := message.RegisterTMRequest{AbstractIdentifyRequest: message.AbstractIdentifyRequest{
 			Version:                 constant.SeataVersion,
-			ApplicationId:           g.conf.ApplicationID,
-			TransactionServiceGroup: g.conf.TxServiceGroup,
+			ApplicationId:           conf.ApplicationID,
+			TransactionServiceGroup: conf.TxServiceGroup,
 		}}
 		err := GetGettyRemotingClient().SendAsyncRequest(request)
 		if err != nil {