Revision 85061b9a lib/http/client.py
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