Add compatibility for Ipv6 address

Signed-off-by: Matt Cipperly <[email protected]>

Author: valentin benozillo

fluent/sender.py

@@ -120,6 +120,13 @@ def close(self):
             self._close()
             self.pendings = None
 
+    def _is_ipv4_host(self):
+        try:
+            socket.getaddrinfo(self.host, None, socket.AF_INET)
+            return True
+        except socket.error:
+            return False
+
     def _make_packet(self, label, timestamp, data):
         if label:
             tag = '.'.join((self.tag, label))
@@ -201,7 +208,12 @@ def _reconnect(self):
                     sock.settimeout(self.timeout)
                     sock.connect(self.host[len('unix://'):])
                 else:
-                    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+                    if self._is_ipv4_host():
+                        sock = socket.socket(socket.AF_INET,
+                                             socket.SOCK_STREAM)
+                    else:
+                        sock = socket.socket(socket.AF_INET6,
+                                             socket.SOCK_STREAM)
                     sock.settimeout(self.timeout)
                     # This might be controversial and may need to be removed
                     sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)