Commit c4bb24dc authored by Vladimir Barsukov's avatar Vladimir Barsukov
Browse files

save

parent a1ea14ab
...@@ -144,7 +144,7 @@ func (d *Pool) execWrapper(pool connMode, dst any, f func(conn *conn, dst1 any) ...@@ -144,7 +144,7 @@ func (d *Pool) execWrapper(pool connMode, dst any, f func(conn *conn, dst1 any)
q = d.async() q = d.async()
} }
repit: repeat:
if err := f(q, dst); err != nil { if err := f(q, dst); err != nil {
if q.Mode == ConnModeMaster { if q.Mode == ConnModeMaster {
return err return err
...@@ -152,12 +152,12 @@ func (d *Pool) execWrapper(pool connMode, dst any, f func(conn *conn, dst1 any) ...@@ -152,12 +152,12 @@ func (d *Pool) execWrapper(pool connMode, dst any, f func(conn *conn, dst1 any)
if try < d.TryOnError && contains(err.Error(), d.ContinuesTry) { if try < d.TryOnError && contains(err.Error(), d.ContinuesTry) {
try++ try++
goto repit goto repeat
} }
if contains(err.Error(), d.Continues) { if contains(err.Error(), d.Continues) {
d.logger.Printf("DB_EXEC_WRAPPER_ERR: %s", err.Error())
d.setNotAliveConn(q) d.setNotAliveConn(q)
d.logger.Printf("DB_EXEC_WRAPPER_ERR: %s", err.Error())
continue continue
} else { } else {
return err return err
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment