^h78SrSSKrSSKrSSKrSSKJrJr SSKJ r J r J r SSK J r SSK Jr SSKJr SS KJr S =rrS rS rS rSrSrSrSrSr\ R<"S5r\S:Hr \RB"5r"SSjr#SSjr$SSjr%"SS5r&SS/r'g)zzmq Socket classN) SocketOption_OptType)ZMQError _check_rc_check_version)ffi)lib)Frame)_retry_sys_callc0[R"SU5$)Nzsize_t*)r newlengths Q/home/james-whalen/.local/lib/python3.13/site-packages/zmq/backend/cffi/socket.pyrsF)Ccl[R"S5[[R"S554$Nz uint64_t*uint64_tr rnspsizeofrrnew_uint64_pointerrs$ 77; SZZ %;!< <>!llx8;;7N "" X^^ #v&&  rc[U5nURnU[R :Xa[ R"X5SS$[ US5$![a [RnNWf=f)Nr)rr9 ValueErrorrr"r>r buffer)r? opt_pointerrr@s rvalue_from_opt_pointerrFGsi$f%##8>>!zz+.q11;q>""  <<  s AA10A1c[US[R5nU[R:Xd[(aU[R :Xa [ U5$U[R:Xa [X5$[U5$r8) r:rr"r;r<r=r0r>r4r2)r?valuerr@s rinitialize_opt_pointerrIXs\v{HLL9H8>>!llx8;;7N"5)) X^^ # // ''rc\rSrSrSrSrSrSrSrSr Sr Sr Sr SSjr \S5rSr\S5rSS jrS rS rS rS rSrSrSrSrSSjrSSjrSSS.S\S\S\4SjjrSSjrSr g) SocketbNFrclUc[RnX@lXlS=UlUlU(a$[ R"SU5UlSUl O-SUl [R"URU5UlUR[ R:Xa [5eSUlg)Nvoid *TF)zmqCOPY_THRESHOLDcopy_thresholdcontext _draft_poller_draft_poller_ptrr cast _zmq_socket_shadowC zmq_socket_zmq_ctxNULLr_closed)selfrR socket_typeshadowrQs r__init__Socket.__init__ms  ! //N, 6::T3 "xx&9D DL DL ||G,<,BB"T%;+%HHSZZ0[[!1!12DL 6 bM rc[U[5(aURS5nOUn[U[5(aUR S5n[ R "URU5nUS:a[(af[ R"5[R:Xa?URSS5SnSUS[S3n[[ R"5US 9e[ R"5[R:Xa8URSS5SnS US 3n[[ R"5US 9e[U5 gg) Nutf8rz://rz ipc path "z" is longer than z+ characters (sizeof(sockaddr_un.sun_path)).)msgz(No such file or directory for ipc path "z".) isinstancestrencoder>decoderXzmq_bindrVIPC_PATH_MAX_LEN zmq_errno errno_mod ENAMETOOLONGsplitrENOENTr)r]address address_br{pathrs rbind Socket.binds gs # #v.II gu % %&&v.G ZZ(() 4 6AKKMY5K5K$K}}UA.r2 &78H7IJAAq{{}#66)"2"22}}UA.r2@bIq{{}#66"  rc[U[5(aURS5n[R"UR U5n[ U5 gNr)rrrrX zmq_unbindrVrr]rr{s runbind Socket.unbinds: gs # #nnV,G \\$**G 4" rc[U[5(aURS5n[R"UR U5n[ U5 gr)rrrrX zmq_connectrVrrs rconnectSocket.connects: gs # #nnV,G ]]4++W 5" rc[U[5(aURS5n[R"UR U5n[ U5 gr)rrrrXzmq_disconnectrVrrs r disconnectSocket.disconnects< gs # #nnV,G   d.. 8" rc Sn[U[5(a [S5e[U5nURn[U[5(a-U[ R:wa[SU35e[U5n[XU5upV[[RURU[R "SU5U5 g![ a [ RnNf=f)Nzunicode not allowed, use bytesznot a bytes sockopt: void*)rr TypeErrorrr9rCrr"r>lenrIr rXzmq_setsockoptrVr rU)r]r?rHrr@c_value_pointerc_sizets rrw Socket.sets eS ! !<= = (!&)F''H eU # #8>>)"7x @AAZF#9&#P        HHWo .    $ ||H  $s CC%$C%c|[U5nURnU[ R :Xa^URbQ[U5up4[R"UR[R"SU55 [ US5$[USS9up5[[RURUUU5 USn[KXU5n U[ RRL:wa/U[RN:XaU RQS 5(aU SS n U $![a [RnGN#f=f![ GanU[R :XGaUR"[ R$R&:XGaUR)[R*5(Ga[-SS5 [ R.(d [1S5e[2R4"[ R6R95SS 9 [R:"S 5Ul[R>"5=UR<S'UlUR[R@:XaS=UlUle[RB"URUR[R@[ RD[ RF-5n[IU5 [R"UR[R"S U55n[IU5 [ US5sSnA$eSnAff=f)Nrrr)z)draft socket FD support via zmq_poller_fdz'libzmq must be built with draft supportr) stacklevelzvoid*[1]rNr))rr9rCrr"rOFDrSrArX zmq_poller_fdr rUr zmq_getsockoptrVrrjErrnoEINVALrh THREAD_SAFEr DRAFT_API RuntimeErrorwarningswarnerrorDraftFDWarningrrTzmq_poller_newr[zmq_poller_addPOLLINPOLLOUTrrF ROUTING_IDr>endswith) r]r?r@r_c_sizet_pointerrmr{szvs rrh Socket.getsz (!&)F''H SVV  2 2 >!5f!= O OOD../0R Sq)* *+?s+S()        TQ  "6B ? c&&11 1HNN* 5!!#2AE $ ||H  $.! ,//)GGsyy///HH\5566y*UV}}&'PQQ cii668QG*-)<&ABAQAQASS&&q)D,>%%1BFFD*T-?%%&&$$HHJJ,  " __&&?(K" ?1-..C! s6 D'ED=<D= L; G$L6/L;5L66L;c[R"S5n[U[5(d[ U5R 5n[R"SU5n[ R"U[U55n[U5 [ R"[ R"U5U[U55 [[ RX0RU5 [ R"U5n[U5 g)zSend a copy of a bufferable zmq_msg_t*zchar[]N)r rrr> memoryviewtobytesrXzmq_msg_init_sizerrmemcpy zmq_msg_datar zmq_msg_sendrV zmq_msg_close)r]bufflagszmq_msg c_messager{rc2s r _send_copySocket._send_copy:s'','#u%%S/))+CGGHc*  #c( 3"  ()SX>1A1A5Ioog&#rcUR5nURn[[RX@R U5 UR nUR5 U$)z1Send a Frame on this socket in a non-copy manner.) fast_copyrr rXrrVtrackerr|)r]framer frame_copyrrs r _send_frameSocket._send_frameIsM__& $$1A1A5I$$rcD[U[5(a [S5eU(a&[U[5(dUR X5$Sn[U[5(a&U(aUR (d [ S5eUnOmUR(aF[U5nURUR:a!UR Xr5 [R$[XURS9nSnURXb5nU(aUR5 U$)Nz.Message must be in bytes, not a unicode objectFzNot a tracked message)trackrQT)rrrr rrrCrQrnbytesrO_FINISHED_TRACKERrr|) r]datarcopyr close_framerrrs rsend Socket.sendTs dC LM M  4//??4/ /K$&&$%<==&&$T*CzzD$7$773"444d@S@ST" &&u4G Nrc.U(a-[R"S5n[R"U5 O [R "US9nUR n[[RX@RU5 U(dW$[R"[R"U5[R"U55nUSSn[R"U5n[U5 U$![a U(a[R"U5 ef=f)Nr)r)r rrX zmq_msg_initrOr rr zmq_msg_recvrV ExceptionrrDr zmq_msg_sizer) r]rrrrr_buffer_bytesr{s rrecv Socket.recvos ggl+G NN7 #IIE*EmmG  ANNG5E5Eu M L**Q^^G4annW6MN __W %"   (  s %C++)D)rrrrreturnc[U5nUR(d [S5eUR(a [S5eUS:a[ SU<S35eUR nUS:XaUnOX%:a[ SU<SUS35e[ R"U5n[[RURXbU5n[U5 U$)Nz%Can only recv_into contiguous buffersz Cannot recv_into readonly bufferrznbytes=z must be non-negativez too big for memoryview of B) r contiguous BufferErrorreadonlyrCrr from_bufferr rXzmq_recvrVr)r]rDrrview view_bytesc_bufr{s r recv_intoSocket.recv_intos&!EF F ==@A A A:y(=>? ?[[ Q;F  y(CJ.>uU"  rcUS:a[RnUc[Rn[ U[ 5(aUR S5n[R"URX5 g)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. rNr) rO EVENT_ALLr r[rrrrXzmq_socket_monitorrV)r]addreventss rmonitorSocket.monitorsS" A:]]F <88D dC ;;v&D T--trs  099"CC=;3J=;3N ::j !1} ))+ !#"(N=N=b ' (r