Function reconcileAllConns

pkg/jobcontroller/jobcontroller.go:250–263

()

}

func reconcileAllConns() {
	connStates.Lock()
	defer connStates.Unlock()

	for connName, cs := range connStates.m {
		if cs.reconciling || cs.actual == cs.processed {
			continue
		}

		cs.reconciling = true
		actual := cs.actual
		go reconcileConn(connName, actual)
	}
}

func reconcileConn(connName string, targetState bool) {
	defer func() {