# -*- coding: utf-8 -*-
#
# © 2009 Digg. All rights reserved.
# Author: Ian Eure <ian@digg.com>
#

"""Replay a log file with multiprocessing."""

from __future__ import with_statement
import logging
from multiprocessing.dummy import Pool
import threading
from replay import mapc_time

from apache_replay import generate, request

POOL = Pool(10)


if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG)
    mapc_time(lambda *args: POOL.apply_async(request, args),
              generate('apache-access.log'))
    POOL.close()
    POOL.join()

01e5f365ab8898836bf92a11766645a8a2875b72
<mask token>

<mask token>
if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG)
    mapc_time(lambda *args: POOL.apply_async(request, args), generate(
        'apache-access.log'))
    POOL.close()
    POOL.join()

<mask token>
POOL = Pool(10)
if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG)
    mapc_time(lambda *args: POOL.apply_async(request, args), generate(
        'apache-access.log'))
    POOL.close()
    POOL.join()

<mask token>
from __future__ import with_statement
import logging
from multiprocessing.dummy import Pool
import threading
from replay import mapc_time
from apache_replay import generate, request
POOL = Pool(10)
if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG)
    mapc_time(lambda *args: POOL.apply_async(request, args), generate(
        'apache-access.log'))
    POOL.close()
    POOL.join()

# -*- coding: utf-8 -*-
#
# © 2009 Digg. All rights reserved.
# Author: Ian Eure <ian@digg.com>
#

"""Replay a log file with multiprocessing."""

from __future__ import with_statement
import logging
from multiprocessing.dummy import Pool
import threading
from replay import mapc_time

from apache_replay import generate, request

POOL = Pool(10)


if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG)
    mapc_time(lambda *args: POOL.apply_async(request, args),
              generate('apache-access.log'))
    POOL.close()
    POOL.join()
