From 9389544d4cc56ef00084e8dbb6afb73e1ec00eca Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期三, 11 九月 2019 17:30:43 +0800
Subject: [PATCH] 改成使用valib的logger，增加一些日志输出
---
tasktag/tasktag.go | 48 ++++++++++++++++++++++++------------------------
1 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/tasktag/tasktag.go b/tasktag/tasktag.go
index 9f54083..3231f0b 100644
--- a/tasktag/tasktag.go
+++ b/tasktag/tasktag.go
@@ -4,60 +4,60 @@
"sync"
"basic.com/pubsub/protomsg.git"
- "github.com/long/test/util"
- "github.com/long/test/logger"
+ "taskpubsub/logger"
+ "taskpubsub/util"
)
-var TaskMapLab sync.Map
+var TaskLabelMap sync.Map
func Init() {
logger.Info("============= init tasktag info =====================")
- GenTaskMap()
+ genTaskLabelMap()
go func(taskflag chan bool) {
for _ = range taskflag {
- GenTaskMap()
+ genTaskLabelMap()
logger.Info("update task finished!")
}
-
}(util.TaskSdkflag)
}
-func GenTaskMap() {
- var tls []protomsg.TaskLabel
+// 浠巗qlite 鎺ュ彛鎷垮埌鎵�鏈夌殑浠诲姟, 姣忎竴涓换鍔￠兘鏈夎嚜宸辩殑鍑犱釜绠楁硶
+//浠� taskid 浣滀负key, 瀵瑰簲鐨勭畻娉曠粍鍚堜綔涓� value
+func genTaskLabelMap() {
+ var newtls []protomsg.TaskLabel
for _, taskSdk := range util.TaskSdks {
var tl protomsg.TaskLabel
tl.Taskid = taskSdk.Task.Taskid
- tl.Taskname = taskSdk.Task.Taskname
+ tl.Taskname = taskSdk.Task.Taskname
for _, sdkinfo := range taskSdk.Sdks {
- sdkinfowithtask := new(protomsg.SdkmsgWithTask)
- sdkinfowithtask.Ipcid = sdkinfo.IpcId
- sdkinfowithtask.Sdktype = sdkinfo.SdkType
- sdkinfowithtask.Sdkdata = make([]byte, 1)
- tl.Sdkinfos = append(tl.Sdkinfos, sdkinfowithtask)
+ sdkinfowithtask := new(protomsg.SdkmsgWithTask)
+ sdkinfowithtask.Ipcid = sdkinfo.IpcId
+ sdkinfowithtask.Sdktype = sdkinfo.SdkType
+ logger.Info("======sdkinfowithtask.Sdktype:", sdkinfowithtask.Sdktype)
+ sdkinfowithtask.Sdkdata = make([]byte, 1)
+ tl.Sdkinfos = append(tl.Sdkinfos, sdkinfowithtask)
}
tl.Index = int32(0)
- tls = append(tls, tl)
+ newtls = append(newtls, tl)
}
- GenTasklab(tls)
- TaskMapLab.Range(func(k, v interface{}) bool {
+ updateTaskLabelMap(newtls)
+ TaskLabelMap.Range(func(k, v interface{}) bool {
logger.Info(k, v)
return true
})
}
-// 浠巗qlite 鎺ュ彛鎷垮埌鎵�鏈夌殑浠诲姟, 姣忎竴涓换鍔￠兘鏈夎嚜宸辩殑鍑犱釜绠楁硶
-//浠� taskid 浣滀负key, 瀵瑰簲鐨勭畻娉曠粍鍚堜綔涓� value
-func GenTasklab(tasklab []protomsg.TaskLabel) {
- TaskMapLab.Range(func(key interface{}, value interface{}) bool {
- TaskMapLab.Delete(key)
+func updateTaskLabelMap(taskLabel []protomsg.TaskLabel) {
+ TaskLabelMap.Range(func(key interface{}, value interface{}) bool {
+ TaskLabelMap.Delete(key)
return true
})
- for _, value := range tasklab {
+ for _, value := range taskLabel {
pv := value
- TaskMapLab.Store(value.Taskid, &pv)
+ TaskLabelMap.Store(value.Taskid, &pv)
}
}
--
Gitblit v1.8.0