gibheer/monzero
1
0
Fork 1
Code Issues 3 Pull Requests Releases 1 Wiki Activity

monwork - add missing continues

Browse Source 
This can lead to longer run times than necessary.
This commit is contained in:
Gibheer 2018-12-13 15:37:03 +01:00
parent e151f056ad
commit 82e582f022
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/monwork/main.go
View File

@ -74,6 +74,7 @@ func startNodeGen(db *sql.DB, checkInterval time.Duration) {
log.Printf("could not update nodes: %s", err) log.Printf("could not update nodes: %s", err)
tx.Rollback() tx.Rollback()
time.Sleep(checkInterval) time.Sleep(checkInterval)
continue
} }
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
log.Printf("could not commit node updates: %s", err) log.Printf("could not commit node updates: %s", err)
@ -100,6 +101,7 @@ func startCommandGen(db *sql.DB, checkInterval time.Duration) {
log.Printf("could not update checks: %s", err) log.Printf("could not update checks: %s", err)
tx.Rollback() tx.Rollback()
time.Sleep(checkInterval) time.Sleep(checkInterval)
continue
} }
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
log.Printf("could not commit command updates: %s", err) log.Printf("could not commit command updates: %s", err)