From 7792a95ee1dc46ec02f697a9332664206e2b0c96 Mon Sep 17 00:00:00 2001 From: Julien Vehent Date: Tue, 10 Sep 2013 18:24:41 -0400 Subject: [PATCH] Scheduler: bump channels buffer size to some magic prime number value --- src/mig/scheduler/scheduler.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/mig/scheduler/scheduler.go b/src/mig/scheduler/scheduler.go index c1ff6d19..d695bf13 100644 --- a/src/mig/scheduler/scheduler.go +++ b/src/mig/scheduler/scheduler.go @@ -30,11 +30,11 @@ var MONGOURI string = "172.21.2.143" // AMQP broker. It also launches the goroutines. func main() { termChan := make(chan bool) - actionNewChan := make(chan string) - cmdLaunchChan := make(chan string) - cmdInFlightChan := make(chan string) - cmdDoneChan := make(chan string) - actionDoneChan := make(chan string) + actionNewChan := make(chan string, 17) + cmdLaunchChan := make(chan string, 67) + cmdInFlightChan := make(chan string, 67) + cmdDoneChan := make(chan string, 43) + actionDoneChan := make(chan string, 11) // Setup connection to MongoDB backend database mgofd, err := mgo.Dial(MONGOURI)