Function reconcileConn

pkg/jobcontroller/jobcontroller.go:265–287

(connName string, targetState bool)

}

func reconcileConn(connName string, targetState bool) {
	defer func() {
		panichandler.PanicHandler("jobcontroller:reconcileConn", recover())
	}()

	if targetState {
		onConnectionUp(connName)
	} else {
		onConnectionDown(connName)
	}

	connStates.Lock()
	defer connStates.Unlock()
	if cs, exists := connStates.m[connName]; exists {
		cs.processed = targetState
		cs.reconciling = false
	}

	select {
	case connStates.reconcileCh <- struct{}{}:
	default:
	}
}

func getMetaInt64(meta wshrpc.FileMeta, key string) int64 {
	val, ok := meta[key]