- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for stopCh (0.26 sec)
-
pkg/controller/job/job_controller_test.go
} manager.podStoreSynced = alwaysReady manager.jobStoreSynced = alwaysReady stopCh := make(chan struct{}) defer close(stopCh) podInformer := sharedInformers.Core().V1().Pods().Informer() go podInformer.Run(stopCh) cache.WaitForCacheSync(stopCh, podInformer.HasSynced) go manager.Run(context.TODO(), 1) // Create job but don't add it to the store.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
stopCh := make(chan struct{}) go kubelet.volumeManager.Run(kubelet.sourcesReady, stopCh) return stopCh } // dirExists returns true if the path exists and represents a directory. func dirExists(path string) bool { s, err := os.Stat(path) if err != nil { return false } return s.IsDir() } // Sort pods by UID. type podsByUID []*v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
// GarbageCollector.Sync(client, period, stopCh): // wait.Until() loops with `period` until the `stopCh` is closed : // wait.PollImmediateUntil() loops with 100ms (hardcode) util the `stopCh` is closed: // GetDeletableResources() // gc.resyncMonitors()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// then we close the channel and abort the loop. if kl.fastNodeStatusUpdate(ctx, kl.clock.Since(start) >= nodeReadyGracePeriod) { close(stopCh) } }, 100*time.Millisecond, stopCh) } // CheckpointContainer tries to checkpoint a container. The parameters are used to // look up the specified container. If the container specified by the given parameters
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
src/runtime/proc.go
notesleep(&newmHandoff.wake) } } // Stops execution of the current m until new work is available. // Returns with acquired P. func stopm() { gp := getg() if gp.m.locks != 0 { throw("stopm holding locks") } if gp.m.p != 0 { throw("stopm holding p") } if gp.m.spinning { throw("stopm spinning") } lock(&sched.lock) mput(gp.m)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
cmd/admin-handlers.go
// Supports following actions: // - restart (restarts all the MinIO instances in a setup) // - stop (stops all the MinIO instances in a setup) // - freeze (freezes all incoming S3 API calls) // - unfreeze (unfreezes previously frozen S3 API calls) // // This newer API now returns back status per remote peer and local regarding // if a "restart/stop" was successful or not. Service signal now supports
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
}) controllers := make(map[string]string) stopFn, err := broadcaster.StartEventWatcher(func(obj runtime.Object) { e, ok := obj.(*eventsv1.Event) if !ok || e.Reason != "Scheduled" { return } controllers[e.Regarding.Name] = e.ReportingController wg.Done() }) if err != nil { t.Fatal(err) } defer stopFn() // Run scheduler. informerFactory.Start(ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
t.Errorf("Admit pod: %v, expected: %v, actual: %v", pod, expected[i], result.Admit) } } // move the clock past transition period to ensure that we stop reporting pressure fakeClock.Step(5 * time.Minute) summaryProvider.result = summaryStatsMaker("2Gi", podStats) podKiller.pod = nil // reset state _, err = manager.synchronize(diskInfoProvider, activePodsFunc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
src/net/http/server.go
// WriteHeader, to make sure we don't consume the // remaining request body to try to advance to the next HTTP // request. Instead, when this is set, we stop reading // subsequent requests on this connection and stop reading // input from it. requestBodyLimitHit bool // trailers are the headers to be sent after the handler // finishes writing the body. This field is initialized from
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
ssc := defaultStatefulSetControl{spc, ssu, history.NewFakeHistory(informerFactory.Apps().V1().ControllerRevisions())} stop := make(chan struct{}) defer close(stop) informerFactory.Start(stop) cache.WaitForCacheSync( stop, informerFactory.Apps().V1().StatefulSets().Informer().HasSynced, informerFactory.Core().V1().Pods().Informer().HasSynced,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)