mirror of https://github.com/jackc/pgx.git
Small improvements
parent
8b5e8d9d89
commit
a83faa67f5
|
@ -97,7 +97,7 @@ type NetConn struct {
|
||||||
writeDeadlineLock sync.Mutex
|
writeDeadlineLock sync.Mutex
|
||||||
writeDeadline time.Time
|
writeDeadline time.Time
|
||||||
|
|
||||||
// Indicates that underlying socket connection mode set to be non-blocking
|
// Indicates that underlying socket connection mode explicitly set to be non-blocking
|
||||||
isNonBlocking bool
|
isNonBlocking bool
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -164,9 +164,11 @@ func (c *NetConn) SetBlockingMode(blocking bool) error {
|
||||||
|
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
c.rawConn.Control(func(fd uintptr) {
|
if ctrlErr := c.rawConn.Control(func(fd uintptr) {
|
||||||
err = setSockMode(fd, mode)
|
err = setSockMode(fd, mode)
|
||||||
})
|
}); ctrlErr != nil {
|
||||||
|
return ctrlErr
|
||||||
|
}
|
||||||
|
|
||||||
if err == nil {
|
if err == nil {
|
||||||
c.isNonBlocking = !blocking
|
c.isNonBlocking = !blocking
|
||||||
|
|
Loading…
Reference in New Issue