ó Ì g]c@s«dZddlZddlZddlZddlZddlZddlZddlmZej e ƒZ de fd„ƒYZ de fd„ƒYZde fd „ƒYZd e fd „ƒYZd e fd „ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZde fd„ƒYZde fd„ƒYZde fd„ƒYZdefd„ƒYZdejjfd„ƒYZdefd„ƒYZdS( s,Implements `AMQPConnectionWorkflow` - the default workflow of performing multiple TCP/[SSL]/AMQP connection attempts with timeouts and retries until one succeeds or all attempts fail. Defines the interface `AbstractAMQPConnectionWorkflow` that facilitates implementing custom connection workflows. iÿÿÿÿN(t __version__tAMQPConnectorExceptioncBseZdZRS(sBase exception for this module(t__name__t __module__t__doc__(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRstAMQPConnectorStackTimeoutcBseZdZRS(s:Overall TCP/[SSL]/AMQP stack connection attempt timed out.(RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRstAMQPConnectorAbortedcBseZdZRS(s Asynchronous request was aborted(RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRstAMQPConnectorWrongStatecBseZdZRS(sjAMQPConnector operation requested in wrong state, such as aborting after completion was reported. (RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR"stAMQPConnectorPhaseErrorBasecBs eZdZd„Zd„ZRS(sMWrapper for exception that occurred during a particular bring-up phase. cGs#tt|ƒj|Œ||_dS(sÈ :param BaseException exception: error that occurred while waiting for a subclass-specific protocol bring-up phase to complete. :param args: args for parent class N(tsuperRt__init__t exception(tselfR targs((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR -scCsdj|jj|jƒS(Ns{}: {!r}(tformatt __class__RR (R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyt__repr__7s(RRRR R(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR(s tAMQPConnectorSocketConnectErrorcBseZdZRS(s*Error connecting TCP socket to remote peer(RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR;st AMQPConnectorTransportSetupErrorcBseZdZRS(sOError setting up transport after TCP connected but before AMQP handshake. (RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR?stAMQPConnectorAMQPHandshakeErrorcBseZdZRS(sError during AMQP handshake(RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyREstAMQPConnectionWorkflowAbortedcBseZdZRS(s%AMQP Connection workflow was aborted.(RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRIst AMQPConnectionWorkflowWrongStatecBseZdZRS(suAMQP Connection Workflow operation requested in wrong state, such as aborting after completion was reported. (RRR(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRMstAMQPConnectionWorkflowFailedcBs eZdZd„Zd„ZRS(s5Indicates that AMQP connection workflow failed. cGs)tt|ƒj|Œt|ƒ|_dS(s˜ :param sequence exceptions: Exceptions that occurred during the workflow. :param args: args to pass to base class N(R RR ttuplet exceptions(R RR ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR XscCsNdj|jjt|jƒ|jdt|jƒdkrG|jdndƒS(NsG{}: {} exceptions in all; last exception - {!r}; first exception - {!r}iÿÿÿÿii(RRRtlenRtNone(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRbs (RRRR R(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRSs t AMQPConnectorcBsžeZdZdZdZdZdZdZdZdZ d„Z d „Z d „Z d „Z d „Zd „Zd„Zd„Zd„Zd„Zdd„ZRS(s;Performs a single TCP/[SSL]/AMQP connection workflow. iiiiiiicCsj||_||_d|_d|_d|_d|_d|_d|_d|_ d|_ |j |_ dS(sª :param callable conn_factory: A function that takes `pika.connection.Parameters` as its only arg and returns a brand new `pika.connection.Connection`-based adapter instance each time it is called. The factory must instantiate the connection with `internal_connection_workflow=False`. :param pika.adapters.utils.nbio_interface.AbstractIOServices nbio: N( t _conn_factoryt_nbioRt _addr_recordt _conn_paramst_on_donet_tcp_timeout_reft_stack_timeout_reft _task_reft_sockt _amqp_connt _STATE_INITt_state(R t conn_factorytnbio((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR ws          cCs~|j|jkr-tdj|jƒƒ‚n||_||_||_|j|_tj|jd Œ|_ |j j t j j tjdƒt jj|jj|j ƒ|j jtƒ|jd}tjdt|ƒ|jj|j |d|jƒ|_d|_|jjdk r;|jj|jj|jƒ|_nd|_ |jj!dk rz|jj|jj!|j"ƒ|_ ndS(s—Asynchronously perform a single TCP/[SSL]/AMQP connection attempt. :param tuple addr_record: a single resolved address record compatible with `socket.getaddrinfo()` format. :param pika.connection.Parameters conn_params: :param callable on_done: Function to call upon completion of the workflow: `on_done(pika.connection.Connection | BaseException)`. If exception, it's going to be one of the following: `AMQPConnectorSocketConnectError` `AMQPConnectorTransportSetupError` `AMQPConnectorAMQPHandshakeError` `AMQPConnectorAborted` s)Already in progress or finished; state={}iiis Pika version %s connecting to %rton_doneN(#R'R&RRRRR t _STATE_TCPtsocketR$t setsockopttpikatcompattSOL_TCPt TCP_NODELAYttcp_socket_optst set_sock_optst tcp_optionst setblockingtFalset_LOGtinfoRRtconnect_sockett_on_tcp_connection_doneR#RR!tsocket_timeoutt call_latert_on_tcp_connection_timeoutR"t stack_timeoutt_on_overall_timeout(R t addr_recordt conn_paramsR*taddr((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pytstart“s2            cCs|j|jkr!tdƒ‚n|j|jkrBtdƒ‚n|j|_|jƒtjd|jj |j ƒ|j d krµtj dƒ|jjtj|jtƒƒƒnf|j jsätj dƒ|j jddƒn7tj dƒ|j|jkstd j|jƒƒ‚d S( sšAbort the workflow asynchronously. The completion callback will be called with an instance of AMQPConnectorAborted. NOTE: we can't cancel/close synchronously because aborting pika Connection and its transport requires an asynchronous operation. :raises AMQPConnectorWrongState: If called after completion has been reported or the workflow not started yet. sCannot abort before starting.s*Cannot abort after completion was reportedsCAMQPConnector: beginning client-initiated asynchronous abort; %r/%ssXAMQPConnector.abort(): no connection, so just scheduling completion report via I/O loop.s*AMQPConnector.abort(): closing Connection.i@s3Client-initiated abort of AMQP Connection Workflow.sCAMQPConnector.abort(): closing of Connection was already initiated.s9Connection is closing, but not in TIMEOUT state; state={}N(R'R&Rt _STATE_DONEt_STATE_ABORTINGt _deactivateR7R8RthostRR%RtdebugRtadd_callback_threadsafet functoolstpartialt_report_completion_and_cleanupRt is_closingtcloset_STATE_TIMEOUTtAssertionErrorR(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pytabortÄs,           cCsf|jƒ|jdk r2|jjƒd|_nd|_d|_d|_d|_|j|_ dS(sqCancel asynchronous tasks and clean up to assist garbage collection. Transition to STATE_DONE. N( RFR$RRNRRRR RDR'(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyt_closeòs       cCs£|jdks'tdj|jƒƒ‚|jdk rO|jjƒd|_n|jdk rw|jjƒd|_n|jdk rŸ|jjƒd|_ndS(s$Cancel asynchronous tasks. s:_deactivate called with self._amqp_conn not None; state={}N( R%RRPRR'R!tcancelR"R#(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRFs     cCsSt|tƒr"tjd|ƒntjd|ƒ|j}|jƒ||ƒdS(s´Clean up and invoke client's `on_done` callback. :param pika.connection.Connection | BaseException result: value to pass to user's `on_done` callback. s%AMQPConnector - reporting failure: %rs%AMQPConnector - reporting success: %rN(t isinstancet BaseExceptionR7terrorR8R RR(R tresultR*((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRLs   cCsDd|_ttjdj|jj|jƒƒƒ}|j |ƒdS(stHandle TCP connection timeout Reports AMQPConnectorSocketConnectError with socket.timeout inside. s)TCP connection attempt timed out: {!r}/{}N( RR!RR,ttimeoutRRRGRRL(R RV((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR=,s   cCsDd|_|j}|j|_||jkr¯dj|jj|jt |jj ƒƒ}t j |ƒ|j j s‰tdj|j ƒƒ‚|j js«|j jd|ƒndS||jkrèttdj|jj|jƒƒƒ}nK||jksýt‚ttdj|jj|jt |jj ƒƒƒƒ}|j|ƒdS(sËHandle overall TCP/[SSL]/AMQP connection attempt timeout by reporting `Timeout` error to the client. Reports AMQPConnectorSocketConnectError if timeout occurred during socket TCP connection attempt. Reports AMQPConnectorTransportSetupError if timeout occurred during tramsport [SSL] setup attempt. Reports AMQPConnectorAMQPHandshakeError if timeout occurred during AMQP handshake. s0Timeout while setting up AMQP to {!r}/{}; ssl={}sUnexpected open state of {!r}i@Ns*Timeout while connecting socket to {!r}/{}s5Timeout while setting up transport to {!r}/{}; ssl={}(RR"R'ROt _STATE_AMQPRRRGRtboolt ssl_optionsR7RVR%tis_openRPRMRNR+RRt_STATE_TRANSPORTRRL(R t prev_statetmsgRV((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR?9s2     c Cs6d|_|jdk r1|jjƒd|_n|dk rjtjd||jƒ|jt|ƒƒdStj d|j ƒ|j |_ d}}|j jdk rá|j jj}|j jj}|dkrá|j j}qán|jjdtj|j|j ƒd|j d|d|d|jƒ|_d|_ dS( sHandle completion of asynchronous socket connection attempt. Reports AMQPConnectorSocketConnectError if TCP socket connection failed. :param None|BaseException exc: None on success; exception object on failure s*TCP Connection attempt failed: %r; dest=%rNs)TCP connection to broker established: %r.tprotocol_factorytsockt ssl_contexttserver_hostnameR*(RR#R!RSR7RVRRLRRHR$R]R'RR[tcontextRcRGRtcreate_streaming_connectionRJRKRt _on_transport_establishment_done(R texcRbRc((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR:gs4              cCs¸d|_t|tƒr]tjd||jj|jt |jj ƒƒ|j t |ƒƒdStj d|ƒ|\}|_|j|_|jj|jdtƒ|jj|jƒdS(sQHandle asynchronous completion of `AbstractIOServices.create_streaming_connection()` Reports AMQPConnectorTransportSetupError if transport ([SSL]) setup failed. :param sequence|BaseException result: On success, a two-tuple (transport, protocol); on failure, exception instance. sCAttempt to create the streaming transport failed: %r; %r/%s; ssl=%sNs"Streaming transport linked up: %r.tremove_default(RR#RTRUR7RVRRGRRZR[RLRR8R%RYR'tadd_on_open_error_callbackt_on_amqp_handshake_donetTruetadd_on_open_callback(R RWt _transport((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRf”s     cCs9tjd|j||jj|jƒd|_|j|jkrLt ƒ}nÜ|j|j kr—t t dj |jj|jt|jjƒƒƒƒ}n‘|j|jkr |dkrÝtjd|jj|j|ƒ|}q(tjd|jj|j|ƒt |ƒ}ntjd|j||ƒdS|j|ƒdS(sµHandle completion of AMQP connection handshake attempt. NOTE: we handle two types of callbacks - success with just connection arg as well as the open-error callback with connection and error Reports AMQPConnectorAMQPHandshakeError if AMQP handshake failed. :param pika.connection.Connection connection: :param BaseException | None error: None on success, otherwise failure sJAMQPConnector: AMQP handshake attempt completed; state=%s; error=%r; %r/%ss,Timeout during AMQP handshake{!r}/{}; ssl={}s8AMQPConnector: AMQP connection established for %r/%s: %rs=AMQPConnector: AMQP connection handshake failed for %r/%s: %rsgAMQPConnector: Ignoring AMQP handshake completion notification due to wrong state=%s; error=%r; conn=%rN(R7RHR'RRGRRR%RERRORRRRZR[RYRL(R t connectionRVRW((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRj¶s:      N(RRRR&R+R]RYRORERDR RCRQRRRFRLR=R?R:RfRRj(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRjs&  1 .    . - "tAbstractAMQPConnectionWorkflowcBs eZdZd„Zd„ZRS(sMInterface for implementing a custom TCP/[SSL]/AMQP connection workflow. cCs t‚dS(s¦Asynchronously perform the workflow until success or all retries are exhausted. Called by the adapter. :param sequence connection_configs: A sequence of one or more `pika.connection.Parameters`-based objects. Will attempt to connect using each config in the given order. :param callable connector_factory: call it without args to obtain a new instance of `AMQPConnector` for each connection attempt. See `AMQPConnector` for details. :param native_loop: Native I/O loop passed by app to the adapter or obtained by the adapter by default. :param callable on_done: Function to call upon completion of the workflow: `on_done(pika.connection.Connection | AMQPConnectionWorkflowFailed | AMQPConnectionWorkflowAborted)`. `Connection`-based adapter on success, `AMQPConnectionWorkflowFailed` on failure, `AMQPConnectionWorkflowAborted` if workflow was aborted. :raises AMQPConnectionWorkflowWrongState: If called in wrong state, such as after starting the workflow. N(tNotImplementedError(R tconnection_configstconnector_factoryt native_loopR*((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRCñscCs t‚dS(s·Abort the workflow asynchronously. The completion callback will be called with an instance of AMQPConnectionWorkflowAborted. NOTE: we can't cancel/close synchronously because aborting pika Connection and its transport requires an asynchronous operation. :raises AMQPConnectionWorkflowWrongState: If called in wrong state, such as before starting or after completion has been reported. N(Rp(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRQ s (RRRRCRQ(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRoìs tAMQPConnectionWorkflowcBs§eZdZejZejZdZdZ dZ dZ e d„Z d„Zd„Zd„Zd „Zd „Zd „Zd „Zd „Zd„Zd„Zd„ZRS(sImplements Pika's default workflow for performing multiple TCP/[SSL]/AMQP connection attempts with timeouts and retries until one succeeds or all attempts fail. The workflow: while not success and retries remain: 1. For each given config (pika.connection.Parameters object): A. Perform DNS resolution of the config's host. B. Attempt to establish TCP/[SSL]/AMQP for each resolved address until one succeeds, in which case we're done. 2. If all configs failed but retries remain, resume from beginning after the given retry pause. NOTE: failure of DNS resolution is equivalent to one cycle and will be retried after the pause if retries remain. iiiicCs|d|_d|_||_d|_d|_d|_d|_d|_d|_ d|_ d|_ g|_ |j |_dS(sã :param int | float retry_pause: Non-negative number of seconds to wait before retrying the config sequence. Meaningful only if retries is greater than 0. Defaults to 2 seconds. :param bool _until_first_amqp_attempt: INTERNAL USE ONLY; ends workflow after first AMQP handshake attempt, regardless of outcome (success or failure). The automatic connection logic in `pika.connection.Connection` enables this because it's not designed/tested to reset all state properly to handle more than one AMQP handshake attempt. TODO: Do we need getaddrinfo timeout? TODO: Would it be useful to implement exponential back-off? N(Rt_attempts_remainingt _retry_pauset_until_first_amqp_attemptRt_current_config_indext_connection_configst_connector_factoryR t _connectorR#t_addrinfo_itert_connection_errorsR&R'(R Rw((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR 3s            cCs ||_dS(sîCalled by the conneciton adapter only on pika's `AMQPConnectionWorkflow` instance to provide it the adapter-specific `AbstractIOServices` object before calling the `start()` method. NOTE: Custom workflow implementations should use the native I/O loop directly because `AbstractIOServices` is private to Pika implementation and its interface may change without notice. :param pika.adapters.utils.nbio_interface.AbstractIOServices nbio: N(R(R R)((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pytset_io_services]s cCs|j|jkr-tdj|jƒƒ‚nyt|ƒWn(tk re}tdj|ƒƒ‚nX|s„tdj|ƒƒ‚n||_||_ ||_ |dj |_ |dj |_|j|_tjdƒ|jjdtj|jdtƒƒ|_dS( sfOverride `AbstractAMQPConnectionWorkflow.start()`. NOTE: This implementation uses `connection_attempts` and `retry_delay` values from the last element of the given `connection_configs` sequence as the overall number of connection attempts of the entire `connection_configs` sequence and pause between each sequence. s)Already in progress or finished; state={}s3connection_configs does not support iteration: {!r}s"connection_configs is empty: {!r}.iÿÿÿÿs1Starting AMQP Connection workflow asynchronously.itfirstN(R'R&RRtitert Exceptiont TypeErrort ValueErrorRyRzR tconnection_attemptsRut retry_delayRvt _STATE_ACTIVER7RHRR<RJRKt_start_new_cycle_asyncRkR#(R RqRrRsR*RV((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRCks*      cCsÄ|j|jkr!tdƒ‚n!|j|jkrBtdƒ‚n|j|_|jƒtjdƒ|jdkr¦tj dƒ|j j t j|jtƒƒƒntj dƒ|jjƒdS(s<Override `AbstractAMQPConnectionWorkflow.abort()`. sCannot abort before starting.s*Cannot abort after completion was reportedsFAMQPConnectionWorkflow: beginning client-initiated asynchronous abort.s`AMQPConnectionWorkflow.abort(): no connector, so just scheduling completion report via I/O loop.s=AMQPConnectionWorkflow.abort(): requesting connector.abort().N(R'R&RRDRERFR7R8R{RRHRRIRJRKRLRRQ(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRQ—s        cCsY|jƒd|_d|_d|_d|_d|_d|_d|_|j |_ dS(srCancel asynchronous tasks and clean up to assist garbage collection. Transition to _STATE_DONE. N( RFRRyRRzR R{R|R}RDR'(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRR²s        cCs,|jdk r(|jjƒd|_ndS(s$Cancel asynchronous tasks. N(R#RRS(R ((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRFÄs cCsSt|tƒr"tjd|ƒntjd|ƒ|j}|jƒ||ƒdS(sÃClean up and invoke client's `on_done` callback. :param pika.connection.Connection | AMQPConnectionWorkflowFailed result: value to pass to user's `on_done` callback. s.AMQPConnectionWorkflow - reporting failure: %rs.AMQPConnectionWorkflow - reporting success: %rN(RTRUR7RVR8R RR(R RWR*((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRLÌs   cCs¿d|_|jdks't|jƒ‚|jdkrft|jƒ}tjd|ƒ|j|ƒdS|jd8_tj d|jƒd|_ |j j |r¦dn|j |jƒ|_dS(sQStart a new workflow cycle (if any more attempts are left) beginning with the first Parameters object in self._connection_configs. If out of attempts, report `AMQPConnectionWorkflowFailed`. :param bool first: if True, don't delay; otherwise delay next attempt by `self._retry_pause` seconds. is$AMQP connection workflow failed: %r.NisQBeginning a new AMQP connection workflow cycle; attempts remaining after this: %s(RR#RuRPRR}R7RVRLRHRxRR<Rvt_try_next_config_async(R RRV((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR‡Üs     c Csíd|_|jdkr$d|_n|jd7_|jt|jƒkrltjdƒ|jdtƒdS|j|j}tjd|j |j ƒ|jdksªt ‚|j j d|j d|j d |jd |jd |jƒ|_dS( swAttempt to connect using the next Parameters config. If there are no more configs, start a new cycle. iis-_try_next_config_async: starting a new cycle.RNs_try_next_config_async: %r:%sRGtporttsocktypetprotoR*(RR#RxRRyR7RHR‡R6RGR‰RPRt getaddrinfot _SOCK_TYPEt_IPPROTOt_on_getaddrinfo_async_done(R tparams((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRˆøs"        cCsd|_t|tƒrLtjd|ƒ|jj|ƒ|jdt ƒdStj dt |ƒƒt |ƒ|_ |jƒdS(säHandles completion callback from asynchronous `getaddrinfo()`. :param list | BaseException addrinfos_or_exc: resolved address records returned by `getaddrinfo()` or an exception object from failure. sgetaddrinfo failed: %r.RNsgetaddrinfo returned %s records(RR#RTRUR7RVR}tappendR‡R6RHRR€R|t_try_next_resolved_address(R taddrinfos_or_exc((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRs cCsŽyt|jƒ}Wn)tk r>tjdƒ|jƒdSXtjd|ƒ|jƒ|_|jjd|d|j |j d|j ƒdS(s}Try connecting using next resolved address. If there aren't any left, continue with next Parameters config. s8_try_next_resolved_address: continuing with next config.Ns-Attempting to connect using address record %rR@RAR*( tnextR|t StopIterationR7RHRˆRzR{RCRyRxt_on_connector_done(R R@((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR’)s   cCsd|_tjd|ƒt|tƒrö|jj|ƒt|tƒr„|j |j ksqt dj |j ƒƒ‚|j tƒƒq|jrét|tƒrétjdƒt|jtjjƒrÊt}nt|jƒ}|j |ƒq|jƒn |j |ƒdS(sÌHandle completion of connection attempt by `AMQPConnector`. :param pika.connection.Connection | BaseException conn_or_exc: See `AMQPConnector.start()` for exception details. s$Connection attempt completed with %rs&Expected _STATE_ABORTING, but got {!r}scEnding AMQP connection workflow after first failed AMQP handshake due to _until_first_amqp_attempt.N(RR{R7RHRTRUR}R‘RR'RERPRRLRRwRR R.RtConnectionOpenAbortedRR’(R t conn_or_excRV((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyR–?s(        (RRRR,t SOCK_STREAMRt IPPROTO_TCPRŽR&R†RERDR6R R~RCRQRRRFRLR‡RˆRR’R–(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyRts&   *  ,        (RRJtloggingR,t pika.compatR.tpika.exceptionstpika.tcp_socket_optsRt getLoggerRR7RRRRRRRRRRRRtobjectRR/t AbstractBaseRoRt(((sL/srv/kernel/kteam-tools/dashboard/pika/adapters/utils/connection_workflow.pyts.      ÿƒ-