From 784eb9afdb354f8d4dd53aa395d9fe05693c2d83 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sat, 20 Jul 2024 22:45:37 +0800 Subject: [PATCH] 1 --- server/light_backtask/task/contribution.go | 11 +++++++---- third_party/f5 | 2 +- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/server/light_backtask/task/contribution.go b/server/light_backtask/task/contribution.go index 25b09282..c0c2c426 100644 --- a/server/light_backtask/task/contribution.go +++ b/server/light_backtask/task/contribution.go @@ -84,21 +84,24 @@ func (this* contribution) internalStat(statTime int64, nowTime int64) bool { } q5.AppendSlice(¶ms, lockMeta.GetAddress()) } - sqlTpl += ")" + sqlTpl += ") LIMIT 1000" } - f5.GetGoStyleDb().BatchLoad( + err := f5.GetGoStyleDb().BatchLoadFullTable( constant.BCNFT_DB, func (lastIdx int64) string { sql := fmt.Sprintf(sqlTpl, lastIdx) return sql }, params, - func () int64 { - return 10 + func () { + time.Sleep(time.Millisecond * 10) }, func (ds *f5.DataSet) bool { return this.loadFromDb(addressHash, ds) }) + if err != nil { + return false + } } return false } diff --git a/third_party/f5 b/third_party/f5 index 7685c139..bc474982 160000 --- a/third_party/f5 +++ b/third_party/f5 @@ -1 +1 @@ -Subproject commit 7685c13942fc25fc89e49640f0b303e029279c7a +Subproject commit bc4749825937d2673d23ae61f2c33c6a3fe1abfd