class ResolvingHost (object):
"""
A host name which is being looked up by a bulk-resolver instance.
+
+ Most notably, this is where the flag-handling logic lives for the
+ $FLAGS[HOSTNAME] syntax.
"""
def __init__(me, name):
"""Make a new resolving-host object for the host NAME."""
me.name = name
- me.addr = None
+ me.addr = []
me.failure = None
- def setaddr(me, addr):
+ def addaddr(me, addr):
"""Add the address ADDR."""
- me.addr = addr
+ me.addr.append(addr)
def failed(me, msg):
"""
"""
me.failure = msg
- def get(me):
- """Return the resolved address."""
+ def get(me, flags):
+ """Return a list of addresses according to the FLAGS string."""
if me.failure is not None: raise ResolverFailure(me.name, me.failure)
- return me.addr
+ aa = me.addr
+ all = False
+ for ch in flags:
+ if ch == '*': all = True
+ else: raise ValueError("unknown address-resolution flag `%s'" % ch)
+ if not aa: raise ResolverFailure(me.name, 'no matching addresses found')
+ if not all: aa = [aa[0]]
+ return aa
class BulkResolver (object):
"""
me._namemap[name] = host = ResolvingHost(name)
host._resolv = M.SelResolveByName(
name,
- lambda cname, alias, addr: me._resolved(host, addr[0]),
- lambda: me._resolved(host, None))
+ lambda cname, alias, addr: me._resolved(host, addr),
+ lambda: me._resolved(host, []))
me._noutstand += 1
def run(me):
"""Run the background DNS resolver until it's finished."""
while me._noutstand: M.select()
- def lookup(me, name):
+ def lookup(me, name, flags):
"""Fetch the address corresponding to the host NAME."""
- return me._namemap[name].get()
+ return me._namemap[name].get(flags)
def _resolved(me, host, addr):
- """Callback function: remember that ADDR is the address for HOST."""
- if addr is None:
+ """Callback function: remember that ADDRs are the addresses for HOST."""
+ if not addr:
host.failed('(unknown failure)')
else:
- host.setaddr(addr)
+ for a in addr: host.addaddr(a)
host._resolv = None
me._noutstand -= 1
## Match a $(VAR) configuration variable reference; group 1 is the VAR.
RX_REF = RX.compile(r'(?x) \$ \( ([^)]+) \)')
-## Match a $[HOST] name resolution reference; group 1 is the HOST.
-RX_RESOLVE = RX.compile(r'(?x) \$ \[ ([^]]+) \]')
+## Match a $FLAGS[HOST] name resolution reference; group 1 are the flags;
+## group 2 is the HOST.
+RX_RESOLVE = RX.compile(r'(?x) \$ ([*]*) \[ ([^]]+) \]')
class ConfigSyntaxError (ExpectedError):
def __init__(me, fname, lno, msg):
def _expand(me, string, resolvep):
"""
- Expands $(...) and (optionally) $[...] placeholders in STRING.
+ Expands $(...) and (optionally) $FLAGS[...] placeholders in STRING.
RESOLVEP is a boolean switch: do we bother to tax the resolver or not?
This is turned off by MyConfigParser's resolve() method while it's
collecting hostnames to be resolved.
"""
- string = RX_REF.sub \
- (lambda m: me.get(m.group(1), resolvep), string)
+ string = RX_REF.sub(lambda m: me.get(m.group(1), resolvep), string)
if resolvep:
- string = RX_RESOLVE.sub(lambda m: me._cp._resolver.lookup(m.group(1)),
- string)
+ string = RX_RESOLVE.sub(
+ lambda m: ' '.join(me._cp._resolver.lookup(m.group(2), m.group(1))),
+ string)
return string
def _parents(me):
* It recognizes `$(VAR)' references to configuration variables during
expansion and processes them correctly.
- * It recognizes `$[HOST]' name-resolver requests and handles them
- correctly.
+ * It recognizes `$FLAGS[HOST]' name-resolver requests and handles them
+ correctly. FLAGS may be empty, or `*' (all addresses, space-separated,
+ rather than just the first).
* Its parsing behaviour is well-defined.
for key in sec.items():
value = sec.get(key, resolvep = False)
for match in RX_RESOLVE.finditer(value):
- me._resolver.prepare(match.group(1))
+ me._resolver.prepare(match.group(2))
me._resolver.run()
###--------------------------------------------------------------------------