fix tcp server exit (#716)

pingcap · Dec 23, 2024 · 9e57860 · 9e57860
1 parent 55f0548
commit 9e57860
Showing 1 changed file with 7 additions and 4 deletions.
diff --git 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) {