관리-도구
편집 파일: retriever.cpython-38.pyc
U (?�fi � @ s d dl Z d dlZz d dlZW n ek r8 d dlZY nX d dlZz d dlZd dlmZmZ W n ek rr Y nX e�ee� dZ zLe j d dkr�e j � � Z nee j d �� � Z ee j �dkr�ee j d �Z W n" ede j d � e�Y nX e�� Ze D ]FZe�� Ze�r ed d k�r$�q d eej�d Ze�eef� �q ej�sXtd ��eej�Zee e�Z de k�r�d k�s�n td ��edejejf � edede d� G dd� dej �Z g Z e e �D ] Z e e�Z!e!�"� e �#e!� �q�e D ]Z$e$�%� �q�dS )� N)�SIGPIPE�SIG_IGN� � �-� � zCUsage: %s <file with URLs to fetch> [<# of concurrent connections>]�#z doc_%03d.datz no URLs giveni' z(invalid number of concurrent connectionsz!PycURL %s (compiled against 0x%x)z ----- Gettingz URLs usingzconnections -----c @ s e Zd Zdd� Zdd� ZdS )� WorkerThreadc C s t j�| � || _d S )N)� threading�Thread�__init__�queue)�selfr � r �\/opt/hc_python/lib64/python3.8/site-packages/../../../share/doc/pycurl/examples/retriever.pyr > s zWorkerThread.__init__c C s z| j �� \}}W n tjk r, t�Y nX t|d�}t�� }|�tj |� |�tj d� |�tj d� |�tj d� |�tj d� |�tjd� |�tj|� z |�� W n, dd l}|jtjd� tj�� Y nX |�� |�� tj�d� tj�� q d S ) N�wbr � � i, r )�file�.)r � get_nowait�Queue�Empty� SystemExit�open�pycurlZCurlZsetopt�URLZFOLLOWLOCATIONZ MAXREDIRSZCONNECTTIMEOUT�TIMEOUTZNOSIGNALZ WRITEDATAZperform� traceback� print_exc�sys�stderr�flush�close�stdout�write)r �url�filename�fpZcurlr r r r �runB s. zWorkerThread.runN)�__name__� __module__� __qualname__r r* r r r r r = s r )&r! r r � ImportErrorr r �signalr r Znum_conn�argv�stdin� readlines�urlsr �len�int�printr r' �stripr( �put�AssertionErrorZnum_urls�min�versionZCOMPILE_LIBCURL_VERSION_NUMr r �threads�range�dummy�t�start�append�thread�joinr r r r �<module> sT "!