fXdZddlZddlmZddlZddlZddlmZddlm Z ddlm Z da ddl mZd Zd ZGd d eZeZd d gZy#e$reZY!wxYw)zDummy Frame objectN)Event)ETERM)ffi)lib) bufferablec~t|tur|St|ts t|}|j S)zReturn content of obj as bytes)typebytes isinstance memoryviewtobytes)objs S/var/www/cvtools/html/venv/lib/python3.12/site-packages/zmq/backend/cffi/message.py_contentrs2 CyE c: &o ;;=ctj}|dk(r|tjk(rtj j ||tjk(r#tj jt|tk(rtj j|tj j|y)Nr) C zmq_errnoerrnoEINTRzmqerrorInterrruptedSystemCallEAGAINAgainrContextTerminatedZMQError)rcerrs r _check_rcr"!s ++-C Rx %++ ))2237 7 ELL ))//%( ( E\))--c2 2))$$S) ) rceZdZdZdZdZdZdZdZdZ dZ dZ ddZ dZ dZdZedZedZd Zd Zed Zd Zd ZdZy)FrameNFc`d|_tjdtjtj d|_|rtj|_ t|tr td|2tj|j }t|d|_y||_t!|t"ur||_t'||_tj*|j(}|j(j,}| |r||krd}nd}|rstj.|j |}t||j(tj0tj2|j |ddd|_y|r+t5}||_tj8||_ t:ddlmatjdtjtj d } t:jA||j6| d_!t:jDstjFt:_"tjd t:jD| d_$tjd t:jJjL| d_'tjP|j ||| }|dk7r?tjR| tjR|j t|d|_y) NTz zmq_msg_t[1] zmq_msg_tz@Unicode strings are not allowed. Only: bytes, buffer interfaces.Fr)gczzhint[1]zhintzmutex_t*zvoid*)* _failed_initrcastrmallocsizeofzmq_msgr_FINISHED_TRACKERtrackerr str TypeError zmq_msg_initr"_datar r _bytesr _buffer from_buffernbyteszmq_msg_init_sizebuffer zmq_msg_datar tracker_eventMessageTrackerzmq_gczmq.utils.garbager'storeid _push_mutexmutex_allocatemutex _push_socket underlyingsockzmq_wrap_msg_init_datafree) selfdatatrackcopycopy_thresholdr c_data data_len_cevthints r__init__zFrame.__init__:sQ xxK9P0QR  00DL dC R  < -B bM %D   : DK!$' .\\(( <*~"= $$T\\:>B bMFJllCJJq~~dll3Z @ C %D   'C!$D --c2DL > 6xx AHHSZZ-@$AB\\$(:(:;Q !!!"!1!1!3F V-?-?@Q xx)<)<)G)GHQ  % % LL      7 FF4L FF4<< bM!rcX|js|js|jyyyN)closedr)closerIs r__del__z Frame.__del__s!{{4#4#4 JJL$5{rc|js|js |jyd|_tj|j}tj |jd|_|dk7r t |yy)NTr)rUr)r-r zmq_msg_closerHr")rIr s rrVz Frame.closes` ;;$++t||/C  __T\\ * t|| 7 bM rc|jUtjtj|j tj |j |_|jt|j|_yy)zQone-time extract buffer from zmq_msg for Frames created by recv N) r3rr9rr:r- zmq_msg_sizer5r rWs r_buffer_from_zmq_msgzFrame._buffer_from_zmq_msgs^ :: t||,annT\\.JDJ << %djj1DL rcR|j|j|jSrT)r5r]rWs rr9z Frame.buffers" <<   % % '||rcp|j|jj|_|jSrT)r4r9rrWs rr z Frame.bytess* ;; ++--/DK{{rc.|jjSrT)r9r7rWs r__len__z Frame.__len__s{{!!!rc2|jt|k(SrT)r r)rIothers r__eq__z Frame.__eq__szzXe_,,rc6|jjSrT)r/donerWs rrfz Frame.dones||  ""rc|jSrT)r9)rIflagss r __buffer__zFrame.__buffer__s {{rc"|jS)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_copyrWs r__copy__zFrame.__copy__s~~rct}tj|j|j|j|_|j |_|j |_|j|_|S)zPFast shallow copy of the Frame. Does not copy underlying data. )r$r zmq_msg_copyr-r3r5r;r/)rInew_msgs rrkzFrame.fast_copysY ' w 5  ,,!% 2 2,,r)NFNN)__name__ __module__ __qualname__r3r/rUmorer5r4r)r;r-rRrXrVr]propertyr9r rardrfrirlrkrrr$r$/s EG F DG FLMGO"b 2  "-## rr$Message)__doc__r threadingrr zmq.error zmq.constantsr_cffirrrr=__pypy__.bufferablermaybe_bufferable ImportErrorobjectrr"r$rv__all__rurrrso    B   j jZ  I UsAAA