o i@sdZddlZddlmZddlZddlZddlmZddlm Z ddlm Z da zddl mZWn ey;eZYnwd d Zd d ZGd ddeZeZddgZdS)zDummy Frame objectN)Event)ETERM)ffi)lib) bufferablecCs*t|tur|St|tst|}|S)zReturn content of obj as bytes)typebytes isinstance memoryviewtobytes)objrS/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/zmq/backend/cffi/message.py_contents  rcCs`t}|dkr.|tjkrtj||tjkrtjt|t kr(tj |tj |dS)Nr) C zmq_errnoerrnoEINTRzmqerrorInterrruptedSystemCallEAGAINAgainrContextTerminatedZMQError)rcerrrrr _check_rc!s      rc@seZdZdZdZdZdZdZdZdZ dZ dZ dddZ ddZ ddZd d Zed d Zed dZddZddZddZeddZddZddZddZdS)FrameNFc Csd|_tdttd|_|rtj|_ t |t rt d|dur2t |j}t|d|_dS||_t|tur>||_t||_t|j}|jj}|dur\|rZ||krZd}nd}|r}t|j|}t||jtt|j|dd<d|_dS|rt}||_t||_ tdurddlmatdttd } t ||j| d_!tj"st#t_"td tj"| d_$td tj%j&| d_'t(|j||| }|dkrt)| t)|jt|d|_dS) 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_datarr _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_thresholdrc_data data_len_cevthintrrr__init__:sh            zFrame.__init__cCs |js |js|dSdSdSN)closedr$closerDrrr__del__s  z Frame.__del__cCsV|js |js |jdur dSd|_t|j}t|jd|_|dkr)t|dSdS)NTr)rOr$r(r zmq_msg_closerCr)rDrrrrrPs   z Frame.closecCsF|jdurtt|jt|j|_|jdur!t|j|_dSdS)zQone-time extract buffer from zmq_msg for Frames created by recv N) r.rr4rr5r( zmq_msg_sizer0r rQrrr_buffer_from_zmq_msgs  zFrame._buffer_from_zmq_msgcCs|jdur ||jSrN)r0rUrQrrrr4s z Frame.buffercCs|jdur |j|_|jSrN)r/r4r rQrrrr s  z Frame.bytescCs|jjSrN)r4r2rQrrr__len__sz Frame.__len__cCs|jt|kSrN)r r)rDotherrrr__eq__sz Frame.__eq__cC |jSrN)r decoderQrrr__str__s z Frame.__str__cCrYrN)r*donerQrrrr\s z Frame.donecCs|jSrN)r4)rDflagsrrr __buffer__szFrame.__buffer__cCs|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_copyrQrrr__copy__szFrame.__copy__cCs:t}t|j|j|j|_|j|_|j|_|j|_|S)zPFast shallow copy of the Frame. Does not copy underlying data. )r r zmq_msg_copyr(r.r0r6r*)rDnew_msgrrrr_szFrame.fast_copy)NFNN)__name__ __module__ __qualname__r.r*rOmorer0r/r$r6r(rMrRrPrUpropertyr4r rVrXr[r\r^r`r_rrrrr /s4 Q     r Message)__doc__r threadingrr zmq.error zmq.constantsr_cffirrrr8__pypy__.bufferablermaybe_bufferable ImportErrorobjectrrr rh__all__rrrrs(      1