U
    Ycc                     @   s  U d Z ddlZddlZddlmZmZmZ ddlmZ dZ	G dd deZ
G dd	 d	eZG d
d deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZejZeed< ejZeed< ejZeed< ejZeed< ejZeed < ejZeed!< ejZeed"< ejZeed#< ejZeed$< ej Z eed%< ej!Z!eed&< ej"Z"eed'< ej#Z#eed(< e
j$Z$eed)< e
j%Z%eed*< e
j&Z&eed+< e
j'Z'eed,< e
j(Z(eed-< e
j)Z)eed.< e
j*Z*eed/< e
j+Z+eed0< e
j,Z,eed1< e
j-Z-eed2< e
j.Z.eed3< e
j/Z/eed4< e
j0Z0eed5< e
j1Z1eed6< e
j2Z2eed7< e
j3Z3eed8< e
j4Z4eed9< e
j5Z5eed:< e
j6Z6eed;< e
j7Z7eed<< e
j8Z8eed=< e
j9Z9eed>< e
j:Z:eed?< e
j;Z;eed@< e
j<Z<eedA< ej=Z>eedB< ej?Z@eedC< ejAZBeedD< ejCZDeedE< ejEZFeedF< ejGZHeedG< ejIZJeedH< ejKZLeedI< ejMZNeedJ< ejOZPeedK< ejQZReedL< ejSZTeedM< ejUZVeedN< ejWZXeedO< ejYZZeedP< ej[Z\eedQ< ej]Z]eedR< ej^Z^eedS< ej_Z_eedT< ej`Z`eedU< ejaZaeedV< ejbZbeedW< ejcZceedX< ejdZdeedY< ejeZeeedZ< ejfZfeed[< ejgZgeed\< ejhZheed]< ejiZieed^< ejjZjeed_< ejkZkeed`< ejlZleeda< ejmZmeedb< ejnZneedc< ejoZoeedd< ejpZpeede< ejqZqeedf< ejrZseedg< ejtZueedh< ejvZweedi< ejxZxeedj< ejyZyeedk< ejzZzeedl< ej{Z{eedm< ej|Z|eedn< ej}Z}eedo< ej~Z~eedp< ejZeedq< ejZeedr< ejZeeds< ejZeedt< ejZeedu< ejZeedv< ejZeedw< ejZeedx< ejZeedy< ejZeedz< ejZeed{< ejZeed|< ejZeed}< ejZeed~< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ej Z eed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< ejZeed< d	ddddd d!d"d#d$d%dd&d'd(ddd)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAddBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdiddjdkdlddddmdndoddpdqdrdsddtdudvdwddxdydzd{d|d}d~ddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddgZee	 ed< dS )zzmq constants as enums    N)EnumIntEnumIntFlag)Listi=R	c                   @   s  e Zd ZdZejZejZejZej	
drvdZdZdZdZdZdZd	Zd
ZdZdZdZdZdZdZdZdZdZdZn eeded Zeeded Zeeded Zeeded Zeeded Zeeded  Zeed!ed" Zeed#ed$ Zeed%ed& Zeed'ed( Zeed)ed* Zeed+ed, Zeed-ed. Zeed/ed0 Zeed1ed2 Zeed3ed4 Zeed5ed6 Zeed7ed8 Zed9 Zed: Z ed; Z!ed< Z"d=S )>Errnoz1libzmq error codes

    .. versionadded:: 23
    win      w   t   d   e   k   p      s   f   v   j   l   ~      n   u   ENOTSUP   EPROTONOSUPPORT   ENOBUFS   ENETDOWN   
EADDRINUSE   EADDRNOTAVAIL   ECONNREFUSED   EINPROGRESS   ENOTSOCK	   EMSGSIZE
   EAFNOSUPPORT   ENETUNREACH   ECONNABORTED   
ECONNRESET   ENOTCONN   	ETIMEDOUT   EHOSTUNREACH   	ENETRESET   3   4   5   6   N)#__name__
__module____qualname____doc__errnoEAGAINEFAULTEINVALsysplatform
startswithr   r   r   r    r"   r$   r&   r(   r*   r,   r.   r0   r2   r4   r6   r8   r:   r<   getattr_HAUSNUMEROEFSMENOCOMPATPROTOETERMEMTHREAD rS   rS   ,lib/python3.8/site-packages/zmq/constants.pyr   
   sZ   r   c                   @   s8   e Zd ZdZdZdZdZdZdZdZ	dZ
dZd	Zd
ZdS )ContextOptionz:Options for Context.get/set

    .. versionadded:: 23
    r   r   r   r!   r#   r%   r'   r)   r+   N)rB   rC   rD   rE   
IO_THREADSMAX_SOCKETSSOCKET_LIMITTHREAD_PRIORITYTHREAD_SCHED_POLICY	MAX_MSGSZ
MSG_T_SIZETHREAD_AFFINITY_CPU_ADDTHREAD_AFFINITY_CPU_REMOVETHREAD_NAME_PREFIXrS   rS   rS   rT   rU   H   s   rU   c                   @   sl   e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZdZe	Ze
ZdZdZdZdZdZdZdZdZdZdS )
SocketTypez/zmq socket types

    .. versionadded:: 23
    r   r   r   r   r!   r#   r%   r'   r)   r+   r-   r/   r1   r3   r5   r7   r9   r;   r=         N)rB   rC   rD   rE   PAIRPUBSUBREQREPDEALERROUTERPULLPUSHXPUBXSUBSTREAMXREQXREPSERVERCLIENTRADIODISHGATHERSCATTERDGRAMPEERCHANNELrS   rS   rS   rT   r`   Z   s0   r`   c                   @   s   e Zd ZdZdZdZdZdS )_OptTypeintint64bytesfdN)rB   rC   rD   r{   r|   r}   r~   rS   rS   rS   rT   rz   }   s   rz   c                   @   s  e Zd ZU dZeed< ejfeedddZdZdej	fZ
dejfZd	ejfZd
ejfZdZdZdZdZdZdejfZdZdZdZdZdZdZdej	fZdZdZdZdZ dZ!dejfZ"dZ#dZ$d Z%d!Z&d"Z'd#Z(d$Z)d%Z*d&Z+d'Z,d(Z-d)ejfZ.d*ejfZ/d+Z0d,ejfZ1d-ejfZ2d.ejfZ3d/Z4d0Z5d1Z6d2Z7d3ejfZ8d4Z9d5Z:d6ejfZ;d7Z<d8ejfZ=d9ejfZ>d:Z?d;Z@d<ejfZAd=ZBd>ZCd?ZDd@ejfZEdAZFdBZGdCZHdDZIdEZJdFZKdGZLdHZMdIZNdJZOdKej	fZPdLej	fZQdMej	fZRdNZSdOZTdPZUdQZVdRejfZWeZXe;ZYdSejfZZdTZ[dUZ\dVZ]dWZ^e(Z_e#Z`e#ZadXZbdYZcdZejfZdd[Zed\Zfd]Zgd^ejfZhd_ejfZid`ZjdaZkdbejfZldcejfZmddejfZndeejfZodfZpdgZqdhZrdiejfZsdjejfZtdkZudlS )mSocketOptionz9Options for Socket.get/set

    .. versionadded:: 23
    	_opt_type)valueopt_typec                 C   s   t | |}||_||_|S )z"Attach option type as `._opt_type`)r{   __new___value_r   )clsr   r   objrS   rS   rT   r      s    zSocketOption.__new__r   r!   r#   r%   r'   r)   r+   r/   r1   r3   r5   r7   r9   r;   r=   ra                            !   "   #   $   %   '   (   )   *   +   ,   -   .   /   0   1   2   r>   r?   r@   rA   7   8   9   =   >   ?   @   A   B   D   E   F   G   H   I   J   K   L   M   N   O   P   Q   T   U   V   W   X   Y   Z   [   \   &   :   ;   <      ]   ^   _   `   a   b   c   r   r   r   g   h   i   r   r   r   m   r   o   r   N)vrB   rC   rD   rE   rz   __annotations__r{   r   HWMr|   AFFINITYr}   
