This commit is contained in:
Liang Ding 2023-01-08 22:57:53 +08:00
parent c4e347f9fb
commit dba12d6111
No known key found for this signature in database
GPG Key ID: 136F30F901A2231D

View File

@ -1230,11 +1230,13 @@ func autoFixIndex() {
for rootID, updated := range rootUpdated {
root := sql.GetBlock(rootID)
if nil == root {
logging.LogWarnf("not found tree [%s] in database, reindex it", rootID)
reindexTree(rootID)
continue
}
if "" == updated {
// BlockTree 迁移v2.6.3 之前没有 updated 字段
reindexTree(rootID)
continue
}
@ -1242,12 +1244,15 @@ func autoFixIndex() {
btUpdated, _ := time.Parse("20060102150405", updated)
dbUpdated, _ := time.Parse("20060102150405", root.Updated)
if dbUpdated.Before(btUpdated.Add(-1 * time.Minute)) {
logging.LogWarnf("tree [%s] is not up to date, reindex it", rootID)
reindexTree(rootID)
continue
}
roots := sql.GetBlockRedundant(rootID)
if 1 < len(roots) {
logging.LogWarnf("exist more than one tree [%s], reindex it", rootID)
sql.RemoveTreeQueue(root.Box, rootID)
reindexTree(rootID)
continue
}