NhEc @ sh d d k Z d d k Td d k l Z l Z d d k Z d e f d YZ d e f d YZ d S( iN( t *( t NamespaceManagert Containert MemcachedNamespaceManagerc B s e Z d Z d Z d Z e d Z d Z d Z d Z d Z
d Z d Z d
Z
d Z d Z d
Z RS( c K s5 t i | | | | t i | g d d | _ d S( Nt debugi ( R t __init__t memcachet Clientt mc( t selft contextt namespacet urlt params( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyR s c C s d S( N( ( R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_acquire_read_lock s c C s d S( N( ( R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_release_read_lock s c C s t S( N( t True( R t wait( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_acquire_write_lock s c C s d S( N( ( R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_release_write_lock s c O s d S( N( ( R t argsR
( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt open s c O s d S( N( ( R R R
( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt close s c C s> | i i | i d | } | d j o t | n | S( Nt _( R t getR t Nonet KeyError( R t keyt value( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt __getitem__ s
c C s! | i i | i d | d j S( NR ( R R R R ( R R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt __contains__ s c C s! | i i | i d | d j S( NR ( R R R R ( R R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt has_key! s c C sv | i i | i d } | d j o
h } n t | | <| i i | i d | | i i | i d | | d S( Ns :keysR ( R R R R R t set( R R R t keys( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt __setitem__$ s
c C sv | i i | i d } y@ | | =| i i | i d | | i i | i d | Wn t j
o
n Xd S( Ns :keysR ( R R R t deleteR R ( R R R! ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt __delitem__, s c C s d S( N( ( R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_remove5 s c C s9 | i i | i d } | d j o g S| i Sd S( Ns :keys( R R R R R! ( R R! ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyR! 8 s
( t __name__t
__module__R R R R R R R R R R R R" R$ R% R! ( ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyR s t MemcachedContainerc B s/ e Z d Z d Z e d Z d Z RS( c K s
d | _ d S( N( R t funclock( R R
( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_initA s c K s t | | | | S( N( R ( R R
R R R
( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt do_create_namespace_managerD s c C sR | i d j o2 t d d | i i d t d | i i | _ n | i i | S( Nt
identifiers memcachedcontainer/funclock/%st use_filest lock_dir( R) R t Synchronizert namespacemanagerR R R. t acquire_write_lock( R R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt lock_createfuncG s
c C s | i i d S( N( R) t release_write_lock( R ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt unlock_createfuncO s ( R& R' R* R+ R R2 R4 ( ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyR( ? s ( R t myghty.synchronizationt myghty.containerR R t sysR R( ( ( ( s8 /usr/lib/python2.6/site-packages/myghty/ext/memcached.pyt s
8