mirror of https://github.com/jackc/pgx.git
Small comment update 2
parent
1298a835bc
commit
c3d62c8783
|
@ -132,7 +132,7 @@ func (c *NetConn) SetBlockingMode(blocking bool) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if blocking {
|
if blocking {
|
||||||
// No ready to exit from non-blocking mode, there are pending non-blocking operations
|
// Not ready to exit from non-blocking mode, there are pending non-blocking operations
|
||||||
if atomic.AddInt32(&c.nbOperCnt, -1) > 0 {
|
if atomic.AddInt32(&c.nbOperCnt, -1) > 0 {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -141,8 +141,6 @@ func (c *NetConn) SetBlockingMode(blocking bool) error {
|
||||||
if atomic.AddInt32(&c.nbOperCnt, 1) > 1 {
|
if atomic.AddInt32(&c.nbOperCnt, 1) > 1 {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
//fmt.Println("socket reverting to blocking mode")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
mode := sockModeNonBlocking
|
mode := sockModeNonBlocking
|
||||||
|
|
Loading…
Reference in New Issue