From db32479c4e1b7bcdc58c57c3ca03819c45638ce6 Mon Sep 17 00:00:00 2001
From: Sergey Stepanov <sergystepanov@gmail.com>
Date: Thu, 5 Dec 2024 01:10:16 +0300
Subject: [PATCH] Destroy rooms when the coordinator was lost

---
 pkg/worker/worker.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go
index f98b2e97..28c29b60 100644
--- a/pkg/worker/worker.go
+++ b/pkg/worker/worker.go
@@ -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)