Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/protocols/__pycache__/memcache.cpython-39.pyc
Ðазад
a k�hc\ � @ s� d Z ddlmZ ddlmZmZmZ ddlmZ ddl m Z ddl m Z ddl mZmZ dZG d d � d e�ZG d d � d e�ZG d d� de�ZG dd� d�ZG dd� dee �Zg d�ZdS )ap Memcache client protocol. Memcached is a caching server, storing data in the form of pairs key/value, and memcache is the protocol to talk with it. To connect to a server, create a factory for L{MemCacheProtocol}:: from twisted.internet import reactor, protocol from twisted.protocols.memcache import MemCacheProtocol, DEFAULT_PORT d = protocol.ClientCreator(reactor, MemCacheProtocol ).connectTCP("localhost", DEFAULT_PORT) def doSomething(proto): # Here you call the memcache operations return proto.set("mykey", "a lot of data") d.addCallback(doSomething) reactor.run() All the operations of the memcache protocol are present, but L{MemCacheProtocol.set} and L{MemCacheProtocol.get} are the more important. See U{http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt} for more information about the protocol. � )�deque)�Deferred� TimeoutError�fail)� LineReceiver)� TimeoutMixin)�log)� nativeString� networkStringi�+ c @ s e Zd ZdZdS )� NoSuchCommandzA Exception raised when a non existent command is called. N��__name__� __module__� __qualname__�__doc__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/protocols/memcache.pyr ( s r c @ s e Zd ZdZdS )� ClientErrorz1 Error caused by an invalid client call. Nr r r r r r . s r c @ s e Zd ZdZdS )� ServerErrorz* Problem happening on the server. Nr r r r r r 4 s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �Commanda8 Wrap a client action into an object, that holds the values used in the protocol. @ivar _deferred: the L{Deferred} object that will be fired when the result arrives. @type _deferred: L{Deferred} @ivar command: name of the command sent to the server. @type command: L{bytes} c K s0 || _ t� | _|�� D ]\}}t| ||� qdS )z� Create a command. @param command: the name of the command. @type command: L{bytes} @param kwargs: this values will be stored as attributes of the object for future use N)�commandr � _deferred�items�setattr)�selfr �kwargs�k�vr r r �__init__G s zCommand.__init__c C s | j �|� dS )zB Shortcut method to fire the underlying deferred. N)r �callback)r �valuer r r �successV s zCommand.successc C s | j �|� dS )z5 Make the underlying deferred fails. N)r Zerrback)r �errorr r r r \ s z Command.failN)r r r r r r! r r r r r r : s r c @ sT e Zd ZdZdZdZdRdd�Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� ZdSd.d/�ZdTd0d1�Zd2d3� Z dUd5d6�Z dVd7d8�Z dWd9d:�Z dXd;d<�Z d=d>� Z!d?d@� Z"dAdB� Z#dYdCdD�Z$dZdEdF�Z%dGdH� Z&d[dJdK�Z'dLdM� Z(dNdO� Z)dPdQ� Z*dIS )\�MemCacheProtocola1 MemCache protocol: connect to a memcached server to store/retrieve values. @ivar persistentTimeOut: the timeout period used to wait for a response. @type persistentTimeOut: L{int} @ivar _current: current list of requests waiting for an answer from the server. @type _current: L{deque} of L{Command} @ivar _lenExpected: amount of data expected in raw mode, when reading for a value. @type _lenExpected: L{int} @ivar _getBuffer: current buffer of data, used to store temporary data when reading in raw mode. @type _getBuffer: L{list} @ivar _bufferLength: the total amount of bytes in C{_getBuffer}. @type _bufferLength: L{int} @ivar _disconnected: indicate if the connectionLost has been called or not. @type _disconnected: L{bool} � F�< c C s* t � | _d| _d| _d| _| | _| _dS )z� Create the protocol. @param timeOut: the timeout to wait before detecting that the connection is dead and close it. It's expressed in seconds. @type timeOut: L{int} N)r �_current� _lenExpected� _getBuffer� _bufferLength�persistentTimeOut�timeOut)r r+ r r r r � s zMemCacheProtocol.__init__c C s | j r | j �� }|�|� q dS )zW Cancel all the outstanding commands, making them fail with C{reason}. N)r& �popleftr )r �reason�cmdr r r �_cancelCommands� s z MemCacheProtocol._cancelCommandsc C s | � td�� | j�� dS )z: Close the connection in case of timeout. zConnection timeoutN)r/ r � transportZloseConnection�r r r r �timeoutConnection� s z"MemCacheProtocol.timeoutConnectionc C s d| _ | �|� t�| |� dS )z9 Cause any outstanding commands to fail. TN)� _disconnectedr/ r �connectionLost)r r- r r r r4 � s z MemCacheProtocol.connectionLostc C s" | j s| �| j� t�| |� dS )zA Override sendLine to add a timeout to response. N)r& � setTimeoutr* r �sendLine)r �liner r r r6 � s zMemCacheProtocol.sendLinec C s� | � � | j�|� | jt|�7 _| j| jd kr�d�| j�}|d| j� }|| jd d� }|}d| _d| _d| _| jd }|jr�|j |j \}}|||f|j |j < n||_ | � |� dS )z) Collect data for a get. � � Nr ) � resetTimeoutr( �appendr) �lenr' �joinr& �multiple�values� currentKeyr Z setLineMode)r �data�buf�rem�valr. �flags�casr r r �rawDataReceived� s" z MemCacheProtocol.rawDataReceivedc C s | j �� �d� dS )z? Manage a success response to a set operation. TN�r& r, r! r1 r r r � cmd_STORED� s zMemCacheProtocol.cmd_STOREDc C s | j �� �d� dS )z� Manage a specific 'not stored' response to a set operation: this is not an error, but some condition wasn't met. FNrH r1 r r r �cmd_NOT_STORED� s z MemCacheProtocol.cmd_NOT_STOREDc C s� | j �� }|jdkrN|jr:dd� |j�� D �}|�|� q�|�|j|jf� nb|jdkr�|jrl|�|j� q�|�|j|j |jf� n,|jdkr�|�|j� nt d� t |j����dS )zB This the end token to a get or a stat operation. � getc S s i | ]\}}||d d d� �qS )Nr8 r )�.0�keyrD r r r � <dictcomp>� r9 z,MemCacheProtocol.cmd_END.<locals>.<dictcomp>� gets� statsz%Unexpected END response to {} commandN) r& r, r r> r? r r! rE r rF � RuntimeError�formatr )r r. r? r r r �cmd_END� s" ��zMemCacheProtocol.cmd_ENDc C s | j �� �d� dS )z= Manage error response for incr/decr/delete. FNrH r1 r r r � cmd_NOT_FOUND� s z MemCacheProtocol.cmd_NOT_FOUNDc C s� | j d }|jdkr(|�� \}}}d}n|�� \}}}}t|�| _g | _d| _|jr�||jvrft d��||_ t|�|g|j |< n"|j |kr�t d��t|�|_ ||_| �� dS )z: Prepare the reading a value after a get. r rK r9 zUnexpected commands answer.N)r& r �split�intr' r( r) r> �keysrQ r@ r? rM rE rF Z setRawMode)r r7 r. rM rE �lengthrF r r r � cmd_VALUE� s$ zMemCacheProtocol.cmd_VALUEc C s( | j d }|�dd�\}}||j|< dS )z- Reception of one stat line. r � � N)r& rU r? )r r7 r. rM rD r r r �cmd_STAT s zMemCacheProtocol.cmd_STATc C s | j �� �|� dS )z% Read version token. NrH )r Z versionDatar r r � cmd_VERSION s z MemCacheProtocol.cmd_VERSIONc C s$ t �d� | j�� }|�t� � dS )z7 A non-existent command has been sent. zNon-existent command sent.N)r �errr& r, r r )r r. r r r � cmd_ERROR s zMemCacheProtocol.cmd_ERRORc C s2 t |�}t�d| � | j�� }|�t|�� dS )z0 An invalid input as been sent. zInvalid input: N)�reprr r^ r& r, r r �r ZerrTextr. r r r �cmd_CLIENT_ERROR s z!MemCacheProtocol.cmd_CLIENT_ERRORc C s2 t |�}t�d| � | j�� }|�t|�� dS )z4 An error has happened server-side. zServer error: N)r` r r^ r& r, r r ra r r r �cmd_SERVER_ERROR( s z!MemCacheProtocol.cmd_SERVER_ERRORc C s | j �� �d� dS )z> A delete command has completed successfully. TNrH r1 r r r � cmd_DELETED1 s z MemCacheProtocol.cmd_DELETEDc C s | j �� �d� dS )z6 The last command has been completed. TNrH r1 r r r �cmd_OK7 s zMemCacheProtocol.cmd_OKc C s | j �� �d� dS )z5 A C{checkAndSet} update has failed. FNrH r1 r r r � cmd_EXISTS= s zMemCacheProtocol.cmd_EXISTSc C s� | � � |�dd�d }t| dt|� d�}|durb|�dd�dd� }|rZ||d � q�|� nL|�dd�}t| dt|� d�}|dur�|� n | j�� }t|�}|�|� | js�| � d� dS )z8 Receive line commands from the server. rZ r[ r Zcmd_N� _) r: rU �getattrr �replacer& r, rV r! r5 )r r7 �tokenr. �argsrD r r r � lineReceivedC s" z MemCacheProtocol.lineReceivedr[ c C s | � d||�S )a� Increment the value of C{key} by given value (default to 1). C{key} must be consistent with an int. Return the new value. @param key: the key to modify. @type key: L{bytes} @param val: the value to increment. @type val: L{int} @return: a deferred with will be called back with the new value associated with the key (after the increment). @rtype: L{Deferred} s incr�� _incrdecr�r rM rD r r r � increment` s zMemCacheProtocol.incrementc C s | � d||�S )a� Decrement the value of C{key} by given value (default to 1). C{key} must be consistent with an int. Return the new value, coerced to 0 if negative. @param key: the key to modify. @type key: L{bytes} @param val: the value to decrement. @type val: L{int} @return: a deferred with will be called back with the new value associated with the key (after the decrement). @rtype: L{Deferred} s decrrm ro r r r � decrementq s zMemCacheProtocol.decrementc C s� | j rttd��S t|t�s4ttdt|�� d���S t|�| jkrNttd��S d� ||dt |�f g�}| � |� t ||d�}| j �|� |jS )z1 Internal wrapper for incr/decr. � not connected�Invalid type for key: �, expecting bytes� Key too longrZ s %d�rM )r3 r rQ � isinstance�bytesr �typer< �MAX_KEY_LENGTHr= rV r6 r r& r; r )r r. rM rD �fullcmd�cmdObjr r r rn � s � zMemCacheProtocol._incrdecrr c C s | � d||||d�S )a� Replace the given C{key}. It must already exist in the server. @param key: the key to replace. @type key: L{bytes} @param val: the new value associated with the key. @type val: L{bytes} @param flags: the flags to store with the key. @type flags: L{int} @param expireTime: if different from 0, the relative time in seconds when the key will be deleted from the store. @type expireTime: L{int} @return: a deferred that will fire with C{True} if the operation has succeeded, and C{False} with the key didn't previously exist. @rtype: L{Deferred} s replacer9 ��_set�r rM rD rE � expireTimer r r ri � s zMemCacheProtocol.replacec C s | � d||||d�S )a� Add the given C{key}. It must not exist in the server. @param key: the key to add. @type key: L{bytes} @param val: the value associated with the key. @type val: L{bytes} @param flags: the flags to store with the key. @type flags: L{int} @param expireTime: if different from 0, the relative time in seconds when the key will be deleted from the store. @type expireTime: L{int} @return: a deferred that will fire with C{True} if the operation has succeeded, and C{False} with the key already exists. @rtype: L{Deferred} s addr9 r} r r r r �add� s zMemCacheProtocol.addc C s | � d||||d�S )a9 Set the given C{key}. @param key: the key to set. @type key: L{bytes} @param val: the value associated with the key. @type val: L{bytes} @param flags: the flags to store with the key. @type flags: L{int} @param expireTime: if different from 0, the relative time in seconds when the key will be deleted from the store. @type expireTime: L{int} @return: a deferred that will fire with C{True} if the operation has succeeded. @rtype: L{Deferred} s setr9 r} r r r r �set� s zMemCacheProtocol.setc C s | � d|||||�S )am Change the content of C{key} only if the C{cas} value matches the current one associated with the key. Use this to store a value which hasn't been modified since last time you fetched it. @param key: The key to set. @type key: L{bytes} @param val: The value associated with the key. @type val: L{bytes} @param cas: Unique 64-bit value returned by previous call of C{get}. @type cas: L{bytes} @param flags: The flags to store with the key. @type flags: L{int} @param expireTime: If different from 0, the relative time in seconds when the key will be deleted from the store. @type expireTime: L{int} @return: A deferred that will fire with C{True} if the operation has succeeded, C{False} otherwise. @rtype: L{Deferred} s casr} )r rM rD rF rE r� r r r � checkAndSet� s z MemCacheProtocol.checkAndSetc C s� | j rttd��S t|t�s4ttdt|�� d���S t|�| jkrNttd��S t|t�spttdt|�� d���S |r|d| }t|�}d� ||t d|||f �g�| }| � |� | � |� t ||||d�} | j �| � | jS ) z6 Internal wrapper for setting values. rr rs rt ru zInvalid type for value: rZ z%d %d %d)rM rE rX )r3 r rQ rw rx r ry r< rz r= r r6 r r& r; r ) r r. rM rD rE r� rF rX r{ r| r r r r~ � s4 � ���� zMemCacheProtocol._setc C s | � d||ddd�S )a� Append given data to the value of an existing key. @param key: The key to modify. @type key: L{bytes} @param val: The value to append to the current value associated with the key. @type val: L{bytes} @return: A deferred that will fire with C{True} if the operation has succeeded, C{False} otherwise. @rtype: L{Deferred} s appendr r9 r} ro r r r r; s zMemCacheProtocol.appendc C s | � d||ddd�S )a� Prepend given data to the value of an existing key. @param key: The key to modify. @type key: L{bytes} @param val: The value to prepend to the current value associated with the key. @type val: L{bytes} @return: A deferred that will fire with C{True} if the operation has succeeded, C{False} otherwise. @rtype: L{Deferred} s prependr r9 r} ro r r r �prepend' s zMemCacheProtocol.prependc C s | � |g|d�S )a� Get the given C{key}. It doesn't support multiple keys. If C{withIdentifier} is set to C{True}, the command issued is a C{gets}, that will return the current identifier associated with the value. This identifier has to be used when issuing C{checkAndSet} update later, using the corresponding method. @param key: The key to retrieve. @type key: L{bytes} @param withIdentifier: If set to C{True}, retrieve the current identifier along with the value and the flags. @type withIdentifier: L{bool} @return: A deferred that will fire with the tuple (flags, value) if C{withIdentifier} is C{False}, or (flags, cas identifier, value) if C{True}. If the server indicates there is no value associated with C{key}, the returned value will be L{None} and the returned flags will be C{0}. @rtype: L{Deferred} F��_get)r rM �withIdentifierr r r �get9 s zMemCacheProtocol.getc C s | � ||d�S )a Get the given list of C{keys}. If C{withIdentifier} is set to C{True}, the command issued is a C{gets}, that will return the identifiers associated with each values. This identifier has to be used when issuing C{checkAndSet} update later, using the corresponding method. @param keys: The keys to retrieve. @type keys: L{list} of L{bytes} @param withIdentifier: If set to C{True}, retrieve the identifiers along with the values and the flags. @type withIdentifier: L{bool} @return: A deferred that will fire with a dictionary with the elements of C{keys} as keys and the tuples (flags, value) as values if C{withIdentifier} is C{False}, or (flags, cas identifier, value) if C{True}. If the server indicates there is no value associated with C{key}, the returned values will be L{None} and the returned flags will be C{0}. @rtype: L{Deferred} @since: 9.0 Tr� )r rW r� r r r � getMultipleQ s z MemCacheProtocol.getMultiplec C s� t |�}| jrttd��S |D ]H}t|t�sHttdt|�� d��� S t|�| j kr ttd�� S q |rrd}nd}d� |g| �}| � |� |r�dd � |D �}t |||d d �}nt ||d d d ddd�}| j �|� |jS )z> Helper method for C{get} and C{getMultiple}. rr rs rt ru rO rK rZ c S s i | ] }|d �qS ))r r9 Nr )rL rM r r r rN � r9 z)MemCacheProtocol._get.<locals>.<dictcomp>T)rW r? r> r Nr9 F)rM r rE rF r> )�listr3 r rQ rw rx r ry r< rz r= r6 r r& r; r ) r rW r� r> rM r. r{ r? r| r r r r� k s. � � zMemCacheProtocol._getNc C sL |rd| }nd}| j r$ttd��S | �|� tdi d�}| j�|� |jS )a� Get some stats from the server. It will be available as a dict. @param arg: An optional additional string which will be sent along with the I{stats} command. The interpretation of this value by the server is left undefined by the memcache protocol specification. @type arg: L{None} or L{bytes} @return: a deferred that will fire with a L{dict} of the available statistics. @rtype: L{Deferred} s stats rP rr )r? �r3 r rQ r6 r r& r; r )r �argr. r| r r r �stats� s zMemCacheProtocol.statsc C s6 | j rttd��S | �d� td�}| j�|� |jS )z� Get the version of the server. @return: a deferred that will fire with the string value of the version. @rtype: L{Deferred} rr s versionr� �r r| r r r �version� s zMemCacheProtocol.versionc C s` | j rttd��S t|t�s4ttdt|�� d���S | �d| � td|d�}| j � |� |j S )a Delete an existing C{key}. @param key: the key to delete. @type key: L{bytes} @return: a deferred that will be called back with C{True} if the key was successfully deleted, or C{False} if not. @rtype: L{Deferred} rr rs rt s delete s deleterv ) r3 r rQ rw rx r ry r6 r r& r; r )r rM r| r r r �delete� s � zMemCacheProtocol.deletec C s6 | j rttd��S | �d� td�}| j�|� |jS )z� Flush all cached values. @return: a deferred that will be called back with C{True} when the operation has succeeded. @rtype: L{Deferred} rr s flush_allr� r� r r r �flushAll� s zMemCacheProtocol.flushAll)r% )r[ )r[ )r r )r r )r r )r r )F)F)N)+r r r r rz r3 r r/ r2 r4 r6 rG rI rJ rS rT rY r\ r] r_ rb rc rd re rf rl rp rq rn ri r� r� r� r~ r; r� r� r� r� r� r� r� r� r r r r r# c sP r# )r# � DEFAULT_PORTr r r N)r � collectionsr Ztwisted.internet.deferr r r Ztwisted.protocols.basicr Ztwisted.protocols.policiesr Ztwisted.pythonr Ztwisted.python.compatr r r� � Exceptionr r r r r# �__all__r r r r �<module> s" ) x
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка