1

server/light_backtask/task/contribution.go

@@ -84,21 +84,24 @@ func (this* contribution) internalStat(statTime int64, nowTime int64) bool {
 				}
 				q5.AppendSlice(&params, 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
 }

third_party/f5

@@ -1 +1 @@
-Subproject commit 7685c13942fc25fc89e49640f0b303e029279c7a
+Subproject commit bc4749825937d2673d23ae61f2c33c6a3fe1abfd