Merge pull request #651 from TheTincho/fix_integration_test_timing

Fix path and timing issues with integration tests.

node_exporter_test.go

@@ -13,8 +13,10 @@ import (
 	"github.com/prometheus/procfs"
 )
 
+var (
+	binary = filepath.Join(os.Getenv("GOPATH"), "bin/node_exporter")
+)
 const (
-	binary  = "./node_exporter"
 	address = "localhost:19100"
 )
 
@@ -54,7 +56,7 @@ func TestFileDescriptorLeak(t *testing.T) {
 		return nil
 	}
 
-	if err := runCommandAndTests(exporter, test); err != nil {
+	if err := runCommandAndTests(exporter, address, test); err != nil {
 		t.Error(err)
 	}
 }
@@ -83,7 +85,7 @@ func TestHandlingOfDuplicatedMetrics(t *testing.T) {
 		return queryExporter(address)
 	}
 
-	if err := runCommandAndTests(exporter, test); err != nil {
+	if err := runCommandAndTests(exporter, address, test); err != nil {
 		t.Error(err)
 	}
 }
@@ -106,27 +108,22 @@ func queryExporter(address string) error {
 	return nil
 }
 
-func runCommandAndTests(cmd *exec.Cmd, fn func(pid int) error) error {
+func runCommandAndTests(cmd *exec.Cmd, address string, fn func(pid int) error) error {
 	if err := cmd.Start(); err != nil {
 		return fmt.Errorf("failed to start command: %s", err)
 	}
-
+	time.Sleep(50 * time.Millisecond)
-	errc := make(chan error)
+	for i := 0; i < 10; i++ {
-	go func() {
+		if err := queryExporter(address); err == nil {
-		if err := cmd.Wait(); err != nil {
+			break
-			errc <- fmt.Errorf("execution of command failed: %s", err)
+		}
-		} else {
+		time.Sleep(500 * time.Millisecond)
-			errc <- nil
+		if cmd.Process== nil || i == 9 {
+			return fmt.Errorf("can't start command")
 		}
-	}()
-
-	// Allow the process to start before running any tests.
-	select {
-	case err := <-errc:
-		return err
-	case <-time.After(100 * time.Millisecond):
 	}
 
+	errc := make(chan error)
 	go func(pid int) {
 		errc <- fn(pid)
 	}(cmd.Process.Pid)