- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,366 for runOne (0.11 sec)
-
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) -
cmd/kubeadm/app/cmd/phases/workflow/runner.go
// path of the phase in the workflow managed by the Runner. generatedName string // use is the phase usage string that will be printed in the workflow help. // It corresponds to the relative path of the phase in the workflow managed by the Runner. use string } // NewRunner return a new runner for composable kubeadm workflows. func NewRunner() *Runner { return &Runner{ Phases: []Phase{}, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 21 05:35:15 UTC 2022 - 16K bytes - Viewed (0) -
pkg/util/async/runner.go
func NewRunner(f ...func(stop chan struct{})) *Runner { return &Runner{loopFuncs: f} } // Start begins running. func (r *Runner) Start() { r.lock.Lock() defer r.lock.Unlock() if r.stop == nil { c := make(chan struct{}) r.stop = &c for i := range r.loopFuncs { go r.loopFuncs[i](*r.stop) } } } // Stop stops running. func (r *Runner) Stop() { r.lock.Lock() defer r.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 06:37:00 UTC 2016 - 1.4K bytes - Viewed (0) -
pkg/kubelet/runonce.go
result, err := kl.runOnce(ctx, u.Pods, runOnceRetryDelay) klog.InfoS("Finished processing pods", "numPods", len(u.Pods)) return result, err case <-time.After(runOnceManifestDelay): return nil, fmt.Errorf("no pod manifest update after %v", runOnceManifestDelay) } } // runOnce runs a given set of pods and returns their status.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
test/rune.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Test rune constants, expressions and types. // Compiles but does not run. package rune var ( r0 = 'a' r1 = 'a'+1 r2 = 1+'a' r3 = 'a'*2 r4 = 'a'/2 r5 = 'a'<<1 r6 = 'b'<<2 r7 int32 r = []rune{r0, r1, r2, r3, r4, r5, r6, r7} ) var ( f0 = 1.2 f1 = 1.2/'a' f = []float64{f0, f1}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 603 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) -
testing/smoke-test/src/smokeTest/groovy/org/gradle/smoketests/BNDSmokeTest.groovy
} """ file(pathToBndrun) << """ -runfw: org.eclipse.osgi -runee: JavaSE-17 -runbundles: bnd-smoke-test -runproperties: -runtrace: true """ file(pathToBndbnd) << """ -sources: true Bundle-Activator: com.example.Activator """ expect: def result = runner(":run") .forwardOutput() .build()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 11.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
final AtomicInteger numCalls = new AtomicInteger(); Runnable runMe = new Runnable() { @Override public void run() { numCalls.incrementAndGet(); throw new RuntimeException("FAKE EXCEPTION!"); } }; e.execute(runMe); e.execute(runMe); fakePool.runAll(); assertEquals(2, numCalls.get()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.4K bytes - Viewed (0) -
src/cmd/cgo/internal/testcshared/cshared_test.go
ldLibPath += ":" } ldLibPath += tmpdir runenv := []string{"LD_LIBRARY_PATH=" + ldLibPath} bin := filepath.Join(tmpdir, "m1") + exeSuffix run(t, goenv, "go", "build", "-o", bin, "./go2c2go/m1") runExe(t, runenv, bin) bin = filepath.Join(tmpdir, "m2") + exeSuffix run(t, goenv, "go", "build", "-o", bin, "./go2c2go/m2") runExe(t, runenv, bin) } func TestIssue36233(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 14 13:19:50 UTC 2023 - 21K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
delayNanos: Long = 0L, block: () -> Long, ) { schedule( object : Task(name) { override fun runOnce(): Long { return block() } }, delayNanos, ) } /** * Executes [block] once on a task runner thread. * * TODO: make this inline once this is fixed: https://github.com/oracle/graal/issues/3466 */ fun execute(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0)