mirror of https://github.com/jackc/pgx.git
parent
c7733fe52e
commit
32c7858e61
|
@ -96,6 +96,11 @@ type NetConn struct {
|
||||||
|
|
||||||
writeDeadlineLock sync.Mutex
|
writeDeadlineLock sync.Mutex
|
||||||
writeDeadline time.Time
|
writeDeadline time.Time
|
||||||
|
|
||||||
|
// nbOperCnt Tracks how many operations performing simultaneously
|
||||||
|
nbOperCnt int
|
||||||
|
// nbOperMu Used to prevent concurrent SetBlockingMode calls
|
||||||
|
nbOperMu sync.Mutex
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewNetConn(conn net.Conn, fakeNonBlockingIO bool) *NetConn {
|
func NewNetConn(conn net.Conn, fakeNonBlockingIO bool) *NetConn {
|
||||||
|
|
Loading…
Reference in New Issue