Format: application/x-python-code
1 o
2
3 ��h � @ sL d dl Z d dlZd dlZd dlmZ d dlmZ G dd� de�Zdd� Z dS )� N)�launcher)�logc @ s8 e Zd ZdZi Z dd� Zdd� Zdd� Zd d d
4 �Zd S )
5 �
6 CaptureOutputz�Captures output from the specified file descriptor, and tees it into another
7 file descriptor while generating DAP "output" events for it.
8 c C s� || j vsJ �| | j |< t�d||� || _|| _|| _t�d�dd�| _|d u r-d | _ n9|j
9 | _ |j }|d u s<|dkr>d}zt� |�| _
10 W n ty^ tjd||dd� t� d�| _
11 Y nw t�d ||� tj| j|d
12 �| _| j�� d S ) NzCapturing {0} of {1}.zutf-8�surrogateescape)�errors�cp65001z6Unsupported {0} encoding {1!r}; falling back to UTF-8.�warning)�levelz Using encoding {0!r} for {1})�target�name)� instancesr �info�category�_whose�_fd�codecs�getincrementaldecoder�_decoder�_stream�buffer�encoding�
13 getencoder�_encode� Exception�swallow_exception� threading�Thread�_worker�_worker_thread�start)�selfZwhoser �fd�streamr � r# �Mc:\Users\shubh\Videos\agent\nova\Lib\site-packages\debugpy/launcher/output.py�__init__ s6
14 �� zCaptureOutput.__init__c C s8 | j }|d urzt�|� W d S ty Y d S w d S )N)r �os�closer )r r! r# r# r$ �__del__7 s ��zCaptureOutput.__del__c C s` | j d ur'z t�| j d�}W n ty Y nw t|�s n
15 | �|� | j d us| jddd� d S )Ni � T��final)r r& �readr �len�_process_chunk)r �sr# r# r$ r ? s
16 �
17
18 �
19 zCaptureOutput._workerFc C s | j j||d�}t|�dkrd S ztj�d| j|�dd�d�� W n ty* Y nw | j d u r2d S z?| �
20 |d�\}}t|�}d}||k ro| j � ||d � �}| j � � |dkrdt
21 �| j� d | _W d S ||7 }||k sEW d S W d S ty� t�d|| j� Y d S w ) Nr* r �outputz
22 �
23 )r r0 r zError printing {0!r} to {1})r �decoder- r ZchannelZ
24 send_eventr �replacer r r �write�flushr& r' r r r )r r/ r+ �_�size�iZwrittenr# r# r$ r. L s8 � �
25
26 �
27 �z CaptureOutput._process_chunkN)F) �__name__�
28 __module__� __qualname__�__doc__r r% r( r r. r# r# r# r$ r
29 s "
30 r c C s2 t j�� D ]\} }t�d| |j� |j�� qdS )z=Waits for all remaining output to be captured and propagated.z!Waiting for remaining {0} of {1}.N)r r �itemsr r
31 r r �join)r �instancer# r# r$ �wait_for_remaining_outputm s �r@ )
32 r r& r Zdebugpyr Zdebugpy.commonr �objectr r@ r# r# r# r$ �<module> s `