ROUTING_ID	SUBSCRIBEUNSUBSCRIBERATERECOVERY_IVLSNDBUFRCVBUFRCVMOREr~   FDEVENTSTYPELINGERRECONNECT_IVLBACKLOGRECONNECT_IVL_MAX
MAXMSGSIZESNDHWMRCVHWMMULTICAST_HOPSRCVTIMEOSNDTIMEOLAST_ENDPOINTROUTER_MANDATORYTCP_KEEPALIVETCP_KEEPALIVE_CNTTCP_KEEPALIVE_IDLETCP_KEEPALIVE_INTVL	IMMEDIATEXPUB_VERBOSE
ROUTER_RAWIPV6	MECHANISMPLAIN_SERVERPLAIN_USERNAMEPLAIN_PASSWORDCURVE_SERVERCURVE_PUBLICKEYCURVE_SECRETKEYCURVE_SERVERKEYPROBE_ROUTERREQ_CORRELATEREQ_RELAXEDCONFLATE
ZAP_DOMAINROUTER_HANDOVERTOSCONNECT_ROUTING_IDGSSAPI_SERVERGSSAPI_PRINCIPALGSSAPI_SERVICE_PRINCIPALGSSAPI_PLAINTEXTHANDSHAKE_IVLSOCKS_PROXYXPUB_NODROPBLOCKYXPUB_MANUALXPUB_WELCOME_MSGSTREAM_NOTIFYINVERT_MATCHINGHEARTBEAT_IVLHEARTBEAT_TTLHEARTBEAT_TIMEOUTXPUB_VERBOSERCONNECT_TIMEOUT	TCP_MAXRTTHREAD_SAFEMULTICAST_MAXTPDUVMCI_BUFFER_SIZEVMCI_BUFFER_MIN_SIZEVMCI_BUFFER_MAX_SIZEVMCI_CONNECT_TIMEOUTUSE_FDGSSAPI_PRINCIPAL_NAMETYPE!GSSAPI_SERVICE_PRINCIPAL_NAMETYPEBINDTODEVICEIDENTITYCONNECT_RIDTCP_ACCEPT_FILTERIPC_FILTER_PIDIPC_FILTER_UIDIPC_FILTER_GIDIPV4ONLYDELAY_ATTACH_ON_CONNECTFAIL_UNROUTABLEROUTER_BEHAVIORZAP_ENFORCE_DOMAINLOOPBACK_FASTPATHMETADATAMULTICAST_LOOPROUTER_NOTIFYXPUB_MANUAL_LAST_VALUESOCKS_USERNAMESOCKS_PASSWORDIN_BATCH_SIZEOUT_BATCH_SIZEWSS_KEY_PEMWSS_CERT_PEMWSS_TRUST_PEMWSS_HOSTNAMEWSS_TRUST_SYSTEMONLY_FIRST_SUBSCRIBERECONNECT_STOP	HELLO_MSGDISCONNECT_MSGPRIORITYrS   rS   rS   rT   r      s   
































