U
    luff                     @   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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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
j/Z/eed5< e
j0Z0eed6< e
j1Z1eed7< e
j2Z2eed8< e
j3Z3eed9< e
j4Z4eed:< 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dA< e
j<Z<eedB< e
j=Z=eedC< ej>Z>eedD< ej?Z?eedE< ej@Z@eedF< ejAZAeedG< ejBZBeedH< ejCZCeedI< ejDZDeedJ< ejEZEeedK< ejFZFeedL< ejGZGeedM< ejHZHeedN< ejIZIeedO< ejJZJeedP< ejKZKeedQ< ejLZLeedR< ejMZMeedS< ejNZNeedT< ejOZOeedU< ejPZPeedV< ejQZQeedW< ejRZReedX< ejSZTeedY< ejUZVeedZ< ejWZXeed[< ejYZZeed\< ej[Z\eed]< ej]Z^eed^< ej_Z`eed_< ejaZbeed`< ejcZdeeda< ejeZfeedb< ejgZheedc< ejiZjeedd< ejkZleede< ejmZneedf< ejoZpeedg< ejqZreedh< ejsZteedi< ejuZveedj< ejwZxeedk< ejyZyeedl< ejzZze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jZe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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< d	ddd d!d"d#d$d%d&d'dd(d)d*ddd+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCddDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkddldmdnd dddodpdqddrdsdtduddvdwdxddydzd{d|dd}d~dddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddd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   1/tmp/pip-unpacked-wheel-h6ekxre8/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S )ReconnectStopzHSelect behavior for socket.reconnect_stop

    .. versionadded:: 25
    c                 C   s
   d|  S )NZRECONNECT_STOP_rS   namerS   rS   rT   _global_name.  s    zReconnectStop._global_namer   r   r!   N)	rB   rC   rD   rE   staticmethodrM  CONN_REFUSEDHANDSHAKE_FAILEDAFTER_DISCONNECTrS   rS   rS   rT   rJ  (  s   
rJ  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   rK  rS   rS   rT   rM  =  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   rN  rM  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   rR  7  sV   
rR  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   r|  v  s
   r|  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   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   rT  rU  rV  rW  rX  rY  rZ  r[  r\  r]  r^  r_  r`  ra  rb  rc  rd  re  rf  rg  rh  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_HANDSHAKE_FAILED_NO_DETAILEVENT_HANDSHAKE_SUCCEEDEDEVENT_HANDSHAKE_FAILED_PROTOCOLEVENT_HANDSHAKE_FAILED_AUTHEVENT_ALL_V1	EVENT_ALLEVENT_PIPES_STATSEVENT_ALL_V2rB  rC  rD  r>  r?  r@  r}  r~  r  r  RECONNECT_STOP_CONN_REFUSEDRECONNECT_STOP_HANDSHAKE_FAILEDRECONNECT_STOP_AFTER_DISCONNECTrF  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  rR  r|  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   rT  rU  rV  rW  rX  rY  rZ  r[  r\  r]  r^  r_  r`  ra  rb  rc  rd  re  rf  rg  rh  ri  r  rj  r  rk  r  rl  r  rm  r  rn  r  ro  r  rp  r  rq  r  rr  r  rs  r  rt  r  ru  r  rv  r  rw  r  rx  r  ry  r  rz  r  r{  r  rB  rC  rD  r>  r?  r@  r}  r~  r  r  rO  r  rP  r  rQ  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  ># ?









 