wip

[hippotat] / client

#!/usr/bin/python3

from hippotat import *

client_cs = None

def set_client(ci,cs,pw):
  global client_cs
  global password
  assert(client_cs is None)
  client_cs = cs
  c.client = ci
  c.max_outstanding = cfg.getint(cs, 'max_requests_outstanding')
  password = pw

def process_cfg():
  global url
  global max_requests_outstanding

  process_cfg_common_always()
  process_cfg_server()

  try:
    c.url = cfg.get('server','url')
  except NoOptionError:
    process_cfg_saddrs()
    sa = c.saddrs[0].url()

  process_cfg_clients(set_client)

  c.routes = cfg.get('virtual','routes')
  c.max_queue_time = cfg.get(client_cs, 'max_queue_time')

  process_cfg_ipif(client_cs,
                   (('local', 'client'),
                    ('peer',  'server'),
                    ('rnets', 'routes')))

outstanding = 0

def start_client():
  global queue
  queue = PacketQueue(c.max_queue_time)

def outbound(packet, saddr, daddr):
  #print('OUT ', saddr, daddr, repr(packet))
  queue.append(packet)
  check_outbound()

def check_outbound():
  while True:
    if outstanding >= c.max_outstanding: break
    elements = { }
    if not queue.nonempty():
      if outstanding >= c.target_

  while (outstanding <  and
         (queue.notempty() or outstanding < c.

common_startup()
process_cfg()
start_ipif(c.ipif_command, outbound)
common_run()