Lines Matching full:closing
45 // proceed w/o taking the lock. So closing, rg, rd, wg and wd are manipulated
51 closing bool
98 pd.closing = false
113 if !pd.closing {
117 throw("netpollClose: blocked write on closing descriptor")
120 throw("netpollClose: blocked read on closing descriptor")
172 // a pending async IO operation. Wait for ioready, ignore closing or timeouts.
180 if pd.closing {
250 if pd.closing {
251 throw("netpollUnblock: already closing")
253 pd.closing = true
256 atomicstorep(unsafe.Pointer(&rg), nil) // full memory barrier between store to closing and read of rg/wg in netpollunblock
298 if pd.closing {
336 // do the opposite: store to closing/rd/wd, membarrier, load of rg/wg