From 41f05616d5e823d71f98ea77809cde204ffdf9ad Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期日, 20 十月 2024 20:46:34 +0800
Subject: [PATCH] fix find move position
---
main.go | 27 +++++++++++++++------------
1 files changed, 15 insertions(+), 12 deletions(-)
diff --git a/main.go b/main.go
index 8130d67..cc459f5 100644
--- a/main.go
+++ b/main.go
@@ -3,6 +3,7 @@
import (
"context"
"fmt"
+ "gat1400Exchange/nvcs"
"net/http"
"os"
"os/signal"
@@ -37,17 +38,7 @@
Handler: r,
}
- // 鍚姩1400瀹㈡埛绔�
- ctx, cancel := context.WithCancel(context.Background())
- go client.Init1400Client(ctx)
-
- // 鍚姩缃戠粶瑙嗛瀛楃鍙犲姞鍣ㄦ湇鍔�
- go service.StartNVCSServer()
-
- go service.InitSubscribeNotificationTasks()
-
- // 鍚姩瀹氭椂浠诲姟
- cron.Init()
+ srv.SetKeepAlivesEnabled(config.ServeConf.Keepalive)
// Initializing the server in a goroutine so that
// it won't block the graceful shutdown handling below
@@ -58,6 +49,18 @@
}()
logger.Info("Server is running at %s:%s", host, port)
+
+ // 鍚姩1400瀹㈡埛绔�
+ ctx, cancel := context.WithCancel(context.Background())
+ go client.Init1400Client(ctx)
+
+ // 鍚姩缃戠粶瑙嗛瀛楃鍙犲姞鍣ㄦ湇鍔�
+ go nvcs.StartNVCSServer(ctx)
+
+ go service.InitSubscribeNotificationTasks()
+
+ // 鍚姩瀹氭椂浠诲姟
+ cron.Init()
// Wait for interrupt signal to gracefully shutdown the server with
// a timeout of 5 seconds.
@@ -72,7 +75,7 @@
// The context is used to inform the server it has 5 seconds to finish
// the request it is currently handling
//ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
- defer cancel()
+ cancel()
if err := srv.Shutdown(ctx); err != nil {
logger.Error("Server forced to shutdown:", err)
}
--
Gitblit v1.8.0