kill process on panic (#164)

livekit · Feb 14, 2024 · a06adc7 · a06adc7
1 parent 0a8bdde
commit a06adc7
Show file tree

Hide file tree

Showing 4 changed files with 45 additions and 18 deletions.
diff --git a/livekit-rtc/livekit/rtc/_ffi_client.py b/livekit-rtc/livekit/rtc/_ffi_client.py
@@ -12,6 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import signal
 import asyncio
 from contextlib import ExitStack
 import ctypes
@@ -145,6 +146,11 @@ def ffi_event_callback(
             )
 
         return  # no need to queue the logs
+    elif which == "panic":
+        logger.critical("Panic: %s", event.panic.message)
+        # We are in a unrecoverable state, terminate the process
+        os.kill(os.getpid(), signal.SIGTERM)
+        return
 
     FfiClient.instance.queue.put(event)
 

diff --git a/livekit-rtc/livekit/rtc/_proto/ffi_pb2.py b/livekit-rtc/livekit/rtc/_proto/ffi_pb2.py