Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WaitForHandlersSync (0.16 sec)

  1. pkg/scheduler/eventhandlers.go

    	// syncedPollPeriod controls how often you look at the status of your sync funcs
    	syncedPollPeriod = 100 * time.Millisecond
    )
    
    // WaitForHandlersSync waits for EventHandlers to sync.
    // It returns true if it was successful, false if the controller should shut down
    func (sched *Scheduler) WaitForHandlersSync(ctx context.Context) error {
    	return wait.PollUntilContextCancel(ctx, syncedPollPeriod, true, func(ctx context.Context) (done bool, err error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  2. cmd/kube-scheduler/app/server.go

    		if cc.DynInformerFactory != nil {
    			cc.DynInformerFactory.WaitForCacheSync(ctx.Done())
    		}
    
    		// Wait for all handlers to sync (all items in the initial list delivered) before scheduling.
    		if err := sched.WaitForHandlersSync(ctx); err != nil {
    			logger.Error(err, "waiting for handlers to sync")
    		}
    
    		close(handlerSyncReadyCh)
    		logger.V(3).Info("Handlers synced")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    		wg.Done()
    	})
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer stopFn()
    
    	// Run scheduler.
    	informerFactory.Start(ctx.Done())
    	informerFactory.WaitForCacheSync(ctx.Done())
    	if err = sched.WaitForHandlersSync(ctx); err != nil {
    		t.Fatalf("Handlers failed to sync: %v: ", err)
    	}
    	go sched.Run(ctx)
    
    	// Send pods to be scheduled.
    	for _, p := range pods {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top