From: Bert Hubert <bert.hubert@netherlabs.nl>
Date: Mon, 10 Jan 2011 13:44:04 +0000 (+0000)
Subject: remote master can now also have a :port number - forward port from 2.9.22.x
X-Git-Tag: auth-3.0~389
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=a370ef3183ba4ba5f0ef9b2327f7e11e1453d476;p=pdns

remote master can now also have a :port number - forward port from 2.9.22.x


git-svn-id: svn://svn.powerdns.com/pdns/trunk/pdns@1858 d19b8d6e-7fed-0310-83ef-9ca221ded41b
---

diff --git a/pdns/resolver.cc b/pdns/resolver.cc
index 1d07d531b..58d0583c3 100644
--- a/pdns/resolver.cc
+++ b/pdns/resolver.cc
@@ -209,16 +209,20 @@ int Resolver::receiveResolve(struct sockaddr* fromaddr, Utility::socklen_t addrl
   return 1;
 }
   
-int Resolver::resolve(const string &ip, const char *domain, int type)
+int Resolver::resolve(const string &ipport, const char *domain, int type)
 {
   makeUDPSocket();
-  sendResolve(ip, domain, type);
+  sendResolve(ipport, domain, type);
   try {
-    ComboAddress from(ip);
+    ServiceTuple st;
+    st.port = 53;   
+    parseService(ipport, st);
+    ComboAddress from(st.host, st.port);
+
     return receiveResolve((sockaddr*)&from, from.getSocklen());
   }
   catch(ResolverException &re) {
-    throw ResolverException(re.reason+" from "+ip);
+    throw ResolverException(re.reason+" from "+ipport);
   }
   return 1;
   
@@ -290,11 +294,15 @@ void Resolver::makeTCPSocket(const string &ip, uint16_t port)
 }
 
 //! returns -1 for permanent error, 0 for timeout, 1 for success
-int Resolver::axfr(const string &ip, const char *domain)
+int Resolver::axfr(const string &ipport, const char *domain)
 {
   d_domain=domain;
 
-  makeTCPSocket(ip);
+  
+  ServiceTuple st;  
+  st.port = 53;     
+  parseService(ipport, st);
+  makeTCPSocket(st.host, st.port);
 
   d_type=QType::AXFR;
   
@@ -311,14 +319,14 @@ int Resolver::axfr(const string &ip, const char *domain)
 
   int ret=Utility::writev(d_sock,iov,2);
   if(ret<0)
-    throw ResolverException("Error sending question to "+ip+": "+stringerror());
+    throw ResolverException("Error sending question to "+ipport+": "+stringerror());
 
   int res = waitForData(d_sock, 10, 0);
   
   if(!res)
-    throw ResolverException("Timeout waiting for answer from "+ip+" during AXFR");
+    throw ResolverException("Timeout waiting for answer from "+ipport+" during AXFR");
   if(res<0)
-    throw ResolverException("Error waiting for answer from "+ip+": "+stringerror());
+    throw ResolverException("Error waiting for answer from "+ipport+": "+stringerror());
 
   d_soacount=0;
   d_inaxfr=true;