- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 171 for stopCh (0.41 sec)
-
pkg/kubelet/volumemanager/volume_manager_test.go
manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient, node) stopCh := runVolumeManager(manager) defer close(stopCh) podManager.SetPods([]*v1.Pod{pod}) // Fake node status update go simulateVolumeInUseUpdate( v1.UniqueVolumeName(node.Status.VolumesAttached[0].Name), stopCh, manager) err = manager.WaitForAttachAndMount(context.Background(), pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// lock is to ensure the access and modify of lastAccessTime, stopped, and immutable are thread safety, // and protecting from closing stopCh multiple times. lock sync.Mutex lastAccessTime time.Time stopped bool immutable bool stopCh chan struct{} } func (i *objectCacheItem) stop() bool { i.lock.Lock() defer i.lock.Unlock() return i.stopThreadUnsafe() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
return s.serverReady.Load() } func (s *DiscoveryServer) Start(stopCh <-chan struct{}) { go s.WorkloadEntryController.Run(stopCh) go s.handleUpdates(stopCh) go s.periodicRefreshMetrics(stopCh) go s.sendPushes(stopCh) go s.Cache.Run(stopCh) } // Push metrics are updated periodically (10s default) func (s *DiscoveryServer) periodicRefreshMetrics(stopCh <-chan struct{}) { ticker := time.NewTicker(periodicRefreshMetrics)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
func (s *shutdown) Check(req *http.Request) error { select { case <-s.stopCh: return fmt.Errorf("process is shutting down") default: } return nil } func (i *informerSync) Check(_ *http.Request) error { stopCh := make(chan struct{}) // Close stopCh to force checking if informers are synced now. close(stopCh) informersByStarted := make(map[bool][]string)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
return t.component.clusters["config"] } func (t *testController) Run(stop chan struct{}) { assert.NoError(t.t, t.controller.Run(stop)) t.client.RunAndWait(stop) } func TestListRemoteClusters(t *testing.T) { stop := make(chan struct{}) c := buildTestController(t, false) c.AddSecret("s0", "c0") c.AddSecret("s1", "c1") c.Run(stop) // before sync
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
} func (vm *volumeManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() if vm.kubeClient != nil { // start informer for CSIDriver go vm.volumePluginMgr.Run(stopCh) } go vm.desiredStateOfWorldPopulator.Run(sourcesReady, stopCh) klog.V(2).InfoS("The desired_state_of_world populator starts")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kube/kclient/client.go
} return cast } func (n *informerClient[T]) applyFilter(t T) bool { if n.filter == nil { return true } return n.filter(t) } func (n *informerClient[T]) Start(stopCh <-chan struct{}) { n.startInformer(stopCh) } func (n *writeClient[T]) Create(object T) (T, error) { api := kubeclient.GetWriteClient[T](n.client, object.GetNamespace()) return api.Create(context.Background(), object, metav1.CreateOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
g.runningMu.Lock() defer g.runningMu.Unlock() if !g.isRunning { g.isRunning = true g.stopCh = make(chan struct{}) go wait.Until(g.Relist, g.relistDuration.RelistPeriod, g.stopCh) } } func (g *GenericPLEG) Stop() { g.runningMu.Lock() defer g.runningMu.Unlock() if g.isRunning { close(g.stopCh) g.isRunning = false } } func (g *GenericPLEG) Update(relistDuration *RelistDuration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
// Wait for the completion of a loop that started after sources are all ready, then set hasAddedPods accordingly klog.InfoS("Desired state populator starts to run") wait.PollUntil(dswp.loopSleepDuration, func() (bool, error) { done := sourcesReady.AllReady() dswp.populatorLoop() return done, nil }, stopCh) dswp.hasAddedPodsLock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
fmt.Fprintf(os.Stderr, "%v\n", err) os.Exit(1) } cliflag.PrintFlags(cmd.Flags()) ctx, cancel := context.WithCancel(context.Background()) defer cancel() go func() { stopCh := server.SetupSignalHandler() <-stopCh cancel() }() cc, sched, err := Setup(ctx, opts, registryOptions...) if err != nil { return err } // add feature enablement metrics
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0)