|
@@ -120,7 +120,7 @@ func mainT() {
|
|
|
mapinfo["gtid"] = sid
|
|
mapinfo["gtid"] = sid
|
|
|
mapinfo["lteid"] = eid
|
|
mapinfo["lteid"] = eid
|
|
|
mapinfo["stop"] = "true"
|
|
mapinfo["stop"] = "true"
|
|
|
- historyTask([]byte{}, mapinfo)
|
|
|
|
|
|
|
+ task([]byte{}, mapinfo)
|
|
|
time.Sleep(5 * time.Second)
|
|
time.Sleep(5 * time.Second)
|
|
|
}
|
|
}
|
|
|
func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
@@ -379,9 +379,6 @@ func historyTask(data []byte, mapInfo map[string]interface{}) {
|
|
|
HM = NewHistorymap(gtid,lteid, minTime, maxTime)
|
|
HM = NewHistorymap(gtid,lteid, minTime, maxTime)
|
|
|
fmt.Println("开始历史数据判重")
|
|
fmt.Println("开始历史数据判重")
|
|
|
|
|
|
|
|
- return
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
defer util.Catch()
|
|
defer util.Catch()
|
|
|
//区间id
|
|
//区间id
|
|
|
sess_history:= mgo.GetMgoConn()
|
|
sess_history:= mgo.GetMgoConn()
|
