if gotState == StateShutdown || State(gotState) == s {
		return
	}
	if s == StateConnected {
		atomic.StoreInt64(&c.LastPong, time.Now().UnixNano())
	}
	atomic.StoreUint32((*uint32)(&c.state), uint32(s))
	if debugPrint {
		fmt.Println(c.Local, "updateState:", gotState, "->", s)
	}
	c.connChange.Broadcast()
}

	default:
	}
}

// Do not accept new MRF operations anymore and start to save
// the current heal status in one available disk
func (m *mrfState) shutdown() {
	atomic.StoreInt32(&m.closing, 1)
	m.wg.Wait()
	close(m.opCh)
	atomic.StoreInt32(&m.closed, 1)

	if len(m.opCh) > 0 {
		healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh))
	}

	newReader := func() io.ReadCloser {

			n, err := rr.ReadAt(p.buf[bufIdx], p.offset)
			if err != nil {
				switch {
				case errors.Is(err, errFileNotFound):
					atomic.StoreInt32(&missingPartsHeal, 1)
				case errors.Is(err, errFileCorrupt):
					atomic.StoreInt32(&bitrotHeal, 1)
				case errors.Is(err, errDiskNotFound):
					atomic.AddInt32(&disksNotFound, 1)
				}

				// This will be communicated upstream.

pkg sync/atomic, func LoadUint64(*uint64) uint64
pkg sync/atomic, func LoadUintptr(*uintptr) uintptr
pkg sync/atomic, func StoreInt32(*int32, int32)
pkg sync/atomic, func StoreInt64(*int64, int64)
pkg sync/atomic, func StorePointer(*unsafe.Pointer, unsafe.Pointer)
pkg sync/atomic, func StoreUint32(*uint32, uint32)
pkg sync/atomic, func StoreUint64(*uint64, uint64)
pkg sync/atomic, func StoreUintptr(*uintptr, uintptr)