Fix panic in Pipeline when PgConn is busy or closed

jackc · Dec 23, 2023 · dfd1980 · dfd1980
1 parent 603c8c1
commit dfd1980
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pgconn/pgconn.go b/pgconn/pgconn.go
@@ -2053,6 +2053,13 @@ func (p *Pipeline) Flush() error {
 
 // Sync establishes a synchronization point and flushes the queued requests.
 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{})
 	err := p.Flush()
 	if err != nil {