§ ï)JfACãó:—dZddlZddlZGd„dejj¦«ZGd„dejj¦«ZGd„dejj¦«ZGd „d ejj¦«Z Gd „d ejj¦«Z Gd „dejj¦«Z dS)aNon-blocking I/O interface for pika connection adapters. I/O interface expected by `pika.adapters.base_connection.BaseConnection` NOTE: This API is modeled after asyncio in python3 for a couple of reasons 1. It's a sensible API 2. To make it easy to implement at least on top of the built-in asyncio Furthermore, the API caters to the needs of pika core and lack of generalization is intentional for the sake of reducing complexity of the implementation and testing and lessening the maintenance burden. éNcóB—eZdZdZejd„¦«Zejd„¦«Zejd„¦«Zejd„¦«Z ejd„¦«Z ejd„¦«Z ej d d „¦«Z ejd „¦«Z ej dd „¦«Zd S)ÚAbstractIOServicesa:Interface to I/O services required by `pika.adapters.BaseConnection` and related utilities. NOTE: This is not a public API. Pika users should rely on the native I/O loop APIs (e.g., asyncio event loop, tornado ioloop, twisted reactor, etc.) that corresponds to the chosen Connection adapter. có—t‚)zrReturns the native I/O loop instance, such as Twisted reactor, asyncio's or tornado's event loop ©ÚNotImplementedError©Úselfs úe/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/pika/adapters/utils/nbio_interface.pyÚget_native_ioloopz$AbstractIOServices.get_native_ioloopó €õ "Ð!ócó—t‚)aRelease IOLoop's resources. the `close()` method is intended to be called by Pika's own test code only after `start()` returns. After calling `close()`, no other interaction with the closed instance of `IOLoop` should be performed. NOTE: This method is provided for Pika's own test scripts that need to be able to run I/O loops generically to test multiple Connection Adapter implementations. Pika users should use the native I/O loop's API instead. rrs r ÚclosezAbstractIOServices.close%ó €õ"Ð!r có—t‚)aRun the I/O loop. It will loop until requested to exit. See `stop()`. NOTE: the outcome or restarting an instance that had been stopped is UNDEFINED! NOTE: This method is provided for Pika's own test scripts that need to be able to run I/O loops generically to test multiple Connection Adapter implementations (not all of the supported I/O Loop frameworks have methods named start/stop). Pika users should use the native I/O loop's API instead. rrs r ÚrunzAbstractIOServices.run5rr có—t‚)aßRequest exit from the ioloop. The loop is NOT guaranteed to stop before this method returns. NOTE: The outcome of calling `stop()` on a non-running instance is UNDEFINED! NOTE: This method is provided for Pika's own test scripts that need to be able to run I/O loops generically to test multiple Connection Adapter implementations (not all of the supported I/O Loop frameworks have methods named start/stop). Pika users should use the native I/O loop's API instead. To invoke `stop()` safely from a thread other than this IOLoop's thread, call it via `add_callback_threadsafe`; e.g., `ioloop.add_callback_threadsafe(ioloop.stop)` rrs r ÚstopzAbstractIOServices.stopEs €õ("Ð!r có—t‚)aoRequests a call to the given function as soon as possible. It will be called from this IOLoop's thread. NOTE: This is the only thread-safe method offered by the IOLoop adapter. All other manipulations of the IOLoop adapter and objects governed by it must be performed from the IOLoop's thread. NOTE: if you know that the requester is running on the same thread as the connection it is more efficient to use the `ioloop.call_later()` method with a delay of 0. :param callable callback: The callback method; must be callable. r)r Úcallbacks r Úadd_callback_threadsafez*AbstractIOServices.add_callback_threadsafe[ó €õ"Ð!r có—t‚)aAdd the callback to the IOLoop timer to be called after delay seconds from the time of call on best-effort basis. Returns a handle to the timeout. If two are scheduled for the same time, it's undefined which one will be called first. :param float delay: The number of seconds to wait to call callback :param callable callback: The callback method :returns: A handle that can be used to cancel the request. :rtype: AbstractTimerReference r)r Údelayrs r Ú call_laterzAbstractIOServices.call_laterlrr rcó—t‚)aÊPerform the equivalent of `socket.getaddrinfo()` asynchronously. See `socket.getaddrinfo()` for the standard args. :param callable on_done: user callback that takes the return value of `socket.getaddrinfo()` upon successful completion or exception upon failure (check for `BaseException`) as its only arg. It will not be called if the operation was cancelled. :rtype: AbstractIOReference r)r ÚhostÚportÚon_doneÚfamilyÚsocktypeÚprotoÚflagss r Ú getaddrinfozAbstractIOServices.getaddrinfo}ó €õ&"Ð!r có—t‚)a&Perform the equivalent of `socket.connect()` on a previously-resolved address asynchronously. IMPLEMENTATION NOTE: Pika's connection logic resolves the addresses prior to making socket connections, so we don't need to burden the implementations of this method with the extra logic of asynchronous DNS resolution. Implementations can use `socket.inet_pton()` to verify the address. :param socket.socket sock: non-blocking socket that needs to be connected via `socket.socket.connect()` :param tuple resolved_addr: resolved destination address/port two-tuple as per `socket.socket.connect()`, except that the first element must be an actual IP address that's consistent with the given socket's address family. :param callable on_done: user callback that takes None upon successful completion or exception (check for `BaseException`) upon error as its only arg. It will not be called if the operation was cancelled. :rtype: AbstractIOReference :raises ValueError: if host portion of `resolved_addr` is not an IP address or is inconsistent with the socket's address family as validated via `socket.inet_pton()` r)r ÚsockÚ resolved_addrrs r Úconnect_socketz!AbstractIOServices.connect_socket’s €õ4"Ð!r Ncó—t‚)a¼Perform SSL session establishment, if requested, on the already- connected socket and link the streaming transport/protocol pair. NOTE: This method takes ownership of the socket. :param callable protocol_factory: called without args, returns an instance with the `AbstractStreamProtocol` interface. The protocol's `connection_made(transport)` method will be called to link it to the transport after remaining connection activity (e.g., SSL session establishment), if any, is completed successfully. :param socket.socket sock: Already-connected, non-blocking `socket.SOCK_STREAM` socket to be used by the transport. We take ownership of this socket. :param callable on_done: User callback `on_done(BaseException | (transport, protocol))` to be notified when the asynchronous operation completes. An exception arg indicates failure (check for `BaseException`); otherwise the two-tuple will contain the linked transport/protocol pair having AbstractStreamTransport and AbstractStreamProtocol interfaces respectively. :param None | ssl.SSLContext ssl_context: if None, this will proceed as a plaintext connection; otherwise, if not None, SSL session establishment will be performed prior to linking the transport and protocol. :param str | None server_hostname: For use during SSL session establishment to match against the target server's certificate. The value `None` disables this check (which is a huge security risk) :rtype: AbstractIOReference r)r Úprotocol_factoryr'rÚ ssl_contextÚserver_hostnames r Úcreate_streaming_connectionz.AbstractIOServices.create_streaming_connection®s €õH"Ð!r )rrrr)NN)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚabcÚabstractmethodr rrrrrr$r)r.©r r rrsU€€€€€ððð Ôð"ð"ñÔð"ð Ôð "ð "ñÔð "ð Ôð "ð "ñÔð "ð Ôð"ð"ñÔð"ð* Ôð"ð"ñÔð"ð  Ôð"ð"ñÔð"ð  Ôð ØØØð"ð"ð"ñÔð"ð( Ôð"ð"ñÔð"ð6 Ôð 15Ø48ð #"ð#"ð#"ñÔð#"ð#"ð#"r rcó’—eZdZdZejd„¦«Zejd„¦«Zejd„¦«Zejd„¦«Z dS)ÚAbstractFileDescriptorServicesaMInterface definition of common non-blocking file descriptor services required by some utility implementations. NOTE: This is not a public API. Pika users should rely on the native I/O loop APIs (e.g., asyncio event loop, tornado ioloop, twisted reactor, etc.) that corresponds to the chosen Connection adapter. có—t‚)a$Call the given callback when the file descriptor is readable. Replace prior reader, if any, for the given file descriptor. :param fd: file descriptor :param callable on_readable: a callback taking no args to be notified when fd becomes readable. r)r ÚfdÚ on_readables r Ú set_readerz)AbstractFileDescriptorServices.set_readerßs €õ"Ð!r có—t‚)zÆStop watching the given file descriptor for readability :param fd: file descriptor :returns: True if reader was removed; False if none was registered. :rtype: bool r©r r9s r Ú remove_readerz,AbstractFileDescriptorServices.remove_readerëó €õ"Ð!r có—t‚)azCall the given callback whenever the file descriptor is writable. Replace prior writer callback, if any, for the given file descriptor. IMPLEMENTATION NOTE: For portability, implementations of `set_writable()` should also watch for indication of error on the socket and treat it as equivalent to the writable indication (e.g., also adding the socket to the `exceptfds` arg of `socket.select()` and calling the `on_writable` callback if `select.select()` indicates that the socket is in error state). Specifically, Windows (unlike POSIX) only indicates error on the socket (but not writable) when connection establishment fails. :param fd: file descriptor :param callable on_writable: a callback taking no args to be notified when fd becomes writable. r)r r9Ú on_writables r Ú set_writerz)AbstractFileDescriptorServices.set_writerör%r có—t‚)zÆStop watching the given file descriptor for writability :param fd: file descriptor :returns: True if reader was removed; False if none was registered. :rtype: bool rr=s r Ú remove_writerz,AbstractFileDescriptorServices.remove_writer r?r N) r/r0r1r2r3r4r;r>rBrDr5r r r7r7Õsš€€€€€ððð Ôð "ð "ñÔð "ð Ôð"ð"ñÔð"ð Ôð"ð"ñÔð"ð( Ôð"ð"ñÔð"ð"ð"r r7có2—eZdZdZejd„¦«ZdS)ÚAbstractTimerReferencez#Reference to asynchronous operationcó—t‚)z>Cancel callback. If already cancelled, has no affect. rrs r ÚcancelzAbstractTimerReference.cancels €õ"Ð!r N©r/r0r1r2r3r4rHr5r r rFrFs7€€€€€Ø-Ð-àÔð"ð"ñÔð"ð"ð"r rFcó2—eZdZdZejd„¦«ZdS)ÚAbstractIOReferencez'Reference to asynchronous I/O operationcó—t‚)z€Cancel pending operation :returns: False if was already done or cancelled; True otherwise :rtype: bool rrs r rHzAbstractIOReference.cancel$ó €õ"Ð!r NrIr5r r rKrK!s7€€€€€Ø1Ð1àÔð"ð"ñÔð"ð"ð"r rKcó’—eZdZdZejd„¦«Zejd„¦«Zejd„¦«Zejd„¦«Z dS)ÚAbstractStreamProtocolz°Stream protocol interface. It's compatible with a subset of `asyncio.protocols.Protocol` for compatibility with asyncio-based `AbstractIOServices` implementation. có—t‚)z¸Introduces transport to protocol after transport is connected. :param AbstractStreamTransport transport: :raises Exception: Exception-based exception on error r)r Ú transports r Úconnection_madez&AbstractStreamProtocol.connection_made5rMr có—t‚)acCalled upon loss or closing of connection. NOTE: `connection_made()` and `connection_lost()` are each called just once and in that order. All other callbacks are called between them. :param BaseException | None error: An exception (check for `BaseException`) indicates connection failure. None indicates that connection was closed on this side, such as when it's aborted or when `AbstractStreamProtocol.eof_received()` returns a result that doesn't evaluate to True. :raises Exception: Exception-based exception on error r)r Úerrors r Úconnection_lostz&AbstractStreamProtocol.connection_lost>rr có—t‚)aÓCalled after the remote peer shuts its write end of the connection. :returns: A falsy value (including None) will cause the transport to close itself, resulting in an eventual `connection_lost()` call from the transport. If a truthy value is returned, it will be the protocol's responsibility to close/abort the transport. :rtype: falsy|truthy :raises Exception: Exception-based exception on error rrs r Ú eof_receivedz#AbstractStreamProtocol.eof_receivedNs €õ"Ð!r có—t‚)z£Called to deliver incoming data to the protocol. :param data: Non-empty data bytes. :raises Exception: Exception-based exception on error r©r Údatas r Ú data_receivedz$AbstractStreamProtocol.data_received[rMr N) r/r0r1r2r3r4rRrUrWr[r5r r rOrO.sš€€€€€ððð  Ôð"ð"ñÔð"ð Ôð "ð "ñÔð "ð Ôð "ð "ñÔð "ð Ôð"ð"ñÔð"ð"ð"r rOcó’—eZdZdZejd„¦«Zejd„¦«Zejd„¦«Zejd„¦«Z dS)ÚAbstractStreamTransportz³Stream transport interface. It's compatible with a subset of `asyncio.transports.Transport` for compatibility with asyncio-based `AbstractIOServices` implementation. có—t‚)aClose connection abruptly without waiting for pending I/O to complete. Will invoke the corresponding protocol's `connection_lost()` method asynchronously (not in context of the abort() call). :raises Exception: Exception-based exception on error rrs r ÚabortzAbstractStreamTransport.abortó €õ"Ð!r có—t‚)zœReturn the protocol linked to this transport. :rtype: AbstractStreamProtocol :raises Exception: Exception-based exception on error rrs r Ú get_protocolz$AbstractStreamTransport.get_protocol‰rMr có—t‚)zÓBuffer the given data until it can be sent asynchronously. :param bytes data: :raises ValueError: if called with empty data :raises Exception: Exception-based exception on error rrYs r ÚwritezAbstractStreamTransport.write’r`r có—t‚)ze :returns: Current size of output data buffered by the transport :rtype: int rrs r Úget_write_buffer_sizez-AbstractStreamTransport.get_write_buffer_sizeœr r N) r/r0r1r2r3r4r_rbrdrfr5r r r]r]xsš€€€€€ððð  Ôð"ð"ñÔð"ð Ôð"ð"ñÔð"ð Ôð"ð"ñÔð"ð Ôð"ð"ñÔð"ð"ð"r r]) r2r3Ú pika.compatÚpikaÚcompatÚ AbstractBaserr7rFrKrOr]r5r r úrksUðð ð ð € € € àÐÐÐð"ð"ð"ð"ð"˜œÔ1ñ"ô"ð"ðD?"ð?"ð?"ð?"ð?" T¤[Ô%=ñ?"ô?"ð?"ðD"ð"ð"ð"ð"˜Tœ[Ô5ñ"ô"ð"ð "ð "ð "ð "ð "˜$œ+Ô2ñ "ô "ð "ð4"ð4"ð4"ð4"ð4"˜Tœ[Ô5ñ4"ô4"ð4"ðT*"ð*"ð*"ð*"ð*"˜dœkÔ6ñ*"ô*"ð*"ð*"ð*"r