goGetAndExpect(t, clock, counter, wr, gots, aval)
}

func goGetExpectNotYet(t *testing.T, clk *testeventclock.Fake, grc counter.GoRoutineCounter, wr promise.WriteOnce, gots chan interface{}, trigger string) {
	grc.Add(1) // count the following goroutine
	go func() {
		defer grc.Add(-1) // count completion of this goroutine
		gots <- wr.Get()
	}()
	clk.Run(nil)
	select {
	case <-gots:

	grc := &waitGroupCounter{}

	if r == nil {
		r = rand.New(rand.NewSource(time.Now().UnixNano()))
		r.Uint64()
		r.Uint64()
		r.Uint64()
	}
	return &Fake{
		FakePassiveClock: *baseclocktest.NewFakePassiveClock(t),
		clientWG:         grc,
		fuzz:             fuzz,
		rand:             r,
	}, grc
}

)

// setOp parses the operation string (first argument).
func setOp(arg string) {
	// Recognize 'go tool pack grc' because that was the
	// formerly canonical way to build a new archive
	// from a set of input files. Accepting it keeps old
	// build systems working with both Go 1.2 and Go 1.3.
	if arg == "grc" {
		arg = "c"
	}

	for _, r := range arg {
		switch r {
		case 'c', 'p', 'r', 't', 'x':
			if op != 0 {

	testenv.WriteImportcfg(t, importcfgfile, nil, hello)

	goBin := testenv.GoToolPath(t)
	run(goBin, "tool", "compile", "-importcfg="+importcfgfile, "-p=main", "hello.go")
	run(packPath(t), "grc", "hello.a", "hello.o")
	run(goBin, "tool", "link", "-importcfg="+importcfgfile, "-o", "a.out", "hello.a")
	out := run("./a.out")
	if out != "hello world\n" {
		t.Fatalf("incorrect output: %q, want %q", out, "hello world\n")

			Addresses: []k8sv1.GatewayStatusAddress{
				{
					Type:  &addrType,
					Value: ip,
				},
			},
		}
	}
	s.grc.CreateOrUpdate(&gateway)
}

func (s *ambientTestServer) deleteWaypoint(t *testing.T, name string) {
	t.Helper()
	s.grc.Delete(name, testNS)
}

func (s *ambientTestServer) addPods(t *testing.T, ip string, name, sa string, labels map[string]string,

	executions, rejects                                                                    []int32
}

func (uss *uniformScenarioState) exercise() {
	uss.t.Logf("%s: Start %s, doSplit=%v, clk=%p, grc=%p", uss.startTime.Format(nsTimeFmt), uss.name, uss.doSplit, uss.clk, uss.counter)
	if uss.evalInqueueMetrics || uss.evalExecutingMetrics {
		metrics.Reset()
	}
	for i, uc := range uss.clients {

qmAqw1YDHuAQyhXR7gUCYiljvgIbAgUJC0c1AACBCRADHuAQyhXR7nYgBBkWCgAd
FiEEymLtEw5AU5REBt9kAYG0XqWGd7wFAmIpY74ACgkQAYG0XqWGd7ybZwD9GwWy
JHsZQyq03sk1t2ofildktfzowN1r7WWWHTnp4E4BAOxcRkMUwhKS+2p4OrRH99+W
8lO9M/grc+FW2qMgkFINAIYA/0i3vicrcWiGMPlVe1rxo/VM6BBV6qOsAHbvp2BE
HMPnAQDYBQo0KYBhEAiBCI2Pza5JWZzM15RymdQG/OSk7lgkBA==
=3N8W
-----END PGP PUBLIC KEY BLOCK-----

pub    0374CF2E8DD1BDFD