| Server IP : 35.236.43.222 / Your IP : 216.73.216.143 Web Server : Apache System : Linux order-form-vm-001 5.10.0-37-cloud-amd64 #1 SMP Debian 5.10.247-1 (2025-12-11) x86_64 User : deploy ( 1002) PHP Version : 8.1.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3/dist-packages/requests_toolbelt/threaded/__pycache__/ |
Upload File : |
a
�ˀX� � @ s@ d Z ddlZddlZddlmZ ddlmZ G dd� de�Z dS )z*Module containing the SessionThread class.� N� )�queuec @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�
SessionThreadc C s$ || _ || _| �� || _|| _d S �N)�_session�_jobs�_create_worker�
_responses� _exceptions)�selfZinitialized_sessionZ job_queueZresponse_queueZexception_queue� r �C/usr/lib/python3/dist-packages/requests_toolbelt/threaded/thread.py�__init__ s
zSessionThread.__init__c C s4 t j| jt�� d�| _d| j_d| j_| j�� d S )N)�target�nameTr ) � threadingZThread�
_make_request�uuidZuuid4�_workerZdaemonZ_state�start�r r r r
r s �z SessionThread._create_workerc
C s~ zlz| j jf i |��}W n6 tjyN } z | j�||f� W Y d }~nd }~0 0 | j�||f� W | j�� n | j�� 0 d S r ) r Zrequest�excZRequestExceptionr
Zputr r Z task_done)r �kwargsZresponse�er r r
�_handle_request s &z SessionThread._handle_requestc C s8 z| j �� }W n tjy& Y q4Y n0 | �|� q d S r )r Z
get_nowaitr ZEmptyr )r r r r r
r & s
zSessionThread._make_requestc C s
| j �� S )z*Proxy to the thread's ``is_alive`` method.)r �is_aliver r r r
r / s zSessionThread.is_alivec C s | j �� dS )z&Join this thread to the master thread.N)r �joinr r r r
r 3 s zSessionThread.joinN) �__name__�
__module__� __qualname__r r r r r r r r r r
r
s
r )
�__doc__r r Zrequests.exceptions�
exceptionsr Z_compatr �objectr r r r r
�<module> s