|
|
@@ -39,8 +39,8 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
if sid == "" || eid == "" {
|
|
|
log.Debug("err", "sid=", sid, ",eid=", eid)
|
|
|
} else {
|
|
|
- go Udpclient.WriteUdp([]byte("udpok"), mu.OP_NOOP, ra)
|
|
|
if stype == "distributed" { //分布式抽取分支
|
|
|
+ go Udpclient.WriteUdp([]byte("udpok"), mu.OP_NOOP, ra)
|
|
|
log.Debug("分布式抽取id段", sid, " ", eid)
|
|
|
InstanceId := qu.ObjToString(rep["InstanceId"])
|
|
|
db.Mgo.Update("ecs", `{"InstanceId":"`+InstanceId+`"}`,
|
|
|
@@ -58,6 +58,11 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
}, true, false)
|
|
|
log.Debug("分布式抽取完成", sid, " ", eid, "释放esc实例", qu.ObjToString(rep["ip"]))
|
|
|
} else {
|
|
|
+ udpinfo, _ := rep["key"].(string)
|
|
|
+ if udpinfo == "" {
|
|
|
+ udpinfo = "udpok"
|
|
|
+ }
|
|
|
+ go Udpclient.WriteUdp([]byte(udpinfo), mu.OP_NOOP, ra)
|
|
|
log.Debug("udp通知抽取id段", sid, " ", eid)
|
|
|
ExtractByUdp(sid, eid)
|
|
|
log.Debug("udp通知抽取完成,eid=", eid)
|
