gopkg/pgx
2
0
Fork 0
Code Activity

Add named error for conn busy

Browse Source
This commit is contained in:
Jack Christensen
2019-04-19 16:16:55 -05:00
parent 7bb6c2f3e9
commit 3710e52a9a
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pgconn.go
+5 -1
View File
@@ -84,6 +84,10 @@ type NotificationHandler func(*PgConn, *Notification)
// PostgreSQL server refuses to use TLS // PostgreSQL server refuses to use TLS
var ErrTLSRefused = errors.New("server refused TLS connection") var ErrTLSRefused = errors.New("server refused TLS connection")
// ErrConnBusy occurs when the connection is busy (for example, in the middle of reading query results) and another
// action is attempted.
var ErrConnBusy = errors.New("conn is busy")
// PgConn is a low-level PostgreSQL connection handle. It is not safe for concurrent usage. // PgConn is a low-level PostgreSQL connection handle. It is not safe for concurrent usage.
type PgConn struct { type PgConn struct {
conn net.Conn // the underlying TCP or unix domain socket connection conn net.Conn // the underlying TCP or unix domain socket connection
@@ -422,7 +426,7 @@ func (pgConn *PgConn) IsAlive() bool {
func (pgConn *PgConn) lock() error { func (pgConn *PgConn) lock() error {
switch pgConn.status { switch pgConn.status {
case connStatusBusy: case connStatusBusy:
return errors.New("connection busy") // This only should be possible in case of an application bug. return ErrConnBusy // This only should be possible in case of an application bug.
case connStatusClosed: case connStatusClosed:
return errors.New("conn closed") return errors.New("conn closed")
case connStatusUninitialized: case connStatusUninitialized: