| Server IP : 46.62.235.243 / Your IP : 216.73.216.163 Web Server : Apache/2.4.58 (Ubuntu) System : Linux Linkabili3Dicembre 6.8.0-100-generic #100-Ubuntu SMP PREEMPT_DYNAMIC Tue Jan 13 16:40:06 UTC 2026 x86_64 User : www-data ( 33) PHP Version : 8.1.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3/dist-packages/twisted/spread/__pycache__/ |
Upload File : |
�
oj, � � � d Z ddlZddlmZ ddlmZmZmZ G d� dej � Z G d� dej � Z d � Z d
� Z
y) z]
Persistently cached objects for PB.
Maintainer: Glyph Lefkowitz
Future Plans: None known.
� N)�defer)�banana�flavors�jellyc �4 � e Zd ZdZd� Zd� Zd� Zd� Zd� Zd� Z y) � Publishablez6An object whose cached state persists across sessions.c �2 � | j � || _ y )N)� republish� publishedID)�selfr s �8/usr/lib/python3/dist-packages/twisted/spread/publish.py�__init__zPublishable.__init__ s � � ����&��� c �6 � t j � | _ y)z=Set the timestamp to current and (TODO) update all observers.N)�time� timestamp�r s r
r
zPublishable.republish s � � �����r c �$ � | j |� S )�
(internal))�getStateToPublishFor�r � perspectives r
�view_getStateToPublishz"Publishable.view_getStateToPublish s � ��(�(��5�5r c �" � | j � S )z:Implement me to special-case your state for a perspective.)�getStateToPublishr s r
r z Publishable.getStateToPublishFor# s � ��%�%�'�'r c �2 � t d| j z � �)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)�NotImplementedError� __class__r s r
r z Publishable.getStateToPublish' s � �!�";�d�n�n�"L�M�Mr c � � |r'|j }|j � j }nd}d}t j || � | j
||| j d�S )z6Get all necessary metadata to keep a clientside cache.�None)�remoter r �servicer )�perspectiveName�
getService� serviceNamer � ViewPointr r )r r �observer�pname�snames r
� getStateToCacheAndObserveForz(Publishable.getStateToCacheAndObserveFor+ s` � � � �/�/�E� �*�*�,�8�8�E��E��E� �'�'� �T�:� �+�+� � � � � �
�
r N)
�__name__�
__module__� __qualname__�__doc__r r
r r r r* � r r
r r s$ � �@�'�%�6�(�N�
r r c �> � e Zd ZdZdZdZd
d�Zd� Zd� Zd� Z d� Z
d� Z y ) �RemotePublishedz6The local representation of remote Publishable object.r c �x � dj | j | j t | j � |� S )Nz {}-{}-{}.{})�formatr" r �strr )r �exts r
� getFileNamezRemotePublished.getFileNameC s6 � � �#�#� �L�L� � � � �� � � !� �
�
r c � � | j j |� g | _ t | j � d� 5 }|j � }d d d � t
j t j � � }|j | j k( }|r#| j j � d| _
y | j j d� j! | j � y # 1 sw Y ��xY w# t $ r d}Y �sw xY w)N�rbr � r )�__dict__�update�_activationListeners�openr6 �readr �unjellyr �decoder �OSError� _cbGotUpdate�_wasCleanWhenLoadedr! �
callRemote� addCallbacks)r �state�dataFile�data�newself�recents r
�setCopyableStatez RemotePublished.setCopyableStateK s� � � �
�
� � �U�#�$&��!� 9��d�&�&�(�$�/�
'�8� �}�}���
'�
�m�m�F�M�M�$�$7�8�G� �&�&�$�.�.�8�F� � � � �g� .� .� /�'(�D� $� �K�K� "� "�#6� 7� D� D�T�EV�EV� W�
'�
'��� ��F� �s( �C> �C2�C> �2C;�7C> �> D � D c �X � | j j � }|d= |d= |d= |d= |d= |S )N�brokerr! �luidr< � isActivated)r: �copy)r �others r
� __getstate__z RemotePublished.__getstate__\ s? � ��
�
�"�"�$�� �(�O� �(�O� �&�M� �(� )� �-� �� r c �t � | j j |� d| _ | j D ]
} || � � g | _ | j � t | j
� d� 5 }|j t j t j | � � � d d d � y # 1 sw Y y xY w)Nr9 �wb) r: r; rO r< � activatedr= r6 �writer �encoder )r �newState�listenerrG s r
rB z RemotePublished._cbGotUpdateg s� � � �
�
� � �X�&� ��� �1�1� �H� �T�N� �$&��!� ����
�$�"�"�$�d�
+� =�x� �N�N�6�=�=����T�):�;� <� =� =� =�s �-8B.�.B7c � � y)znImplement this method if you want to be notified when your
publishable subclass is activated.
Nr/ r s r
rU zRemotePublished.activatedr s � r c �d � | j r || � y| j j |� y)zZExternally register for notification when this publishable has received all relevant data.N)rO r< �append)r �callbacks r
�callWhenActivatedz!RemotePublished.callWhenActivatedw s& � � � � � �T�N� � %� %� ,� ,�X� 6r N)�pub) r+ r, r- r. rO rC r6 rK rR rB rU r^ r/ r r
r1 r1 = s/ � �@��K���
�X�" � =� �
7r r1 c �t � t j � }| j t |j |f�� |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 �DeferredrE � _pubReady�errback)�d�d2s r
� whenReadyrg s- � �
� � � �B��N�N�9�b�j�j��u�N�=�
�Ir c �: � | j |j � y)r N)r^ r] )�resultrf s r
rc rc � s � �
� � �R�[�[�)r )r. r �twisted.internetr �twisted.spreadr r r � Cacheabler � RemoteCacher1 rg rc r/ r r
�<module>rn sH ��
� � "� 1� 1�&
�'�#�#� &
�R?7�g�)�)� ?7�D � *r