Destroy rooms when the coordinator was lost

This commit is contained in:
Sergey Stepanov 2024-12-05 01:10:16 +03:00
parent 8fa53f4e32
commit db32479c4e
No known key found for this signature in database
GPG key ID: A56B4929BAA8556B

View file

@ -113,6 +113,7 @@ func (w *Worker) Start(done chan struct{}) {
case <-done:
return
default:
w.Reset()
cord, err := newCoordinatorConnection(remoteAddr, w.conf.Worker, w.address, w.log)
if err != nil {
onRetryFail(err)