From a5489516ebbf450504db38a801d001d44f0dc402 Mon Sep 17 00:00:00 2001
From: Miroslav Stampar <miroslav.stampar@gmail.com>
Date: Fri, 20 Nov 2015 16:52:59 +0100
Subject: [PATCH] Fixes #1550

---
 lib/core/option.py | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/lib/core/option.py b/lib/core/option.py
index b666c79a6..7c7a39d5e 100644
--- a/lib/core/option.py
+++ b/lib/core/option.py
@@ -1027,12 +1027,13 @@ def _setSocketPreConnect():
     def _():
         while kb.threadContinue:
             try:
-                for address in socket._ready:
-                    if len(socket._ready[address]) < SOCKET_PRE_CONNECT_QUEUE_SIZE:
-                        s = socket.socket()
+                for key in socket._ready:
+                    if len(socket._ready[key]) < SOCKET_PRE_CONNECT_QUEUE_SIZE:
+                        family, type, proto, address = key
+                        s = socket.socket(family, type, proto)
                         s._connect(address)
                         with kb.locks.socket:
-                            socket._ready[address].append(s._sock)
+                            socket._ready[key].append(s._sock)
             except socket.error:
                 pass
             finally:
@@ -1040,11 +1041,12 @@ def _setSocketPreConnect():
 
     def connect(self, address):
         found = False
+        key = (self.family, self.type, self.proto, address)
         with kb.locks.socket:
-            if address not in socket._ready:
-                socket._ready[address] = []
-            if len(socket._ready[address]) > 0:
-                self._sock = socket._ready[address].pop(0)
+            if key not in socket._ready:
+                socket._ready[key] = []
+            if len(socket._ready[key]) > 0:
+                self._sock = socket._ready[key].pop(0)
                 found = True
         if not found:
             self._connect(address)