5iqdZddlZddlmZddlmZddlZddlmZGddeZ dZ d Z Gd d eZ Gd d eZ Gdde ZGddeZdZGddeZGddeZGddZGddeZGddeZGddZGdd eZGd!d"eZd#Zd$ZGd%d&eZGd'd(eZy))z I/O library for `awscrt`. All networking in `awscrt` is asynchronous. Long-running event-loop threads are used for concurrency. N)NativeResource)IntEnum)Unionc(eZdZdZdZdZdZdZdZdZ y) LogLevelrN) __name__ __module__ __qualname__NoLogsFatalErrorWarnInfoDebugTracek/home/marpiech/ifpan-abm-pgxpred/analysis/marpiech-gwas-test/venv/lib/python3.12/site-packages/awscrt/io.pyrrs% F E E D D E Errc@|J|Jtj||y)aInitialize logging in `awscrt`. Args: log_level (LogLevel): Display messages of this importance and higher. file_name (str): Logging destination. To write to stdout or stderr pass 'stdout' or 'stderr' as strings. Otherwise, a file path is assumed. N)_awscrt init_logging) log_level file_names rrrs,      I.rc6|Jtj|y)zChange the log level of `awscrt`. init_logging() must have been called before using this function or else an exception will be raised. Args: log_level (LogLevel): Display messages of this importance and higher. N)r set_log_level)rs rr!r!*s    )$rcneZdZdZdZej ZdZdfd Z e dZ e dZ xZ S)EventLoopGroupaaA collection of event-loops. An event-loop is a thread for doing async work, such as I/O. Classes that need to do async work will ask the EventLoopGroup for an event-loop to use. Args: num_threads (Optional[int]): Maximum number of event-loops to create. If unspecified, one is created for each processor on the machine. cpu_group (Optional[int]): Optional processor group to which all threads will be pinned. Useful for systems with non-uniform memory access (NUMA) nodes. If specified, the number of threads will be capped at the number of processors in the group. Attributes: shutdown_event (threading.Event): Signals when EventLoopGroup's threads have all finished shutting down. Shutdown begins when the EventLoopGroup object is destroyed. Nshutdown_eventct||d}|d}d}nd}tjfd}|_t j |||||_y)NrFTc&jyNsetr$sr on_shutdownz,EventLoopGroup.__init__..on_shutdown^    r)super__init__ threadingEventr$revent_loop_group_new_binding)self num_threads cpu_group is_pinnedr+r$ __class__s @rr.zEventLoopGroup.__init__Osb   K  III"* !-44[)YXcd rctj5tjtt_tjcdddS#1swYyxYwr'r#_static_event_loop_group_lock_static_event_loop_grouprrrget_or_create_static_defaultz+EventLoopGroup.get_or_create_static_defaultds@  9 9 ;66>:H:J7!:: ; ; ;s 3AAcdtj5dt_dddy#1swYyxYwr'r9rrrrelease_static_defaultz%EventLoopGroup.release_static_defaultks(  9 9 ;6:N 3 ; ; ; &/NN)rrr__doc__r;r/Lockr: __slots__r. staticmethodr<r> __classcell__r7s@rr#r#6sR( $$2INN$4!!Ie*;; ;;rr#ceZdZdZdZy)HostResolverBasezDNS host resolver.rN)rrrrArCrrrrHrHqs IrrHcneZdZdZdZej ZdZdfd Z e dZ e dZ xZ S)DefaultHostResolverzDefault DNS host resolver. Args: event_loop_group (EventLoopGroup): EventLoopGroup to use. max_hosts(int): Max host names to cache. Nrc|t|tsJt| t j |||_yr') isinstancer#r-r.rhost_resolver_new_defaultr2)r3event_loop_group max_hostsr7s rr.zDefaultHostResolver.__init__s4*N;;; 99)EUV rctj5tj&ttj t_tjcdddS#1swYyxYwr')rJ_static_host_resolver_lock_static_host_resolverr#r<rrrr<z0DefaultHostResolver.get_or_create_static_defaultsP ; ; ="88@z*DefaultHostResolver.release_static_defaults) ; ; =8<  5 = = =r?))rrrrArRr/rBrQrCr.rDr<r>rErFs@rrJrJvsR!!/!1IW ====rrJcleZdZdZdZej ZdZfdZ e dZ e dZ xZ S)ClientBootstrapaHandles creation and setup of client socket connections. Args: event_loop_group (EventLoopGroup): EventLoopGroup to use. host_resolver (HostResolverBase): DNS host resolver to use. Attributes: shutdown_event (threading.Event): Signals when the ClientBootstrap's internal resources finish shutting down. Shutdown begins when the ClientBootstrap object is destroyed. Nr$ct|tsJt|tsJt|t j fd}|_tj||||_ y)Nc&jyr'r(r*srr+z-ClientBootstrap.__init__..on_shutdownr,r) rLr#rHr-r.r/r0r$rclient_bootstrap_newr2)r3rN host_resolverr+r$r7s @rr.zClientBootstrap.__init__sc*N;;;-)9::: "* !-445E}Vab rctj5tj9ttj t j t_tjcdddS#1swYyxYwr')rV_static_client_bootstrap_lock_static_client_bootstrapr#r<rJrrrr<z,ClientBootstrap.get_or_create_static_defaults]  : : <77?;J"??A'DDFz&ClientBootstrap.release_static_defaults(  : : <7;O 4 < < rErFs@rrVrVsR  $$2INN$4!!I c<<<@D=A:>83>816sDy1A814858 8 ;> 8 8; 88t.(HH.,.%('rrc,eZdZdZdZfdZdZxZS)ClientTlsContextzClient TLS context. A context is expensive, but can be used for the lifetime of the application by all outgoing connections that wish to use the same TLS configuration. Args: options (TlsContextOptions): Configuration options. rc>t|tsJt| t j |j j|jj|j|jt|j|j|j|j|j |j"|j$|j&|j(|j*|j,|j.|j0|j2|_yr')rLrr-r.rclient_tls_ctx_newrrrrr_alpn_list_to_strrrrrrrrrrrrrrrr2)r3optionsr7s rr.zClientTlsContext.__init__cs'#4555 22    % %    % %       g// 0  & &  & &  # #  # #        $ $  # #  ' '  - -  * *  . .  , ,%  rct|S)zCreate a :class:`TlsConnectionOptions` that makes use of this TLS context. Returns: TlsConnectionOptions: )TlsConnectionOptionsrs rnew_connection_optionsz'ClientTlsContext.new_connection_options|s $D))r)rrrrArCr.rrErFs@rrrXsI 2*rrc2eZdZdZdZfdZdZdZxZS)ra6Connection-specific TLS options. Note that, while a TLS context is an expensive object, a :class:`TlsConnectionOptions` is cheap. Args: tls_ctx (ClientTlsContext): TLS context. A context can be shared by many connections. Attributes: tls_ctx (ClientTlsContext): TLS context. tls_ctxct|tsJt| ||_t j ||_yr')rLrr-r.rr$tls_connections_options_new_from_ctxr2)r3rr7s rr.zTlsConnectionOptions.__init__s8'#3444  DDWM rcBtj|t|y)aGSet names to use in Application Layer Protocol Negotiation (ALPN). This overrides any ALPN list on the TLS context, see :attr:`TlsContextOptions.alpn_list`. ALPN is not supported on all systems, see :meth:`is_alpn_available()`. Args: alpn_list (List[str]): List of protocol names. N)r$tls_connection_options_set_alpn_listr)r3rs r set_alpn_listz"TlsConnectionOptions.set_alpn_lists 44T;LY;WXrc0tj||y)zSet server name. Sets name for TLS Server Name Indication (SNI). Name is also used for x.509 validation. Args: server_name (str): Server name. N)r&tls_connection_options_set_server_name)r3 server_names rset_server_namez$TlsConnectionOptions.set_server_names 66t[Ir) rrrrArCr.rrrErFs@rrrs! IN Y JrrcN|r#t|trJdj|Sy)ze Transform ['h2', 'http/1.1'] -> "h2;http/1.1" None is returned if list is None or empty ;N)rLrjoin)rs rrrs) i---xx "" rc*tjS)z^Returns True if Application Layer Protocol Negotiation (ALPN) is supported on this system.)ris_alpn_availablerrrrrs  $ $ &&rcDeZdZdZdZfdZdZdZeddZ xZ S) InputStreamzInputStream allows `awscrt` native code to read from Python binary I/O classes. Args: stream (io.IOBase): Python binary I/O stream to wrap. _streamctt|dds tdt|trJt |||_tj||_ y)NrczI/O stream type expected) callablegetattr TypeErrorrLrr-r.rrinput_stream_newr2)r3streamr7s rr.zInputStream.__init__sV5667 7fk222  006 rc t|jdr|jj|St|jdr|jj|St|jdr%|jj t |}n$|jj t |}t |}||d||S#t$rYywxYw)N readinto1readintoread1)hasattrrrrrlenrcBlockingIOError)r3mdatans r_read_into_memoryviewz!InputStream._read_into_memoryviews t||[1||--a00t||Z0||,,Q//t||W-||))#a&1||((Q0D AAbqEH  s0C0C$A0C C! C!c:|jj||Sr')rseek)r3offsetwhences r_seekzInputStream._seeks||  00rc@||ryt|tr|S||S)ad Given some stream type, returns an :class:`InputStream`. Args: stream (Union[io.IOBase, InputStream, None]): Binary I/O stream to wrap. allow_none (bool): Whether to allow `stream` to be None. If False (default), and `stream` is None, an exception is raised. Returns: Union[InputStream, None]: If `stream` is already an :class:`InputStream`, it is returned. Otherwise, an :class:`InputStream` which wraps the `stream` is returned. If `allow_none` is True, and `stream` is None, then None is returned. N)rLr)clsr allow_nones rwrapzInputStream.wraps' >j fk *M6{r)F) rrrrArCr.rr classmethodrrErFs@rrrs2 I 7(1rrcHeZdZdZGddeZdddedeffdZxZS) ra Handle to a loaded PKCS#11 library. For most use cases, a single instance of :class:`Pkcs11Lib` should be used for the lifetime of your application. Keyword Args: file (str): Path to PKCS#11 library. behavior (Optional[InitializeFinalizeBehavior]): Specifies how `C_Initialize()` and `C_Finalize()` will be called on the PKCS#11 library (default is :attr:`InitializeFinalizeBehavior.DEFAULT`) c eZdZdZdZ dZ dZy)$Pkcs11Lib.InitializeFinalizeBehaviorz~ An enumeration. Controls how `C_Initialize()` and `C_Finalize()` are called on the PKCS#11 library. rrr N)rrrrArOMITSTRICTrrrInitializeFinalizeBehaviorr s+    rrN)behaviorfilerct||tjj}t j |||_yr')r-r.rrrrpkcs11_lib_newr2)r3rrr7s rr.zPkcs11Lib.__init__2s9    ;;CCH..tX> r) rrrrArrrr.rErFs@rrrs5   W  DMQ??/I??rr)rArawscrtrenumrr/typingrrrr!r#rHrJrVrgrirnrrrrrrrrrrrrrrrs!w / %8;^8;v~ =*=@+(JV' >.>B5?5?r