Method maybeCloseLocked

broker.go:384–392

maybeCloseLocked closes on transport errors and reports whether a close was performed. NOTE: caller must hold b.lock.

(err error)

// maybeCloseLocked closes on transport errors and reports whether a close was performed.
// NOTE: caller must hold b.lock.
func (b *Broker) maybeCloseLocked(err error) bool {
	if !shouldCloseBrokerConn(err) {
		return false
	}

	b.connErr = err
	_ = b.closeLocked()
	return true
}

// closeLocked closes the broker connection and resets state.
// NOTE: caller must hold b.lock.