Name	Size	Mode	Actions
compat.cpython-313.pyc	2870	0644	editdlrm
crt.cpython-313.pyc	5581	0644	editdlrm
exceptions.cpython-313.pyc	5204	0644	editdlrm
session.cpython-313.pyc	20112	0644	editdlrm
utils.cpython-313.pyc	3691	0644	editdlrm
__init__.cpython-313.pyc	3341	0644	editdlrm

� ���j���SrS
SK
r
S
SKrS
SKJr S
SKJrJrJ r J r Jr SqSq \
R"5rSrSrSrSrS rS r"SS5rS rSrSrg)a6
This file contains private functionality for interacting with the AWS Common Runtime library (awscrt) in boto3. All code contained within this file is for internal usage within this project and is not intended for external consumption. All interfaces contained within are subject to abrupt breaking changes. �N)
�Session)�BotocoreCRTCredentialsWrapper�BotocoreCRTRequestSerializer�CRTTransferManager�acquire_crt_s3_process_lock�create_s3_crt_client�boto3c�$�US
US.n[
S0UD
6
$)z�Create a CRT S3 Client for file transfer. Instantiating many of these may lead to degraded performance or system resource exhaustion. T)�region�use_ssl�crt_credentials_provider�)
r)�session�config�region_name� cred_provider�create_crt_client_kwargss �s<��1��=�L� �<�<�>�M���7�K�G���� �rc��[
[5
nUc
g
[5nURRnUR5n[ X45n[X1XEU5nXg4$)N)NN)r�PROCESS_LOCK_NAMEr�metar�_get_credentialsrr!)�clientrrrrr� serializer� s3_clients r�#_initialize_crt_transfer_primativesr)Lsa��&�'8�9�D��|���i�G��+�+�)�)�K��)�)�+�K�/��E�J�%���4��I�� � rc��[ [c[X
5up#UqUq
SSS5 [$!,(d
f  [$=f
�
N)�CLIENT_CREATION_LOCK� CRT_S3_CLIENTr)�BOTOCORE_CRT_SERIALIZER)r&rr'r(s r�get_crt_s3_clientr/_sH�� �� �$G��%�!�J�'1�#�%�M� ��� � ���s �.� A
c
��\r
SrS
rSrSrSrg)r�nak
This wrapper keeps track of our underlying CRT client, the lock used to acquire it and the region we've used to instantiate the client. Due to limitations in the existing CRT interfaces, we can only make calls in a single region and does not support redirects. We track the region to ensure we don't use the CRT client when a successful request cannot be made. c�4�XlX l
X0lX@lgr+)� crt_client�process_lockrr)�selfr3r4rrs r�__init__�CRTS3Client.__init__xs��$��(����*�r)rr3r4rN)�__name__� __module__�__qualname__�__firstlineno__�__doc__r6�__static_attributes__rrrrrns���+rrc���U
c
g
UR
5nUc
g
[UR5U
R5nURR U
R:HnU=
(a U$)zz Boto3 client must use same signing region and credentials as the CRT_S3_CLIENT singleton. Otherwise fallback to classic. F)r%�compare_identity�get_frozen_credentialsrr$rr)r&� crt_s3_client�boto3_creds�is_same_identity�is_same_regions r�is_crt_compatible_requestrEsk�� ����)�)�+�K����'��*�*�,�m�.I�.I����[�[�,�,� �0D�0D�D�N��.�.�.rc�
�U
"5nURUR:H=
(a9 UR UR:H=
(a URUR:HnU$![RRa g
f=f
)NF) �botocore� exceptions�NoCredentialsError� access_key� access_key_id� secret_key�secret_access_key�token� session_token)rB�crt_s3_creds� crt_creds�is_matching_identitys rr?r?�s���� �N� � ���)�"9�"9�9� 9��"�"�i�&A�&A�A� 9�����!8�!8�8��  ������1�1�
��
�s�A$�$B�
Bc�n�[
X
5n[X5(a[UR[5$g
)z8Create a CRTTransferManager for optimized data transfer.N)r/rErr3r.)r&rrAs r�create_crt_transfer_managerrT�s5��%�f�5�M� ��7�7�!��$�$�&=� � �r)r<� threading�botocore.exceptionsrG�botocore.sessionr�s3transfer.crtrrrrrr-r.�Lockr,r#rrr!r)r/rrEr?rTrrr�rZ
sq�


�
�
��$�
�
�� ��� �~�~�'����
<�
�
�
!�&
�
+�
+�"
/�&
�
r