X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?a=blobdiff_plain;f=server;h=de28624452c8dec55a20be22ad2d08e3aee0b141;hb=aa6632821086a1a41c4f8464537db704f83a03de;hp=aa06eb6dad656f3c51cb8770262b4ab9e9b4f057;hpb=3a6076b4288cc01264d280d8c7b7f2793445ca90;p=hippotat.git

diff --git a/server b/server
index aa06eb6..de28624 100755
--- a/server
+++ b/server
@@ -1,5 +1,8 @@
 #!/usr/bin/python3
 
+import signal
+signal.signal(signal.SIGINT, signal.SIG_DFL)
+
 import sys
 import os
 
@@ -55,7 +58,7 @@ mtu = 1500
 [server]
 ipif = userv root ipif %(host)s,%(relay)s,%(mtu)s,slip %(network)s
 addrs = 127.0.0.1 ::1
-port = 80
+port = 8099
 
 [limits]
 max_batch_down = 262144
@@ -63,6 +66,20 @@ max_queue_time = 121
 max_request_time = 121
 '''
 
+#---------- error handling ----------
+
+def crash(err):
+  print('CRASH ', err, file=sys.stderr)
+  try: reactor.stop()
+  except twisted.internet.error.ReactorNotRunning: pass
+
+def crash_on_defer(defer):
+  defer.addErrback(lambda err: crash(err))
+
+def crash_on_critical(event):
+  if event.get('log_level') >= LogLevel.critical:
+    crash(twisted.logger.formatEvent(event))
+
 #---------- "router" ----------
 
 def route(packet, saddr, daddr):
@@ -288,7 +305,7 @@ def start_http():
       addr = ipaddress.IPv6Address(addrspec)
       endpointfactory = twisted.internet.endpoints.TCP6ServerEndpoint
     ep = endpointfactory(reactor, cfg.getint('server','port'), addr)
-    ep.listen(sitefactory)
+    crash_on_defer(ep.listen(sitefactory))
 
 #---------- config and setup ----------
         
@@ -333,14 +350,6 @@ def process_cfg():
 
   ipif_command = cfg.get('server','ipif', vars=iic_vars)
 
-def crash_on_critical(event):
-  if event.get('log_level') >= LogLevel.critical:
-    print('crashing: ', twisted.logger.formatEvent(event), file=sys.stderr)
-    #print('crashing!', file=sys.stderr)
-    #os._exit(1)
-    try: reactor.stop()
-    except twisted.internet.error.ReactorNotRunning: pass
-
 def startup():
   global cfg
 
@@ -363,3 +372,4 @@ def startup():
 
 startup()
 reactor.run()
+print('CRASHED (end)', file=sys.stderr)