Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-4-0-patch / contego deb
Repository URL to install this package:
|
Version:
4.0.112 ▾
|
ó
ëEYc @ s[ d d l m Z d d l Z e j e Z d e f d YZ d e f d YZ d S( i ( t threadingiÿÿÿÿNt LockErrorc B s e Z RS( ( t __name__t
__module__( ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyR s t ReadWriteMutexc B sA e Z d Z d Z e d Z d Z e d Z d Z RS( sÄ A mutex which allows multiple readers, single writer.
:class:`.ReadWriteMutex` uses a Python ``threading.Condition``
to provide this functionality across threads within a process.
The Beaker package also contained a file-lock based version
of this concept, so that readers/writers could be synchronized
across processes with a common filesystem. A future Dogpile
release may include this additional class at some point.
c C s. d | _ d | _ t j t j | _ d S( Ni ( t asynct Nonet current_sync_operationR t Conditiont Lockt condition( t self( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyt __init__ s c C s | j j zb | r< x6 | j d k r8 | j j q Wn | j d k rO t S| j d 7_ t j d | Wd | j j X| s t
Sd S( s Acquire the 'read' lock.i s %s acquired read lockN( R
t acquireR R t waitt FalseR t logt debugt releaset True( R R ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyt acquire_read_lock" s
c C s | j j zr | j d 8_ | j d k rP | j d k rn | j j qn n | j d k rn t d n t j d | Wd | j j Xd S( s Release the 'read' lock.i i s7 Synchronizer error - too many release_read_locks calleds %s released read lockN(
R
R
R R R t notifyAllR R R R ( R ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyt release_read_lock8 s
c C sà | j j z | r< x6 | j d k r8 | j j q Wn | j d k rO t St j | _ | j d k r | r | j j q d | _ t Sn t j
d | Wd | j j X| s¿ t Sd S( s Acquire the 'write' lock.i s %s acquired write lockN(
R
R
R R R R R t
currentThreadR R R R R ( R R ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyt acquire_write_lockL s"
c C sp | j j zN | j t j k r4 t d n d | _ | j j t j d | Wd | j j
Xd S( s Release the 'write' lock.s? Synchronizer error - current thread doesn't have the write locks %s released write lockN( R
R
R R R R R R R R R ( R ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyt release_write_lockr s
( R R t __doc__R R R R R R ( ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyR s
&(
t compatR t loggingt getLoggerR R t ExceptionR t objectR ( ( ( sP /home/tvault/.virtenv/lib/python2.7/site-packages/dogpile/util/readwrite_lock.pyt <module> s