Method setState

db/active_replicator_common.go:430–437

setState updates replicator state and resets lastError to nil. Expects callers to be holding activeReplicatorCommon.lock

(state string)

// setState updates replicator state and resets lastError to nil.  Expects callers
// to be holding activeReplicatorCommon.lock
func (arc *activeReplicatorCommon) setState(state string) {
	arc.stateErrorLock.Lock()
	arc.state = state
	if state == ReplicationStateRunning {
		arc.lastError = nil
	}
	arc.stateErrorLock.Unlock()
}

func (arc *activeReplicatorCommon) getState() string {
	arc.stateErrorLock.RLock()