LBRYCommunity/reflector.go
1
0
Fork 0
Code Issues7 Pull requests Projects Releases10 Packages Wiki Activity

log timed-out query

Browse source
This commit is contained in:
Alex Grintsvayg 2019-06-27 15:34:12 -04:00
parent 2047fe6c05
commit c3ab5dd2a5
No known key found for this signature in database
GPG key ID: AEB3F089F86A22B5
1 changed files with 6 additions and 3 deletions

5
db/db.go
View file

@ -419,10 +419,13 @@ func exec(e Executor, query string, args ...interface{}) error {
Retry: Retry:
attempt++ attempt++
_, err = e.Exec(query, args...) _, err = e.Exec(query, args...)
if e, ok := err.(*mysql.MySQLError); ok && attempt <= maxAttempts && e.Number == 1205 { if e, ok := err.(*mysql.MySQLError); ok && e.Number == 1205 {
if attempt <= maxAttempts {
//Error 1205: Lock wait timeout exceeded; try restarting transaction //Error 1205: Lock wait timeout exceeded; try restarting transaction
goto Retry goto Retry
} }
err = errors.Prefix("Timed out query "+query, err)
}
return errors.Err(err) return errors.Err(err)
} }