|
@@ -541,6 +541,7 @@ func (gw *BackendGateway) Start() error {
|
|
|
stop := make(chan bool)
|
|
stop := make(chan bool)
|
|
|
go func(workerId int, stop chan bool) {
|
|
go func(workerId int, stop chan bool) {
|
|
|
// blocks here until the worker exits
|
|
// blocks here until the worker exits
|
|
|
|
|
+ // for-loop used so that if workDispatcher panics, re-enter gw.workDispatcher
|
|
|
for {
|
|
for {
|
|
|
state := gw.workDispatcher(
|
|
state := gw.workDispatcher(
|
|
|
gw.conveyor,
|
|
gw.conveyor,
|
flashmob