Synnefo

from httplib import (

        HTTPConnection  as http_class,

        HTTPSConnection as https_class,

        ResponseNotReady

)

from new import instancemethod

_pools = {}

pool_size = 8

def put_http_connection(conn):

    pool = conn._pool

    if pool is None:

        return

    # conn._pool = None

    pool.pool_put(conn)

    }

    def __init__(self, scheme, netloc, size=None):

        ObjectPool.__init__(self, size=size)

        connection_class = self._scheme_to_class.get(scheme, None)

        self.netloc = netloc

    def _pool_create(self):

        conn = self.connection_class(self.netloc)

        conn._use_counter = USAGE_LIMIT

        conn._pool = self

        return conn

    def _pool_verify(self, conn):

            return False

        if sock is None:

            return True

        if select((conn.sock,), (), (), 0)[0]:

        return True

    def _pool_cleanup(self, conn):

        # every connection can be used a finite number of times

        conn._use_counter -= 1

        # see httplib source for connection states documentation

        if conn._use_counter > 0 and conn._HTTPConnection__state == 'Idle':

            try:

            except ResponseNotReady:

        conn._real_close()

        return True

def get_http_connection(netloc=None, scheme='http', pool_size=pool_size):

    if netloc is None:

        m = "netloc cannot be None"

        raise ValueError(m)

    # does the pool need to be created?

    if netloc not in _pools:

        pool = HTTPConnectionPool(scheme, netloc, size=pool_size)

        _pools[netloc] = pool