o i,@sdZddlZddlmZddlmZddZZddZ d dZ d dZ d dZ d dZ d dZddZddZeddkZeZddlZddlmZmZddlmZmZmZddlmZddlm Z dddZ!dddZ"dddZ#GdddZ$ddgZ%dS) zzmq Socket classN)ffi)libcCs td|S)Nzsize_t*)rnewlengthrR/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/zmq/backend/cffi/socket.py s r cCtdttdfSNz uint64_t*uint64_trrnspsizeofrrrr r cCr Nzint64_t*int64_trrrrr r rcCr Nzint*intrrrrr r rcCs td|ttd|fS)Nchar[%d]charrrrrr r s cCtd|tdfSr rrrvalrrr r cCrrrrrrr r rcCrrrrrrr r rcCs"td|d|td|fS)Nrrrr)rrrrr r s ZMQ_FD_T) SocketOption_OptType)ZMQError _check_rc_check_version)Frame)_retry_sys_callcCsDt|dtj}|tjkstr|tjkrtS|tjkrt|St SN _opt_type) getattrr rint64 ZMQ_FD_64BITfdnew_int64_pointerbytesnew_binary_datanew_int_pointer)optionropt_typerrr new_pointer_from_opt)s  r2cCsVzt|}Wn tytj}Ynw|j}|tjkr%t||ddSt|dS)Nr)r ValueErrorr rr'r-rbuffer)r0 opt_pointerrr1rrr value_from_opt_pointer5s     r6cCsJt|dtj}|tjkstr|tjkrt|S|tjkr!t||St |Sr&) r(r rr)r*r+value_int64_pointerr-value_binary_datavalue_int_pointer)r0valuerr1rrr initialize_opt_pointerFs   r;c@seZdZdZdZdZdZdZdZdZ d&ddZ e ddZ dd Z e d d Zd'd d ZddZddZddZddZddZddZddZddZd(ddZd)d!d"Zd*d$d%ZdS)+SocketNFrcCsf|durtj}||_||_|rtd||_d|_n d|_t |j ||_|jtj kr.t d|_ dS)Nzvoid *TF)zmqCOPY_THRESHOLDcopy_thresholdcontextrcast _zmq_socket_shadowC zmq_socket_zmq_ctxNULLr!_closed)selfr@ socket_typeshadowr?rrr __init__Ys  zSocket.__init__cCsttd|jS)z+The address of the underlying libzmq socketsize_t)rrrArBrIrrr underlyingiszSocket.underlyingc Cst|jrdSz |tjWdSty9}z|jtjkr&d|_WYd}~dS|jtjkr-nWYd}~dSd}~ww)zthorough check of whether the socket has been closed, even if by another entity (e.g. ctx.destroy). Only used by the `closed` property. returns True if closed, False otherwise TNF)rHgetr=TYPEr!errnoENOTSOCKETERM)rIerrr _check_closed_deepns     zSocket._check_closed_deepcCs|SN)rVrNrrr closedsz Socket.closedcCs^d}|js#t|dr#|jdur |dur|tj|t|j}d|_|dkr-t|dSdS)NrrBT) rHhasattrrBsetr=LINGERrD zmq_closer")rIlingerrcrrr closes   z Socket.closecCst|tr |d}n|}t|tr|d}t|j|}|dkrdtrAt t j krA| ddd}d |t}tt |dt t jkr^| ddd}d|d }tt |dt|dSdS) Nutf8rz://rzJipc path "{}" is longer than {} characters (sizeof(sockaddr_un.sun_path)).)msgz(No such file or directory for ipc path "z".) isinstancestrencoder-decoderDzmq_bindrBIPC_PATH_MAX_LEN zmq_errno errno_mod ENAMETOOLONGsplitformatr!ENOENTr")rIaddress address_br^pathrbrrr binds*      z Socket.bindcC8tddt|tr|d}t|j|}t|dS)Nunbindr`)r#rcrdrerD zmq_unbindrBr"rIror^rrr rw    z Socket.unbindcCs.t|tr |d}t|j|}t|dS)Nr`)rcrdrerD zmq_connectrBr"ryrrr connects   zSocket.connectcCrs)Nrt disconnectr`)r#rcrdrerDzmq_disconnectrBr"ryrrr r}rzzSocket.disconnectcCsd}t|tr tdzt|}Wn tytj}Ynw|j}t|tr5|tjkr1td|t |}t |||\}}t t j |j|td||dS)Nzunicode not allowed, use bytesznot a bytes sockopt: %szvoid*)rcrd TypeErrorrr3r rr'r-lenr;r%rDzmq_setsockoptrBrrA)rIr0r:rr1c_value_pointerc_sizetrrr rZs*        z Socket.setcCszt|}Wn tytj}Ynw|j}t|dd\}}ttj|j ||||d}t |||}|t jj krH|tj krH|drH|dd}|S)Nrrra)rr3r rr'r2r%rDzmq_getsockoptrBr6r= ROUTING_IDr-endswith)rIr0r1rc_sizet_pointerszvrrr rPs$       z Socket.getcCstd}t|tst|}td|}t|t|}t |t t ||t|t tj ||j|t|}t |dS)zSend a copy of a bufferable zmq_msg_t*zchar[]N)rrrcr- memoryviewtobytesrDzmq_msg_init_sizerr"memcpy zmq_msg_datar% zmq_msg_sendrB zmq_msg_close)rIbufflagszmq_msg c_messager^rc2rrr _send_copys      zSocket._send_copycCs2|}|j}ttj||j||j}||S)z1Send a Frame on this socket in a non-copy manner.) fast_copyrr%rDrrBtrackerr_)rIframer frame_copyrrrrr _send_frames zSocket._send_framec Cst|tr td|rt|ts|||Sd}t|tr)|r&|js&td|}n |jr?t|}|j |jkr?|||t j St|||jd}d}| ||}|rU| |S)Nz.Message must be in bytes, not a unicode objectFzNot a tracked message)trackr?T)rcrdrr$rrr3r?rnbytesr=_FINISHED_TRACKERrr_) rIdatarcopyr close_framerrrrrr sends(       z Socket.sendTc Cs|r td}t|n tj|d}|j}z ttj||j |Wnt y0|r/t |w|s5|St t |t|}|dd}t |}t||S)Nr)r)rrrD zmq_msg_initr=r$rr% zmq_msg_recvrB Exceptionrr4r zmq_msg_sizer") rIrrrrr_buffer_bytesr^rrr recv.s&       z Socket.recvracCsNtdd|dkr tj}|durtj}t|tr|d}t |j ||dS)as.monitor(addr, flags) Start publishing socket events on inproc. See libzmq docs for zmq_monitor for details. Note: requires libzmq >= 3.2 Parameters ---------- addr : str The inproc url used for monitoring. Passing None as the addr will cause an existing socket monitor to be deregistered. events : int [default: zmq.EVENT_ALL] The zmq event bitmask for which events will be sent to the monitor. rtmonitorrNr`) r#r= EVENT_ALLrrGrcrdrerDzmq_socket_monitorrB)rIaddreventsrrr rFs   zSocket.monitor)NNrNrW)rFF)rTF)ra)__name__ __module__ __qualname__r@rJrBrH_refrCr?rLpropertyrOrVrXr_rrrwr|r}rZrPrrrrrrrrr r<Ps4      r<rh)r)&__doc__rRrj_cffirrrDrnew_sizet_pointernew_uint64_pointerr,r/r.value_uint64_pointerr7r9r8rr*get_ipc_path_max_lenrhr= zmq.constantsrr zmq.errorr!r"r#messager$utilsr%r2r6r;r<__all__rrrr s6