+def process_request(request, desca):
+ # find client, update config, etc.
+ metadata = request.args['m']
+ metadata = metadata.split(b'\n')
+ (ci_s, pw, tro) = metadata.split(b'\n')[0:3]
+ desca['m'] = [ci_s, tro]
+ ci = ipaddr(ci_s)
+ desca['ci'] = ci
+ cl = clients[ci]
+ if pw != cl.pw: raise ValueError('bad password')
+ desca['pwok']=True
+
+ if tro != cl.target_requests_outstanding:
+ raise ValueError('tro must be %d' % cl.target_requests_outstanding)
+
+ try:
+ d = request.args['d']
+ desca['d'] = d
+ except KeyError: d = ''
+
+ cl.process_arriving_data(d)
+ cl.new_request(request)
+
+def log_http(desca, msg):
+ try:
+ d = desca['d']
+ del desca['d']
+ except KeyError:
+ d = None
+ log_debug(DBG.HTTP, msg + repr(desca), d=d)
+