hZSrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r J r SSK J r SSKJrJr SS KJr \R&\R(\R*\R,1rS r\"5rS rS r\R:"S 5rSSSSSS.r\4Sjr "SS5r!"SS\!5r""SS\!5r#SSjr$g)zTransport implementation.N)contextmanager)SSLError)packunpack)UnexpectedFrame)KNOWN_TCP_OPTSSOL_TCP) set_cloexeci(isAMQP z\[([\.0-9a-f:]+)\](?::(\d+))?i< ) TCP_NODELAYTCP_USER_TIMEOUT TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNTcUn[RU5nU(aDURS5nURS5(a[URS55nX4$SU;aUR SS5up[U5nX4$)z1Convert hostname:port string to host, port tuple.r:) IPV6_LITERALmatchgroupintrsplit)hostdefaultportms 6D:\TimeStamps\venv\Lib\site-packages\amqp/transport.py to_host_portr!(s{ D4 Awwqz 771::qwwqz?D : $;S!,JDt9D :c\rSrSrSrSSjrSrSrSr\ S5r S r S r S r S rSS jrSrSrSrSr\4SjrSrSrg)_AbstractTransport7aCommon superclass for TCP and SSL transports. PARAMETERS: host: str Broker address in format ``HOSTNAME:PORT``. connect_timeout: int Timeout of creating new connection. read_timeout: int sets ``SO_RCVTIMEO`` parameter of socket. write_timeout: int sets ``SO_SNDTIMEO`` parameter of socket. socket_settings: dict dictionary containing `optname` and ``optval`` passed to ``setsockopt(2)``. raise_on_initial_eintr: bool when True, ``socket.timeout`` is raised when exception is received during first read. See ``_read()`` for details. Nc SUlSUlX`l[Ul[ U5uUlUlX lX0l X@l XPl gNF) connectedsockraise_on_initial_eintr EMPTY_BUFFER _read_bufferr!rrconnect_timeout read_timeout write_timeoutsocket_settings)selfrr-r.r/r0r*kwargss r __init___AbstractTransport.__init__WsK &<#(+D1 49.(*.r") connectionr)r*r,rrr-r.r/r0__dict__ __weakref__c  UR(aURR5SSURR5S3nURR5SSURR5S3nS[ U5R SUSUS[U5S S 3 $S[ U5R S [U5S S 3$![RanSU3nSnANpSnAff=f) NrrrzERROR:  z at z#x>z: (disconnected) at )r) getsockname getpeernamesocketerrortype__name__id)r1srcdstes r __repr___AbstractTransport.__repr__ts 99YY**,Q/0$))2G2G2I!2L1MNC $..034Adii6K6K6Ma6P5QRtDz**+2cU$se44}AN NtDz**++?4}AN N LL $sm $s=CD3C==DcUR(agURURURUR5 UR UR URUR5 SUlg![[4aE UR(a2UR(d!URR5 SUl ef=f)NT) r(_connectrrr- _init_socketr0r.r/OSErrorrr)closer1s r connect_AbstractTransport.connects ~~ MM$))TYY0D0D E   $$d&7&79K9K  "DN" yy !    sA>A)A>>ACc#R# UcURv gURnUR5nX1:waURU5 URv X:waURU5 gg![aNnS[ U5;a[ R "5eS[ U5;a[ R "5eeSnAf[a9nUR[R:Xa[ R "5eeSnAff=f!X:waURU5 ff=f7f)N timed outzThe operation did not complete) r) gettimeout settimeoutrstrr=timeoutrJerrno EWOULDBLOCK)r1rTr)prevexcs r having_timeout!_AbstractTransport.having_timeouts ?))O99D??$D( *ii?OOD)# #c(* ..**5SA ..** 99 1 11 ..**  ?OOD)#sCAD'A/D'/ D9A C D4DDD D$$D'c^[R"X[R[R[5n[ U5HuupVUupxpn [R"XxU 5Ul[UR S5 UR RU5 UR RU 5 g g![a NGf=f![RaI UR (aUR R5 SUlUS-[U5:aeMf=f)NTr)r= getaddrinfo AF_UNSPEC SOCK_STREAMr enumerater)r NotImplementedErrorrRrMr>rKlen) r1rrrTentriesiresafsocktypeproto canonnamesas r rH_AbstractTransport._connects$$ ((&*<*  40 $$W- !!"%#) +<< 99IIOO%  q5CL()  s7C.B?6C? C  C C  CAD,+D,c URRS5 URR[R[R S5 UR U5 [RU4[RU44HZupEUcM [U5n[XV- S-5nURR[RU[SXg55 M\ UR5 UR[5 g)Nri@Bll)r)rR setsockoptr= SOL_SOCKET SO_KEEPALIVE_set_socket_options SO_SNDTIMEO SO_RCVTIMEOrr_setup_transport_writeAMQP_PROTOCOL_HEADER)r1r0r.r/rTintervalsecusecs r rI_AbstractTransport._init_sockets T" V..0C0CQG   1$*#5#5}"E#)#5#5|"D"F G#(mHNg56 $$%%ws) "F  ()r"cl0n[HnSnUS:XaSSKJn O%[ [U5(a[ [U5nU(dMAU[ ;a [ UX$'MX[ [U5(dMoUR[[ [U55X$'M U$![a SnNqf=f)Nrr)r) r r=r ImportErrorhasattrgetattrDEFAULT_SOCKET_SETTINGS getsockoptr )r1r)tcp_optsoptenums r _get_tcp_socket_defaults+_AbstractTransport._get_tcp_socket_defaultss!CD((?%%vs+t11%BHIr"rntrPFNzReceived frame_end z#04xz while expecting 0xce)rr+SIGNED_INT_MAXr=rTrJrjoinordr, isinstancer>osnamerUrVrS_UNAVAILr(r) r1rreadread_frame_buffer frame_header frame_typechannelsizepart1part2payload frame_endrXs r read_frame_AbstractTransport.read_frameszz(, 4=L  - (.v|(D %Jn$^, !67E((E>2t*  ( DG I2  / /!%i%55JKM MM:&.% ~~  14E4E ED  " 3 --"''T/II!2!22 %68I8I$I!nn&&#x(([CH-D%68I8I$I!nn&&yy(!& ' s0/CB0C%CC7G".226>B / I O(**4.*&*4D  D,!'@MDr"r$c^\rSrSrSrSU4SjjrSrSrSSjrSSjr SS jr S r S\ R\ R\ R44S jrS rS rU=r$) SSLTransportigaoTransport that works over SSL. PARAMETERS: host: str Broker address in format ``HOSTNAME:PORT``. connect_timeout: int Timeout of creating new connection. ssl: bool|dict parameters of TLS subsystem. - when ``ssl`` is not dictionary, defaults of TLS are used - otherwise: - if ``ssl`` dictionary contains ``context`` key, :attr:`~SSLTransport._wrap_context` is used for wrapping socket. ``context`` is a dictionary passed to :attr:`~SSLTransport._wrap_context` as context parameter. All others items from ``ssl`` argument are passed as ``sslopts``. - if ``ssl`` dictionary does not contain ``context`` key, :attr:`~SSLTransport._wrap_socket_sni` is used for wrapping socket. All items in ``ssl`` argument are passed to :attr:`~SSLTransport._wrap_socket_sni` as parameters. kwargs: additional arguments of :class:`~amqp.transport._AbstractTransport` class c ~>[U[5(aUO0Ul[Ul[ TU]"U4SU0UD6 g)Nr-)rdictssloptsr+r,superr3)r1rr-sslr2 __class__s r r3SSLTransport.__init__s@(d33s (   ="1 =5; =r")rcUR"UR40URD6UlURRUR5 URR 5 URR Ulg)z!Wrap the socket in an SSL object.N) _wrap_socketr)rrRr- do_handshaker _quick_recvrLs r rsSSLTransport._setup_transportsY%%dii@4<<@  T112  99>>r"c \U(aUR"X40UD6$UR"U40UD6$r) _wrap_context_wrap_socket_sni)r1r)contextrs r rSSLTransport._wrap_sockets1 %%d?w? ?$$T5W55r"c `[R"S0UD6nX5lUR"U40UD6$)uWrap socket without SNI headers. PARAMETERS: sock: socket.socket Socket to be wrapped. sslopts: dict Parameters of :attr:`ssl.SSLContext.wrap_socket`. check_hostname Whether to match the peer cert’s hostname. See :attr:`ssl.SSLContext.check_hostname` for details. ctx_options Parameters of :attr:`ssl.create_default_context`. r)rcreate_default_contextcheck_hostname wrap_socket)r1r)rr ctx_optionsctxs r rSSLTransport._wrap_contexts1*((7;7+t/w//r"Fc UUUUU S.n U c'U(a[RO[Rn [R"U 5n UbU R X25 UbU R U5 U bU R U 5 [R=(a U SLU lUbX]l UcjU R[R:waLU(a[RRO[RRnU RU5 U R "S0U D6nU$![a Nf=f)umSocket wrap with SNI headers. stdlib :attr:`ssl.SSLContext.wrap_socket` method augmented with support for setting the server_hostname field required for SNI hostname header. PARAMETERS: sock: socket.socket Socket to be wrapped. keyfile: str Path to the private key certfile: str Path to the certificate server_side: bool Identifies whether server-side or client-side behavior is desired from this socket. See :attr:`~ssl.SSLContext.wrap_socket` for details. cert_reqs: ssl.VerifyMode When set to other than :attr:`ssl.CERT_NONE`, peers certificate is checked. Possible values are :attr:`ssl.CERT_NONE`, :attr:`ssl.CERT_OPTIONAL` and :attr:`ssl.CERT_REQUIRED`. ca_certs: str Path to “certification authority” (CA) certificates used to validate other peers’ certificates when ``cert_reqs`` is other than :attr:`ssl.CERT_NONE`. do_handshake_on_connect: bool Specifies whether to do the SSL handshake automatically. See :attr:`~ssl.SSLContext.wrap_socket` for details. suppress_ragged_eofs (bool): See :attr:`~ssl.SSLContext.wrap_socket` for details. server_hostname: str Specifies the hostname of the service which we are connecting to. See :attr:`~ssl.SSLContext.wrap_socket` for details. ciphers: str Available ciphers for sockets created with this context. See :attr:`ssl.SSLContext.set_ciphers` ssl_version: Protocol of the SSL Context. The value is one of ``ssl.PROTOCOL_*`` constants. )r) server_sidedo_handshake_on_connectsuppress_ragged_eofsserver_hostnameNr)rPROTOCOL_TLS_SERVERPROTOCOL_TLS_CLIENT SSLContextload_cert_chainload_verify_locations set_ciphersHAS_SNIrAttributeError verify_mode CERT_NONEPurpose CLIENT_AUTH SERVER_AUTHload_default_certsr)r1r)keyfilecertfiler cert_reqsca_certsrrrciphers ssl_versionoptsrpurposes r rSSLTransport._wrap_socket_snis2H&'>$8.    '',,  ..-    # #H 6    ) )( 3      (  ;t ;  "  "+    3 3s}} D ''[[,,   & &w /""*T* #   s D00 D=<D=c^URb URR5Ulgg)z/Unwrap a SSL socket, so we can call shutdown().N)r)unwraprLs r r SSLTransport._shutdown_transport2s% 99  ((*DI !r"cURnURn[U5U:a<U"U[U5- 5nU(d [S5eXV- n[U5U:aM<USUXQSsolU$![aInURU;a3U(a&UR (a[ R"5eSnAMeSnAff=f! XPle=f)N%Server unexpectedly closed connectionrr,rarJrUr*r=rT r1rr_errnosrecvrbufrrXresults r rSSLTransport._read7s    d)a- QT]+A!"IJJ d)a-"%)!Hd2h!! yyG+"t'B'B"(.."22   $  9C A5%C 5 C?=C<C CCC CcURRnU(a)U"U5nU(d [S5eXSnU(aM(gg![a SnN/f=f)z+Write a string out to the SSL socket fully.rz Socket closedN)r)r ValueErrorrJ)r1rrrs r rtSSLTransport._writeSsX  !Ho.."Aa    sA AA)rr,r)r)NNr) NNFNNFTNNN)r@rrrrr3rrsrrrrrUENOENTEAGAINEINTRrrtr __classcell__)rs@r rrgsl D=  I*6 02=A6:@EDH37 vp+ %||U\\5;;?8r"rcX\rSrSrSrSrS\R\R44Sjr Sr g) TCPTransportidzvTransport that deals directly with TCP socket. All parameters are :class:`~amqp.transport._AbstractTransport` class. cURRUl[UlURR Ulgr)r)sendallrtr+r,rrrLs r rsTCPTransport._setup_transportjs-ii'' (99>>r"FcURnURn[U5U:a<U"U[U5- 5nU(d [S5eXV- n[U5U:aM<USUXQSsolU$![aInURU;a3U(a&UR (a[ R"5eSnAMeSnAff=f! XPle=f)z%Read exactly n bytes from the socket.Nrrrs r rTCPTransport._readqs   d)a-QT]+A!"IJJ d)a- %)!Hd2h!! yyG+"t'B'B"(.."22    $  r)rr,rtN) r@rrrrrsrUr r rrrr"r r r ds% * %u||U[[.Ir"r c >U(a[O[nU"U4XS.UD6$)a[Create transport. Given a few parameters from the Connection constructor, select and create a subclass of :class:`~amqp.transport._AbstractTransport`. PARAMETERS: host: str Broker address in format ``HOSTNAME:PORT``. connect_timeout: int Timeout of creating new connection. ssl: bool|dict If set, :class:`~amqp.transport.SSLTransport` is used and ``ssl`` parameter is passed to it. Otherwise :class:`~amqp.transport.TCPTransport` is used. kwargs: additional arguments of :class:`~amqp.transport._AbstractTransport` class )r-r)rr )rr-rr2 transports r Transportrs"8!$ I T N? Nv NNr"r')%rrUrrer=r contextlibrrstructrr exceptionsrplatformr r utilsr r r rrVr AMQP_PORTbytesr+rrucompilerrr!r$rr rrr"r rs %'- LL%++u||U5F5F G  w /zz:;   ) mm` z%zz#%#LOr"