+
    ˧6j$                     f    ^ RI t ^ RIt^ RIt^ RIt ! R R4      t]! 4       tR tR tR tR t	R t
R# )	    Nc                       ] tR t^tRtR# )_worker_State N)__name__
__module____qualname____firstlineno____static_attributes__r       L/opt/hart-platform/venv/lib/python3.14/site-packages/pymupdf/_apply_pages.pyr   r      s    r   r   c                     V \         n        V\         n        V\         n        V\         n        V\         n        R \         n        V'       d   V! V/ VB  R # R # N)_worker_statepathpagefnpagefn_argspagefn_kwargsstatsdocument)r   initfninitfn_argsinitfn_kwargsr   r   r   r   s   &&&&&&&&r   _worker_initr      sI     M!M +M"/MM!M-}- r   c           	          \         P                   ! 4       V ,
          p V ^
8  d8   \        P                  ! R\        P                  ! 4       : RV R RV R24       R# R# )
   os.getpid()=z: 2fzs: .N)timepymupdflogosgetpid)tlabels   &&r   _stats_writer&   %   sF    		aABw|ryy{nBqfCwa89 r   c                    \         P                  '       g{   \         P                  '       d   \        P                  ! 4       p\        P
                  ! \         P                  4      \         n        \         P                  '       d   \        XR 4       \         P                  '       d   \        P                  ! 4       p\         P                  V ,          p\         P                  '       d   \        XR4       \         P                  '       d   \        P                  ! 4       p\         P                  ! V.\         P                  O5/ \         P                  B p\         P                  '       d   \        XR4       V# )zpymupdf.Document()z#_worker_state.document[page_number]z_worker_state.pagefn())r   r   r   r   r    Documentr   r&   r   r   r   )page_numberr$   pagerets   &   r   
_worker_fnr,   +   s    !!!		A!(!1!1-2D2D!E01IIK!!+.DQ=>IIK


&& ))C
 Q01Jr   c
                     \         P                  ! V\        V WVVW#VV	34      ;_uu_ 4       p
V
P                  \        V4      pVP                  4       uuR R R 4       #   + '       g   i     R # ; ir   )multiprocessingPoolr   	map_asyncr,   get)r   pagesr   r   r   r   r   r   concurrencyr   poolresults   &&&&&&&&&&  r   _multiprocessingr6   G   se     
		]]		
 	
 
E2zz|	
 	
 	
 	
s   &AA-	c
                 `	  a aaaaaaa	aaa ^ oVf   \         P                  ! 4       p\         P                  ! 4       o\         P                  ! 4       oVVVVVVV VVV	V3R lp
Rp\        4       p S	'       d   \        P                  ! 4       p\        V4       F  p\        P                  ! 4       pV^ 8X  dW     V
! 4         S'       d/   \        P                  ! R\        P                  ! 4       : R24       \        P                  ! ^ 4       VP                  V4       K  	  S	'       d   \        XR4       S	'       d   \        P                  ! 4       pS'       d   \        P                  ! R4       \        \        V4      4       F  pSP!                  V4       K  	  S	'       d   \        XR4       R.\        V4      ,          p\        \        V4      4       Fy  pSP#                  4       w  ppS'       d(   \        P                  ! R	V: R
\        V4      : 24       VV,          e   Q h\%        V\        4      '       d   V'       g   Tp M	VVV&   K{  	  \        V4       F  pSP!                  R4       K  	  S'       d   \        P                  ! R4       SP'                  4        V'       d   VhS'       d$   \        P                  ! R\        V4      : 24       TS	'       d   \        P                  ! 4       pV Fe  pS'       d   \        P                  ! RV: R24       \        P(                  ! V^ 4      pS'       g   KG  \        P                  ! RV: RV: 24       Kg  	  S	'       d   \        XR4       # #   \         d8   p\        P                  ! R\        P                  ! 4       : RT: 24       h Rp?ii ; i  S'       d/   \        P                  ! R\        P                  ! 4       : R24       \        P                  ! ^ 4       i ; i  S	'       d   \        P                  ! 4       pT Fe  pS'       d   \        P                  ! RT: R24       \        P(                  ! T^ 4      pS'       g   KG  \        P                  ! RT: RT: 24       Kg  	  S	'       d   \        XR4       i i ; i)r   Nc            
      F  < R p S'       d6   \         P                  ! R\        P                  ! 4       : RS: RS: 24       \	        SSSSS	S
SS4        S'       d/   \         P                  ! R\        P                  ! 4       : R24       SP                  4       pS'       d3   \         P                  ! R\        P                  ! 4       : RV: R24       Vf   R #  V '       gH   S'       d   \        P                  ! 4       p\         P                  ! S4      p S'       d   \        XR4       S'       d   \        P                  ! 4       pW,          pS'       d   \        XR4       S'       d6   \         P                  ! R\        P                  ! 4       : R	\        : 24       S'       d   \        P                  ! 4       pS	! V.\        P                  O5/ \        P                  B pS'       d   \        XR
V: R24       S'       d6   \         P                  ! R\        P                  ! 4       : RT: RT: 24       SP                  Y34       EK    \         dF   pS'       d2   \         P                  ! R\        P                  ! 4       : RT: 24       Tp R p?LR p?ii ; i)Nr   z	: initfn=z initfn_args=z: calling get().z: page_num=r   zpymupdf.Document(path)zdocument[page_num]z: _worker_state=	page_num=z	 pagefn()z: exception e=z: sending page_num=z ret=)r    r!   r"   r#   r   r1   r   r(   r&   r   r   r   	Exceptionput)r   page_numr$   r*   r+   er   r   r   r   r   r   r   
queue_downqueue_upr   verboses         r   childfn_fork.<locals>.childfn{   s   KK<299;.
6)>[NCD		 |ryy{n,<=>!~~'H|ryy{nLxk;< IIK&//5H$Q(@A		A) $89KK<299;.0A=2B CD		A&22 (55
  yxk$;< |ryy{n,@xk3&IJLL8/+  GKK<299;.QD(IJsC   I #I +2I I 28I +<I (AI -I J ;JJ r   z: childfn() => e=z: calling os._exit(0)zcreate child processeszSending page numbers.zSend page numbersr9   z len(text)=zClosing queues.z%After concurrent, returning len(ret)=zwaiting for pid=r   zpid=z => e=zJoin all child proceses)r.   	cpu_countQueuelistr   ranger"   forkr:   r    r!   r#   _exitappendr&   lenr;   r1   
isinstanceclosewaitpid)r   r2   r   r   r   r   r   r   r3   r   rA   errorpidsr$   ipr=   r<   r+   textpidr>   r?   r@   s   f&ffffff&f           @@@r   _forkrT   b   sa    G%//1 !&&(J$$&H6, 6,p E6DG7		A{#A	AAv	 	
 |ryy{n4I$JKHHQKKKN $ 45 		AKK/1c%j)HNN8$ */0 fs5z!s5z"A%\\^NHdyxk3t9,78x=((($	** E CM # {#ANN4  $GKK/3KKK@s3xkBC 		AC/3&23

3"AwtsfG-.  56 w % |ryy{n4FA4$HI |ryy{n4I$JKHHQKZ 		AC/3&23

3"AwtsfG-.  56 s   .AP 7M8?P A P (P <P A	P #B"P 7P >-P ,	P 6$P 8N:2N55N::N==APP A"R-5)R-R-)r.   r"   r   r    r   r   r   r&   r,   r6   rT   r   r   r   <module>rU      s<     	  	 	.*:86[7r   