OwlCyberSecurity - MANAGER
Edit File: memcacher.pyc
� �t�ac @ s~ d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d e f d � � YZ d S( i����N( t succeed( t Logger( t CachePoolUserMixIn( t configt Memcacherc B sW e Z e � Z d Z d Z d Z e e e d Z d Z e j d j g e d � D] Z e e � ^ qR � e d � d d d � Z e Z i d e 6d e 6Z d d d � � YZ d d d � � YZ e e e d � Z d � Z d � Z d d � Z d d � Z d d d � Z e d � Z d � Z d d � Z d d � Z d � Z! e" d � � Z# RS( i� i i i t i! i t _t memoryCacherc B s� e Z d Z e d � Z d � Z d � Z d d � Z d d � Z d d d � Z e d � Z d � Z d d � Z d d � Z d � Z d � Z RS( s A class implementing the memcache client API we care about but using a dict to store the results in memory. This can be used for caching on a single instance server, and for tests, where memcached may not be running. c C s i | _ d | _ | | _ d S( Ni ( t _cachet _clockt _pickle( t selft pickle( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt __init__7 s c C s" t | t � s t d � � n d S( Ns memcache keys must be str type( t isinstancet strt ValueError( R t key( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt _check_key< s c C s- | j r) t | t � r) t d � � n d S( Ns memcache values must be str type( R R R R ( R t value( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt _check_value@ s i c C s� | j | � | j | � t | � t j k sJ t t | � � t j k rT t t � S| | j k r� | sr d } n | | j | d f | j | <t t � St t � Sd S( Ni�� i ( R R t lenR t MEMCACHE_KEY_LIMITR t MEMCACHE_VALUE_LIMITR t FalseR R t True( R R R t expireTime( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt addD s 0 c C s� | j | � | j | � t | � t j k sJ t t | � � t j k rT t t � S| sc d } n | | j k r� | j | d } | d 7} n d } | | j | | f | j | <t t � S( Ni�� i i i ( R R R R R R R R R R R R ( R R R R t identifier( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt setR s 0 c C s� | j | � | j | � t | � t j k sJ t t | � � t j k rT t t � S| sc d } n | | j k r� | j | d } | t | � k r� t t � S| d 7} n t t � S| | j | | f | j | <t t � S( Ni�� i i ( R R R R R R R R R R R R ( R R R t cast flagsR R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt checkAndSetb s 0 c C s� | j | � t | � t j k r4 d \ } } } n< | j j | d � \ } } } | j | k rp d } d } n | r� t d | t | � f � St d | f � Sd S( Ni R ( Ni R ( Ni R ( R R R R t NoneR t getR R R ( R R t withIdentifierR t expiresR ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR" t s c C sc | j | � t | � t j k r, t t � Sy | j | =t t � SWn t k r^ t t � SXd S( N( R R R R R R R R t KeyError( R R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt delete� s i c C s� | j | � t | � t j k r, t t � S| j j | d � } | d k r� | \ } } } y t | � } Wn t k r� d } q� X| | 7} t | � | | f | j | <n t | � S( N( R R R R R R R R" R! t intR R ( R R t deltaR t expireR ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt incr� s c C s� | j | � t | � t j k r, t t � S| j j | d � } | d k r� | \ } } } y t | � } Wn t k r� d } q� X| | 8} | d k r� d } n t | � | | f | j | <n t | � S( Ni ( R R R R R R R R" R! R' R R ( R R R( R R) R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt decr� s c C s i | _ t t � S( N( R R R ( R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt flushAll� s c C s | j | 7_ d S( N( R ( R t seconds( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt advanceClock� s ( t __name__t __module__t __doc__R R R R R R R R" R& R* R+ R, R. ( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR / s t nullCacherc B sk e Z d Z d d � Z d d � Z d d d � Z e d � Z d � Z d d � Z d d � Z d � Z RS( sz A class implementing the memcache client API we care about but does not actually cache anything. i c C s t t � S( N( R R ( R R R R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR � s c C s t t � S( N( R R ( R R R R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR � s c C s t t � S( N( R R ( R R R R R R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR � s c C s t d � S( Ni ( i N( R R! ( R R R# ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR" � s c C s t t � S( N( R R ( R R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR& � s i c C s t d � S( N( R R! ( R R R( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR* � s c C s t d � S( N( R R! ( R R R( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR+ � s c C s t t � S( N( R R ( R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR, � s ( R/ R0 R1 R R R R R" R& R* R+ R, ( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR2 � s c C se t | � t j k s+ t d t j f � � d | _ | | _ | | _ | | _ | | _ | | _ d S( s @param namespace: a unique namespace for this cache's keys @type namespace: C{str} @param pickle: if C{True} values will be pickled/unpickled when stored/read from the cache, if C{False} values will be stored directly (and therefore must be strings) @type pickle: C{bool} @param no_invalidation: if C{True} the cache is static - there will be no invalidations. This allows Memcacher to use the memoryCacher cache instead of nullCacher for the multi-instance case when memcached is not present,as there is no issue with caches in each instance getting out of sync. If C{False} the nullCacher will be used for the multi-instance case when memcached is not configured. @type no_invalidation: C{bool} @param key_normalization: if C{True} the key is assumed to possibly be longer than the Memcache key size and so additional work is done to truncate and append a hash. @type key_normalization: C{bool} sD Memcacher namespace must be less than or equal to %s characters longN( R R t NAMESPACE_MAX_LENGTHt AssertionErrorR! t _memcacheProtocolt _cachePoolHandlet _namespaceR t _noInvalidationt _key_normalization( R t namespaceR t no_invalidationt key_normalization( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR � s + c C s� | j d k r | j St j j j j r: | j � | _ n� t j d k s[ | j s[ | j r� t j | j d k r� t j | j � t j | j <n t j | j | _ n t j � | _ t | _ | j S( Nt Single( R5 R! R t Memcachedt Poolst Defaultt ClientEnabledt getCachePoolt ProcessTypeR8 t allowTestCacheR t memoryCacheInstanceR R R2 R ( R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt _getMemcacheProtocol� s ! c C s� t | t � r! | j d � } n t | t � s< t d � � | j r� t j | � j � } | t j } d | j t j � | f S| Sd S( Ns utf-8s Key must be a str.s %s-%s( R t unicodet encodeR R4 R9 t hashlibt md5t hexdigestR t TRUNCATED_KEY_LENGTHt translatet keyNormalizeTranslateTable( R R t hash( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt _normalizeKey s i c C so | j � } | } | j r- t j | � } n | j j d d | �| j d | j | j | � f | d | �S( Ns Adding Cache Token for {k!r}t ks %s:%sR ( RF R t cPicklet dumpst logt debugR R7 RP ( R R R R t protot my_value( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR s c C so | j � } | } | j r- t j | � } n | j j d d | �| j d | j | j | � f | d | �S( Ns Setting Cache Token for {k!r}RQ s %s:%sR ( RF R RR RS RT RU R R7 RP ( R R R R RV RW ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR " s c C sr | j � } | } | j r- t j | � } n | j j d d | �| j d | j | j | � f | | d | �S( Ns Setting Cache Token for {k!r}RQ s %s:%sR ( RF R RR RS RT RU R R7 RP ( R R R R R R RV RW ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR , s c sj � f d � } � j j d d | �� j � j d � j � j | � f d | �} | j | | � | S( Nc sd | r | \ } } } n | \ } } � j rK | d k rK t j | � } n | r` | | f } n | S( N( R R! RR t loads( t resultR# t _ignore_flagsR R ( R ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt _gotit7 s s Getting Cache Token for {k!r}RQ s %s:%sR# ( RT RU RF R" R7 RP t addCallback( R R R# R[ t d( ( R s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR" 6 s 1c C s? | j j d d | �| j � j d | j | j | � f � S( Ns Deleting Cache Token for {k!r}RQ s %s:%s( RT RU RF R& R7 RP ( R R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR& G s i c C sB | j j d d | �| j � j d | j | j | � f | � S( Ns" Incrementing Cache Token for {k!r}RQ s %s:%s( RT RU RF R* R7 RP ( R R R( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR* K s c C sB | j j d d | �| j � j d | j | j | � f | � S( Ns" Decrementing Cache Token for {k!r}RQ s %s:%s( RT RU RF R* R7 RP ( R R R( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR+ O s c C s | j j d � | j � j � S( Ns Flushing All Cache Tokens( RT RU RF R, ( R ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR, S s c C s i d t 6d t 6| _ d S( s* Reset the memory cachers N( R! R R RE ( t cls( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt resetW s i N( ( ($ R/ R0 R RT R R3 t HASH_LENGTHRL R t stringt maketranst joint ranget it chrRN R RD R! R RE R R2 R RF RP R R R R" R& R* R+ R, t classmethodR_ ( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyR s2 L � ( RI RR Ra t twisted.internet.deferR t twext.python.logR t twistedcaldav.memcachepoolR t twistedcaldav.configR R ( ( ( s* /opt/cpanel-ccs/twistedcaldav/memcacher.pyt <module> s