mirror of https://github.com/jackc/pgx.git
Failing to write to Conn.conn kills Conn
parent
ae6a87545b
commit
713a8f48a7
6
conn.go
6
conn.go
|
@ -722,6 +722,9 @@ func (c *Conn) sendSimpleQuery(sql string, arguments ...interface{}) (err error)
|
||||||
wbuf.closeMsg()
|
wbuf.closeMsg()
|
||||||
|
|
||||||
_, err = c.conn.Write(wbuf.buf)
|
_, err = c.conn.Write(wbuf.buf)
|
||||||
|
if err != nil {
|
||||||
|
c.die(err)
|
||||||
|
}
|
||||||
|
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@ -821,6 +824,9 @@ func (c *Conn) sendPreparedQuery(ps *PreparedStatement, arguments ...interface{}
|
||||||
wbuf.closeMsg()
|
wbuf.closeMsg()
|
||||||
|
|
||||||
_, err = c.conn.Write(wbuf.buf)
|
_, err = c.conn.Write(wbuf.buf)
|
||||||
|
if err != nil {
|
||||||
|
c.die(err)
|
||||||
|
}
|
||||||
|
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue