관리-도구

편집 파일: resource_sharer.cpython-39.opt-2.pyc

a �����DOg����������������������@���s����d�d
l�Z�d�d
l
Z
d�d
lZd�d
lZd�d
lZddlmZ
�ddlmZ
�ddlm Z
�dg
Z ejdkrxe dg
7�Z G�d d��de�Z ne d g
7�Z G�dd ��d e�ZG�dd ��d e�Ze��ZejZd
S�)�����N�
���)
�process)
� reduction)
�util�stop�win32� DupSocketc�������������������@���s���e�Z
d�Zd
d��Zdd��ZdS�)r���c��������������������s(���|
��������f
d
d�}t
�|��j�|�_d�S�)Nc��������������������s�������|
�
}|��
|�

�d�S��
N)�share� send_bytes)�conn�pidr ����
Znew_sock���7/usr/lib64/python3.9/multiprocessing/resource_sharer.py�send���s����

z DupSocket.__init__.<locals>.send)�dup�_resource_sharer�register�close�_id)�self�sockr���r���r���r����__init__���s����

zDupSocket.__init__c
�����������������C���sB���t��
|�j�
�"}
|
���}t�|�
W��d����
�S�1�s40�
�
�
�Y�
�d�S�r ���)r����get_connectionr���� recv_bytes�socketZ fromshare)r���r���r ���r���r���r����detach$���s����

zDupSocket.detachN��__name__� __module__�__qualname__r���r���r���r���r���r���r������s����DupFdc�������������������@���s���e�Z
d�Zd
d��Zdd��ZdS�)r"���c��������������������s4���t��
|
�
����f
d
d�}��f
dd�}t�||�|�_d�S�)Nc��������������������s���t��
|���|
�
�d�S�r ���)r����send_handle)r���r ����
Znew_fdr���r���r���1���s����
zDupFd.__init__.<locals>.sendc����������������������s���t��
���

�d�S�r ���)�osr���r���r$���r���r���r���3���s����
zDupFd.__init__.<locals>.close)r%���r���r���r���r���)r����fdr���r���r���r$���r���r���/���s����

zDupFd.__init__c
�����������������C���s:���t��
|�j�
�}
t�|
�
W��d����
�S�1�s,0�
�
�
�Y�
�d�S�r ���)r���r���r���r����recv_handle)r���r���r���r���r���r���7���s����
zDupFd.detachNr���r���r���r���r���r"���-���s���c�������������������@���sJ���e�Z
d�Zd
d��Zdd��Zedd���
Zddd �
Zd d��Zdd ��Z dd��Z dS�)�_ResourceSharerc
�����������
������C���s:���d
|�_�i�|�_
t���|�_d�|�_d�|�_d�|�_t� |�t j�
�d�S�)Nr
���)�_key�_cache� threading�Lock�_lock� _listener�_address�_threadr����register_after_forkr(���� _afterfork)
r���r���r���r���r���?���s����






z_ResourceSharer.__init__c�����������������C���sf���|�j��L
�|�j
d�u�r|����
�|��jd
7��_|
|f|�j|�j<�|�j
|�jfW��d����
�S�1�sX0�
�
�
�Y�
�d�S�)Nr���)r-���r/����_startr)���r*���)r���r���r���r���r���r���r���H���s����




z_ResourceSharer.registerc
�����������������C���s<���d
dl�m
}

�|�\}}|
|t���jd�}|�|t���f�

�|S�)Nr����
�Client�
�authkey)� connectionr5���r����current_processr7���r���r%����getpid)�identr5����address�key�
cr���r���r���r���Q���s ����



z_ResourceSharer.get_connectionNc�����������������C���s����d
dl�m
}
�|�j��
�|�jd�u
r�||�jt���jd�}|�d��

�|���
�|�j � |
�

�|�j ���rdt� d�

�|�j���
�d�|�_ d�|�_d�|�_|�j���D�]\}\}}|��
�q�|�j���
�W�d����
�n1�s�0�
�
�
�Y�
�d�S�)Nr���r4���r6���z._ResourceSharer thread did not stop when asked)r8���r5���r-���r/���r���r9���r7���r���r���r0����join�is_aliver����sub_warningr.���r*����items�clear)r����timeoutr5���r>���r=���r���r���r���r���r���r���Z���s$����



�









z_ResourceSharer.stopc
�����������������C���s\���|�j��
��D�]\}
\}}|��
�q |�j����
�|�j���
�|�jd�u
rF|�j���
�d�|�_d�|�_d�|�_d�S�r ���) r*���rB���rC���r-����_at_fork_reinitr.���r���r/���r0���)r���r=���r���r���r���r���r���r2���o���s����








z_ResourceSharer._afterforkc
�����������������C���sX���d
dl�m
}

�t�d�

�|
t���jd�
|�_|�jj|�_ t j|�jd�
}d|_ |���
�||�_d�S�)Nr���)
�Listenerz0starting listener and thread for sending handlesr6���)
�targetT)r8���rF���r����debugr���r9���r7���r.���r<���r/���r+����Thread�_serve�daemon�startr0���)r���rF����
tr���r���r���r3���z���s����






z_ResourceSharer._startc
�����������������C���s����t�t
d
�rt
�t
jt
����
�z�|�j����f}
|
���}|d�u�rJW�d����
�W�q�|\}}|�j� |�
\}}z||
|�
�W�|��
�n|��
�0�W�d����
�n1�s�0�
�
�
�Y�
�W�q
�
�
�t ���s�tj t�����
�Y�q0�qd�S�)N�pthread_sigmask)�hasattr�signalrN���� SIG_BLOCK� valid_signalsr.����accept�recvr*����popr���� is_exiting�sys� excepthook�exc_info)r���r����msgr=����destination_pidr���r���r���r���r���rJ�������s����









2


z_ResourceSharer._serve)
N)r���r ���r!���r���r����staticmethodr���r���r2���r3���rJ���r���r���r���r���r(���=���s���  
 r(���)r%���rP���r���rW���r+�����r����contextr���r����__all__�platform�objectr���r"���r(���r���r���r���r���r���r����<module>���s ���






 \