From ba96922f40f82d12e9a5f4cfa4d887e78f460125 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 26 十二月 2019 15:23:17 +0800
Subject: [PATCH] update
---
main.go | 41 ++++++++++++++++++++---------------------
1 files changed, 20 insertions(+), 21 deletions(-)
diff --git a/main.go b/main.go
index 535173e..263c91a 100644
--- a/main.go
+++ b/main.go
@@ -1,15 +1,14 @@
package main
import (
- "flag"
"net/http"
+ "flag"
_ "net/http/pprof"
+ "time"
"taskpubsub/camera"
"taskpubsub/sdk"
"taskpubsub/tasktag"
"taskpubsub/util"
- "time"
-
"basic.com/valib/logger.git"
"github.com/spf13/viper"
)
@@ -18,14 +17,14 @@
var useShm bool
const (
- configFilePath = "/opt/vasystem/config/"
+ configFilePath = "/opt/vasystem/config/"
configFileType = "yaml"
- LOGBASEPATH = "/data/disk1/valog/taskpubsub.log"
+ LOGBASEPATH = "/data/disk1/valog/taskpubsub.log"
)
var envirment = flag.String("e", "pro", "")
-func init() {
+func init(){
viper.SetConfigType(configFileType)
viper.SetConfigName(*envirment)
viper.AddConfigPath(configFilePath)
@@ -36,33 +35,33 @@
//panic(err)
}
- var logFile = LOGBASEPATH
+ var logFile = LOGBASEPATH
if viper.GetString("LogBasePath") != "" {
logFile = viper.GetString("LogBasePath") + "/taskpubsub.log"
}
- // 鏃ュ織鍒濆鍖�
+ // 鏃ュ織鍒濆鍖�
if viper.IsSet("LogLevel") &&
viper.GetInt("LogLevel") >= logger.PanicLevel &&
viper.GetInt("LogLevel") <= logger.DebugLevel {
logger.Config(logFile, viper.GetInt("LogLevel"))
- } else {
+ }else{
logger.Config(logFile, logger.DebugLevel)
}
- var logSaveDays = 15
- logger.SetSaveDays(logSaveDays)
+ var logSaveDays = 15
+ logger.SetSaveDays(logSaveDays)
logger.Info("loginit success !")
-
+
flag.BoolVar(&useShm, "shm", false, "use shm for performance")
-}
-
+}
+
func main() {
- flag.Parse()
- time.Sleep(time.Second)
+ flag.Parse()
+ time.Sleep(time.Second)
- if useShm {
+ if useShm{
logger.Info("USE SHARE MEMORY")
- } else {
+ }else{
logger.Info("USE PIPE")
}
// pprof 鐢ㄤ簬鍒嗘瀽鎬ц兘
@@ -73,8 +72,8 @@
go util.Init(initchan)
logger.Info("init ok !!!!, start sdk, task, camera init process ....", <-initchan)
- sdk.Init(useShm) // 鑾峰彇鎵�鏈夌畻娉昳d ,寤虹珛 sdk 涓婚锛� 寤虹珛sdk server(send, recv 杩愯)
- tasktag.Init() // 鑾峰彇鎵�鏈変换鍔★紝寤虹珛浠诲姟鏍囩锛� 鍦ㄦ暟鎹繘鍏ユ椂锛� 鎵撴爣绛�
- camera.Init(useShm) //鑾峰彇cid, taskid, sdkid ,鍏崇郴
+ sdk.Init(useShm) // 鑾峰彇鎵�鏈夌畻娉昳d ,寤虹珛 sdk 涓婚锛� 寤虹珛sdk server(send, recv 杩愯)
+ tasktag.Init() // 鑾峰彇鎵�鏈変换鍔★紝寤虹珛浠诲姟鏍囩锛� 鍦ㄦ暟鎹繘鍏ユ椂锛� 鎵撴爣绛�
+ camera.Init(useShm) //鑾峰彇cid, taskid, sdkid ,鍏崇郴
select {}
}
--
Gitblit v1.8.0