open 1 conn at a time
This commit is contained in:
@@ -7,6 +7,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"gitea.bel.blue/bel/with"
|
"gitea.bel.blue/bel/with"
|
||||||
@@ -30,14 +31,20 @@ func run(ctx context.Context) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for i := 0; i < *p-1; i++ {
|
for i := 0; i < *p-1; i++ {
|
||||||
go with.PSQL(ctx, *c, func(pg *sql.DB) error {
|
func() {
|
||||||
with.GoEvery(ctx, *d, func() {
|
connected := &sync.WaitGroup{}
|
||||||
if _, err := pg.ExecContext(ctx, `SELECT 1`); err != nil {
|
connected.Add(1)
|
||||||
log.Println("!", err)
|
go with.PSQL(ctx, *c, func(pg *sql.DB) error {
|
||||||
}
|
connected.Done()
|
||||||
|
with.GoEvery(ctx, *d, func() {
|
||||||
|
if _, err := pg.ExecContext(ctx, `SELECT 1`); err != nil {
|
||||||
|
log.Println("!", err)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
return ctx.Err()
|
||||||
})
|
})
|
||||||
return ctx.Err()
|
connected.Wait()
|
||||||
})
|
}()
|
||||||
}
|
}
|
||||||
|
|
||||||
return with.PSQL(ctx, *c, func(pg *sql.DB) error {
|
return with.PSQL(ctx, *c, func(pg *sql.DB) error {
|
||||||
|
|||||||
Reference in New Issue
Block a user