Function connReconcileWorker

pkg/jobcontroller/jobcontroller.go:240–248

()

}

func connReconcileWorker() {
	defer func() {
		panichandler.PanicHandler("jobcontroller:connReconcileWorker", recover())
	}()

	for range connStates.reconcileCh {
		reconcileAllConns()
	}
}

func reconcileAllConns() {
	connStates.Lock()