| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/spread/__pycache__/ |
Upload File : |
o
�b, � @ sd d Z ddlZddlmZ ddlmZmZmZ G dd� dej�Z G dd� dej
�Z d d
� Z d d � Z
dS )
z]
Persistently cached objects for PB.
Maintainer: Glyph Lefkowitz
Future Plans: None known.
� N)�defer)�banana�flavors�jellyc @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )� Publishablez6An object whose cached state persists across sessions.c C s | � � || _d S )N)� republish� publishedID)�selfr � r
�8/usr/lib/python3/dist-packages/twisted/spread/publish.py�__init__ s
zPublishable.__init__c C s t � � | _dS )z=Set the timestamp to current and (TODO) update all observers.N)�time� timestamp�r r
r
r r � zPublishable.republishc C s
| � |�S )�
(internal))�getStateToPublishFor�r � perspectiver
r
r �view_getStateToPublish s
z"Publishable.view_getStateToPublishc C s | � � S )z:Implement me to special-case your state for a perspective.)�getStateToPublishr r
r
r r # s z Publishable.getStateToPublishForc C s t d| j ��)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)�NotImplementedError� __class__r r
r
r r ' r z Publishable.getStateToPublishc C s: |r |j }|�� j}nd}d}t�|| �| j||| jd�S )z6Get all necessary metadata to keep a clientside cache.�None)�remoter r �servicer )�perspectiveName�
getService� serviceNamer � ViewPointr r )r r �observer�pname�snamer
r
r � getStateToCacheAndObserveFor+ s
�z(Publishable.getStateToCacheAndObserveForN)
�__name__�
__module__� __qualname__�__doc__r r r r r r# r
r
r
r r s r c @ sJ e Zd ZdZdZdZddd�Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dS )�RemotePublishedz6The local representation of remote Publishable object.r �pubc C s d� | j| jt| j�|�S )Nz {}-{}-{}.{})�formatr r �strr )r �extr
r
r � getFileNameC s �zRemotePublished.getFileNamec C s� | j �|� g | _z t| �� d�� }|�� }W d � n1 s w Y W n ty1 d}Y nw t�t �
|��}|j | j k}|rM| � |j � d| _
d S | j�d��| j � d S )N�rbr � r )�__dict__�update�_activationListeners�openr- �read�OSErrorr �unjellyr �decoder � _cbGotUpdate�_wasCleanWhenLoadedr �
callRemote� addCallbacks)r �state�dataFile�data�recent�newselfr
r
r �setCopyableStateK s
�� �
z RemotePublished.setCopyableStatec C s, | j �� }|d= |d= |d= |d= |d= |S )N�brokerr �luidr2 � isActivated)r0 �copy)r �otherr
r
r � __getstate__\ s
z RemotePublished.__getstate__c C s~ | j �|� d| _| jD ]}|| � q g | _| �� t| �� d��}|�t� t
�
| ��� W d � d S 1 s8w Y d S )Nr/ �wb) r0 r1 rD r2 � activatedr3 r- �writer �encoder )r �newState�listenerr= r
r
r r8 g s
"�z RemotePublished._cbGotUpdatec C s dS )znImplement this method if you want to be notified when your
publishable subclass is activated.
Nr
r r
r
r rI r s zRemotePublished.activatedc C s" | j r || � dS | j�|� dS )zZExternally register for notification when this publishable has received all relevant data.N)rD r2 �append)r �callbackr
r
r �callWhenActivatedw s z!RemotePublished.callWhenActivatedN)r) ) r$ r% r& r' rD r9 r- rA rG r8 rI rP r
r
r
r r( = s
r( c C s t �� }| jt|j|fd� |S )aD
Wrap a deferred returned from a pb method in another deferred that
expects a RemotePublished as a result. This will allow you to wait until
the result is really available.
Idiomatic usage would look like::
publish.whenReady(serverObject.getMeAPublishable()).addCallback(lookAtThePublishable)
)� callbackArgs)r �Deferredr; � _pubReady�errback)�d�d2r
r
r � whenReady s
rW c C s | � |j� dS )r N)rP rO )�resultrV r
r
r rS � s rS )r' r
�twisted.internetr �twisted.spreadr r r � Cacheabler � RemoteCacher( rW rS r
r
r
r �<module> s )B