Method Run

tests/t.go:306–357

Run completes the configuration of test environment and starts the test server. T.Close should be called by the end of test to release any resources and shutdown the server. The parameter waitListeners specifies the amount of listeners the server is supposed to configure. Run() will block before a

(waitListeners int)

// The parameter waitListeners specifies the amount of listeners the server is
// supposed to configure. Run() will block before all of them are up.
func (t *T) Run(waitListeners int) {
	t.ensureCanRun()
	cmd := t.buildCmd("run")

	// Capture maddy log and redirect it.
	logOut, err := cmd.StderrPipe()
	if err != nil {
		t.Fatal("Test configuration failed:", err)
	}

	t.Log("launching maddy", cmd.Args)
	if err := cmd.Start(); err != nil {
		t.Fatal("Test configuration failed:", err)
	}

	serverStarted := make(chan bool)

	go func() {
		defer close(serverStarted)
		scnr := bufio.NewScanner(logOut)
		for scnr.Scan() {
			line := scnr.Text()

			t.Log("maddy:", line)

			if strings.HasPrefix(line, "server started") {
				serverStarted <- true
			}

			if strings.HasPrefix(line, "new server started") {
				select {
				case t.reloadedChan <- struct{}{}:
					t.Log("server reload confirmed, continuing test")
				default:
					t.Log("unexpected reloads detected")
					t.Fail()
				}
			}
		}
		if err := scnr.Err(); err != nil {
			t.Log("stderr I/O error:", err)
		}
	}()

	if !<-serverStarted {
		t.Fatal("Log ended before all expected listeners are up. Start-up error?")
	}

	t.servProc = cmd

	t.Cleanup(t.killServer)
}

func (t *T) StateDir() string {
	return filepath.Join(t.testDir, "statedir")