Show More
@@ -156,7 +156,7 b' class ConnectionManager(object):' | |||||
156 | try: |
|
156 | try: | |
157 | for c in self._hostmap[host]: |
|
157 | for c in self._hostmap[host]: | |
158 | if self._readymap[c]: |
|
158 | if self._readymap[c]: | |
159 |
self._readymap[c] = |
|
159 | self._readymap[c] = False | |
160 | conn = c |
|
160 | conn = c | |
161 | break |
|
161 | break | |
162 | finally: |
|
162 | finally: | |
@@ -200,7 +200,7 b' class KeepAliveHandler(object):' | |||||
200 | def _request_closed(self, request, host, connection): |
|
200 | def _request_closed(self, request, host, connection): | |
201 | """tells us that this request is now closed and that the |
|
201 | """tells us that this request is now closed and that the | |
202 | connection is ready for another request""" |
|
202 | connection is ready for another request""" | |
203 |
self._cm.set_ready(connection, |
|
203 | self._cm.set_ready(connection, True) | |
204 |
|
204 | |||
205 | def _remove_connection(self, host, connection, close=0): |
|
205 | def _remove_connection(self, host, connection, close=0): | |
206 | if close: |
|
206 | if close: | |
@@ -237,7 +237,7 b' class KeepAliveHandler(object):' | |||||
237 | if DEBUG: |
|
237 | if DEBUG: | |
238 | DEBUG.info("creating new connection to %s (%d)", |
|
238 | DEBUG.info("creating new connection to %s (%d)", | |
239 | host, id(h)) |
|
239 | host, id(h)) | |
240 |
self._cm.add(host, h, |
|
240 | self._cm.add(host, h, False) | |
241 | self._start_transaction(h, req) |
|
241 | self._start_transaction(h, req) | |
242 | r = h.getresponse() |
|
242 | r = h.getresponse() | |
243 | # The string form of BadStatusLine is the status line. Add some context |
|
243 | # The string form of BadStatusLine is the status line. Add some context |
General Comments 0
You need to be logged in to leave comments.
Login now