Revision 6293aa78 kamaki/clients/__init__.py
b/kamaki/clients/__init__.py | ||
---|---|---|
281 | 281 |
recvlog.debug( |
282 | 282 |
'\n'.join(['%s' % type(err)] + format_stack())) |
283 | 283 |
raise |
284 |
raise ClientError( |
|
285 |
'Failed while http-connecting to %s (%s)' % ( |
|
286 |
self.request.url, err)) |
|
287 | 284 |
|
288 | 285 |
@property |
289 | 286 |
def status_code(self): |
... | ... | |
383 | 380 |
self.token = token |
384 | 381 |
self.headers, self.params = dict(), dict() |
385 | 382 |
self.poolsize = None |
383 |
self.headers_to_decode, self.header_prefices = [], [] |
|
386 | 384 |
|
387 | 385 |
def _init_thread_limit(self, limit=1): |
388 | 386 |
assert isinstance(limit, int) and limit > 0, 'Thread limit not a +int' |
... | ... | |
503 | 501 |
req, |
504 | 502 |
poolsize=self.poolsize, |
505 | 503 |
connection_retry_limit=self.CONNECTION_RETRY_LIMIT) |
504 |
r.headers_to_decode = self.headers_to_decode |
|
505 |
r.header_prefices = self.header_prefices |
|
506 | 506 |
r.LOG_TOKEN, r.LOG_DATA, r.LOG_PID = ( |
507 | 507 |
self.LOG_TOKEN, self.LOG_DATA, self.LOG_PID) |
508 | 508 |
r._token = headers['X-Auth-Token'] |
Also available in: Unified diff