- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,237 for startingAt (0.21 sec)
-
src/cmd/covdata/covdata.go
flag.Usage = func() { op.Usage("") } flag.Parse() telemetry.Inc("covdata/invocations") telemetry.CountFlags("covdata/flag:", *flag.CommandLine) // Mode-independent flag setup dbgtrace(1, "starting mode-independent setup") if flag.NArg() != 0 { op.Usage("unknown extra arguments") } if *pkgpatflag != "" { pats := strings.Split(*pkgpatflag, ",") matchers := []func(name string) bool{}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 5.7K bytes - Viewed (0) -
hack/make-rules/test-cmd.sh
# # Exports: # APISERVER_PID function run_kube_apiserver() { kube::log::status "Building kube-apiserver" make -C "${KUBE_ROOT}" WHAT="cmd/kube-apiserver" # Start kube-apiserver kube::log::status "Starting kube-apiserver" # Admission Controllers to invoke prior to persisting objects in cluster ENABLE_ADMISSION_PLUGINS="LimitRanger,ResourceQuota"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 09:10:14 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/ActionExecutionWorker.java
public ActionExecutionWorker(Action<? super WorkerProcessContext> action) { this.action = action; } @Override public void execute(final WorkerProcessContext workerContext) { LOGGER.debug("Starting {}.", workerContext.getDisplayName()); ObjectConnection clientConnection = workerContext.getServerConnection(); clientConnection.addUnrecoverableErrorHandler(new Action<Throwable>() { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 2.4K bytes - Viewed (0) -
src/os/pidfd_linux_test.go
// Non-pidfd code paths tested in exec_unix_test.go. t.Skipf("skipping: pidfd not available: %v", err) } p, err := os.StartProcess(testenv.GoToolPath(t), []string{"go"}, &os.ProcAttr{}) if err != nil { t.Fatalf("starting test process: %v", err) } p.Wait() // Use pid of a non-existing process. proc, err := os.FindProcess(p.Pid) // FindProcess should never return errors on Unix. if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/BuildOperationListener.java
* Implementations must take care to be threadsafe. * * Related signals are guaranteed to be serialized. * That is, a listener will not concurrently be notified of the same operation starting and finishing. * * @since 3.5 */ @EventScope(Global.class) public interface BuildOperationListener { void started(BuildOperationDescriptor buildOperation, OperationStartEvent startEvent);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.6K bytes - Viewed (0) -
src/internal/types/testdata/fixedbugs/issue50426.go
g[[]float64](s, 0) } // Keep using constraint type inference after function // type inference for untyped arguments so we infer // missing type arguments for which we only have the // untyped arguments as starting point. func h[E any, R []E](v E) R { return R{v} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 1.1K bytes - Viewed (0) -
docs/en/docs/deployment/concepts.md
## Previous Steps Before Starting There are many cases where you want to perform some steps **before starting** your application. For example, you might want to run **database migrations**. But in most cases, you will want to perform these steps only **once**. So, you will want to have a **single process** to perform those **previous steps**, before starting the application.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 02 22:37:31 UTC 2024 - 18K bytes - Viewed (0) -
pkg/util/async/runner_test.go
funcs []func(chan struct{}) ) done := make(chan struct{}, 20) for i := 0; i < 10; i++ { iCopy := i funcs = append(funcs, func(c chan struct{}) { lock.Lock() events = append(events, fmt.Sprintf("%v starting\n", iCopy)) lock.Unlock() <-c lock.Lock() events = append(events, fmt.Sprintf("%v stopping\n", iCopy)) lock.Unlock() done <- struct{}{} }) } r := NewRunner(funcs...) r.Start()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 06:37:00 UTC 2016 - 1.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
// basically lazy loading the informer, if we stop it when we lose the lock we will never // recreate it again. s.kubeClient.RunAndWait(stop) log.Infof("Starting ingress controller") ingressSyncer.Run(leaderStop) }). Run(stop) return nil }) } // Wrap the config controller with a cache.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
logger.V(1).Info("Starting controller", "controller", controllerName) initFunc := controllerDescriptor.GetInitFunc() ctrl, started, err := initFunc(klog.NewContext(ctx, klog.LoggerWithName(logger, controllerName)), controllerCtx, controllerName) if err != nil { logger.Error(err, "Error starting controller", "controller", controllerName) return nil, err } if !started {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0)