prow/cmd/pipeline/controller.go
func (c *controller) hasSynced() bool {
	if !c.pjInformer.HasSynced() {
		if c.wait != "prowjobs" {
			c.wait = "prowjobs"
			ns := c.pjNamespace()
			if ns == "" {
				ns = "controllers"
			}
			logrus.Infof("Waiting on prowjobs in %s namespace...", ns)
		}
		return false // still syncing prowjobs
	}
	if !c.prowJobsDone {
		c.prowJobsDone = true
		logrus.Info("Synced prow jobs")
	}
	if c.pipelinesDone == nil {
		c.pipelinesDone = map[string]bool{}
	}
	for n, cfg := range c.pipelines {
		if !cfg.informer.Informer().HasSynced() {
			if c.wait != n {
				c.wait = n
				logrus.Infof("Waiting on %s pipelines...", n)
			}
			return false // still syncing pipelines in at least one cluster
		} else if !c.pipelinesDone[n] {
			c.pipelinesDone[n] = true
			logrus.Infof("Synced %s pipelines", n)
		}
	}
	return true // Everyone is synced
}
func (c *controller) hasSynced() bool {
	if !c.pjInformer.HasSynced() {
		if c.wait != "prowjobs" {
			c.wait = "prowjobs"
			ns := c.pjNamespace()
			if ns == "" {
				ns = "controllers"
			}
			logrus.Infof("Waiting on prowjobs in %s namespace...", ns)
		}
		return false // still syncing prowjobs
	}
	if !c.prowJobsDone {
		c.prowJobsDone = true
		logrus.Info("Synced prow jobs")
	}
	if c.pipelinesDone == nil {
		c.pipelinesDone = map[string]bool{}
	}
	for n, cfg := range c.pipelines {
		if !cfg.informer.Informer().HasSynced() {
			if c.wait != n {
				c.wait = n
				logrus.Infof("Waiting on %s pipelines...", n)
			}
			return false // still syncing pipelines in at least one cluster
		} else if !c.pipelinesDone[n] {
			c.pipelinesDone[n] = true
			logrus.Infof("Synced %s pipelines", n)
		}
	}
	return true // Everyone is synced
}
func ( c * controller ) hasSynced ( ) bool { if ! c . pjInformer . HasSynced ( ) { if c . wait != " " { c . wait = " " ns := c . pjNamespace ( ) if ns == " " { ns = " " } logrus . Infof ( " " , ns ) } return false // still syncing prowjobs } if ! c . prowJobsDone { c . prowJobsDone = true logrus . Info ( " " ) } if c . pipelinesDone == nil { c . pipelinesDone = map [ string ] bool { } } for n , cfg := range c . pipelines { if ! cfg . informer . Informer ( ) . HasSynced ( ) { if c . wait != n { c . wait = n logrus . Infof ( " " , n ) } return false // still syncing pipelines in at least one cluster } else if ! c . pipelinesDone [ n ] { c . pipelinesDone [ n ] = true logrus . Infof ( " " , n ) } } return true // Everyone is synced }
// hasSynced returns true when every prowjob and pipeline informer has synced.
hasSynced returns true when every prowjob and pipeline informer has synced .