import os
import twisted.internet
-import twisted.internet.endpoints
from twisted.web.server import NOT_DONE_YET
#import twisted.web.server import Site
clients = { }
-defcfg = '''
-[DEFAULT]
-max_batch_down = 65536
-max_queue_time = 10
-max_request_time = 54
-target_requests_outstanding = 3
-ipif = userv root ipif %(local)s,%(peer)s,%(mtu)s,slip %(rnets)s
-
-[virtual]
-mtu = 1500
-# network
-# [server]
-# [relay]
-
-[server]
-addrs = 127.0.0.1 ::1
-port = 8099
-
-[limits]
-max_batch_down = 262144
-max_queue_time = 121
-max_request_time = 121
-target_requests_outstanding = 10
-'''
-
#---------- "router" ----------
def route(packet, saddr, daddr):
except KeyError: dclient = None
if dclient is not None:
dclient.queue_outbound(packet)
- elif saddr.is_link_local or daddr.is_link_local:
- log_discard(packet, saddr, daddr, 'link-local')
elif daddr == c.server or daddr not in c.network:
print('TRACE INBOUND ', saddr, daddr, packet)
queue_inbound(packet)
req = cfg.getint(cs, k)
limit = cfg.getint('limits',k)
self.__dict__[k] = min(req, limit)
+
self._pq = PacketQueue(self.max_queue_time)
if ip in clients:
def queue_outbound(self, packet):
self._pq.append(packet)
+ self._check_outbound()
def http_request(self, request):
request.setHeader('Content-Type','application/octet-stream')
if pw != c.pw: raise ValueError('bad password')
# update config
+
+ xxx check sanity, do not update
for r, w in (('mbd', 'max_batch_down'),
('mqt', 'max_queue_time'),
('mrt', 'max_request_time'),
process_cfg_ipif('server',
(('local','server'),
- ('peer','relay'),
+ ('peer', 'relay'),
('rnets','network')))
common_startup(defcfg)