⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.12
/
multiprocessing
/
__pycache__
/
View File Name :
resource_sharer.cpython-312.pyc
CRh d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ ddlm Z dgZ ej dk( re dgz Z G d de Z ne d gz Z G d d e Z G d d e Z e Zej" Zy) N )process) reduction)utilstopwin32 DupSocketc e Zd ZdZd Zd Zy)r z Picklable wrapper for a socket.c z |j fd}t j |j | _ y )Nc J j | }| j | y N)share send_bytes)connpidr new_socks 6/usr/lib/python3.12/multiprocessing/resource_sharer.pysendz DupSocket.__init__.<locals>.send s s+& )dup_resource_sharerregisterclose_id)selfsockr r s @r __init__zDupSocket.__init__ s- xxzH ' (00x~~FDHr c t j | j 5 }|j }t j | cddd S # 1 sw Y yxY w)z1Get the socket. This should only be called once.N)r get_connectionr recv_bytessocket fromshare)r r r s r detachzDupSocket.detach$ s< !00:d ) ''. ;::s %AAN__name__ __module__ __qualname____doc__r r# r r r r s - G /r DupFdc e Zd ZdZd Zd Zy)r* z-Wrapper for fd which can be used at any time.c z t j | fd}fd}t j || | _ y )Nc 4 t j | | y r )r send_handle)r r new_fds r r z DupFd.__init__.<locals>.send1 s %%dFC8r c 0 t j y r )osr )r/ s r r z DupFd.__init__.<locals>.close3 s r )r1 r r r r )r fdr r r/ s @r r zDupFd.__init__/ s. VVBZF 9 !'00u=DHr c t j | j 5 }t j | cddd S # 1 sw Y yxY w)z-Get the fd. This should only be called once.N)r r r r recv_handle)r r s r r# z DupFd.detach7 s0 !00:d ,,T2 ;::s ?ANr$ r) r r r* r* - s ; > 3r c F e Zd ZdZd Zd Zed Zd dZd Z d Z d Z y) _ResourceSharerz.Manager for resources using background thread.c d| _ i | _ t j | _ d | _ d | _ d | _ t j | t j y )Nr ) _key_cache threadingLock_lock _listener_address_threadr register_after_forkr6 _afterfork)r s r r z_ResourceSharer.__init__? sI ^^% 'A'ABr c | j 5 | j | j | xj dz c_ ||f| j | j < | j | j fcddd S # 1 sw Y yxY w)z+Register resource, returning an identifier.Nr )r< r> _startr8 r9 )r r r s r r z_ResourceSharer.registerH sY ZZ}}$ IINI&*E]DKK "MM499- ZZs A$A;;Bc ddl m} | \ }} ||t j j }|j |t j f |S )z<Return connection from which to receive identified resource.r Clientauthkey) connectionrF r current_processrH r r1 getpid)identrF addresskeycs r r z _ResourceSharer.get_connectionQ sG ' 7G$;$;$=$E$E F RYY[!"r Nc ddl m} | j 5 | j || j t j j }|j d |j | j j | | j j rt j d | j j d| _ d| _ d| _ | j j! D ] \ }\ }} | | j j# ddd y# 1 sw Y yxY w)z:Stop the background thread and clear registered resources.r rE NrG z._ResourceSharer thread did not stop when asked)rI rF r< r> r rJ rH r r r? joinis_aliver sub_warningr= r9 itemsclear)r timeoutrF rO rN r r s r r z_ResourceSharer.stopZ s & ZZ}}(4==#*#:#:#<#D#DFt !!'*<<((*$$ &; <$$& # $ !%*.++*;*;*=&C $G +> !!#! ZZs D D::Ec : | j j D ] \ }\ }} | | j j | j j | j | j j d | _ d | _ d | _ y r ) r9 rT rU r< _at_fork_reinitr= r r> r? )r rN r r s r rA z_ResourceSharer._afterforko sv "&++"3"3"5 C $ G #6 ""$ >> % NN " r c h ddl m} | j J d t j d |t j j d | _ | j j | _ t j | j }d|_ |j || _ y ) Nr )ListenerzAlready have Listenerz0starting listener and thread for sending handles )rH backlog)targetT)rI rZ r= r debugr rJ rH rM r> r: Thread_servedaemonstartr? )r rZ ts r rC z_ResourceSharer._startz s (~~%>'>>% EF!'*A*A*C*K*KUXY .. DKK 0 r c * t t d r6t j t j t j | j j 5 }|j }| d d d y |\ }}| j j | \ }} ||| | d d d v# | w xY w# 1 sw Y xY w# t j s$t j t j Y UxY w)Npthread_sigmask)hasattrsignalre SIG_BLOCK valid_signalsr= acceptrecvr9 popr is_exitingsys excepthookexc_info)r r msgrN destination_pidr r s r r` z_ResourceSharer._serve s 6, - " "6#3#3V5I5I5K L 4^^**, ))+C{ -, ,/(C "&++//#"6KD% T?3 - -, 4(NNCLLN3sH C #C 7C #C $ B>-C 5C > CC CC :Dr ) r% r& r' r( r r staticmethodr r rA rC r` r) r r r6 r6 = s8 8C. $* 4r r6 )r1 rg r! rn r: r contextr r __all__platformobjectr r* r6 r r r) r r <module>ry s ( <<7 } G /F / yG 3 3 Y4f Y4x #$ r