- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for runEnv (0.12 sec)
-
src/cmd/go/internal/envcmd/env.go
} // Handle 'go env -w' and 'go env -u' before calling buildcfg.Check, // so they can be used to recover from an invalid configuration. if *envW { runEnvW(args) return } if *envU { runEnvU(args) return } buildcfg.Check() if cfg.ExperimentErr != nil { base.Fatal(cfg.ExperimentErr) } for _, arg := range args {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 17:13:51 UTC 2024 - 19.6K bytes - Viewed (0) -
src/cmd/dist/build.go
goCmd = append(goCmd, "-v") } // Force only one process at a time on vx32 emulation. if gohostos == "plan9" && os.Getenv("sysname") == "vx32" { goCmd = append(goCmd, "-p=1") } runEnv(workdir, ShowOutput|CheckExit, env, append(goCmd, args...)...) } func checkNotStale(env []string, goBinary string, targets ...string) { goCmd := []string{goBinary, "list"} if noOpt {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 18:34:40 UTC 2024 - 54K bytes - Viewed (0) -
pkg/test/framework/suite_test.go
g := NewWithT(t) var waitForRun1 sync.WaitGroup waitForRun1.Add(1) var waitForTestCompletion sync.WaitGroup waitForTestCompletion.Add(1) runFn1 := func(ctx *suiteContext) int { waitForRun1.Done() waitForTestCompletion.Wait() return 0 } runFn2 := func(ctx *suiteContext) int { return 0 } var waitForExit1Call sync.WaitGroup waitForExit1Call.Add(1) var errCode1 int
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/test/framework/integration/framework_test.go
subTest.Run(child.runInternal) } } } tst.runEnd = time.Now() } func (tst *test) timeRange() timeRange { return timeRange{ start: tst.runStart, end: tst.cleanupEnd, } } func (tst *test) doCheck() error { // Make sure the component was closed after the test's run method exited. if tst.componentCloseStart.Before(tst.runEnd) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 5.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
mu sync.RWMutex } // Run will start leader election, calling all runFns when we become the leader. // If leader election is disabled, it skips straight to the runFns. func (l *LeaderElection) Run(stop <-chan struct{}) { if !l.enabled { log.Infof("bypassing leader election: %v", l.electionID) for _, f := range l.runFns { go f(stop) } <-stop return } if l.defaultWatcher != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0) -
src/runtime/runtime_test.go
b.ReportMetric(float64(latencies[len(latencies)*99/100]), "p99-ns") } return func(b *testing.B) { b.Run("idle", runOne) b.Run("loaded", func(b *testing.B) { stop := applyGCLoad(b) runOne(b) // Make sure to stop the timer before we wait! The load created above // is very heavy-weight and not easy to stop, so we could end up
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 11.7K bytes - Viewed (0) -
src/testing/benchmark.go
// benchmark function that calls ReportAllocs. func (b *B) ReportAllocs() { b.showAllocResult = true } // runN runs a single benchmark for the specified number of iterations. func (b *B) runN(n int) { benchmarkLock.Lock() defer benchmarkLock.Unlock() defer func() { b.runCleanup(normalPanic) b.checkRaces() }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
}, retry.Timeout(time.Second)) } func TestLeaderElectionDisabled(t *testing.T) { client := fake.NewSimpleClientset() watcher := &fakeDefaultWatcher{} // Prevent LeaderElection from creating a lease, so that the runFn only runs // if leader election is disabled. client.Fake.PrependReactor("*", "*", func(action k8stesting.Action) (bool, runtime.Object, error) { return true, nil, fmt.Errorf("nope, out of luck") })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0)