Catch reconnection errors through the on_error workflow. Fixes: #3635

savonet · Jan 16, 2024 · 284b758 · 284b758
1 parent 2f7fb67
commit 284b758
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/core/outputs/icecast2.ml b/src/core/outputs/icecast2.ml
@@ -547,6 +547,7 @@ class output p =
 
     method icecast_send b =
       try
+        if Cry.get_status connection = Cry.Disconnected then self#icecast_start;
         Strings.iter
           (fun s offset length -> Cry.send connection ~offset ~length s)
           b;
@@ -567,8 +568,7 @@ class output p =
     method send b =
       match Cry.get_status connection with
         | Cry.Disconnected when Unix.time () > restart_time ->
-            self#icecast_start;
-            self#send b
+            self#icecast_send b
         | Cry.Connected _ -> self#icecast_send b
         | _ -> ()