- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 49 for handleCrash (0.29 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
expBackoff: exponentialbackoff.ExponentialBackoff{}, }) } go func() (eventErr, detailedErr error) { // Handle unhandled panics (very unlikely) defer k8sRuntime.HandleCrash() // Handle completion of and error, if any, from operationFunc() defer grm.operationComplete(opKey, &detailedErr) return generatedOperations.Run() }() return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
defer close(serverShutdownCh) <-stopCh ctx, cancel := context.WithTimeout(context.Background(), shutDownTimeout) server.Shutdown(ctx) cancel() }() go func() { defer utilruntime.HandleCrash() defer close(listenerStoppedCh) var listener net.Listener listener = tcpKeepAliveListener{ln} if server.TLSConfig != nil { listener = tls.NewListener(listener, server.TLSConfig) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
tc.clock = clock.RealClock{} return tc } // Run starts the workers to clean up Jobs. func (tc *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer tc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting TTL after finished controller") defer logger.Info("Shutting down TTL after finished controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/rc_patch.go
patchContext networking.EnvoyFilter_PatchContext, proxy *model.Proxy, efw *model.EnvoyFilterWrapper, routeConfiguration *route.RouteConfiguration, ) (out *route.RouteConfiguration) { defer runtime.HandleCrash(runtime.LogPanic, func(any) { IncrementEnvoyFilterErrorMetric(Route) log.Errorf("route patch %s/%s caused panic, so the patches did not take effect", efw.Namespace, efw.Name) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
Reason: "InstanceDeletionCompleted", Message: "removed all instances", }, nil } func (c *CRDFinalizer) Run(workers int, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting CRDFinalizer") defer klog.Info("Shutting down CRDFinalizer") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
if err := c.requeueAllOtherGroupCRDs(key); err != nil { return err } return nil } func (c *NamingConditionController) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting NamingConditionController") defer klog.Info("Shutting down NamingConditionController") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { c.queue.Add(key) } } func (c *MetaAllocator) run() { defer runtime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting ServiceCIDR Allocator Controller") defer klog.Info("Stopping ServiceCIDR Allocator Controllerr")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
} // Run will not return until stopCh is closed. workers determines how many // endpoints will be handled in parallel. func (e *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start events processing pipeline. e.eventBroadcaster.StartStructuredLogging(3) e.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: e.client.CoreV1().Events("")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
} // Register prometheus metrics metrics.RegisterMetrics() return gcc } func (gcc *PodGCController) Run(ctx context.Context) { logger := klog.FromContext(ctx) defer utilruntime.HandleCrash() logger.Info("Starting GC controller") defer gcc.nodeQueue.ShutDown() defer logger.Info("Shutting down GC controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
// read and write deadlines are pushed every time a new message is received. func IgnoreReceives(ws *websocket.Conn, timeout time.Duration) { defer runtime.HandleCrash() var data []byte for { resetTimeout(ws, timeout) if err := websocket.Message.Receive(ws, &data); err != nil { return } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0)