Method Start

dgraphtest/local_cluster.go:489–555

()

}

func (c *LocalCluster) Start() error {
	log.Printf("[INFO] starting cluster with prefix [%v]", c.conf.prefix)
	startAll := func() error {
		var wg sync.WaitGroup
		errCh := make(chan error, c.conf.numZeros+c.conf.numAlphas)

		for i := range c.conf.numZeros {
			wg.Add(1)
			go func(id int) {
				defer wg.Done()
				if err := c.StartZero(id); err != nil {
					errCh <- fmt.Errorf("failed to start zero %d: %w", id, err)
				}
			}(i)
		}

		for i := range c.conf.numAlphas {
			wg.Add(1)
			go func(id int) {
				defer wg.Done()
				if err := c.StartAlpha(id); err != nil {
					errCh <- fmt.Errorf("failed to start alpha %d: %w", id, err)
				}
			}(i)
		}

		wg.Wait()
		close(errCh)
		for err := range errCh {
			if err != nil {
				return err
			}
		}

		return c.HealthCheck(false)
	}

	// sometimes health check doesn't work due to unmapped ports. We dont
	// know why this happens, but checking it 3 times before failing the test.
	retry := 0
	for {
		retry++

		if err := startAll(); err == nil {
			return nil
		} else if retry == 3 {
			return err
		} else {
			log.Printf("[WARNING] saw the err, trying again: %v", err)
		}

		if err1 := c.Stop(); err1 != nil {
			log.Printf("[WARNING] error while stopping :%v", err1)
		}
		c.Cleanup(true)

		if err := c.cleanupDocker(); err != nil {
			log.Printf("[ERROR] while cleaning old dockers %v", err)