}
		n.SetFrameOffset(-s.stksize)
		if mls != nil && mls.IsLeader(n) {
			leaders[n] = -s.stksize
		}
	}

	if mls != nil {
		// Update offsets of followers (subsumed vars) to be the
		// same as the leader var in their partition.
		for i := 0; i < len(fn.Dcl); i++ {
			n := fn.Dcl[i]
			if !mls.Subsumed(n) {
				continue
			}
			leader := mls.Leader(n)
			off, ok := leaders[leader]
			if !ok {

	for k, testcase := range testcases {
		mls, err := liveness.MakeMergeLocalsState(testcase.partition, testcase.vars)
		t.Logf("tc %d err is %v\n", k, err)
		if testcase.experr && err == nil {
			t.Fatalf("tc:%d missing error mls %v", k, mls)
		} else if !testcase.experr && err != nil {
			t.Fatalf("tc:%d unexpected error mls %v", k, err)
		}
		if mls != nil {
			t.Logf("tc %d: mls: %v\n", k, mls.String())
		}
	}
}

	// 2. Workload by IP
	if wls := a.workloads.ByAddress.Lookup(networkAddr); len(wls) > 0 {
		// If there is just one, return it
		if len(wls) == 1 {
			return []model.AddressInfo{modelWorkloadToAddressInfo(wls[0])}
		}
		// Otherwise, try to find a pod - pods have precedence
		pod := slices.FindFunc(wls, func(info model.WorkloadInfo) bool {
			return info.Source == kind.Pod
		})

## Develop and verify

After you make a change, you can run `mvn clean teamcity-configs:generate` to generate and verify the generated TeamCity configuration XMLs.

You also need to run `mvn clean verify` with Java 8 before committing changes.

If you have ktlint errors, you can automatically fix them by running `mvn com.github.gantsign.maven:ktlint-maven-plugin:1.1.1:format`.

		return false
	}, retry.Timeout(5*time.Minute), retry.Delay(1*time.Second))
	return lastUpdateTime
}

func getPodID(i echo.Instance) (string, error) {
	wls, err := i.Workloads()
	if err != nil {
		return "", nil
	}

	for _, wl := range wls {
		return wl.PodName(), nil
	}

	return "", fmt.Errorf("no workloads")

	// 2. IP dispatch listener, handling both VIPs and direct pod IPs.
	// 3. Encapsulation CONNECT listener, originating the tunnel
	wls, wps := findWaypointResources(lb.node, lb.push)

	listeners = append(listeners,
		lb.buildWaypointInboundConnectTerminate(),
		lb.buildWaypointInternal(wls, wps.orderedServices),
		buildWaypointConnectOriginateListener())

	return listeners
}

				}
				return nil
			}, retry.Timeout(time.Second*20))
		})
}

func getPodID(i echo.Instance) (string, error) {
	wls, err := i.Workloads()
	if err != nil {
		return "", nil
	}

	for _, wl := range wls {
		return wl.PodName(), nil
	}

	return "", fmt.Errorf("no workloads")
}

func TestProxyConfig(t *testing.T) {
	// nolint: staticcheck

	assertOrderedWaypoint := func(t *testing.T, network, address string, expected ...string) {
		t.Helper()
		wls := s.WorkloadsForWaypoint(model.WaypointKey{
			Network:   network,
			Addresses: []string{address},
		})
		wl := make([]string, len(wls))
		for i, e := range wls {
			wl[i] = e.ResourceName()
		}
		assert.Equal(t, wl, expected)
	}

(CMOV(QEQ|QLE|QGE|QCC|QLS|LEQ|LLE|LGE|LCC|LLS|WEQ|WLE|WGE|WCC|WLS) _ x (FlagEQ)) => x
(CMOV(QNE|QLT|QGT|QCS|QHI|LNE|LLT|LGT|LCS|LHI|WNE|WLT|WGT|WCS|WHI) y _ (FlagEQ)) => y
(CMOV(QNE|QGT|QGE|QHI|QCC|LNE|LGT|LGE|LHI|LCC|WNE|WGT|WGE|WHI|WCC) _ x (FlagGT_UGT)) => x
(CMOV(QEQ|QLE|QLT|QLS|QCS|LEQ|LLE|LLT|LLS|LCS|WEQ|WLE|WLT|WLS|WCS) y _ (FlagGT_UGT)) => y
(CMOV(QNE|QGT|QGE|QLS|QCS|LNE|LGT|LGE|LLS|LCS|WNE|WGT|WGE|WLS|WCS) _ x (FlagGT_ULT)) => x

tiTkmòosŒiVtJy_@~Çå|G\m†`ñZ¾o{{Vû ?¾ZïKHòinOœ¢{jã:UDyy[ÚóbDˆCväêåk}Dym|<rGRý¨GwÈohWKnMªLB¼"iI²,% Œ; „vDoFûHewŠA{qmýGzã R¾Ùîñþ,ÏutSQTá>ï|¾N]n|çlM®‰sj…—†Yp¤~iÄ»two\Edtv}Ö~EE~m¬¸û|w\OF îo¾ ïhN ilñL¥zqK/t¢Sxst·ttcˆ¯ b_2ú m þ WlONl]FeIˆïTryrYT÷ETNIº W_c¢v`G eZ› „ Wls~`mDIÕ BsD}^yL5¤ÌFNLG ³¹si@xÃæÀ{[÷·ugòS{—YÐGFiÜy\‘~jC|»kKÕvID­8 + èepéì^˜»¹† ixÄãynï\º x]Ti|ôMV ëvÜø5]ï¾Xle¦BñpPow]xM a[eoKò~IˆBñúDC þãÆ_xOxHÿô l}¼?ûp›?ªQïR~qx†iq GŠym`@mûlsÖšÎÔµL}TDãnst ² qò3 í ~rOâË>ÁòÁ<ÆóõÀ áíÛüÏÐ hm^ w}XôY¼ìAHGdñxgeòx¾}Zì¦KPk~CKNyiT....