ó
öEYc@@s·dZd
dl
mZmZ
d
dlZd
dlmZ
ddlmZ
ddl	m
Z
mZ
ddl
mZ
dd	lmZ
d
„Zdef
d„ƒYZd
ef
d„ƒYZdS(u%Generic resource pool implementation.i(tabsolute_importtunicode_literalsN(
tdequei
(
t
exceptions(tEmptyt	LifoQueue(
tregister_after_fork(
tlazyc

C@s&y|jƒ
Wnt
k
r!


n
XdS(
N(tforce_close_allt	Exception(
tresource((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyt_after_fork_cleanup_resources




Rc
B@seZ
dZd
„ZRS(u#Last in first out version of Queue.cC@stƒ|_
dS(
N(Rtqueue(tselftmaxsize((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyt_inits
(t__name__t
__module__t__doc__R(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyRs
tResourcecB@s
eZ
dZejZeZdddd
„Zd„Z	d„Z
edd„Zd„Zd„Z
d„Zd„Zd	„Zd
„Zd„Zeeed„Zd
„Zed„ƒ
Zejd„ƒ
Zejjdƒ
r
eZeZdZd„Zd„ZnRS(uPool of resources.cC@sŠ|
|_|pd
|_
t|_|dk	r3|n|j|_tƒ|_tƒ|_	|jr|t
dk	r|t
|tƒ
n|jƒ
dS(Ni(
t_limittpreloadtFalset_closedtNonetclose_after_forkRt	_resourcetsett_dirtyRRtsetup(R
tlimitRR((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyt__init__#s
	

	



c

C@std
ƒ
‚
dS(Nusubclass responsibility(
tNotImplementedError(
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR2s
c

C@sP|jr6t
|jƒ
|jkr6|j|jƒ
‚
n|jj|jƒƒ

dS(
N(RtlenRt
LimitExceededRt
put_nowaittnew(
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyt_add_when_empty5s
!
c@s
ˆ
jrt
d
ƒ
‚
nˆ
jrÑxÂyˆ
jjd|
d|ƒ‰Wntk
r`


ˆ
jƒ
q$Xyˆ
jˆƒ
‰WnCtk
r¹


t	ˆt
ƒr¦ˆ
jjˆƒ

n
ˆ
jˆƒ

‚n
Xˆ
j
jˆƒ

Pq$nˆ
jˆ
jƒƒ
‰‡‡
fd†}|ˆ_ˆS(uv
Acquire resource.

        Arguments:
            block (bool): If the limit is exceeded,
                then block until there is an available item.
            timeout (float): Timeout to wait
                if ``block`` is true.  Default is :const:`None` (forever).

        Raises:
            LimitExceeded: if block is false and the limit has been exceeded.
        uAcquire on closed pooltblockttimeoutc@sˆ
jˆƒ

d
S(u
Release resource so it can be used by another thread.

            Warnings:
                The caller is responsible for discarding the object,
                and to never use the resource again.  A new resource must
                be acquired if so needed.
            N(
trelease((t
RR
(sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR(as(RtRuntimeErrorRRtgetRR%tpreparet
BaseExceptiont
isinstanceRR#R(RtaddR$(R
R&R'R(((R)R
sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pytacquire=s*	

	













		c
C@s|
S(
N((R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR,ns
c
C@s|
jƒ
dS(
N(
tclose(R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pytclose_resourceqs
c
C@sdS(
N((R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pytrelease_resourcets
cC@s-|jr|j
j|
ƒ

n|j|
ƒ

d
S(uqReplace existing resource with a new instance.

        This can be used in case of defective resources.
        N(RRtdiscardR2(R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pytreplacews	

cC@sJ|jr9|j
j|
ƒ

|jj|
ƒ

|j|
ƒ

n
|j|
ƒ

dS(
N(RRR4RR#R3R2(R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR(€s

	


c
C@sdS(
N((R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pytcollect_resourceˆs
c
C@sÏ|jr
d
St
|_|j}
|j}xMy|
jƒ}Wntk
rO


Pn
Xy|j|ƒ

Wq+tk
rt


q+Xq+xPy|jjƒ}Wnt	k
r¢


Pn
Xy|j|ƒ

Wq{tk
rÇ


q{Xq{d
S(u®Close and remove all resources in the pool (also those in use).

        Used to close resources from parent processes after fork
        (e.g. sockets/connections).
        N(
RtTrueRRtpoptKeyErrorR6tAttributeErrorRt
IndexError(R
tdirtyR
tdrestres((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR‹s.	

	
	
	




















cC@s°|j}|j
rU|
|jkrU|rU|sLtd
j|
|jƒƒ
‚
nt}n|
|_|r‰y|jƒ
Wq‰tk
r…


q‰Xn|jƒ
|
|kr¬|jƒ
ndS(Nu.Can't shrink pool when in use: was={0} now={1}(	RRR*tformatR7RR	Rt_shrink_down(R
Rtforcet
ignore_errorstresett
prev_limit((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pytresize¬s 
	





	
	









c
C@sR|j}
|
j
:
x2t|
jƒ
|jkrG|j|
jjƒƒ

qWWdQXdS(
N(RtmutexR!RRR6tpopleft(R
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR@¾s
	


c


C@s|jS(
N(
R(
R
((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyRÅscC@s|j|
ƒ

dS(
N(
RE(R
R((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyRÉsuKOMBU_DEBUG_POOLic
O@sžd
dl}|j
d}|_
dj||jjƒGH|j|
|Ž}||_dj||jjƒGHt|dƒs„g|_n|jj	|j
ƒƒ

|S(Nii
u+{0} ACQUIRE {1}u-{0} ACQUIRE {1}uacquired_by(t	tracebackt_next_resource_idR?t	__class__Rt
_orig_acquiret_resource_idthasattrtacquired_bytappendtformat_stack(R
targstkwargsRHtidt
r((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR0Ós




	




cC@sY|
j}d
j
||jjƒGH|j|
ƒ
}dj
||jjƒGH|jd8_|S(Nu+{0} RELEASE {1}u-{0} RELEASE {1}i
(RLR?RJRt
_orig_releaseRI(R
R
RSRT((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyR(ßs
	




N(RRRRR"RRRRRR%R0R,R2R3R5R(R6RRER@tpropertyRtsettertostenvironR+RKRURI(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyRs0
			1								!	

	(Rt
__future__RR
RXtcollectionsRtRtfiveRRt
_LifoQueuetutils.compatRtutils.functionalRRtobjectR(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/resource.pyt<module>
s