Linux iad1-shared-b7-18 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64
Apache
: 67.205.6.31 | : 216.73.216.47
Cant Read [ /etc/named.conf ]
8.2.29
fernandoquevedo
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
README
+ Create Folder
+ Create File
/
usr /
lib /
python3 /
dist-packages /
boto /
__pycache__ /
[ HOME SHELL ]
Name
Size
Permission
Action
__init__.cpython-310.pyc
31.33
KB
-rw-r--r--
auth.cpython-310.pyc
28.84
KB
-rw-r--r--
auth_handler.cpython-310.pyc
1.5
KB
-rw-r--r--
compat.cpython-310.pyc
2.07
KB
-rw-r--r--
connection.cpython-310.pyc
32.05
KB
-rw-r--r--
endpoints.cpython-310.pyc
8.1
KB
-rw-r--r--
exception.cpython-310.pyc
17.35
KB
-rw-r--r--
handler.cpython-310.pyc
1.87
KB
-rw-r--r--
https_connection.cpython-310.p...
4.42
KB
-rw-r--r--
jsonresponse.cpython-310.pyc
4.27
KB
-rw-r--r--
plugin.cpython-310.pyc
1.81
KB
-rw-r--r--
provider.cpython-310.pyc
11.63
KB
-rw-r--r--
regioninfo.cpython-310.pyc
7.12
KB
-rw-r--r--
requestlog.cpython-310.pyc
1.74
KB
-rw-r--r--
resultset.cpython-310.pyc
4.61
KB
-rw-r--r--
storage_uri.cpython-310.pyc
30.2
KB
-rw-r--r--
utils.cpython-310.pyc
28.99
KB
-rw-r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : connection.cpython-310.pyc
o ckF[3� � @ s d Z ddlmZ ddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZ ddl Z ddlZ ddlZ ddlZ ddl mZmZ ddlmZmZmZmZmZ ddlmZ dd lm Z dd lm Z dd lm Z dd l m Z dd l!m"Z" dZ#zddl$Z$ddl m%Z% e&e$d�r�dZ#W n e'y� Y nw zddl(Z(W n e'y� ddl)Z(Y nw e*dd� dD ��Z+ddd�Z,ej-�.ej-�/ej-�0e j1j2��d�Z3G dd� de4�Z5G dd � d e4�Z6G d d � d e4�Z7G d d � d ej8�Z8G d!d"� d"e4�Z9G d#d$� d$e9�Z:dS )%z" Handles basic connections to AWS � )�datetimeN)�auth)� auth_handler)�config� UserAgent)�six� http_client�urlparse�quote� encodebytes)�AWSConnectionError)�BotoClientError)�BotoServerError)�PleaseRetryException)�Provider)� ResultSetF)�https_connection�SSLErrorTc c s � | ]}|t jv V qd S �N)�os�environ)�.0�key� r �1/usr/lib/python3/dist-packages/boto/connection.py� <genexpr>W s � r )� USER_IS_ADMIN�CURRENT_VERSION_ID�APPLICATION_ID� �P )TFz cacerts.txtc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�HostConnectionPoola� A pool of connections for one remote (host,port,is_secure). When connections are added to the pool, they are put into a pending queue. The _mexe method returns connections to the pool before the response body has been read, so they connections aren't ready to send another request yet. They stay in the pending queue until they are ready for another request, at which point they are returned to the pool of ready connections. The pool of ready connections is an ordered list of (connection,time) pairs, where the time is the time the connection was returned from _mexe. After a certain period of time, connections are considered stale, and discarded rather than being reused. This saves having to wait for the connection to time out if AWS has decided to close it on the other end because of inactivity. Thread Safety: This class is used only from ConnectionPool while it's mutex is held. c C s g | _ d S r )�queue��selfr r r �__init__z � zHostConnectionPool.__init__c C s t | j�S )z� Returns the number of connections in the pool for this host. Some of the connections may still be in use, and may not be ready to be returned by get(). )�lenr" r# r r r �size} s zHostConnectionPool.sizec C s | j �|t�� f� dS )zZ Adds a connection to the pool, along with the time it was added. N)r" �append�time)r$ �connr r r �put� s zHostConnectionPool.putc C sL | � � tt| j��D ]}| j�d�\}}| �|�r | S | �|� q dS )z� Returns the next connection in this pool that is ready to be reused. Returns None if there aren't any. r N)�clean�ranger' r" �pop� _conn_readyr, )r$ �_r+ r r r �get� s zHostConnectionPool.getc C s$ t rdS t|dd�}|du p|�� S )aZ There is a nice state diagram at the top of http_client.py. It indicates that once the response headers have been read (which _mexe does before adding the connection to the pool), a response is attached to the connection, and it stays there until it's done reading. This isn't entirely true: even after the client is done reading, the response may be closed, but not removed from the connection yet. This is ugly, reading a private instance variable, but the state we care about isn't available in any public methods. F�_HTTPConnection__responseN)� ON_APP_ENGINE�getattr�isclosed)r$ r+ �responser r r r0 � s z HostConnectionPool._conn_readyc C sX t | j�dkr&| �| jd �r*| j�d� t | j�dkr(| �| jd �sdS dS dS dS )z/ Get rid of stale connections. r N)r' r" � _pair_staler/ r# r r r r- � s .�zHostConnectionPool.cleanc C s |\}}t � � }|tj |k S )z[ Returns true of the (connection,time) pair is too old to be used. )r* �ConnectionPool�STALE_DURATION)r$ �pair�_conn� return_time�nowr r r r8 � s z HostConnectionPool._pair_staleN) �__name__� __module__� __qualname__�__doc__r% r( r, r2 r0 r- r8 r r r r r! ` s r! c @ sP e Zd ZdZdZdZdd� Zdd� Zdd � Zd d � Z d d � Z dd� Z dd� Z dS )r9 z� A connection pool that expires connections after a fixed period of time. This saves time spent waiting for a connection that AWS has timed out on the other end. This class is thread-safe. g @g N@c C s, i | _ d| _t�� | _t�ddtj�t_d S )Ng �Boto�connection_stale_duration) � host_to_pool�last_clean_time� threading�Lock�mutexr �getfloatr9 r: r# r r r r% � s ��zConnectionPool.__init__c C s t � | j�}i |d< |d= |S )NrE rI )�copy�__dict__)r$ � pickled_dictr r r � __getstate__� s zConnectionPool.__getstate__c C s | � � d S r )r% )r$ �dctr r r � __setstate__� � zConnectionPool.__setstate__c C s t dd� | j�� D ��S )z@ Returns the number of connections in the pool. c s s � | ]}|� � V qd S r )r( )r �poolr r r r � s � z&ConnectionPool.size.<locals>.<genexpr>)�sumrE �valuesr# r r r r( � s zConnectionPool.sizec C sf | � � | j�" |||f}|| jvr W d � dS | j| �� W d � S 1 s,w Y dS )z� Gets a connection from the pool for the named host. Returns None if there is no connection that can be reused. It's the caller's responsibility to call close() on the connection when it's no longer needed. N)r- rI rE r2 )r$ �host�port� is_securer r r r �get_http_connection s � $�z"ConnectionPool.get_http_connectionc C s\ | j �! |||f}|| jvrt� | j|< | j| �|� W d � dS 1 s'w Y dS )zm Adds a connection to the pool of connections that can be reused for the named host. N)rI rE r! r, )r$ rU rV rW r+ r r r r �put_http_connection s "�z"ConnectionPool.put_http_connectionc C s� | j �D t�� }| j| j |k r?g }| j�� D ]\}}|�� |�� dkr*|�|� q|D ]}| j|= q-|| _W d � dS W d � dS 1 sJw Y dS )a+ Clean up the stale connections in all of the pools, and then get rid of empty pools. Pools clean themselves every time a connection is fetched; this cleaning takes care of pools that aren't being used any more, so nothing is being gotten from them. r N) rI r* rF �CLEAN_INTERVALrE �itemsr- r( r) )r$ r> � to_removerU rR r r r r- s � �"�zConnectionPool.cleanN) r? r@ rA rB rZ r: r% rN rP r( rX rY r- r r r r r9 � s r9 c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� HTTPRequestc C s| || _ || _|| _|| _|| _|du r|}|| _|| _|r6d|v r6|d dkr6| j dkr6|�� | _| jd= n|| _| | _ dS )ay Represents an HTTP request. :type method: string :param method: The HTTP method name, 'GET', 'POST', 'PUT' etc. :type protocol: string :param protocol: The http protocol used, 'http' or 'https'. :type host: string :param host: Host to which the request is addressed. eg. abc.com :type port: int :param port: port on which the request is being sent. Zero means unset, in which case default port will be chosen. :type path: string :param path: URL path that is being accessed. :type auth_path: string :param path: The part of the URL path used when creating the authentication string. :type params: dict :param params: HTTP url query parameters, with key as name of the param, and value as value of param. :type headers: dict :param headers: HTTP headers, with key as name of the header and value as value of header. :type body: string :param body: Body of the HTTP request. If not present, will be None or empty string (''). N�Transfer-Encoding�chunked�PUT) �method�protocolrU rV �path� auth_path�paramsrK �headers�body) r$ ra rb rU rV rc rd re rf rg r r r r% 1 s $ zHTTPRequest.__init__c C s( d| j | j| j| j| j| j| j| jf S )NzTmethod:(%s) protocol:(%s) host(%s) port(%s) path(%s) params(%s) headers(%s) body(%s))ra rb rU rV rc re rf rg r# r r r �__str__h s ��zHTTPRequest.__str__c K s� t | dd�s*| jD ]}| j| }t|tj�r#d}t|�d�|�| j|< q t| dd� t| jd< |j j | fi |�� d| jvrVd| jvsJ| jd d krXt t | j ��| jd< d S d S d S ) N�_headers_quotedFz !"#$%&'()*+,/:;<=>?@[\]^`{|}~ �utf-8Tz User-AgentzContent-Lengthr^ r_ )r5 rf � isinstancer � text_typer �encode�setattrr � _auth_handler�add_auth�strr' rg )r$ � connection�kwargsr �val�safer r r � authorizen s � �zHTTPRequest.authorizeN)r? r@ rA r% rh rv r r r r r] / s 7 r] c @ s e Zd Zdd� Zddd�ZdS )� HTTPResponsec O s$ t jj| g|�R i |�� d| _d S )N� )r rw r% �_cached_response)r$ �argsrs r r r r% � s zHTTPResponse.__init__Nc C s0 |du r| j stj�| �| _ | j S tj�| |�S )a< Read the response. This method does not have the same behavior as http_client.HTTPResponse.read. Instead, if this method is called with no ``amt`` arg, then the response body will be cached. Subsequent calls to ``read()`` with no args **will return the cached response**. N)ry r rw �read)r$ �amtr r r r{ � s zHTTPResponse.readr )r? r@ rA r% r{ r r r r rw � s rw c @ s\ e Zd Z d?dd�Zdd � Zd d � Zd d � Zdd� Zeee�Z dd� Z dd� Z ee e �Z dd� Z ee �Z dd� Zee�ZeZeZdd� Zee�ZeZeZdd� Zee�Zd@d d �ZdAd d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� ZdBd*d+�Z dAd,d-�Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z! dCd6d7�Z" dDd9d:�Z# dEd;d<�Z$d=d>� Z%dS )F�AWSAuthConnectionNTr �/�awsc C s* || _ d| _t�dd�rt�dd�}|| _t�dd|�| _| jr&ts&t d��t� ddt �}|dkr3d}|| _ |r<|| _ nt| | _ | �|||| � tjtjtjtjf| _g | _tr`| j�tj� tj f| _ | durx| d | _ | j| d 7 _nd| _ |r�d | _ nd | _ || _ | | _!t"| t#j$�s�d } t�%dd | �| _&d| _'i | _(t)j*d t)j*d fdkr�t�%ddd�| j(d< t"| t+�r�| | _,n | | _-t+| j-||||�| _,| j,j r�| j,j | _ | j,j r�| j,j | _ | j,j'r�| j,j'| _'t.� | _/| j | j | jf| _0d| _1t2�3|t| j,| �4� �| _5t6| dd�du�r| j7| _8d| _9dS )a0 :type host: str :param host: The host to make the connection to :keyword str aws_access_key_id: Your AWS Access Key ID (provided by Amazon). If none is specified, the value in your ``AWS_ACCESS_KEY_ID`` environmental variable is used. :keyword str aws_secret_access_key: Your AWS Secret Access Key (provided by Amazon). If none is specified, the value in your ``AWS_SECRET_ACCESS_KEY`` environmental variable is used. :keyword str security_token: The security token associated with temporary credentials issued by STS. Optional unless using temporary credentials. If none is specified, the environment variable ``AWS_SECURITY_TOKEN`` is used if defined. :type is_secure: boolean :param is_secure: Whether the connection is over SSL :type https_connection_factory: list or tuple :param https_connection_factory: A pair of an HTTP connection factory and the exceptions to catch. The factory should have a similar interface to L{http_client.HTTPSConnection}. :param str proxy: Address/hostname for a proxy server :type proxy_port: int :param proxy_port: The port to use when connecting over a proxy :type proxy_user: str :param proxy_user: The username to connect with on the proxy :type proxy_pass: str :param proxy_pass: The password to use when connection over a proxy. :type port: int :param port: The port to use to connect :type suppress_consec_slashes: bool :param suppress_consec_slashes: If provided, controls whether consecutive slashes will be suppressed in key paths. :type validate_certs: bool :param validate_certs: Controls whether SSL certificates will be validated or not. Defaults to True. :type profile_name: str :param profile_name: Override usual Credentials section in config file to use a named set of keys instead. � rC rW �https_validate_certificatesz�SSL server certificate validation is enabled in boto configuration, but Python dependencies required to support this feature are not available. Certificate validation is only supported when running under Python 2.6 or later.�ca_certificates_file�systemNr � �https�http�debug)� r� �http_socket_timeout�F �timeout�AuthServiceName):�suppress_consec_slashes� num_retriesr � has_option� getbooleanrW �getboolr� �HAVE_HTTPS_CONNECTIONr � get_value�DEFAULT_CA_CERTS_FILEr� rV �PORTS_BY_SECURITY� handle_proxyr � HTTPException�socket�error�gaierror� BadStatusLine�http_exceptions�http_unretryable_exceptionsr) r �InvalidCertificateException�errno�EINTR�socket_exception_values�https_connection_factoryrb rU rc rk r � integer_types�getintr� � host_header�http_connection_kwargs�sys� version_infor �provider�_provider_typer9 �_pool� _connection�_last_rsr �get_auth_handler�_required_auth_capabilityro r5 r� �auth_service_name� request_hook)r$ rU �aws_access_key_id�aws_secret_access_keyrW rV �proxy� proxy_port� proxy_user� proxy_passr� r� rc r� �security_tokenr� �validate_certs� profile_name� certs_filer r r r% � s� 9 � �� �� � � � zAWSAuthConnection.__init__c C s d| j j| jf S )Nz%s:%s)� __class__r? rU r# r r r �__repr__> s zAWSAuthConnection.__repr__c C � g S r r r# r r r r� A � z+AWSAuthConnection._required_auth_capabilityc C � t | jd�S )N� service_name�r5 ro r# r r r �_get_auth_service_nameD rQ z(AWSAuthConnection._get_auth_service_namec C � || j _d S r )ro r� �r$ �valuer r r �_set_auth_service_nameJ rQ z(AWSAuthConnection._set_auth_service_namec C r� )N� region_namer� r# r r r �_get_auth_region_nameN rQ z'AWSAuthConnection._get_auth_region_namec C r� r )ro r� r� r r r �_set_auth_region_nameQ rQ z'AWSAuthConnection._set_auth_region_namec C s | j | j� S r )rX r� r# r r r rr U rQ z AWSAuthConnection.connectionc C � | j jS r )r� � access_keyr# r r r r� Y � z#AWSAuthConnection.aws_access_key_idc C r� r )r� � secret_keyr# r r r r� _ r� z'AWSAuthConnection.aws_secret_access_keyc C r� r )r� r� r# r r r r� e r� z AWSAuthConnection.profile_namec C s� | j s | jt�dd|� S |�d�}|dkr#||d � }|d |� }nd }|d dkr.d}nd}| j�d�}|�|�d�� d d � |D �}dd�|� }|d dkrX|rX|d7 }|r^|| }|S ) Nz^(/*)/z\1�?r ���r~ TFc S s g | ]}|r|�qS r r )r �pr r r � <listcomp>| s z.AWSAuthConnection.get_path.<locals>.<listcomp>)r� rc �re�sub�find�split�extend�join)r$ rc �posre � need_trailing� path_elementsr r r �get_pathi s& zAWSAuthConnection.get_pathc C sh |s| j }|dkr| j}|S trtjd d� dks"tjd d� dv r+|dkr+| j}|S d| j|f }|S )Nr � z2.5)z2.6z2.7r �%s:%d)rV rU r4 r� �version)r$ rV �signature_hostr r r � server_name� s ��z AWSAuthConnection.server_namec C s || _ || _|| _|| _dtjv r<| j s<t�d�}|�tjd �}|r;|� d�| _ |� d�| _|� d�| _|� d�| _n,| j sGt � ddd �| _ | jsRt � dd d �| _| js]t � dd d �| _| jsht � dd d �| _| jsv| j rvt d � | j | _tj�d d�p�tj�dd�| _| j d u| _d S )N� http_proxyzX(?:http://)?(?:(?P<user>[\w\-\.]+):(?P<pass>.*)@)?(?P<host>[\w\-\.]+)(?::(?P<port>\d+))?rU rV �user�passrC r� r� r� r� zFhttp_proxy environment variable does not specify a port, using default�no_proxyrx �NO_PROXY)r� r� r� r� r r r� �compile�match�groupr r� �printrV r2 r� � use_proxy)r$ r� r� r� r� �patternr� r r r r� � s8 � � z AWSAuthConnection.handle_proxyc C s* | j �|||�}|d ur|S | �|||�S r )r� rX �new_http_connection)r$ rU rV rW r+ r r r rX � s z%AWSAuthConnection.get_http_connectionc C s^ | j sdS | j dkr dS |}|�d�d }| j �d�D ]}|r,|�|�s)|�|�r, dS qdS )NF�*T�:r �,)r� r� �endswith)r$ rU �hostonly�namer r r � skip_proxy� s �z AWSAuthConnection.skip_proxyc C s` |d u r| � � }tj�|�}| j�� }||d< | jr+|s+| �|�s+| j}t | j �|d< |rmtj � d||� | jrH| �|�sH| � ||rDdpEd�}nC| jrQ| �|�}n:| jrctrctj|fd| ji|��}n(tj|fi |��}n tj � d| � | jr�| j|fi |��}n tj|fi |��}| j dkr�|�| j � |�d�d | jkr�|| jkr�|||f| _t |_ |S ) NrV z1establishing HTTPS connection: host=%s, kwargs=%sr r �ca_certsz'establishing HTTP connection: kwargs=%sr� r� r ) r� �boto�utils� parse_hostr� rK r� r� r� �intr� �logr� � proxy_sslr� r� r� r � CertValidatingHTTPSConnectionr� r �HTTPSConnection�HTTPConnection�set_debuglevelr� rU rW r� rw �response_class)r$ rU rV rW r� rr r r r r� � sh �� ���������� z%AWSAuthConnection.new_http_connectionc C s | j �||||� d S r )r� rY )r$ rU rV rW rr r r r rY s z%AWSAuthConnection.put_http_connectionc C s |r |r d||f }nd| j | jf }| j�d�}|d ur*t�| jt| j�f|�}n t�| jt| j�f�}t j � d|� |� d| � |� dt � | jrq| jrq| �� �� D ] \}}|� d||f � qVt�ddd �rp|� d � n|� d � tj|d | j d �}|�� |jd kr�t�dd| j| j|j|jf ��|�� t�|�}| j r�t r�d} | j r�| d| j 7 } n| d7 } t j � | � | j�dd �} | j�dd �} t j || | t j!| j d�} | �"� } | j �#dd�d }t$�%| |�s�t$�&|| d��nt'td�r�tj �(|�} n t� |d d �} t�)|| �} | |_*|S )Nr� r� z'Proxy connection: CONNECT %s HTTP/1.0 zCONNECT %s HTTP/1.0 zUser-Agent: %s z%s: %s rC �"send_crlf_after_proxy_auth_headersFz T)�strict� debuglevel�� i����z*Error talking to HTTP proxy %s:%s: %s (%s)z,wrapping ssl socket for proxied connection; zCA certificate file=%sz using system provided SSL certs�key_file� cert_file)�keyfile�certfile� cert_reqsr� r� r zhostname mismatch�ssl)+rU rV r� r2 r� �create_connectionr� r� r� r� r� r� �sendallr r� r� �get_proxy_auth_headerr[ r r� r rw �begin�statusr� �reason�closer� r� r� r� r � wrap_socket� CERT_REQUIRED� getpeercertr� r �ValidateCertificateHostnamer� �hasattr� SSLSocket� FakeSocket�sock)r$ rU rV r� r �k�v�resp�h�msgr r �sslSock�cert�hostnamer r r r� sv �� � ��� � �� zAWSAuthConnection.proxy_sslc C s | j d |p | �� | }|S )N�://)rb r� )r$ rc rU r r r �prefix_proxy_to_pathU s z&AWSAuthConnection.prefix_proxy_to_pathc C s t | jd | j �}dd| iS )Nr� zProxy-AuthorizationzBasic %s)r r� r� )r$ r r r r r Y s z'AWSAuthConnection.get_proxy_auth_headerc C sZ | j sd S | js | jr | jrd| j| jf }nd| j }nd}d|| jt| jp)| j�f S )Nz%s:%s@z%s@rx zhttp://%s%s:%s)r� r� r� r� rq r� rV )r$ � login_infor r r �get_proxy_url_with_auth^ s z)AWSAuthConnection.get_proxy_url_with_authc C sJ z| j �| j|�|jd< W d S ty$ | j�dd�d |jd< Y d S w )N�Hostr� r� r )ro r� rU rf �AttributeErrorr� )r$ �requestr r r �set_host_headerl s � �z!AWSAuthConnection.set_host_headerc C s || _ d S r )r� )r$ �hookr r r �set_request_hooks r& z"AWSAuthConnection.set_request_hookc C s� t j�d|j � t j�d|j � t j�d|j � t j�d|j � t j�d|j � t j�d|j � t j�d|j � d}d}d}|du rRt � d d | j �}n|}d } | � |j|j| j�} t|jt�sst|jd �rs|j�d �|_| |k�rGtt�� d| t j �d dd��} �zDt j�d| jj � |j| d� d| �� vr�t| dd�s�|j�d�s�| �|� t j�d|j � t � � |_ t |�r�|| |j|j|j|j�}n| � |j|j|j|j� | �!� }t j�d|�"� � |�#d�} |jdkr�t|dd�r�d |_$t |��r!||| | �} | �r!| \}} } |�rt j�|� t%�&| � W qs|j'd v �rHd |j' }|d | 7 }t j�|� |�(� }t|t��rG|�)d �}n�|j'd k �sW|j'd k�sW| �s�|�#d!�}|d"k�rf| �*� n | �+|j|j| j| � | j,du�r~| j,�-||� |W S t.| �\}|_|_}}}|�r�| jd#| 7 _d$|jv �r�|j�/d$d%�\|_|_d&| d' }||j|j 7 }t j�|� | � |j|j|d(k�} d}W qsW nk t0�y� } z t j�d)| � | �1|j|j| j�} |j2}|}W Y d}~nFd}~w | j3�y9 } z4| j4D ]}t||��rt j�d*|j5j6 � � �qt j�d+|j5j6 � | �1|j|j| j�} |}W Y d}~nd}~ww t%�&| � | d%7 } | |ksx| j,du�rV| j,j-||d,d-� |�rat7|j'|j8|��|�rf|�d.}t9|��)/a> mexe - Multi-execute inside a loop, retrying multiple times to handle transient Internet errors by simply trying again. Also handles redirects. This code was inspired by the S3Utils classes posted to the boto-users Google group by Larry Bates. Thanks! z Method: %szPath: %szData: %sz Headers: %szHost: %szPort: %sz Params: %sNrC r� r rm rj r� �max_retry_delay�< z Token: %s)rr �s3�anonFr& zFinal headers: %szResponse headers: %s�location�HEADr_ )i� i� i� i� zReceived %d response. zRetrying in %3.1f secondsi, i� rr r r� r� r� zRedirecting: %sr" r� z!encountered a retry exception: %sz0encountered unretryable %s exception, re-raisingz&encountered %s exception, reconnectingT)r� z-Please report this exception as a Boto Issue!):r� r� r� ra rc rg rf rU rV re r r� r� rX rW rk �bytesr rm �min�randomr2 r� r� rv r� r5 r) r r> � start_time�callabler( � getresponse� getheaders� getheaderr_ r* �sleepr r{ �decoder rY r� �handle_request_datar r� r r� r7 r� r� r� r? r r r )r$ r( �sender�override_num_retries� retry_handlerr7 rg �exr� �irr � next_sleepr0 r r �conn_header_value�schemere �query�fragment�e� unretryabler r r �_mexev s �� � � � � �� � � �� �� ���� ��� � izAWSAuthConnection._mexerx c C s� | � |�}|d ur| � |�}|d u ri }n|�� }|d u r i }n|�� }| jr3tj�d|�s3| j|d< |p7| j}| jrZ| �|�sZ|sD|}| � ||�}| j rZ| j rZ| j sZ|� | �� � t|| j|| j|||||� S )NrU )r� rK r� r� r� �find_matching_headersrU r� r� r# r� r� rW �updater r] rb rV )r$ ra rc rd re rf �datarU r r r �build_base_http_request s* �z)AWSAuthConnection.build_base_http_requestc C s4 | du ri } | � |||| |||�} | j| ||| d�S )z?Makes a request to the server, with stock multiple-retry logic.N)r? )rM rI ) r$ ra rc rf rL rU rd r= r> re r? � http_requestr r r � make_request& s � �z AWSAuthConnection.make_requestc C s t j�d� d| _dS )z�(Optional) Close any open HTTP connections. This is non-destructive, and making a new request will open a connection again.z closing all HTTP connectionsN)r� r� r� r� r# r r r r 1 s zAWSAuthConnection.close)NNTNNNNNr Nr~ r NTTN)r~ r )NN)NNN)NNrx N)Nrx NNNNNN)&r? r@ rA r% r� r� r� r� �propertyr� r� r� �auth_region_namerr r� �gs_access_key_idr� r� �gs_secret_access_keyr� r� r� r� r� rX r� r� rY r� r# r r% r) r+ rI rM rO r r r r r r} � sn � $9 F � � � r} c s� e Zd ZdZeZ d� fdd� Zd d � Zd d � Zddd�Z dd� Z dd� Z d dd�Z d dd�Z d dd�Z� ZS ) �AWSQueryConnectionrx NTr r~ r c s4 t t| �j| ||||||||| | | | |||d� d S )N)r� r� r� r� )�superrT r% )r$ r� r� rW rV r� r� r� r� rU r� r� rc r� r� r� r� �r� r r r% > s �zAWSQueryConnection.__init__c C r� r r r# r r r r� N r� z,AWSQueryConnection._required_auth_capabilityc C s t j�|�S r )r� r� �get_utf8_valuer� r r r rW Q rQ z!AWSQueryConnection.get_utf8_value�GETc C sB | � ||d |i d| j�}|r||jd< | jr | j|jd< | �|�S )Nrx �Action�Version)rM rU re � APIVersionrI )r$ �actionre rc �verbrN r r r rO T s � z AWSQueryConnection.make_requestc C sF t |tj�r |g}tdt|�d �D ]}||d |d||f < qd S )Nr� z%s.%d)rk r � string_typesr. r' )r$ re r[ �labelrA r r r �build_list_params^ s �z$AWSQueryConnection.build_list_paramsc C sL t |d�D ] \}}d||f }t||�D ]\}} d||f } | || < qqdS )a Serialize a list of structures. For example:: items = [('foo', 'bar', 'baz'), ('foo2', 'bar2', 'baz2')] label = 'ParamName.member' names = ('One', 'Two', 'Three') self.build_complex_list_params(params, items, label, names) would result in the params dict being updated with these params:: ParamName.member.1.One = foo ParamName.member.1.Two = bar ParamName.member.1.Three = baz ParamName.member.2.One = foo2 ParamName.member.2.Two = bar2 ParamName.member.2.Three = baz2 :type params: dict :param params: The params dict. The complex list params will be added to this dict. :type items: list of tuples :param items: The list to serialize. :type label: string :param label: The prefix to apply to the parameter. :type names: tuple of strings :param names: The names associated with each tuple element. r� z%s.%sN)� enumerate�zip) r$ re r[ r_ �namesrA �item�current_prefixr r� �full_keyr r r �build_complex_list_paramsd s " ��z,AWSQueryConnection.build_complex_list_paramsc C s� |s| }| � ||||�}|�� }tj�|� |s)tj�d| � | �|j|j|��|jdkrMt |�} tj � | |�} t |t j�rD|�d�}tj�|| � | S tj�d|j|jf � tj�d| � | �|j|j|���N� Null body %sr rj �%s %s�%s)rO r{ r� r� r� r� � ResponseErrorr r r �handler� XmlHandlerrk r rl rm �xml�sax� parseString) r$ r\ re �markersrc �parentr] r7 rg �rsr r r r �get_list� �$ zAWSQueryConnection.get_listc C s� |s| }| � ||||�}|�� }tj�|� |s)tj�d| � | �|j|j|��|jdkrM||�} tj � | |�} t |t j �rD|�d�}tj�|| � | S tj�d|j|jf � tj�d| � | �|j|j|��rh )rO r{ r� r� r� r� rl r r rm rn rk r rl rm ro rp rq ) r$ r\ re �clsrc rs r] r7 rg �objr r r r � get_object� rv z AWSQueryConnection.get_objectc C s� |s| }| � ||||�}|�� }tj�|� |s)tj�d| � | �|j|j|��|jdkrBt � }tj � ||�} t j �|| � |jS tj�d|j|jf � tj�d| � | �|j|j|��)Nri r rj rk )rO r{ r� r� r� r� rl r r r rm rn ro rp rq ) r$ r\ re rc rs r] r7 rg rt r r r r � get_status� s z AWSQueryConnection.get_status)NNTNNNNNNr Nr~ NTNr )Nr~ rX )r~ NrX )r? r@ rA r[ r rl r% r� rW rO r` rg ru ry rz � __classcell__r r rV r rT 9 s* � * � �rT );rB r r� r r4 r� r� r� r* �xml.saxro rK r� r r � boto.utils� boto.handler� boto.cacertsr r � boto.compatr r r r r �boto.exceptionr r r r � boto.providerr �boto.resultsetr r� r r r � ImportErrorrG �dummy_threading�allr4 r� rc r� �dirname�abspath�cacerts�__file__r� �objectr! r9 r] rw r} rT r r r r �<module> sp ) � � ��"jeT
Close
