fdZddlmZddlmZddlZddlZddlmZGddejZy)z,A threadsafe pool of httplib2.Http handlers.)absolute_import)print_functionN)rangec*eZdZdZddZdZdZdZy)Httpz.A threadsafe pool of httplib2.Http transports.ctjtj|_t |Dcgc] }| c}|_ycc}wN) threading ConditionLock _conditionr _transports)selftransport_factorysize_s >lib/third_party/containerregistry/transport/transport_pool_.py__init__z Http.__init__s=)))..*:;DO5:4[A[)+[ADAsAc|j5 |jr#|jjcdddS|jjJ#1swYyxYwr )r rpopwait)rs r_get_transportzHttp._get_transport!sM     !!%%'    s'AAA"c|j5|jj||jjddddy#1swYyxYw)N)n)r rappendnotify)r transports r_return_transportzHttp._return_transport+s>  i( ooq! s 8AAc|j} |j|i||j|S#|j|wxYw)zThis awaits a transport and delegates the request call. Args: *args: arguments to request. **kwargs: named arguments to request. Returns: tuple of response and content. )rrequestr)rargskwargsrs rr!z Http.request2sI##%I( Y   / / Y'dY's 5AN))__name__ __module__ __qualname____doc__rrrr!rrrs6B"(r*r) r( __future__rrr httplib2 six.movesrrr)r*rr.s)3&%&(8==&(r*