- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 4,772 for startm (0.16 sec)
-
pkg/controller/nodeipam/node_ipam_controller.go
ic.nodeLister = nodeInformer.Lister() ic.nodeInformerSynced = nodeInformer.Informer().HasSynced return ic, nil } // Run starts an asynchronous loop that monitors the status of cluster nodes. func (nc *Controller) Run(ctx context.Context) { defer utilruntime.HandleCrash() // Start event processing pipeline. nc.eventBroadcaster.StartStructuredLogging(3)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
assertThat(manager.servicesByState().keySet()).containsExactly(Service.State.FAILED); } private static void assertState( ServiceManager manager, Service.State state, Service... services) { Collection<Service> managerServices = manager.servicesByState().get(state); for (Service service : services) { assertEquals(service.toString(), state, service.state());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
} } // run is running in the background. It handles blocking initialization (like // syncing the informer) and then syncs the actual with the desired state. func (c *nodeResourcesController) run(ctx context.Context) { logger := klog.FromContext(ctx) // When kubelet starts, we have two choices: // - Sync immediately, which in practice will delete all ResourceSlices
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
cni/pkg/log/uds.go
} l.loggingServer = loggingServer pluginLog.SetOutputLevel(level) return l } // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin. func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error { if sockAddress == "" { return nil } log.Info("Start a UDS server for CNI plugin logs") unixListener, err := uds.NewListener(sockAddress) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} } private void checkAndUpdateState(State oldState, State newState) { checkState( compareAndUpdateState(oldState, newState), "Expected state to be %s, but it was %s", oldState, newState); } private boolean compareAndUpdateState(State oldState, State newState) { return state.compareAndSet(oldState, newState); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
func (m *kubeletServerCertificateDynamicFileManager) Current() *tls.Certificate { return m.currentTLSCertificate.Load() } // Start starts watching the certificate and key files func (m *kubeletServerCertificateDynamicFileManager) Start() { var ctx context.Context ctx, m.cancelFn = context.WithCancel(context.Background()) go m.dynamicCertificateContent.Run(ctx, 1) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
containerStates := make(map[kubecontainer.State]bool) for state := range oldContainerStateCount { containerStates[state] = true } for state := range currentContainerStateCount { containerStates[state] = true } // update the metric via difference of old and current counts for state := range containerStates { diff := currentContainerStateCount[state] - oldContainerStateCount[state]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
cmd/consolelogger.go
if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/api/apps/v1beta2/types_swagger_doc_generated.go
"start": "start is the number representing the first replica's index. It may be used to number replicas from an alternate index (eg: 1-indexed) over the default 0-indexed names, or to orchestrate progressive movement of replicas from one StatefulSet to another. If set, replica indices will be in the range:\n [.spec.ordinals.start, .spec.ordinals.start + .spec.replicas).\nIf unset, defaults to 0. Replica indices will be in the...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 05:34:30 UTC 2023 - 34.3K bytes - Viewed (0) -
src/runtime/mpagealloc.go
p.summaryMappedReady += p.scav.index.grow(base, limit, p.sysStat) // Update p.start and p.end. // If no growth happened yet, start == 0. This is generally // safe since the zero page is unmapped. firstGrowth := p.start == 0 start, end := chunkIndex(base), chunkIndex(limit) if firstGrowth || start < p.start { p.start = start } if end > p.end { p.end = end }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 39.2K bytes - Viewed (0)