§
    ‹Ÿj  ã                   ó´   — d Z ddlZddlmZ ddlZddlZddlmZ ddlm	Z	 ddlm
Z da	 ddlmZ n# e$ r eZY nw xY wd	„ Zd
„ Z G d„ de¦  «        ZeZddgZdS )zDummy Frame objecté    N)ÚEvent)ÚETERMé   )Úffi)Úlib)Ú
bufferablec                 ó¢   — t          | ¦  «        t          u r| S t          | t          ¦  «        st          | ¦  «        } |                      ¦   «         S )zReturn content of obj as bytes)ÚtypeÚbytesÚ
isinstanceÚ
memoryviewÚtobytes)Úobjs    úe/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/zmq/backend/cffi/message.pyÚ_contentr      sC   € åˆC�y„y•EÐÐØˆ
Ý�c�:Ñ&Ô&ð Ý˜‰oŒoˆØ�;Š;‰=Œ=Ðó    c                 ó�  — t          j        ¦   «         }| dk    r¬|t          j        k    rt          j                             |¦  «        ‚|t          j        k    r$t          j                             t          ¦  «        ‚|t          k    rt          j         
                    |¦  «        ‚t          j                             |¦  «        ‚dS )Néÿÿÿÿr   )ÚCÚ	zmq_errnoÚerrnoÚEINTRÚzmqÚerrorÚInterrruptedSystemCallÚEAGAINÚAgainr   ÚContextTerminatedÚZMQError)ÚrcÚerrs     r   Ú	_check_rcr"   !   s”   € Ý
Œ+‰-Œ-€CØ	ˆR‚x€xØ•%”+ÒÐÝ”)×2Ò2°3Ñ7Ô7Ð7Ø•E”LÒ Ð Ý”)—/’/¥%Ñ(Ô(Ð(Ø•EŠ\ˆ\Ý”)×-Ò-¨cÑ2Ô2Ð2å”)×$Ò$ SÑ)Ô)Ð)Øˆ1r   c                   ó¬   — e Zd ZdZdZdZdZdZdZdZ	dZ
dZdd„Zd„ Zd„ Zd„ Zed„ ¦   «         Zed„ ¦   «         Zd	„ Zd
„ Zed„ ¦   «         Zd„ Zd„ Zd„ ZdS )ÚFrameNFc                 óV  — d| _         t          j        dt          j        t          j        d¦  «        ¦  «        ¦  «        | _        |rt          j        | _	        t          |t          ¦  «        rt          d¦  «        ‚|€1t          j        | j        ¦  «        }t          |¦  «         d| _         d S || _        t!          |¦  «        t"          u r|| _        t'          |¦  «        | _        | j        j        st-          d¦  «        ‚t          j        | j        ¦  «        }| j        j        }|€|r	||k     rd}nd}|rht          j        | j        |¦  «        }t          |¦  «         | j        t          j        t          j        | j        ¦  «        |¦  «        d d …<   d| _         d S |r.t9          ¦   «         }|| _        t          j        |¦  «        | _	        t>          €ddl m!a t          j        d	t          j        t          j        d
¦  «        ¦  «        ¦  «        }	t>           "                    || j        ¦  «        |	d         _#        t>          j$        st          j%        ¦   «         t>          _$        t          j        dt>          j$        ¦  «        |	d         _&        t          j        dt>          j'        j(        ¦  «        |	d         _)        t          j*        | j        |||	¦  «        }|dk    r<t          j+        |	¦  «         t          j+        | j        ¦  «         t          |¦  «         d| _         d S )NTzzmq_msg_t[1]Ú	zmq_msg_tz@Unicode strings are not allowed. Only: bytes, buffer interfaces.Fz/memoryview: underlying buffer is not contiguousr   )Úgczzhint[1]Úzhintzmutex_t*zvoid*),Ú_failed_initr   Úcastr   ÚmallocÚsizeofÚzmq_msgr   Ú_FINISHED_TRACKERÚtrackerr   ÚstrÚ	TypeErrorÚzmq_msg_initr"   Ú_datar
   r   Ú_bytesr   Ú_bufferÚ
