- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 4,025 for startm (0.3 sec)
-
pkg/kubelet/pluginmanager/operationexecutor/operation_executor_test.go
socketPath := fmt.Sprintf("%s/plugin-%d.sock", socketDir, i) oe.RegisterPlugin(socketPath, time.Now(), nil /* plugin handlers */, nil /* actual state of the world updator */) } if !isOperationRunConcurrently(ch, quit, numPluginsToRegister) { t.Fatalf("Unable to start register operations in Concurrent for plugins") } } func TestOperationExecutor_RegisterPlugin_SerialRegisterPlugin(t *testing.T) { ch, quit, oe := setup()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 4.8K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_server.go
return &EtcdMigrateServer{cfg: cfg, client: client} } // Start starts an etcd server as a separate process, waits until it has started, and returns a exec.Cmd. // TODO: Add support for listening to client via TLS. func (r *EtcdMigrateServer) Start(version *EtcdVersion) error { etcdCmd := exec.Command( fmt.Sprintf("%s/etcd-%s", r.cfg.binPath, version), "--name", r.cfg.name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
src/cmd/compile/internal/base/timings.go
} func (t *Timings) append(labels []string, start bool) { t.list = append(t.list, timestamp{time.Now(), strings.Join(labels, ":"), start}) } // Start marks the beginning of a new phase and implicitly stops the previous phase. // The phase name is the colon-separated concatenation of the labels. func (t *Timings) Start(labels ...string) { t.append(labels, true) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 5.8K bytes - Viewed (0) -
releasenotes/notes/alt-stat-name.yaml
Rama Chavali <******@****.***> 1716199771 +0530
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 20 10:09:31 UTC 2024 - 184 bytes - Viewed (0) -
pkg/controller/cronjob/utils.go
// // However, if there is a bug somewhere, or incorrect clock // on controller's server or apiservers (for setting creationTimestamp) // then there could be so many missed start times (it could be off // by decades or more), that it would eat up all the CPU and memory // of this controller. In that case, we want to not try to list // all the missed start times. // // I've somewhat arbitrarily picked 100, as more than 80,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 10.7K bytes - Viewed (0) -
platforms/enterprise/enterprise-logging/src/main/java/org/gradle/internal/logging/progress/ProgressLogger.java
*/ ProgressLogger start(String description, String status); /** * Logs the start of the operation, with no initial status. */ void started(); /** * Logs the start of the operation, with the given status. * * @param status The initial status message. Can be null or empty. */ void started(String status); /** * Logs some progress, indicated by a new status.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jul 17 10:17:11 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/kube/kclient/interfaces.go
// to the underlying informer are not touched ShutdownHandlers() // Start starts just this informer. Typically, this is not used. Instead, the `kube.Client.Run()` is // used to start all informers at once. // However, in some cases we need to run individual informers directly. // This function should only be called once. It does not wait for the informer to become ready nor does it block,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:09:57 UTC 2024 - 3.4K bytes - Viewed (0) -
pkg/kube/kclient/delayed.go
(*c).Start(stop) } s.hm.Lock() defer s.hm.Unlock() s.started = stop } var _ Informer[controllers.Object] = &delayedClient[controllers.Object]{} func (s *delayedClient[T]) set(inf Informer[T]) { if inf != nil { s.inf.Swap(&inf) s.hm.Lock() defer s.hm.Unlock() for _, h := range s.handlers { inf.AddEventHandler(h) } s.handlers = nil if s.started != nil { inf.Start(s.started)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 31 02:32:59 UTC 2023 - 3.5K bytes - Viewed (0) -
src/internal/trace/event/go122/event.go
EvGoCreateBlocked // goroutine creation (starts blocked) [timestamp, new goroutine ID, new stack ID, stack ID] // GoStatus with stack. Added in Go 1.23. EvGoStatusStack // goroutine status at the start of a generation, with a stack [timestamp, goroutine ID, M ID, status, stack ID] // Batch event for an experimental batch with a custom format. Added in Go 1.23.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 14.8K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/BuildStatusRenderer.java
// Once the root build starts configuring, we are in Configuring phase phaseStarted(startEvent, Phase.Configuring); } else if (startEvent.getBuildOperationCategory() == BuildOperationCategory.CONFIGURE_BUILD && currentPhase == Phase.Configuring) { // Any configuring event received from nested or buildSrc builds before the root build starts configuring is ignored
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 7.6K bytes - Viewed (0)