Merge pull request #152 from bakwc/fixDnsIssue

Fix dns issue

Author: bakwc

pysyncobj/dns_resolver.py

@@ -24,6 +24,7 @@ def resolve(self, hostname):
             prevIps = ips
             ips = self.__doResolve(hostname)
             if not ips:
+                logging.warning("failed to resolve hostname: " + hostname)
                 ips = prevIps
             self.__cache[hostname] = (currTime, ips)
         return None if not ips else random.choice(ips)

pysyncobj/node.py

@@ -69,7 +69,7 @@ def __init__(self, address, **kwargs):
         self.__address = address
         self.__host, port = address.rsplit(':', 1)
         self.__port = int(port)
-        self.__ip = globalDnsResolver().resolve(self.host)
+        #self.__ip = globalDnsResolver().resolve(self.host)
 
     @property
     def address(self):
@@ -85,7 +85,7 @@ def port(self):
 
     @property
     def ip(self):
-        return self.__ip
+        return globalDnsResolver().resolve(self.__host)
 
     def __repr__(self):
         v = vars(self)

pysyncobj/tcp_connection.py

@@ -71,6 +71,8 @@ def setOnDisconnectedCallback(self, onDisconnected):
         self.__onDisconnected = onDisconnected
 
     def connect(self, host, port):
+        if host is None:
+            return False
         self.__state = CONNECTION_STATE.DISCONNECTED
         self.__fileno = None
         self.__socket = socket.socket(_getAddrType(host), socket.SOCK_STREAM)