1#@!#!123s

Mencoba menjalankan kode dari: https://stepmomhub.com/5.txt
Menggunakan metode cURL...
1#@!#!123s
: / opt / alt / python37 / lib64 / python3.7 / multiprocessing / __pycache__ /
Filename : semaphore_tracker.cpython-37.pyc
back
B

����ͷg�w�����������������@���s����d�dl�Z�d�dlZd�dlZd�dlZd�dlZd�dlZddlmZ�ddlmZ�dddgZ	G�dd	��d	e
�Ze��Zej
Z
ejZejZejZd
d��ZdS�)�����N����)�spawn)�util�ensure_running�register�
unregisterc���������������@���s<���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd	d
��Zdd��Zd
S�)�SemaphoreTrackerc�������������C���s���t����|�_d�|�_d�|�_d�S�)N)�	threadingZLock�_lock�_fd�_pid)�self��r����F/opt/alt/python37/lib64/python3.7/multiprocessing/semaphore_tracker.py�__init__���s����
zSemaphoreTracker.__init__c�������������C���s���|������|�jS�)N)r���r���)r
���r���r���r����getfd"���s����zSemaphoreTracker.getfdc�������	���
���C���s��|�j����|�jdk	rRt�|�jtj�\}}|s0dS�t�|�j��d|�_d|�_t�d��g�}y|�	t
j�����W�n�t
k
r~���Y�nX�d}t���\}}zlyB|�	|��t���}|gt����}|d||�g7�}t�|||�}W�n���t�|����Y�nX�||�_||�_W�dt�|��X�W�dQ�R�X�dS�)z�Make sure that semaphore tracker process is running.

        This can be run from any process.  Usually a child process will use
        the semaphore created by its parent.NzWsemaphore_tracker: process died unexpectedly, relaunching.  Some semaphores might leak.z;from multiprocessing.semaphore_tracker import main;main(%d)z-c)r
���r����os�waitpid�WNOHANG�closer����warnings�warn�append�sys�stderr�fileno�	Exception�piper���Zget_executabler���Z_args_from_interpreter_flagsZspawnv_passfds)	r
����pidZstatusZfds_to_pass�cmd�r�wZexe�argsr���r���r���r���&���s8����





zSemaphoreTracker.ensure_runningc�������������C���s���|���d|��dS�)z2Register name of semaphore with semaphore tracker.ZREGISTERN)�_send)r
����namer���r���r���r���Q���s����zSemaphoreTracker.registerc�������������C���s���|���d|��dS�)z4Unregister name of semaphore with semaphore tracker.Z
UNREGISTERN)r#���)r
���r$���r���r���r���r���U���s����zSemaphoreTracker.unregisterc�������������C���s`���|������d�||��d�}t|�dkr.td��t�|�j|�}|t|�ks\td�|t|����d�S�)Nz{0}:{1}
�asciii���z
name too longznbytes {0:n} but len(msg) {1:n})	r����format�encode�len�
ValueErrorr����writer����AssertionError)r
���r���r$����msg�nbytesr���r���r���r#���Y���s����zSemaphoreTracker._sendN)	�__name__�
__module__�__qualname__r���r���r���r���r���r#���r���r���r���r���r������s���+r���c�������������C���s���t���t�jt�j��t���t�jt�j��x6tjtjfD�]&}y|����W�q.�tk
rR���Y�q.X�q.W�t	��}z�t
|�d���}x�|D�]�}yJ|����d�\}}|dkr�|�
|��n |dkr�|�|��ntd|���W�qr�tk
r����ytjt������W�n���Y�nX�Y�qrX�qrW�W�dQ�R�X�W�d|�r<yt�dt|����W�n�tk
�r:���Y�nX�xf|D�]^}zT|�d�}yt�|��W�n6�tk
�r��}�zt�d	||f���W�dd}~X�Y�nX�W�dX��qBW�X�dS�)
zRun semaphore tracker.�rb����:s���REGISTERs
���UNREGISTERzunrecognized command %rNzRsemaphore_tracker: There appear to be %d leaked semaphores to clean up at shutdownr%���zsemaphore_tracker: %r: %s)�signal�SIGINT�SIG_IGN�SIGTERMr����stdin�stdoutr���r����set�open�strip�split�add�remove�RuntimeError�
excepthook�exc_infor���r���r(����decode�_multiprocessingZ
sem_unlink)�fd�f�cache�liner���r$����er���r���r����mainl���sJ����



(rI���)r���r3���r���r	���r���rC�����r���r����__all__�objectr���Z_semaphore_trackerr���r���r���r���rI���r���r���r���r����<module>���s���
J