r   c                   @   s   e Zd ZdZdZdZdZdS )MessageOptionz;Options on zmq.Frame objects

    .. versionadded:: 23
    r   r   r   N)rB   rC   rD   rE   MORESHAREDSRCFDrS   rS   rS   rT   r=    s   r=  c                   @   s   e Zd ZdZdZdZeZdS )Flagz.Send/recv flags

    .. versionadded:: 23
    r   r   N)rB   rC   rD   rE   DONTWAITSNDMORENOBLOCKrS   rS   rS   rT   rA    s   rA  c                   @   s    e Zd ZdZdZdZdZdZdS )SecurityMechanismzaSecurity mechanisms (as returned by ``socket.get(zmq.MECHANISM)``)

    .. versionadded:: 23
    r   r   r   r   N)rB   rC   rD   rE   NULLPLAINCURVEGSSAPIrS   rS   rS   rT   rE    s
   rE  c                   @   s   e Zd ZdZedd ZdZdZdZdZ	dZ
d	Zd
ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*e*Z+d)Z,e*e,B Z-d*S )+Eventz7Socket monitoring events

    .. versionadded:: 23
    c                 C   s   |  dr| S d|  S d S )NZPROTOCOL_ERROR_ZEVENT_)rL   )namerS   rS   rT   _global_name.  s    
