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-07-23 16:20:45 +08:00
parent 2e198e3ab2
commit 7e388eeeef
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbpool.go
View File

@ -27,6 +27,7 @@ type dataSource struct {
type maxIdxMonitorProgItem struct {
execTimes int64
okTimes int64
errTimes int64
abortTimes int64
lastIdx *int64
@ -63,13 +64,14 @@ func (this *dbPool) outputMonitorLog() {
GetSysLog().Info("--------------------------------------------------------------------------------------")
this.maxIdxMonitorProgHash.Range(func (k string, ele *maxIdxMonitorProg) bool {
ele.itemHash.Range(func (k1 string, ele2 *maxIdxMonitorProgItem) bool {
GetSysLog().Info("%s.%s.%s maxIdx:%d lastIdx:%d exec:%d err:%d abort:%d",
GetSysLog().Info("%s.%s.%s maxIdx:%d lastIdx:%d exec:%d ok:%d err:%d abort:%d",
ele.dataSource,
ele.tblName,
k1,
*ele.maxIdx,
*ele2.lastIdx,
ele2.execTimes,
ele2.okTimes,
ele2.errTimes,
ele2.abortTimes)
return true
@ -330,6 +332,7 @@ func (this *dbPool) IncrementLoad(
item.abortTimes += 1
return
}
item.okTimes += 1
if idx > lastIdx {
lastIdx = idx
} else {