test/databoard-transform
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix(code): condition error

Browse Source
This commit is contained in:
eson 2020-12-10 19:00:35 +08:00
parent e9862571e2
commit e228a71a57
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
collect.go
View File

@ -17,7 +17,7 @@ func collectCopyCountLiveAnchors(cxt *WorkerContext) {
var err error var err error
var ok bool var ok bool
var lastLiveAnchor *CountLiveAnchors
for !ps.IsClose() { for !ps.IsClose() {
liveanchor := &CountLiveAnchors{} liveanchor := &CountLiveAnchors{}
@ -33,17 +33,8 @@ func collectCopyCountLiveAnchors(cxt *WorkerContext) {
} }
cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": last}}) cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": last}})
} else { } else {
if lastLiveAnchor != nil {
if liveanchor.UID == liveanchor.UID {
ps.Wait(time.Second * 2)
continue
}
}
last = liveanchor.CreateAt last = liveanchor.CreateAt
log.Println("last: ", last, liveanchor.UID) log.Println("last: ", last, liveanchor.UID)
lastLiveAnchor = liveanchor
cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": last}}) cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": last}})
} }
@ -61,6 +52,7 @@ func collectCopyCountLiveAnchors(cxt *WorkerContext) {
if err != nil { if err != nil {
panic(err) panic(err)
} }
c := &CountLiveAnchors{} c := &CountLiveAnchors{}
c.UID = la.ObjectID.Hex() c.UID = la.ObjectID.Hex()