From 4a4702d6cd7555793a9bc1755079b8ac3adb9a1f Mon Sep 17 00:00:00 2001
From: Gregory Eremin <g@erem.in>
Date: Thu, 12 Feb 2015 02:50:30 +0700
Subject: [PATCH] New supervisor interface

---
 core/supervisor.go | 27 ++++++++++++---------------
 1 file changed, 12 insertions(+), 15 deletions(-)

diff --git a/core/supervisor.go b/core/supervisor.go
index ae02271..1e4f873 100644
--- a/core/supervisor.go
+++ b/core/supervisor.go
@@ -1,7 +1,7 @@
 package core
 
 import (
-	"fmt"
+	"log"
 	"os"
 	"os/exec"
 	"time"
@@ -9,25 +9,22 @@ import (
 
 type (
 	Supervisor struct {
-		pythonBin     string
-		pythonWrapper string
+		Bin     string
+		Wrapper string
 	}
 )
 
 // XXX: We're about to spawn hundreds of Python processes
-func (s *Supervisor) StartAll(units []string) {
+func (s *Supervisor) Start(units ...string) {
 	for _, name := range units {
-		s.Start(name)
-		time.Sleep(500 * time.Millisecond) // Don't spawn processes too fast
-	}
-}
+		log.Printf("Starting unit: %s", name)
 
-func (s *Supervisor) Start(name string) {
-	fmt.Println("Starting unit: " + name)
-	cmd := exec.Command(s.pythonBin, s.pythonWrapper, name)
-	cmd.Stdout = os.Stdout // Sorry
-	if err := cmd.Start(); err != nil {
-		fmt.Println("Failed to start unit: ", name)
-		fmt.Println(err.Error())
+		cmd := exec.Command(s.Bin, s.Wrapper, name)
+		cmd.Stdout = os.Stderr // Sorry
+		if err := cmd.Start(); err != nil {
+			log.Printf("Failed to start unit: %s (%s)", name, err.Error())
+		}
+
+		time.Sleep(200 * time.Millisecond) // Don't spawn processes too fast
 	}
 }