svc/connect.in: Add a backstop exception handler to the pinger loop.

[tripe] / svc / connect.in

diff --git a/svc/connect.in b/svc/connect.in
index c68e520d03e6f1d65363ad26a915731e920b26c5..37714252569109f640aab6c9592f019e467e36b4 100644 (file)
--- a/svc/connect.in
+++ b/svc/connect.in
@@ -37,6 +37,7 @@ from math import sqrt
 import cdb as CDB
 import mLib as M
 import re as RX
+import sys as SYS
 from time import time
 import subprocess as PROC
 
@@ -567,7 +568,9 @@ class Pinger (T.Coroutine):
     while True:
       (peer, seq), code, stuff = me._q.get()
       if peer in me._peers and seq == me._peers[peer].seq:
-        me._peers[peer].event(code, stuff)
+        try: me._peers[peer].event(code, stuff)
+        except Exception, e:
+          SYS.excepthook(*SYS.exc_info())
 
   def add(me, peer, pingnow):
     """