Added fix for race condition which leads to channels blocking on writ…

…e due to zero length.
ninjasphere · Sep 10, 2014 · 2b5cd7e · 2b5cd7e
1 parent 297f3cb
commit 2b5cd7e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/upnp/event.go b/upnp/event.go
@@ -281,8 +281,8 @@ func (this *upnpDefaultReactor) ServeHTTP(writer http.ResponseWriter, request *h
 func MakeReactor() Reactor {
 	reactor := &upnpDefaultReactor{}
 	reactor.eventMap = make(upnpEventMap)
-	reactor.subscrChan = make(chan *upnpEventRecord)
-	reactor.unpackChan = make(chan *upnpEvent)
-	reactor.eventChan = make(chan Event)
+	reactor.subscrChan = make(chan *upnpEventRecord, 1)
+	reactor.unpackChan = make(chan *upnpEvent, 1)
+	reactor.eventChan = make(chan Event, 1)
 	return reactor
 }