server_common/f5
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-06-29 21:30:56 +08:00
parent 2ff2d1c71b
commit 94bdf86097
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbpool.go
View File

@ -136,6 +136,7 @@ func (this *dbPool) SyncBatchLoadFullTable(dataSource string, sqlTpl string,
func (this *dbPool) LoopLoad( func (this *dbPool) LoopLoad(
dataSource string, dataSource string,
name string,
watchTable string, watchTable string,
watchTimeCb func() int64, watchTimeCb func() int64,
sqlCb func(int64) string, sqlCb func(int64) string,
@ -180,6 +181,11 @@ func (this *dbPool) LoopLoad(
cond.L.Lock() cond.L.Lock()
cond.Wait() cond.Wait()
cond.L.Unlock() cond.L.Unlock()
if !hasNextData {
GetSysLog().Info("dbpool.LoopLoad %s fetch next batch last_idx:%d", name, lastIdx)
} else {
GetSysLog().Info("dbpool.LoopLoad %s fetch next round last_idx:%d", name, lastIdx)
}
} }
} }