X-Git-Url: http://git.pjr.cc/?p=goDBhammer.git;a=blobdiff_plain;f=src%2Fbenchcontroller.go;h=6bd48a34aba68659b656fa058ea243deaaed4d8f;hp=bb49570d5b8532171a9ad13359a42105c9b2c124;hb=4644c6698a7b6ce6fdb913c2efd170cba3ebec16;hpb=c9e1d3b61ac854f6ca704d627957241a725d4bc2 diff --git a/src/benchcontroller.go b/src/benchcontroller.go index bb49570..6bd48a3 100644 --- a/src/benchcontroller.go +++ b/src/benchcontroller.go @@ -4,7 +4,7 @@ package benchcontroller import ( //"./dbconnector"; - "os"; + "fmt"; "time"; ) @@ -25,14 +25,15 @@ func CreateController()(contConfig *BenchControllerConfig) return bcConfig; } -func MainLoop(conf *BenchControllerConfig, commInChan chan int, commOutChan chan int) +func MainLoop(conf *BenchControllerConfig, commInChan chan string, commOutChan chan string) { for { time.Sleep(1000000000); i := <-commInChan; - os.Stdout.WriteString("got a coms\n"); - switch i { + fmt.Printf("coms: %s\n", i); + + /*switch i { case 1: // this means shutdown os.Stdout.WriteString("shutdown\n"); @@ -43,6 +44,6 @@ func MainLoop(conf *BenchControllerConfig, commInChan chan int, commOutChan chan case 3: // start the clients os.Stdout.WriteString("start clients\n"); - } + }*/ } } \ No newline at end of file