- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 46 for HandleCrash (0.28 sec)
-
staging/src/k8s.io/apiserver/pkg/server/hooks.go
} func runPostStartHook(name string, entry postStartHookEntry, context PostStartHookContext) { var err error func() { // don't let the hook *accidentally* panic and kill the server defer utilruntime.HandleCrash() err = entry.hook(context) }() // if the hook intentionally wants to kill server, let it. if err != nil { klog.Fatalf("PostStartHook %q failed: %v", name, err) } close(entry.done) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
systemNamespaces: systemNamespaces, interval: interval, } } // Run starts one worker. func (c *Controller) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer klog.Infof("Shutting down system namespaces controller") klog.Infof("Starting system namespaces controller") if !cache.WaitForCacheSync(stopCh, c.namespaceSynced) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
// // Deprecated: Will be removed when the legacy polling methods are removed. func runConditionWithCrashProtection(condition ConditionFunc) (bool, error) { defer runtime.HandleCrash() return condition() } // runConditionWithCrashProtectionWithContext runs a ConditionWithContextFunc // with crash protection. // // Deprecated: Will be removed when the legacy polling methods are removed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
ctx := wait.ContextForChannel(stopCh) if pr.contextMetadata != nil { ctx = metadata.NewOutgoingContext(ctx, pr.contextMetadata) } go func() { defer utilruntime.HandleCrash() <-stopCh pr.mux.Lock() defer pr.mux.Unlock() pr.stopped = true pr.cond.Signal() }() timer := pr.clock.NewTimer(progressRequestPeriod) defer timer.Stop() for { stopped := func() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
ec.queue.AddAfter(key, timeout) } // Run starts the EstablishingController. func (ec *EstablishingController) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer ec.queue.ShutDown() klog.Info("Starting EstablishingController") defer klog.Info("Shutting down EstablishingController") if !cache.WaitForCacheSync(stopCh, ec.crdSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service.go
if err != nil { return nil, fmt.Errorf("failed to create connection to %s, error: %v", endpoint, err) } s.kmsClient = kmsapi.NewKeyManagementServiceClient(s.connection) go func() { defer utilruntime.HandleCrash() <-ctx.Done() _ = s.connection.Close() }() return s, nil } // Decrypt a given data string to obtain the original byte data.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 23:18:16 UTC 2023 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting.go
value: initial, } if doneCh != nil { activeCounter.Add(1) // count start of the following goroutine go func() { defer activeCounter.Add(-1) // count completion of this goroutine defer runtime.HandleCrash() activeCounter.Add(-1) // count suspension for channel receive <-doneCh // Whatever goroutine unblocked the preceding receive MUST // have already accounted for this activation. lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 3.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager.go
desiredStateOfWorld cache.DesiredStateOfWorld } var _ PluginManager = &pluginManager{} func (pm *pluginManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() if err := pm.desiredStateOfWorldPopulator.Start(stopCh); err != nil { klog.ErrorS(err, "The desired_state_of_world populator (plugin watcher) starts failed!") return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
// Types of object are calculated from policy.Spec.MatchingConstraints typeChecker *validatingadmissionpolicy.TypeChecker } func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() if !cache.WaitForNamedCacheSync(ControllerName, ctx.Done(), c.policySynced) { return } defer c.policyQueue.ShutDown() for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service.go
if err != nil { return nil, fmt.Errorf("failed to create connection to %s, error: %v", endpoint, err) } s.kmsClient = kmsapi.NewKeyManagementServiceClient(s.connection) go func() { defer utilruntime.HandleCrash() <-ctx.Done() _ = s.connection.Close() }() return s, nil } func (g *gRPCService) checkAPIVersion(ctx context.Context) error { g.mux.Lock() defer g.mux.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 00:47:46 UTC 2023 - 4.4K bytes - Viewed (0)