U lu f@sdZddlZddlmZddlZddlZddlmZddlm Z ddlm Z da zddl mZWnek rxeZYnXd d Zd d ZGd ddeZeZddgZdS)zDummy Frame objectN)Event)ETERM)ffi)lib) bufferablecCs*t|tkr|St|ts"t|}|S)zReturn content of obj as bytes)typebytes isinstance memoryviewtobytes)objrt d|dkrdt |j}t|d|_dS||_t|tkr|||_t||_t|j}|jj}|dkr|r||krd}nd}|rt|j|}t||jtt|j|dd<d|_dS|rt}||_t||_ tdkr.ddlmatdttd } t ||j| d_!tj"slt#t_"td tj"| d_$td tj%j&| d_'t(|j||| }|dkrt)| t)|jt|d|_dS) NTz zmq_msg_t[1]Z zmq_msg_tz@Unicode strings are not allowed. Only: bytes, buffer interfaces.Fr)gczzhint[1]Zzhintzmutex_t*zvoid*)* _failed_initrcastrZmallocsizeofzmq_msgrZ_FINISHED_TRACKERtrackerr str TypeErrorZ zmq_msg_initr_datarr _bytesr _buffer from_buffernbytesZzmq_msg_init_sizebuffer zmq_msg_datar tracker_eventZMessageTrackerzmq_gcZzmq.utils.garbagerstoreidZ _push_mutexZmutex_allocatemutexZ _push_socketZ underlyingsockZzmq_wrap_msg_init_datafree) selfdatatrackcopyZcopy_thresholdrZc_dataZ data_len_cZevthintrrr__init__:sh             zFrame.__init__cCs|js|js|dSN)closedrcloser1rrr__del__s z Frame.__del__cCsR|js|js|jdkrdSd|_t|j}t|jd|_|dkrNt|dS)NTr)r8rrrZ zmq_msg_closer0r)r1rrrrr9s  z Frame.closecCsB|jdkr(tt|jt|j|_|jdkr>t|j|_dS)zQone-time extract buffer from zmq_msg for Frames created by recv N) r#rr(rr)rZ zmq_msg_sizer%r r:rrr_buffer_from_zmq_msgs   zFrame._buffer_from_zmq_msgcCs|jdkr||jSr7)r%r<r:rrrr(s z Frame.buffercCs|jdkr|j|_|jSr7)r$r(r r:rrrr s  z Frame.bytescCs|jjSr7)r(r'r:rrr__len__sz Frame.__len__cCs|jt|kSr7)r r)r1otherrrr__eq__sz Frame.__eq__cCs |jSr7)r decoder:rrr__str__sz Frame.__str__cCs |jSr7)r doner:rrrrBsz Frame.donecCs|jSr7)r()r1flagsrrr __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_copyr:rrr__copy__szFrame.__copy__cCs:t}t|j|j|j|_|j|_|j|_|j|_|S)zPFast shallow copy of the Frame. Does not copy underlying data. )rrZ zmq_msg_copyrr#r%r*r )r1Znew_msgrrrrEszFrame.fast_copy)NFNN)__name__ __module__ __qualname__r#r r8Zmorer%r$rr*rr6r;r9r<propertyr(r r=r?rArBrDrFrErrrrr/s2 Q      rMessage)__doc__r threadingrrZ zmq.errorZ zmq.constantsrZ_cffirrrr+Z__pypy__.bufferablerZmaybe_bufferable ImportErrorobjectrrrrK__all__rrrrs$      1