ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
twistedcaldav
/
Filename :
memcachepool.pyc
back
Copy
� �t�ac @ s d d l m Z d d l m Z m Z d d l m Z d d l m Z m 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 e f d � � YZ d e f d � � YZ d e f d � � YZ i Z i Z d e d � Z d e d � Z d � Z d S( i����( t Failure( t Deferredt fail( t ReconnectingClientFactory( t MemCacheProtocolt NoSuchCommand( t Logger( t GAIEndpoint( t connect( t UNIXClientEndpointt PooledMemCacheProtocolc B s e Z d Z d Z d � Z RS( s� A MemCacheProtocol that will notify a connectionPool that it is ready to accept requests. @ivar factory: A L{MemCacheClientFactory} instance. c C sE t j | � | j j d k rA | j j j | � d | j _ n d S( sL Notify our factory that we're ready to accept connections. N( R t connectionMadet factoryt deferredt Nonet callback( t self( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR & s N( t __name__t __module__t __doc__R R R ( ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR s t MemCacheClientFactoryc B sM e Z d Z e � Z e Z d Z d Z d � Z d � Z d � Z d � Z RS( sf A client factory for MemCache that reconnects and notifies a pool of it's state. @ivar connectionPool: A managing connection pool that we notify of events. @ivar deferred: A L{Deferred} that represents the initial connection. @ivar _protocolInstance: The current instance of our protocol that we pass to our connectionPool. c C s t � | _ d S( N( R R ( R ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt __init__A s c C sb | j j r d S| j j d d | �| j d k rK | j j | j � n t j | | | � d S( sK Notify the connectionPool that we've lost our connection. Ns MemCache connection lost: {r}t r( t connectionPoolt shutdown_requestedt logt errort _protocolInstanceR t clientBusyR t clientConnectionLost( R t connectort reason( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR D s c C sR | j j d d | �| j d k r; | j j | j � n t j | | | � d S( sH Notify the connectionPool that we're unable to connect s MemCache connection failed: {r}R N( R R R R R R R t clientConnectionFailed( R R R ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR V s c C sG | j d k r% | j j | j � n | j � | _ | | j _ | j S( st Attach the C{self.connectionPool} to the protocol so it can tell it, when we've connected. N( R R R t clientGonet protocolR ( R t addr( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt buildProtocolc s N( R R R R R R R" R R R R R R R$ ( ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR 1 s t MemCachePoolc B s� e Z d Z e � Z e Z d Z d d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� A connection pool for MemCacheProtocol instances. @ivar clientFactory: The L{ClientFactory} implementation that will be used for each protocol. @ivar _maxClients: A C{int} indicating the maximum number of clients. @ivar _endpoint: An L{IStreamClientEndpoint} provider indicating the server to connect to. @ivar _reactor: The L{IReactorTCP} provider used to initiate new connections. @ivar _busyClients: A C{set} that contains all currently busy clients. @ivar _freeClients: A C{set} that contains all currently free clients. @ivar _pendingConnects: A C{int} indicating how many connections are in progress. i i c C s� | | _ | | _ | d k r1 d d l m } n | | _ d | _ t | _ | j d d | j � t g � | _ t g � | _ d | _ g | _ d S( s @param endpoint: An L{IStreamClientEndpoint} indicating the server to connect to. @param maxClients: A C{int} indicating the maximum number of clients. @param reactor: An L{IReactorTCP} provider used to initiate new connections. i����( t reactort beforet shutdowni N( t _endpointt _maxClientsR t twisted.internetR& t _reactort shutdown_deferredt FalseR t addSystemEventTriggert _shutdownCallbackt sett _busyClientst _freeClientst _pendingConnectst _commands( R t endpointt maxClientsR& ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR � s c C s7 t | j � d k o6 t | j � d k o6 | j d k S( Ni ( t lenR2 R5 R4 ( R ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt _isIdle� s c C s, t | _ | j � r d St � | _ | j S( N( t TrueR R9 R R R- ( R ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR0 � s c s� � j j d d � j �� j � � j d 7_ � f d � } � j � } t | _ � | _ t � j | � | j } | j | � | S( s| Create a new client connection. @return: A L{Deferred} that fires with the L{IProtocol} instance. s* Initiating new client connection to: {r!r}R i c s � j d 8_ | S( Ni ( R4 ( t client( R ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt _connected� s ( R t debugR) t _logClientStatsR4 t clientFactoryR. t noisyR R R t addCallback( R R< R t d( ( R s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt _newClientConnection� s c s� � � f d � } � � � � f d � } � j � � t � � d � } | d k rg | � | � } n t t t � � � } | j | | � | S( s Perform the given request on the given client. @param client: A L{PooledMemCacheProtocol} that will be used to perform the given request. @param command: A C{str} representing an attribute of L{MemCacheProtocol}. @param args: Any positional arguments that should be passed to C{command}. @param kwargs: Any keyword arguments that should be passed to C{command}. @return: A L{Deferred} that fires with the result of the given command. c s � j � � | S( N( t clientFree( t result( R; R ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt _freeClientAfterRequest� s c sF � j j d d | j d � d d j � � � j �� j � � d S( s� Upon memcache error, log the failed request along with the error message and free the client. s+ Memcache error: {ex}; request: {cmd} {args}t ext cmdt argst N( R R t valuet joint REQUEST_LOGGING_SIZERD ( t failure( RI R; t commandR ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt _reportError� s N( R t getattrR R R R t addCallbacks( R R; RO RI t kwargsRF RP t methodRB ( ( RI R; RO R s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt _performRequestOnClient� s c O s� t | j � d k r? | j j � } | j | | | | � } n� t | j � | j | j k r� t � } | j j | | | | f � | j j d d | d | d | �| j � n% | j � } | j | j | | | � | S( s� Select an available client and perform the given request on it. @param command: A C{str} representing an attribute of L{MemCacheProtocol}. @param args: Any positional arguments that should be passed to C{command}. @param kwargs: Any keyword arguments that should be passed to C{command}. @return: A L{Deferred} that fires with the result of the given command. i s! Command queued: {c}, {a!r}, {k!r}t ct at k( R8 R3 t popRU R2 R4 R* R R5 t appendR R= R> RC RA ( R RO RI RS R; RB ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt performRequest� s c C sJ | j j d d t | j � d t | j � d | j d t | j � �d S( Ns; Clients #free: {f}, #busy: {b}, #pending: {p}, #queued: {q}t ft bt pt q( R R= R8 R3 R2 R4 R5 ( R ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR> $ s c C sh | | j k r" | j j | � n" | | j k rD | j j | � n | j j d d | �| j � d S( s� Notify that the given client is to be removed from the pool completely. @param client: An instance of L{PooledMemCacheProtocol}. s Removed client: {c!r}RV N( R2 t removeR3 R R= R> ( R R; ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR! - s c C sV | | j k r" | j j | � n | j j | � | j j d d | �| j � d S( s� Notify that the given client is being used to complete a request. @param client: An instance of C{self.clientFactory} s Busied client: {c!r}RV N( R3 R` R2 t addR R= R> ( R R; ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR < s c C s | | j k r" | j j | � n | j j | � | j rZ | j � rZ | j j d � n t | j � d k r� | j j d � \ } } } } | j j d d | d | d | �| j � | j | | | � } | j | j � n | j j d d | �| j � d S( s� Notify that the given client is free to handle more requests. @param client: An instance of C{self.clientFactory} i s( Performing Queued Command: {c}, {a}, {k}RV RW RX s Freed client: {c!r}N( R2 R` R3 Ra R- R9 R R R8 R5 RY R R= R> R[ RA ( R R; RB RO RI RS t _ign_d( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRD K s c C s | | _ d S( s� Suggest the maximum number of concurrently connected clients. @param maxClients: A C{int} indicating how many client connections we should keep open. N( R* ( R R7 ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt suggestMaxClientsj s c O s | j d | | � S( Nt get( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRd s s c O s | j d | | � S( NR1 ( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR1 v s c O s | j d | | � S( Nt checkAndSet( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRe y s c O s | j d | | � S( Nt delete( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRf | s c O s | j d | | � S( NRa ( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRa s c O s | j d | | � S( Nt increment( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt incr� s c O s | j d | | � S( Nt decrement( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt decr� s c O s | j d | | � S( Nt flushAll( R[ ( R RI RS ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRk � s N( R R R R R R R? RM R R R9 R0 RC RU R[ R> R! R RD Rc Rd R1 Re Rf Ra Rh Rj Rk ( ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyR% p s. , % t CachePoolUserMixInc B s# e Z d Z d Z d Z d � Z RS( s~ A mixin that returns a saved cache pool or fetches the default cache pool. @ivar _cachePool: A saved cachePool. t Defaultc C s# | j d k r t | j � S| j S( N( t _cachePoolR t defaultCachePoolt _cachePoolHandle( R ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt getCachePool� s N( R R R R Rn Rp Rq ( ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRl � s i c C s� | d k r d d l m } n x� | j � D]r \ } } | d r, | j d � rg t | | d � } n t | | d | d � } t | | d | | | � q, q, Wd S( Ni����( R& t ClientEnabledt MemcacheSockett BindAddresst Portt HandleCacheTypes( R R+ R& t itemsRd R R t _installPool( t poolsR7 R& t namet poolt ep( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt installPools� s c C sA t | d | d d �} | t | <x | D] } | t | <q) Wd S( NR7 R& ( R% R t _memCachePoolst _memCachePoolHandler( Rz t handleTypest serverEndpointR7 R& R{ t handle( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRx � s c C s | t k r d } n t | S( NRm ( R ( Rz ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyRo � s N( t twisted.python.failureR t twisted.internet.deferR R t twisted.internet.protocolR t twisted.protocols.memcacheR R t twext.python.logR t twext.internet.gaiendpointR t twext.internet.adaptendpointR t twisted.internet.endpointsR R R t objectR% Rl R~ R R R} Rx Ro ( ( ( s- /opt/cpanel-ccs/twistedcaldav/memcachepool.pyt <module> s" ?