From 9e57860d1bae83cb069fd30bd12c091fc61224b3 Mon Sep 17 00:00:00 2001
From: nhsmw <nhsmwk@gmail.com>
Date: Mon, 23 Dec 2024 18:25:47 +0800
Subject: [PATCH] fix tcp server exit (#716)

---
 server/server.go | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/server/server.go b/server/server.go
index e9536dab9..d04074e42 100644
--- a/server/server.go
+++ b/server/server.go
@@ -154,6 +154,13 @@ func (c *server) initialize(ctx context.Context) error {
 	for _, subModule := range c.subModules {
 		appctx.SetService(subModule.Name(), subModule)
 	}
+	// start tcp server
+	go func() {
+		err := c.tcpServer.Run(ctx)
+		if err != nil {
+			log.Error("tcp server exist", zap.Error(cerror.Trace(err)))
+		}
+	}()
 	log.Info("server initialized", zap.Any("server", c.info))
 	return nil
 }
@@ -170,10 +177,6 @@ func (c *server) Run(ctx context.Context) error {
 	}()
 
 	g, ctx := errgroup.WithContext(ctx)
-	// start tcp server
-	g.Go(func() error {
-		return c.tcpServer.Run(ctx)
-	})
 	// start all submodules
 	for _, sub := range c.subModules {
 		func(m common.SubModule) {