Revision 85061b9a
| b/lib/http/client.py | ||
|---|---|---|
| 188 | 188 |
""" |
| 189 | 189 |
assert not self._req, "Another request is already started" |
| 190 | 190 |
|
| 191 |
logging.debug("Starting request %r", req)
|
|
| 192 |
|
|
| 191 | 193 |
self._req = req |
| 192 | 194 |
self._resp_buffer = StringIO() |
| 193 | 195 |
|
| ... | ... | |
| 297 | 299 |
self._generation = 0 |
| 298 | 300 |
self._pool = {}
|
| 299 | 301 |
|
| 302 |
# Create custom logger for HTTP client pool. Change logging level to |
|
| 303 |
# C{logging.NOTSET} to get more details.
|
|
| 304 |
self._logger = logging.getLogger(self.__class__.__name__) |
|
| 305 |
self._logger.setLevel(logging.INFO) |
|
| 306 |
|
|
| 300 | 307 |
@staticmethod |
| 301 | 308 |
def _GetHttpClientCreator(): |
| 302 | 309 |
"""Returns callable to create HTTP client. |
| ... | ... | |
| 317 | 324 |
# Need to create new client |
| 318 | 325 |
client = self._GetHttpClientCreator()(self._curl_config_fn) |
| 319 | 326 |
pclient = _PooledHttpClient(identity, client) |
| 320 |
logging.debug("Created new client %s", pclient)
|
|
| 327 |
self._logger.debug("Created new client %s", pclient)
|
|
| 321 | 328 |
else: |
| 322 |
logging.debug("Reusing client %s", pclient)
|
|
| 329 |
self._logger.debug("Reusing client %s", pclient)
|
|
| 323 | 330 |
|
| 324 | 331 |
assert pclient.identity == identity |
| 325 | 332 |
|
| ... | ... | |
| 332 | 339 |
@param req: HTTP request |
| 333 | 340 |
|
| 334 | 341 |
""" |
| 335 |
logging.debug("Starting request %r", req)
|
|
| 336 | 342 |
pclient = self._Get(req.identity) |
| 337 | 343 |
|
| 338 | 344 |
assert req.identity not in self._pool |
| ... | ... | |
| 347 | 353 |
|
| 348 | 354 |
""" |
| 349 | 355 |
for pc in pclients: |
| 350 |
logging.debug("Returning client %s to pool", pc)
|
|
| 356 |
self._logger.debug("Returning client %s to pool", pc)
|
|
| 351 | 357 |
assert pc.identity not in self._pool |
| 352 | 358 |
assert pc not in self._pool.values() |
| 353 | 359 |
self._pool[pc.identity] = pc |
| ... | ... | |
| 355 | 361 |
# Check for unused clients |
| 356 | 362 |
for pc in self._pool.values(): |
| 357 | 363 |
if (pc.lastused + self._MAX_GENERATIONS_DROP) < self._generation: |
| 358 |
logging.debug("Removing client %s which hasn't been used"
|
|
| 359 |
" for %s generations", |
|
| 360 |
pc, self._MAX_GENERATIONS_DROP) |
|
| 364 |
self._logger.debug("Removing client %s which hasn't been used"
|
|
| 365 |
" for %s generations",
|
|
| 366 |
pc, self._MAX_GENERATIONS_DROP)
|
|
| 361 | 367 |
self._pool.pop(pc.identity, None) |
| 362 | 368 |
|
| 363 | 369 |
assert compat.all(pc.lastused >= (self._generation - |
Also available in: Unified diff