From 16b22dcca27939e4cf7ead17b8571d9f6f7485bf Mon Sep 17 00:00:00 2001
From: Victor Vieux <vieux@docker.com>
Date: Thu, 20 Nov 2014 22:39:45 +0000
Subject: [PATCH] do not block if one node is availalble

---
 manage.go | 42 ++++++++++++++++++++++--------------------
 1 file changed, 22 insertions(+), 20 deletions(-)

diff --git a/manage.go b/manage.go
index c6b4c560d2..60f0f3159a 100644
--- a/manage.go
+++ b/manage.go
@@ -41,29 +41,31 @@ func manage(c *cli.Context) {
 	cluster := cluster.NewCluster()
 	cluster.Events(&logHandler{})
 
-	if c.String("token") != "" {
-		nodes, err := discovery.FetchSlaves(c.String("token"))
-		if err != nil {
-			log.Fatal(err)
+	go func() {
+		if c.String("token") != "" {
+			nodes, err := discovery.FetchSlaves(c.String("token"))
+			if err != nil {
+				log.Fatal(err)
 
-		}
-		if err := refresh(cluster, nodes); err != nil {
-			log.Fatal(err)
-		}
-		go func() {
-			for {
-				time.Sleep(25 * time.Second)
-				nodes, err = discovery.FetchSlaves(c.String("token"))
-				if err == nil {
-					refresh(cluster, nodes)
-				}
 			}
-		}()
-	} else {
-		if err := refresh(cluster, c.Args()); err != nil {
-			log.Fatal(err)
+			if err := refresh(cluster, nodes); err != nil {
+				log.Fatal(err)
+			}
+			go func() {
+				for {
+					time.Sleep(25 * time.Second)
+					nodes, err = discovery.FetchSlaves(c.String("token"))
+					if err == nil {
+						refresh(cluster, nodes)
+					}
+				}
+			}()
+		} else {
+			if err := refresh(cluster, c.Args()); err != nil {
+				log.Fatal(err)
+			}
 		}
-	}
+	}()
 
 	s := scheduler.NewScheduler(cluster, &strategy.BinPackingPlacementStrategy{}, []filter.Filter{&filter.AttributeFilter{}, &filter.PortFilter{}})