FileMgr

✏️ /usr/lib/python3/dist-packages/landscape/lib/__pycache__/message.cpython-312.pyc

✕ Tutup

�

�����~�eJ
����������������������������d�Z��e��������Zd��Zy)z/Helpers for reliable persistent message queues.c������������������l����d}|�j��������������������������}||z
��|�j��������������������������kD��r|�j���������������������������d}t��������}nP||kD��r|�j���������������������������||z
��}n5|||�j	��������������������������z
��k��r	d}t��������}n|�j	��������������������������|z���|z
��}|�j������������������|��������|�j
������������������|��������|S�)a���Our peer has told us what it expects our next message's sequence to be.

Call this with the message store and sequence number that the peer
    wants next; this will do various things based on what *this* side
    has in its outbound queue store.

0. The peer expects a sequence number from the server that is too high, the
       difference greater than pending messages in the peer. We flush the older
       messages in queue b/c the server does not want old or ancient messages,
       however we also reset the offset so that the pending messages are
       resent. Then we resynchronize by returning RESYNC. See LP: #1917540

1. The peer expects a sequence greater than what we last
       sent. This is the common case and generally it should be
       expecting last_sent_sequence+len(messages_sent)+1.

2. The peer expects a sequence number our side has already sent,
       and we no longer have that message. In this case, just send
       *all* messages we have, including the previous generation,
       starting at the sequence number the peer expects (meaning that
       messages have probably been lost).

3. The peer expects a sequence number we already sent, and we
       still have that message cached. In this case, we send starting
       from that message.

If the next expected sequence from the server refers to a message
    older than we have, then L{RESYNC} will be returned.
    N�����)�get_sequence�count_pending_messages�delete_old_messages�RESYNC�get_pending_offset�set_pending_offset�set_sequence)�store�
next_expected�ret�old_sequence�pending_offsets���     �7/usr/lib/python3/dist-packages/landscape/lib/message.py�got_next_expectedr������s�������<��C��%�%�'�L���$��(D�(D�(F�F�
�!�!�#�����	��	%�
�!�!�#�&��5��	�,��)A�)A�)C�C�	D�������
�$�$�&��6��E��	��
���^�,�	���}�%��J�����N)�__doc__�objectr���r�����r���r����<module>r������s������5�	���6r���

Batal

⬅ lib 45 item

Nama	Tipe	Ukuran	Diubah	Perm	Aksi
📄 __init__.cpython-312.pyc	pyc	361 B	15/06/26 13:45	0644	✏️ ⬇
📄 amp.cpython-312.pyc	pyc	26.5 KB	15/06/26 13:45	0644	✏️ ⬇
📄 backoff.cpython-312.pyc	pyc	2.7 KB	15/06/26 13:45	0644	✏️ ⬇
📄 base64.cpython-312.pyc	pyc	291 B	15/06/26 13:45	0644	✏️ ⬇
📄 bootstrap.cpython-312.pyc	pyc	3.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 bpickle.cpython-312.pyc	pyc	9.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 cli.cpython-312.pyc	pyc	697 B	15/06/26 13:45	0644	✏️ ⬇
📄 cloud.cpython-312.pyc	pyc	2.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 compat.cpython-312.pyc	pyc	669 B	15/06/26 13:45	0644	✏️ ⬇
📄 config.cpython-312.pyc	pyc	14.1 KB	15/06/26 13:45	0644	✏️ ⬇
📄 disk.cpython-312.pyc	pyc	5.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 encoding.cpython-312.pyc	pyc	1015 B	15/06/26 13:45	0644	✏️ ⬇
📄 fd.cpython-312.pyc	pyc	1.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 fetch.cpython-312.pyc	pyc	10.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 format.cpython-312.pyc	pyc	2.9 KB	15/06/26 13:45	0644	✏️ ⬇
📄 fs.cpython-312.pyc	pyc	4.5 KB	15/06/26 13:45	0644	✏️ ⬇
📄 gpg.cpython-312.pyc	pyc	2.6 KB	15/06/26 13:45	0644	✏️ ⬇
📄 hashlib.cpython-312.pyc	pyc	522 B	15/06/26 13:45	0644	✏️ ⬇
📄 jiffies.cpython-312.pyc	pyc	2.1 KB	15/06/26 13:45	0644	✏️ ⬇
📄 juju.cpython-312.pyc	pyc	1.1 KB	15/06/26 13:45	0644	✏️ ⬇
📄 lock.cpython-312.pyc	pyc	1.8 KB	15/06/26 13:45	0644	✏️ ⬇
📄 log.cpython-312.pyc	pyc	754 B	15/06/26 13:45	0644	✏️ ⬇
📄 logging.cpython-312.pyc	pyc	4.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 machine_id.cpython-312.pyc	pyc	1.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 message.cpython-312.pyc	pyc	2.5 KB	15/06/26 13:45	0644	✏️ ⬇
📄 monitor.cpython-312.pyc	pyc	10 KB	15/06/26 13:45	0644	✏️ ⬇
📄 network.cpython-312.pyc	pyc	12.6 KB	15/06/26 13:45	0644	✏️ ⬇
📄 os_release.cpython-312.pyc	pyc	2.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 persist.cpython-312.pyc	pyc	26.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 plugin.cpython-312.pyc	pyc	3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 process.cpython-312.pyc	pyc	6.8 KB	15/06/26 13:45	0644	✏️ ⬇
📄 reactor.cpython-312.pyc	pyc	12.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 schema.cpython-312.pyc	pyc	10.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 scriptcontent.cpython-312.pyc	pyc	878 B	15/06/26 13:45	0644	✏️ ⬇
📄 sequenceranges.cpython-312.pyc	pyc	6.9 KB	15/06/26 13:45	0644	✏️ ⬇
📄 store.cpython-312.pyc	pyc	1.8 KB	15/06/26 13:45	0644	✏️ ⬇
📄 sysstats.cpython-312.pyc	pyc	11.7 KB	15/06/26 13:45	0644	✏️ ⬇
📄 tag.cpython-312.pyc	pyc	1.1 KB	15/06/26 13:45	0644	✏️ ⬇
📄 testing.cpython-312.pyc	pyc	36.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 timestamp.cpython-312.pyc	pyc	575 B	15/06/26 13:45	0644	✏️ ⬇
📄 twisted_util.cpython-312.pyc	pyc	6.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 user.cpython-312.pyc	pyc	1.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 versioning.cpython-312.pyc	pyc	1.8 KB	15/06/26 13:45	0644	✏️ ⬇
📄 vm_info.cpython-312.pyc	pyc	3.8 KB	15/06/26 13:45	0644	✏️ ⬇
📄 warning.cpython-312.pyc	pyc	722 B	15/06/26 13:45	0644	✏️ ⬇

✏️ Rename

🔑 Ubah Permission