PortAllocator.Run() is no longer blocking.

We no longer need the goroutine, so cleaning it up.
googleforgames · Jan 30, 2019 · beba965 · beba965
1 parent 69be283
commit beba965
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/pkg/gameservers/controller.go b/pkg/gameservers/controller.go
@@ -261,11 +261,9 @@ func (c *Controller) Run(workers int, stop <-chan struct{}) error {
 	}
 
 	// Run the Port Allocator
-	go func() {
-		if err := c.portAllocator.Run(stop); err != nil {
-			c.logger.WithError(err).Error("error running the port allocator")
-		}
-	}()
+	if err = c.portAllocator.Run(stop); err != nil {
+		return errors.Wrap(err, "error running the port allocator")
+	}
 
 	// Run the Health Controller
 	go c.healthController.Run(stop)