return 0, io.EOF
	}
	n, err = s.r.Read(p)
	if atomic.LoadUint32(&s.closed) == 1 {
		return 0, io.EOF
	}
	return n, err
}

func (s *safeCloser) Close() error {
	atomic.CompareAndSwapUint32(&s.closed, 0, 1)
	return nil

		defer func() {
			if rec := recover(); rec != nil {
				gridLogIf(ctx, fmt.Errorf("handleMessages: panic recovered: %v", rec))
				debug.PrintStack()
			}
			c.connChange.L.Lock()
			if atomic.CompareAndSwapUint32((*uint32)(&c.state), StateConnected, StateConnectionError) {
				c.connChange.Broadcast()
			}
			c.connChange.L.Unlock()
			conn.Close()
			c.handleMsgWg.Done()
		}()

pkg sync/atomic, func CompareAndSwapInt64(*int64, int64, int64) bool
pkg sync/atomic, func CompareAndSwapPointer(*unsafe.Pointer, unsafe.Pointer, unsafe.Pointer) bool
pkg sync/atomic, func CompareAndSwapUint32(*uint32, uint32, uint32) bool
pkg sync/atomic, func CompareAndSwapUint64(*uint64, uint64, uint64) bool
pkg sync/atomic, func CompareAndSwapUintptr(*uintptr, uintptr, uintptr) bool