Changeset 922 for trunk/packages/sipb-xen-dns/code

Timestamp:

Aug 25, 2008, 1:27:07 AM (16 years ago)

Author:

y_z

Message:

• Search for longest-matching domain name instead of first-matching.
• ns1.prod.xvm.mit.edu (0.0.0.0) is the primary nameserver for the prod zone.

File:

• trunk/packages/sipb-xen-dns/code/dnsserver.py (modified) (4 diffs)

trunk/packages/sipb-xen-dns/code/dnsserver.py

@@ -57 +57 @@
         ttl = 900
         name = name.lower()
+
+        # XXX hack for the transition to two separate dev/prod clusters
+        if 'dev.xvm.mit.edu' in self.domains and name.endswith('prod.xvm.mit.edu'):
+            # import time, sys
+            # print time.localtime(), 'handling prod request', name
+            # sys.stdout.flush()
+
+            # Point the client in the right direction for prod requests.
+            authority = dns.RRHeader('prod.xvm.mit.edu', dns.NS, dns.IN, 3600,
+                    dns.Record_NS(name='ns1.prod.xvm.mit.edu', ttl=3600), auth=True)
+            additional = dns.RRHeader('ns1.prod.xvm.mit.edu', dns.A, dns.IN, 3600,
+                    dns.Record_A(address='0.0.0.0', ttl=3600), auth=True)
+            return defer.succeed(([], [authority], [additional]))
+
         if name in self.domains:
             domain = name
         else:
-            # This works because domain will remain bound after breaking out of the loop
+            # Look for the longest-matching domain.  (This works because domain
+            # will remain bound after breaking out of the loop.)
+            best_domain = ''
             for domain in self.domains:
-                if name.endswith('.'+domain):
-                    break
-            else: #Not us
+                if name.endswith('.'+domain) and len(domain) > len(best_domain):
+                    best_domain = domain
+            if best_domain == '':
                 return defer.fail(failure.Failure(dns.DomainError(name)))
+            domain = best_domain
         results = []
         authority = []
@@ -71 +88 @@
         authority.append(dns.RRHeader(domain, dns.NS, dns.IN,
                                       3600, self.ns, auth=True))
+
         if cls == dns.IN:
             host = name[:-len(domain)-1]
-            if not host:
+            if not host: # Request for the domain itself.
                 if type in (dns.A, dns.ALL_RECORDS):
                     record = dns.Record_A(config.dns.nameservers[0].ip, ttl)
@@ -85 +103 @@
                     results.append(dns.RRHeader(domain, dns.SOA, dns.IN,
                                                 ttl, self.soa, auth=True))
-            else:
+            else: # Request for a subdomain.
                 if 'passup' in dir(config.dns) and host in config.dns.passup:
                     record = dns.Record_CNAME('%s.%s' % (host, config.dns.parent), ttl)
@@ -92 +110 @@
                         [], []))
 
-                if host:
-                    value = invirt.database.Machine.get_by(name=host)
-                    if value is None or not value.nics:
-                        return defer.fail(failure.Failure(dns.AuthoritativeDomainError(name)))
-                    ip = value.nics[0].ip
-                    if ip is None:  #Deactivated?
-                        return defer.fail(failure.Failure(dns.AuthoritativeDomainError(name)))
+                value = invirt.database.Machine.get_by(name=host)
+                if value is None or not value.nics:
+                    return defer.fail(failure.Failure(dns.AuthoritativeDomainError(name)))
+                ip = value.nics[0].ip
+                if ip is None:  #Deactivated?
+                    return defer.fail(failure.Failure(dns.AuthoritativeDomainError(name)))
+
                 if type in (dns.A, dns.ALL_RECORDS):
                     record = dns.Record_A(ip, ttl)