
    TNj	                        S SK Jr  S SKrS SKrS SKJr  S SKJr  \" \5      R                  5       R                  r\" \R                  " S\S-  S-  S-  5      5      rS	r\S
-  r\S-  r\S-  rSS jrSSS jjrSS jrg)    )annotationsN)Path)	CORE_ROOTORIGUS_CORE_PYTHONz.venvbinpythonconnectors.techexpertruntimeztechexpert_sync.logztechexpert_sync.pidc                 b   [         R                  5       (       d  g  [        [         R                  SS9R	                  5       5      n [        SU  35      nUR                  5       (       d  [         R                  SS9  g  US-  R                  SSS9nUR                  S	5      nX#S
-   S  R                  5       nU(       a  US   S:X  a  [         R                  SS9  g  US-  R                  5       R                  SS5      R                  SSS9nSU;  d	  SSU 3;  a  [         R                  SS9  g   [        R                  " U S5        U $ ! [
         a    [         R                  SS9   g f = f! [
         a     Nf = f! [
         a     NYf = f! [         a    [         R                  SS9   g f = f)Nutf-8encodingT)
missing_okz/proc/statreplacer   errors)   r   Zcmdline        )r   r	   z sync )SYNC_PIDexistsint	read_textstrip	Exceptionunlinkr   rfindsplit
read_bytesr   decodeoskillOSError)pidprocr   rparentailcmds         -/mnt/data/_core_build/package/core/runtime.py_running_pidr/      s   ??6""G"4::<= 
sen	D;;==4(6k$$gY$Gzz#()_""$DGSLOOtO,T)^'')11%=DDWT]D^"#-!C5	1IOOtO,T 2J6
As
)  64(6      64(6sI   *E >AE. AE> 2F E+*E+.
E;:E;>
F
FF.-F.c           	        [        5       nU(       a  [        SU S35      e[        R                  SSS9  [	        [
        5      S[        S/nU (       a  USU /-  n[        R                  SS	S
9nUR                  SU (       a  SU -   OS S35        UR                  5         [        R                  " U[	        [        5      U[        R                  SSS9n[        R!                  [	        UR"                  5      S	S
9  UR"                  $ )Nu>   Синхронизация уже выполняется (PID z).T)parentsexist_okz-msyncz
--documentar   r   z

===== START zONE ALLz =====
)cwdstdoutstderrstart_new_session	close_fds)r/   RuntimeErrorRUNTIME_DIRmkdirstrPYTHONCONNECTOR_MODULESYNC_LOGopenwriteflush
subprocessPopenBASE_DIRSTDOUTr   
write_textr)   )document_slugrunningr-   logr*   s        r.   
start_syncrM   -   s    NG[\c[ddfghhdD1	VT*62C]++c7+CII !5E RRZ[\IIK			HS
0A0A
D DHHw788O    c                     [        5       n Sn[        R                  5       (       a   [        R                  SSS9nUSS  n[        U 5      XS.$ ! [         a     Nf = f)N r   r   r   i )rK   r)   log_tail)r/   rA   r   r   r    bool)r)   r,   texts      r.   
sync_staterT   ?   se    C	D	##WI#FDfgD 3ic::  		s   A 
AA)returnz
int | None)N)rJ   z
str | NonerU   r   )rU   dict)
__future__r   r&   rE   pathlibr   core_dbr   __file__resolveparentrG   getenvr?   r@   r<   rA   r   r/   rM   rT    rN   r.   <module>r_      s    " 	   >!!#**	bii,h.@5.H8.ST	U* )#....6:$	;rN   