contiguousÚBufferErrorÚfrom_bufferÚnbytesÚzmq_msg_init_sizeÚbufferÚzmq_msg_datar   Útracker_eventÚMessageTrackerÚzmq_gcÚzmq.utils.garbager'   ÚstoreÚidÚ_push_mutexÚmutex_allocateÚmutexÚ_push_socketÚ
underlyingÚsockÚzmq_wrap_msg_init_dataÚfree)
ÚselfÚdataÚtrackÚcopyÚcopy_thresholdr    Úc_dataÚ
data_len_cÚevtÚhints
             r   Ú__init__zFrame.__init__:   sÀ  € Ø ˆÔå”x µ´½¼ÀKÑ9PÔ9PÑ0QÔ0QÑRÔRˆŒð ð 	1ÝÔ0ˆDŒLå�d�CÑ Ô ð 	ÝØRñô ð ð ˆ<Ý” ¤Ñ-Ô-ˆBÝ�b‰MŒMˆMØ %ˆDÔØˆFàˆŒ
Ý�‰:Œ:�ÐÐàˆDŒKå! $Ñ'Ô'ˆŒØŒ|Ô&ð 	QÝÐOÑPÔPÐPå” ¤Ñ.Ô.ˆØ”\Ô(ˆ
àˆ<Øð  *¨~Ò"=Ð"=Ø��à�àð 	åÔ$ T¤\°:Ñ>Ô>ˆBÝ�b‰MŒMˆMØFJÄl�CŒJ•q”~ d¤lÑ3Ô3°ZÑ@Ô@ÀÀÀÑCØ %ˆDÔØˆFð ð 	3Ý‘'”'ˆCØ!$ˆDÔÝÔ-¨cÑ2Ô2ˆDŒLõ
 ˆ>Ø6Ð6Ð6Ð6Ð6Ð6åŒx˜
¥A¤H­S¬Z¸Ñ-@Ô-@Ñ$AÔ$AÑBÔBˆÝ—\’\ $¨Ô(:Ñ;Ô;ˆˆQŒŒ
ÝÔ!ð 	4Ý!"Ô!1Ñ!3Ô!3�FÔåœ ­VÔ-?Ñ@Ô@ˆˆQŒŒÝ”x ­Ô)<Ô)GÑHÔHˆˆQŒŒõ Ô%ØŒLØØØñ	
ô 
ˆð �Š7ˆ7ÝŒF�4‰LŒLˆLÝŒF�4”<Ñ Ô Ð Ý�b‰MŒMˆMØ!ˆÔÐÐr   c                 óR   — | j         s| j        s|                      ¦   «          d S d S d S ©N)Úclosedr)   Úclose©rK   s    r   Ú__del__zFrame.__del__Ž   s;   € ØŒ{ð 	 4Ô#4ð 	Ø�JŠJ‰LŒLˆLˆLˆLð	ð 	ð 	ð 	r   c                 óâ   — | j         s| j        s| j        €d S d| _         t          j        | j        ¦  «        }t          j        | j        ¦  «         d | _        |dk    rt          |¦  «         d S d S )NTr   )rW   r)   r-   r   Úzmq_msg_closerJ   r"   )rK   r    s     r   rX   zFrame.close’   sr   € ØŒ;ð 	˜$Ô+ð 	¨t¬|Ð/CØˆFØˆŒÝŒ_˜Tœ\Ñ*Ô*ˆÝ	ŒˆtŒ|ÑÔÐØˆŒØ�Š7ˆ7Ý�b‰MŒMˆMˆMˆMð ˆ7r   c                 óè   — | j         €Ht          j        t          j        | j        ¦  «        t          j        | j        ¦  «        ¦  «        | _         | j        €t          | j         ¦  «        | _        dS dS )zQone-time extract buffer from zmq_msg

        for Frames created by recv
        N)	r3   r   r;   r   r<   r-   Úzmq_msg_sizer5   r   rY   s    r   Ú_buffer_from_zmq_msgzFrame._buffer_from_zmq_msgœ   sc   € ð
 Œ:ÐÝœÝ”˜tœ|Ñ,Ô,­a¬n¸T¼\Ñ.JÔ.Jñô ˆDŒJð Œ<ÐÝ% d¤jÑ1Ô1ˆDŒLˆLˆLð  Ðr   c                 óF   — | j         €|                      ¦   «          | j         S rV   )r5   r_   rY   s    r   r;   zFrame.buffer¨   s$   € àŒ<ÐØ×%Ò%Ñ'Ô'Ð'ØŒ|Ðr   c                 óZ   — | j         €| j                             ¦   «         | _         | j         S rV   )r4   r;   r   rY   s    r   r   zFrame.bytes®   s'   € àŒ;ÐØœ+×-Ò-Ñ/Ô/ˆDŒKØŒ{Ðr   c                 ó   — | j         j        S rV   )r;   r9   rY   s    r   Ú__len__zFrame.__len__´   s   € ØŒ{Ô!Ð!r   c                 ó2   — | j         t          |¦  «        k    S rV   )r   r   )rK   Úothers     r   Ú__eq__zFrame.__eq__·   s   € ØŒz�X e™_œ_Ò,Ð,r   c                 ó4   — | j                              ¦   «         S rV   )r/   ÚdonerY   s    r   rh   z