zEvent._global_namei   0i   i  i  i  i  i  i  i  i  i  i  i  i  i  i    i   i   i   i   i   r   r   r!   r)   r9   r   r   r      i   i   i   i   i    i @  i  i   N).rB   rC   rD   rE   staticmethodrL  PROTOCOL_ERROR_WS_UNSPECIFIEDPROTOCOL_ERROR_ZMTP_UNSPECIFIED&PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND$PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE1PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED-PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR+PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY-PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME$PROTOCOL_ERROR_ZMTP_INVALID_METADATA!PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC&PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCHPROTOCOL_ERROR_ZAP_UNSPECIFIED"PROTOCOL_ERROR_ZAP_MALFORMED_REPLY!PROTOCOL_ERROR_ZAP_BAD_REQUEST_IDPROTOCOL_ERROR_ZAP_BAD_VERSION&PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE#PROTOCOL_ERROR_ZAP_INVALID_METADATA	CONNECTEDCONNECT_DELAYEDCONNECT_RETRIED	LISTENINGBIND_FAILEDACCEPTEDACCEPT_FAILEDCLOSEDCLOSE_FAILEDDISCONNECTEDMONITOR_STOPPEDHANDSHAKE_FAILED_NO_DETAILHANDSHAKE_SUCCEEDEDHANDSHAKE_FAILED_PROTOCOLHANDSHAKE_FAILED_AUTHALL_V1ALLPIPES_STATSALL_V2rS   rS   rS   rT   rJ  (  sV   
rJ  c                   @   s    e Zd ZdZdZdZdZdZdS )	PollEventzFWhich events to poll for in poll methods

    .. versionadded: 23
    r   r   r!   r)   N)rB   rC   rD   rE   POLLINPOLLOUTPOLLERRPOLLPRIrS   rS   rS   rT   rw  g  s
   rw  c                   @   s   e Zd ZdZdZdZdZdS )
DeviceTypezBDevice type constants for zmq.device

    .. versionadded: 23
    r   r   r   N)rB   rC   rD   rE   STREAMER	FORWARDERQUEUErS   rS   rS   rT   r|  s  s   r|  rV   rW   rX   rY   rZ   r[   r\   r]   r^   r_   r}  r~  r  rG   rH   rI   r   r   r   r    r"   r$   r&   r(   r*   r,   r.   r0   r2   r4   r6   r8   r:   r<   rO   rP   rQ   rR   EVENT_CONNECTEDEVENT_CONNECT_DELAYEDEVENT_CONNECT_RETRIEDEVENT_LISTENINGEVENT_BIND_FAILEDEVENT_ACCEPTEDEVENT_ACCEPT_FAILEDEVENT_CLOSEDEVENT_CLOSE_FAILEDEVENT_DISCONNECTEDEVENT_MONITOR_STOPPED	EVENT_ALL EVENT_HANDSHAKE_FAILED_NO_DETAILEVENT_HANDSHAKE_SUCCEEDEDEVENT_HANDSHAKE_FAILED_PROTOCOLEVENT_HANDSHAKE_FAILED_AUTHrP  rQ  rR  rS  rT  rU  rV  rW  rX  rY  rZ  r[  r\  r]  r^  r_  r`  ra  rb  rc  rO  EVENT_PIPES_STATSEVENT_ALL_V1EVENT_ALL_V2rB  rC  rD  r>  r?  r@  rx  ry  rz  r{  rF  rG  rH  rI  r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r  r  r  r  r  r	  r
  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r   r!  r"  r#  r$  r%  r&  r'  r(  r)  r*  r+  r,  r-  r.  r/  r0  r1  r2  r3  r4  r5  r6  r7  r8  r9  r:  r;  r<  rc   rd   re   rf   rg   rh   ri   rj   rk   rl   rm   rn   ro   rp   rq   rr   rs   rt   ru   rv   rw   rx   ry   r   r   r   __all__(
  rE   rF   rJ   enumr   r   r   typingr   rN   r   rU   r`   rz   r   r=  rA  rE  rJ  rw  r|  rV   r{   r   rW   rX   rY   rZ   r[   r\   r]   r^   r_   r}  r~  r  rG   rH   rI   r   r   r   r    r"   r$   r&   r(   r*   r,   r.   r0   r2   r4   r6   r8   r:   r<   rO   rP   rQ   rR   rd  r  re  r  rf  r  rg  r  rh  r  ri  r  rj  r  rk  r  rl  r  rm  r  rn  r  rt  r  ro  r  rp  r  rq  r  rr  r  rP  rQ  rR  rS  rT  rU  rV  rW  rX  rY  rZ  r[  r\  r]  r^  r_  r`  ra  rb  rc  rO  ru  r  rs  r  rv  r  rB  rC  rD  r>  r?  r@  rx  ry  rz  r{  rF  rG  rH  rI  r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r  r  r  r  r  r	  r
  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r   r!  r"  r#  r$  r%  r&  r'  r(  r)  r*  r+  r,  r-  r.  r/  r0  r1  r2  r3  r4  r5  r6  r7  r8  r9  r:  r;  r<  rc   rd   re   rf   rg   rh   ri   rj   rk   rl   rm   rn   ro   rp   rq   rr   rs   rt   ru   rv   rw   rx   ry   r  strrS   rS   rS   rT   <module>   s  ># ?









 