GOMODULES/pgx
1
0
Fork 0
mirror of https://github.com/jackc/pgx.git synced 2025-05-07 16:12:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix panic in Pipeline when PgConn is busy or closed

Browse Source
This commit is contained in:
Ryan Fowler 2023-12-16 09:23:17 -08:00 committed by Jack Christensen
parent 603c8c1e90
commit dfd198003a
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pgconn/pgconn.go
View File

@ -2053,6 +2053,13 @@ func (p *Pipeline) Flush() error {
// Sync establishes a synchronization point and flushes the queued requests. // Sync establishes a synchronization point and flushes the queued requests.
func (p *Pipeline) Sync() error { func (p *Pipeline) Sync() error {
if p.closed {
if p.err != nil {
return p.err
}
return errors.New("pipeline closed")
}
p.conn.frontend.SendSync(&pgproto3.Sync{}) p.conn.frontend.SendSync(&pgproto3.Sync{})
err := p.Flush() err := p.Flush()
if err != nil { if err != nil {