@@ -500,6 +500,7 @@ <h1>Source code for mantidimaging.core.parallel.manager</h1><div class="highligh
500
500
< span class ="kn "> import</ span > < span class ="w "> </ span > < span class ="nn "> os</ span >
501
501
< span class ="kn "> import</ span > < span class ="w "> </ span > < span class ="nn "> uuid</ span >
502
502
< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> logging</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> getLogger</ span >
503
+ < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> pathlib</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> Path</ span >
503
504
< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> typing</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> TYPE_CHECKING</ span >
504
505
505
506
< span class ="kn "> import</ span > < span class ="w "> </ span > < span class ="nn "> psutil</ span >
@@ -592,7 +593,8 @@ <h1>Source code for mantidimaging.core.parallel.manager</h1><div class="highligh
592
593
593
594
< span class ="k "> def</ span > < span class ="w "> </ span > < span class ="nf "> _is_safe_to_remove</ span > < span class ="p "> (</ span > < span class ="n "> mem_name</ span > < span class ="p "> :</ span > < span class ="nb "> str</ span > < span class ="p "> )</ span > < span class ="o "> -></ span > < span class ="nb "> bool</ span > < span class ="p "> :</ span >
594
595
< span class ="n "> process_start</ span > < span class ="o "> =</ span > < span class ="n "> psutil</ span > < span class ="o "> .</ span > < span class ="n "> Process</ span > < span class ="p "> ()</ span > < span class ="o "> .</ span > < span class ="n "> create_time</ span > < span class ="p "> ()</ span >
595
- < span class ="k "> if</ span > < span class ="n "> _is_mi_shared_mem</ span > < span class ="p "> (</ span > < span class ="n "> mem_name</ span > < span class ="p "> )</ span > < span class ="ow "> and</ span > < span class ="n "> os</ span > < span class ="o "> .</ span > < span class ="n "> path</ span > < span class ="o "> .</ span > < span class ="n "> getmtime</ span > < span class ="p "> (</ span > < span class ="sa "> f</ span > < span class ="s1 "> '</ span > < span class ="si "> {</ span > < span class ="n "> MEM_DIR_LINUX</ span > < span class ="si "> }</ span > < span class ="s1 "> /</ span > < span class ="si "> {</ span > < span class ="n "> mem_name</ span > < span class ="si "> }</ span > < span class ="s1 "> '</ span > < span class ="p "> )</ span > < span class ="o "> <</ span > < span class ="n "> process_start</ span > < span class ="p "> :</ span >
596
+ < span class ="n "> mem_path</ span > < span class ="o "> =</ span > < span class ="n "> Path</ span > < span class ="p "> (</ span > < span class ="n "> MEM_DIR_LINUX</ span > < span class ="p "> )</ span > < span class ="o "> /</ span > < span class ="n "> mem_name</ span >
597
+ < span class ="k "> if</ span > < span class ="n "> _is_mi_shared_mem</ span > < span class ="p "> (</ span > < span class ="n "> mem_name</ span > < span class ="p "> )</ span > < span class ="ow "> and</ span > < span class ="n "> mem_path</ span > < span class ="o "> .</ span > < span class ="n "> exists</ span > < span class ="p "> ()</ span > < span class ="ow "> and</ span > < span class ="n "> mem_path</ span > < span class ="o "> .</ span > < span class ="n "> stat</ span > < span class ="p "> ()</ span > < span class ="o "> .</ span > < span class ="n "> st_mtime</ span > < span class ="o "> <</ span > < span class ="n "> process_start</ span > < span class ="p "> :</ span >
596
598
< span class ="k "> try</ span > < span class ="p "> :</ span >
597
599
< span class ="n "> pid</ span > < span class ="o "> =</ span > < span class ="nb "> int</ span > < span class ="p "> (</ span > < span class ="n "> mem_name</ span > < span class ="o "> .</ span > < span class ="n "> split</ span > < span class ="p "> (</ span > < span class ="s1 "> '_'</ span > < span class ="p "> )[</ span > < span class ="mi "> 1</ span > < span class ="p "> ])</ span >
598
600
< span class ="n "> _lookup_process</ span > < span class ="p "> (</ span > < span class ="n "> pid</ span > < span class ="p "> )</ span >
0 commit comments