import (
"context"
"fmt"
- "os"
"git.arvados.org/arvados.git/lib/cmd"
"git.arvados.org/arvados.git/lib/service"
QueueSize: cluster.API.WebsocketServerEventQueue,
Logger: ctxlog.FromContext(ctx),
}
+ done := make(chan struct{})
go func() {
eventSource.Run()
ctxlog.FromContext(ctx).Error("event source stopped")
- if !testMode {
- os.Exit(1)
- }
+ close(done)
}()
eventSource.WaitReady()
if err := eventSource.DBHealth(); err != nil {
client: client,
eventSource: eventSource,
newPermChecker: func() permChecker { return newPermChecker(*client) },
+ done: done,
}
return rtr
}