Frame.doneº   s   € àŒ|× Ò Ñ"Ô"Ð"r   c                 ó   — | j         S rV   )r;   )rK   Úflagss     r   Ú
__buffer__zFrame.__buffer__¾   s
   € ØŒ{Ðr   c                 ó*   — |                       ¦   «         S )a<  Create a shallow copy of the message.

        This does not copy the contents of the Frame, just the pointer.
        This will increment the 0MQ ref count of the message, but not
        the ref count of the Python object. That is only done once when
        the Python is first turned into a 0MQ message.
        )Ú	fast_copyrY   s    r   Ú__copy__zFrame.__copy__Á   s   € ð �~Š~ÑÔÐr   c                 óÀ   — t          ¦   «         }t          j        |j        | j        ¦  «         | j        |_        | j        |_        | j        |_        | j        |_        |S )zPFast shallow copy of the Frame.

        Does not copy underlying data.
        )r$   r   Úzmq_msg_copyr-   r3   r5   r=   r/   )rK   Únew_msgs     r   rm   zFrame.fast_copyË   sR   € õ
 ‘'”'ˆõ 	
Œ�w”¨¬Ñ5Ô5Ð5àœ
ˆŒØœ,ˆŒð !%Ô 2ˆÔØœ,ˆŒàˆr   )NFNN)Ú__name__Ú
__module__Ú__qualname__r3   r/   rW   Úmorer5   r4   r)   r=   r-   rT   rZ   rX   r_   Úpropertyr;   r   rc   rf   rh   rk   rn   rm   © r   r   r$   r$   /   s#  € € € € € Ø€EØ€GØ€FØ€DØ€GØ€FØ€LØ€MØ€GðR"ð R"ð R"ð R"ðhð ð ðð ð ð
2ð 
2ð 
2ð ðð ñ „Xðð
 ðð ñ „Xðð
"ð "ð "ð-ð -ð -ð ð#ð #ñ „Xð#ðð ð ð ð  ð  ðð ð ð ð r   r$   ÚMessage)Ú__doc__r   Ú	threadingr   r   Ú	zmq.errorÚzmq.constantsr   Ú_cffir   r   r   r?   Ú__pypy__.bufferabler   Úmaybe_bufferableÚImportErrorÚobjectr   r"   r$   rx   Ú__all__rw   r   r   ú<module>rƒ      s   ðØ Ð ð
 €€€Ø Ð Ð Ð Ð Ð à 
€
€
€
Ø Ð Ð Ð Ø Ð Ð Ð Ð Ð à Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð à	€ðØBÐBÐBÐBÐBÐBÐBøØð ð ð ØÐÐÐðøøøðð ð ðð ð ðmð mð mð mð mÐñ mô mð mð` €à�IÐ
€€€s   ª1 ±;º;