- 对于长时间未提交事务报警
This commit is contained in:
@@ -79,7 +79,7 @@ func Begin(db *DaoDB) (err error) {
|
|||||||
func (db *DaoDB) startWatchTransaction() {
|
func (db *DaoDB) startWatchTransaction() {
|
||||||
db.beginTransactionStack = debug.Stack()
|
db.beginTransactionStack = debug.Stack()
|
||||||
db.transactionWatchTimer = utils.AfterFuncWithRecover(transactionWarningSeconds*time.Second, func() {
|
db.transactionWatchTimer = utils.AfterFuncWithRecover(transactionWarningSeconds*time.Second, func() {
|
||||||
globals.SugarLogger.Debugf("Begin Transaction too long, %s", string(db.beginTransactionStack))
|
globals.SugarLogger.Warnf("Begin Transaction too long, %s", string(db.beginTransactionStack))
|
||||||
db.transactionWatchTimer = nil
|
db.transactionWatchTimer = nil
|
||||||
db.beginTransactionStack = nil
|
db.beginTransactionStack = nil
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user