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

		if rec := recover(); rec != nil {
			gridLogIf(ctx, fmt.Errorf("handleMessages: panic recovered: %v", rec))
			debug.PrintStack()
		}
		cancel(ErrDisconnected)
		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