Skip to content

Commit

Permalink
Fix for #193
Browse files Browse the repository at this point in the history
  • Loading branch information
mattatcha committed May 26, 2016
1 parent 38fa4b7 commit a923387
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion router/routes.go
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,6 @@ func (rm *RouteManager) RoutingFrom(containerID string) bool {

func (rm *RouteManager) Run() error {
rm.Lock()
defer rm.Unlock()

This comment has been minimized.

Copy link
@mattatcha

mattatcha May 26, 2016

Author Member

Lock was being held indefinitely.

for _, route := range rm.routes {
rm.wg.Add(1)
go func(route *Route) {
Expand All @@ -171,6 +170,7 @@ func (rm *RouteManager) Run() error {
}(route)
}
rm.routing = true
rm.Unlock()
rm.wg.Wait()
// Temp fix to allow logspout to run without routes defined.
if len(rm.routes) == 0 {
Expand Down

0 comments on commit a923387

Please sign in to comment.