- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,800 for startm (0.12 sec)
-
pkg/kubelet/runtimeclass/testing/fake_manager.go
) } // StartManagerSync starts the manager, and waits for the informer cache to sync. // Returns a function to stop the manager, which should be called with a defer: // // defer StartManagerSync(t, m)() func StartManagerSync(m *runtimeclass.Manager) func() { stopCh := make(chan struct{}) m.Start(stopCh) m.WaitForCacheSync(stopCh) return func() { close(stopCh) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/logging/comparison/DiffUtils.java
break; } // Calculate the start line index of the current block in fullDiff start = max(0, next - contextSize); // Record the start line number in original and revised file of the current block startLineOrigin = lineNumOrigin - (next - start - 1); startLineRevised = lineNumRevised - (next - start - 1);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 9.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
} // Run starts the controller and blocks until context is killed. func (c *DynamicCertKeyPairContent) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.InfoS("Starting controller", "name", c.name) defer klog.InfoS("Shutting down controller", "name", c.name) // doesn't matter what workers say, only start one.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/ServeDocs.java
import org.gradle.work.DisableCachingByDefault; import javax.inject.Inject; import java.util.Arrays; /** * Serves the given directory with a simple HTTP server. */ @DisableCachingByDefault(because = "This task starts a HTTP server and should not be cached.") public abstract class ServeDocs extends DefaultTask { @InputFiles @PathSensitive(PathSensitivity.RELATIVE) protected abstract DirectoryProperty getDocsDirectory();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 12:38:47 UTC 2024 - 2.9K bytes - Viewed (0) -
src/go/doc/testdata/benchmark.go
benchmark InternalBenchmark bytes int64 timerOn bool result BenchmarkResult } // StartTimer starts timing a test. This function is called automatically // before a benchmark starts, but it can also used to resume timing after // a call to StopTimer. func (b *B) StartTimer() { if !b.timerOn { b.start = time.Now() b.timerOn = true } } // StopTimer stops timing a test. This can be used to pause the timer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 7.4K bytes - Viewed (0) -
pkg/envoy/agent_test.go
ctx, cancel := context.WithCancel(context.Background()) start := func(_ <-chan error) error { return nil } cleanup := func() { cancel() } a := NewAgent(TestProxy{run: start, cleanup: cleanup}, 0, 0, "", 0, 0, 0, true) go func() { a.Run(ctx) }() <-ctx.Done() } func TestActiveConnections(t *testing.T) { cases := []struct { name string stats string expected int }{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 19 20:22:09 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_windows.go
cm.capacity[rName] = rCap } } ctx := context.Background() containerMap, containerRunningSet := buildContainerMapAndRunningSetFromRuntime(ctx, runtimeService) // Starts device manager. if err := cm.deviceManager.Start(devicemanager.ActivePodsFunc(activePods), sourcesReady, containerMap, containerRunningSet); err != nil { return err } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 11:25:36 UTC 2023 - 8.7K bytes - Viewed (0) -
src/net/sendfile_unix_alt.go
} if remain == 0 { fi, err := f.Stat() if err != nil { return 0, err, false } remain = fi.Size() } // The other quirk with Darwin/FreeBSD/DragonFly/Solaris's sendfile // implementation is that it doesn't use the current position // of the file -- if you pass it offset 0, it starts from // offset 0. There's no way to tell it "start from current
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 2.3K bytes - Viewed (0) -
src/net/http/pprof/pprof_test.go
runtime.Gosched() } } } // mutexHog starts multiple goroutines that runs the given hogger function for the specified duration. // The hogger function will be given two mutexes to lock & unlock. func mutexHog(duration time.Duration, hogger func(mu1, mu2 *sync.Mutex, start time.Time, dt time.Duration)) { start := time.Now() mu1 := new(sync.Mutex) mu2 := new(sync.Mutex) var wg sync.WaitGroup
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 07 19:52:28 UTC 2023 - 9.7K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/process/JavaDebugOptions.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 16 14:16:38 UTC 2022 - 2.6K bytes - Viewed (0)