X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?p=hippotat.git;a=blobdiff_plain;f=server;h=3abebe96bfb69bdf5921dfa64cf1a8da2f70bbf0;hp=e813ca0b650e24f9dfe6a263f6b0b12c01d5517f;hb=8e279651cf76bb0e7d532307c0afbfbd7dc4986b;hpb=a63dd5015893d7a9b500c0e58b8d2c9c6a7e889f diff --git a/server b/server index e813ca0..3abebe9 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): @@ -142,8 +159,9 @@ def slip_decode(data): #print('ESC ', repr((pdata, packet, eix))) pdata += packet[0 : eix] ck = packet[eix+1] - if ck == slip_esc_esc: pdata += slip_esc - elif ck == slip_esc_end: pdata += slip_end + #print('ESC... %o' % ck) + if ck == slip_esc_esc[0]: pdata += slip_esc + elif ck == slip_esc_end[0]: pdata += slip_end else: raise ValueError('invalid SLIP escape') packet = packet[eix+2 : ] out.append(pdata) @@ -277,6 +295,9 @@ class IphttpResource(twisted.web.resource.Resource): c.process_arriving_data(d) c.new_request(request) + def render_GET(self, request): + return 'hippotit' + def start_http(): resource = IphttpResource() sitefactory = twisted.web.server.Site(resource) @@ -288,8 +309,7 @@ def start_http(): addr = ipaddress.IPv6Address(addrspec) endpointfactory = twisted.internet.endpoints.TCP6ServerEndpoint ep = endpointfactory(reactor, cfg.getint('server','port'), addr) - defer = ep.listen(sitefactory) - defer.addErrback(lambda err: err.raiseException()) + crash_on_defer(ep.listen(sitefactory)) #---------- config and setup ---------- @@ -334,14 +354,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 @@ -364,3 +376,4 @@ def startup(): startup() reactor.run() +print('CRASHED (end)', file=sys.stderr)