name: test ===> taskpubsub

554325746@qq.com

2019-07-24 f7f669143a2429091b362115ae87fd941e076003

 tasktag/tasktag.go

@@ -1,23 +1,23 @@
package tasktag

import (
   "fmt"
   "sync"

   "basic.com/pubsub/protomsg.git"
   "github.com/long/test/util"
   "github.com/long/taskpubsub/util"
    "github.com/long/taskpubsub/logger"
)

var TaskMapLab sync.Map

func Init() {

   fmt.Println("============= init tasktag info =====================")
   logger.Info("============= init tasktag info =====================")
   GenTaskMap()
   go func(taskflag chan bool) {
      for _ = range taskflag {
         GenTaskMap()
         fmt.Println("update task finished!")
         logger.Info("update task finished!")
      }

   }(util.TaskSdkflag)
@@ -26,14 +26,15 @@
func GenTaskMap() {
   var tls []protomsg.TaskLabel
   for _, taskSdk := range util.TaskSdks {

      var tl protomsg.TaskLabel
      tl.Taskid = taskSdk.Task.Taskid
        tl.Taskname = taskSdk.Task.Taskname

      for _, sdkinfo := range taskSdk.Sdks {
            sdkinfowithtask := new(protomsg.SdkmsgWithTask) 
            sdkinfowithtask.Sdkid = sdkinfo.Id
            sdkinfowithtask.Ipcid = sdkinfo.IpcId
            sdkinfowithtask.Sdktype = sdkinfo.SdkType
            sdkinfowithtask.SdkName = sdkinfo.SdkName
            sdkinfowithtask.Sdkdata = make([]byte, 1)
            tl.Sdkinfos = append(tl.Sdkinfos, sdkinfowithtask)
      }
@@ -42,7 +43,7 @@
   }
   GenTasklab(tls)
   TaskMapLab.Range(func(k, v interface{}) bool {
      fmt.Println(k, v)
      logger.Info(k, v)
      return true
   })
}