Add the maximal number of hosts as option

exec/exec.go

@@ -150,6 +150,7 @@ func Waiter(host *formatter.Host) {
 func Disconnection(
 	hosts []*formatter.Host,
 	disconnected <-chan *formatter.Host,
+	HostsMax int,
 ) {
 
 	for {
@@ -179,6 +180,7 @@ func Disconnection(
 		formatter.Dispatcher(
 			host.Commands[host.CommandNumber-1:],
 			hosts,
+			HostsMax,
 			false,
 		)
 
@@ -327,6 +329,7 @@ func RunCommands(
 	go Disconnection(
 		hosts,
 		disconnected,
+		config.HostsMax,
 	)
 
 	// if we use the timer, run the go routine

exec/exec_test.go

@@ -11,26 +11,26 @@ var (
 
 	// A list of host
 	hostnames = []string{
+		"arbois",
+		"verdejo",
 		"courbu",
 		"aspiran",
+		"tressalier",
+		"picardan",
 		"roussanne",
 		"doucillon",
-		"verdejo",
 		"molette",
 		"mauzac",
 		"mancin",
 		"vaccarese",
 		"carmenere",
-		"tressalier",
 		"null",
 		"tockay",
 		"bidule",
 		"toké",
 		"poulsard",
-		"arbois",
 		"machin",
 		"ugni",
-		"picardan",
 	}
 )
 
@@ -61,6 +61,8 @@ func TestRunCommands(t *testing.T) {
 	conf.MemoryMax = 30.0
 	conf.ExcludeLoaded = true
 	conf.WorkTimer = true
+	conf.WorkTime = 120
+	conf.HostsMax = 5
 
 	// Create a command which will be duplicated
 	command := &formatter.Command{
@@ -97,6 +99,7 @@ func TestRunCommands(t *testing.T) {
 	formatter.Dispatcher(
 		commands,
 		hosts,
+		conf.HostsMax,
 		true,
 	)
 

runner/runner.go

@@ -31,6 +31,7 @@ func Run() {
 	formatter.Dispatcher(
 		commands,
 		hosts,
+		data_config.HostsMax,
 		true,
 	)