Wj d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z m
Z
dZdZd Z e j d
Zd efd Zdd
ZddZdS ) N)
get_client) XRayError) read_sys_id)initialize_manager)remove_xray_inisclear_dbm_filez*/usr/share/alt-php-xray/running_tasks_listz /usr/share/alt-php-xray/migratedz#/var/log/alt-php-xray/migration.logmigratereturnc t d t } | }t d| n # t
$ r t
cY S w xY wd |d D }t d| t t d 5 }| d
| d d d n # 1 swxY w Y |S )
z9
Get list of running tasks and save it into file
lists) system_idzLoaded tasks: %sc 6 g | ]}|d dk |d S )statusrunningtracing_task_id ).0ts S/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/reconfiguration/migrate.py
z!running_tasks..& s6 ) ) ){i'' "#''' resultzRunning tasks: %sw
N) r r
get_task_listloggerinfor listopenstoragewritejoin)clienttasksr fs r
running_tasksr& s3 !Z
;==
9
9
9F$$&& &.... vv
) )U8_ ) ) )G
KK#W---
gs $q '""###$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ Ns# /A A21A27)C,,C03C0c B t t } t D ]X}t d| | | n# t $ r Y nw xY wt j d Yt t dS )zO
Stop running tasks.
Try to remove ini and clear dbm storage after
zStopping task %s N) r r r& r r stopr timesleepr r )managertasks r
stop_tasksr. . s
! //G &--- LL D
1
s A
A+*A+c t t } t t 5 }d | d D }ddd n # 1 swxY w Y n# t $ r Y dS w xY wt d| t j
t |D ]X}t d| | | n# t $ r Y nw xY wt j d Yt j t t j t j z t j z t j z d }t j | dS ) c g | ]}||S r r )r ls r r z"continue_tasks..E s :::1:Q:::r r NzSaved task list loaded: %szContinue task %sr( i )r r r r readsplitOSErrorr r osunlink continue_r r* r+ markerO_CREATO_WRONLYO_TRUNC
O_NOFOLLOWclose)r, r% r$ r- fds r continue_tasksr@ @ s //G
']] ;a::t 4 4:::E ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; KK,e444Ig &--- d # # # # D
1
bk1BJ> NPU V VBHRLLLLLsF A; 2A/# A; /A33A; 6A37A; ;
B B C66
DD)r
N)loggingr6 r* xray.apiclientr xray.internal.exceptionsr xray.internal.utilsr xray.managerr $xray.reconfiguration.system_id_shiftr r r r9
migration_log getLoggerr r r& r. r@ r r r rI s % % % % % % . . . . . . + + + + + + + + + + + +
7 +5
9 % %t $ $ r