X-Git-Url: http://git.pjr.cc/?p=goDBhammer.git;a=blobdiff_plain;f=src%2Fbenchcontroller.go;h=21150e1f459ca0236bfd9ba30f707c33f2f297a2;hp=5370173235729dc1019634c34abd4197bfff599e;hb=ea18014aa62ab7de47d63b4d123d52230eb96c53;hpb=bb4d7a9f770f69fe0317d6f6e525df6d6611fbbd

diff --git a/src/benchcontroller.go b/src/benchcontroller.go
index 5370173..21150e1 100644
--- a/src/benchcontroller.go
+++ b/src/benchcontroller.go
@@ -3,9 +3,8 @@
 package benchcontroller
 
 import (
-	//"./dbconnector";
+	"./dbconnector";
 	"fmt";
-	"time";
 	"strings";
 	"strconv";
 	"os";
@@ -32,7 +31,6 @@ func CreateController()(contConfig *BenchControllerConfig)
 func MainLoop(conf *BenchControllerConfig, commInChan chan string, commOutChan chan string)
 {
 	for {
-		time.Sleep(1000000000);
 		i := <-commInChan;
 		
 		fmt.Printf("coms: %s\n", i);
@@ -62,9 +60,26 @@ func MainLoop(conf *BenchControllerConfig, commInChan chan string, commOutChan c
 				conf.dbpass = calls[4];
 				conf.dbname = calls[5];
 				
-			case "asdf":
+			case "begin":
 				// get ready to bench - start the clients
 				os.Stdout.WriteString("ready clients\n");
+
+				comchan := make(chan int);
+				var cont bool;
+				
+				
+				go dbconnector.DBSetup("mysql", conf.dbhost, conf.dbuser, conf.dbpass, conf.dbname, conf.datamult, comchan);
+				cont=true;
+				 
+				for cont{
+					val := <- comchan;
+					fmt.Printf("val: %d\n", val);
+					if val == 100 {
+						 cont = false;
+					}
+				}
+				
+				os.Stdout.WriteString("ok, im done\n");
 			case "qwer":
 				// start the clients
 				os.Stdout.WriteString("start clients\n");