Revision 61d579fb
b/kamaki/clients/__init__.py | ||
---|---|---|
340 | 340 |
self.base_url = base_url |
341 | 341 |
self.token = token |
342 | 342 |
self.headers, self.params = dict(), dict() |
343 |
self.poolsize = None |
|
343 | 344 |
|
344 | 345 |
def _init_thread_limit(self, limit=1): |
345 | 346 |
assert isinstance(limit, int) and limit > 0, 'Thread limit not a +int' |
... | ... | |
457 | 458 |
data=data, headers=headers, params=params) |
458 | 459 |
# req.log() |
459 | 460 |
r = ResponseManager( |
460 |
req, connection_retry_limit=self.CONNECTION_RETRY_LIMIT) |
|
461 |
req, |
|
462 |
poolsize=self.poolsize, |
|
463 |
connection_retry_limit=self.CONNECTION_RETRY_LIMIT) |
|
461 | 464 |
r.LOG_TOKEN, r.LOG_DATA, r.LOG_PID = ( |
462 | 465 |
self.LOG_TOKEN, self.LOG_DATA, self.LOG_PID) |
463 | 466 |
r._token = headers['X-Auth-Token'] |
Also available in: Unified diff