数据推送日志添加最后一条数据状态

zhangzengfei

2021-12-01 3fdd5c558b1cf801ebd39ceb65d4b910e7d4aba0

 logc.go

@@ -1,7 +1,7 @@
package logc

import (
   "basic.com/valib/bhomebus.git"
   "basic.com/valib/c_bhomebus.git/proto/source/bhome_msg"
   "fmt"
   "sync"
   "time"
@@ -44,7 +44,7 @@
}

type LogRegister struct {
   Nodes      []bhomebus.NetNode
   Nodes      []bhome_msg.BHAddress
   Topic      string
   Payload     []byte
}
@@ -108,6 +108,10 @@
   deliverLog(log, timeout)
}

func SaveRuleServerLog(ruleServerPushLog RuleServerPushLog, timeout time.Duration) {
   deliverLog(&ruleServerPushLog, timeout)
}

func deliverLog(l LogPrinter, timeout time.Duration) {
   select {
   case logCh <- l:
@@ -162,6 +166,7 @@
const (
   OperationLogTopic = "operationLogSaveTopic"
   ScheduleLogTopic = "scheduleLogSaveTopic"
   RuleServerLogTopic = "ruleServerLogSaveTopic"
)

func saveLoop(logCallback LogReportCallback, wg *sync.WaitGroup, done  chan struct{}) {
@@ -180,8 +185,8 @@
         if err != nil {
            logger.Error("failed to Marshal", log)
         } else {
               var nodes []bhomebus.NetNode
               nodes = append(nodes, bhomebus.NetNode{})
               var nodes []bhome_msg.BHAddress
               nodes = append(nodes, bhome_msg.BHAddress{})

               reg := &LogRegister {
                  nodes,