+
    Švj$  ã                   ó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   ó    ÚX/var/www/html/daimler-pipeline/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ØˆB„wÜ�Š�|”r—y’y“{‘n B q¨ f¨C°¨w°aÐ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´-×2DÑ2DÓ!EŒÔÜ××ÐÜ˜Ð0Ô1ä××ÐÜ�IŠI‹KˆÜ×!Ñ! +Õ.€DÜ××ÐÜ�QÐ=Ô>ä××ÐÜ�IŠI‹KˆÜ
×
Ò
Øðä×&Ñ&òô ×)Ñ)ñ€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ˆØ�z‰z‹|÷	
÷ 	
÷ 	
ó 	
ú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?L�R 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ë  ø€ ØˆßÜ�KŠK˜<œ2Ÿ9š9›;™.¨
¨6©)°>°[±NÐCÔDÜØØØØØØØØô		ð ßÜ—’˜|œrŸyšy›{™nÐ,<Ð=Ô>Ø!—~‘~Ó'ˆHßÜ—’˜|œrŸyšy›{™n¨L¨x©k¸Ð;Ô<ØÒÙðßßÜ ŸIšI›K˜Ü&×/Ò/°Ó5�HßÜ$ QÐ(@ÔAçÜŸ	š	›�AØÕ)�ßÜ  Ð$8Ô9çÜ—K’K <¤2§9¢9£;¡.Ð0A´=Ñ2BÐ CÔDçÜŸ	š	›�AÙØðä&×2Ñ2òô (×5Ñ5ñ�÷
 Ü   y x¡k°Ð$;Ô<÷ Ü—’˜|œrŸyšy›{™nÐ,@°x±kÀÀ3Á&ÐIÔJà�L‰L˜8˜/×+øô ô ßœGŸKšK¨<¬2¯9ª9«;©.¸ÀQÁDÐ(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ä‹6€DðG7çÜ—	’	“ˆAÜ�{Ö#ˆAÜ—’“	ˆAØ�AŒvð	 ðÙ�	÷
 ÜŸš |¤r§y¢y£{¡nÐ4IÐ$JÔKÜ—H’H˜Q”KØ�K‰K˜ŽNñ $÷ Ü˜Ð4Ô5÷ Ü—	’	“ˆAßÜ�KŠKÐ/Ô1Üœc %›jÖ)ˆHØ�N‰N˜8Ö$ñ *çÜ˜Ð/Ô0ð ˆf”s˜5“zÕ!ˆÜ”s˜5“zÖ"ˆAØ%Ÿ\™\›^‰NˆH�dßÜ—’˜y˜x™k¨¬3¨t«9©,Ð7Ô8Ø�x•=Ò(Ð(Ð(Ü˜$¤	×*Ò*ßØ �EÙØ ˆC�‹Mñ #ô �{Ö#ˆAØ�N‰N˜4Ö ñ $ç”G—K’K /Ô3Ø×ÑÔçØˆKßÜ�KŠKÐ@´s¸3³x±kÐBÔCØ÷ Ü—	’	“ˆAÛˆCßÜ—’Ð/¨3©&°Ð2Ô3Ü—
’
˜3 Ó"ˆAß‰wÜ—’˜t˜s™f G¨©Ð-Ö.ñ ÷ Ü˜Ð5Õ6ð øôw %ô ÜŸš |¤r§y¢y£{¡nÐ4FÀAÁ4Ð$HÔIØûðû÷ ÜŸš |¤r§y¢y£{¡nÐ4IÐ$JÔKÜ—H’H˜Q•Kû÷Z Ü—	’	“ˆAÛˆCßÜ—’Ð/¨3©&°Ð2Ô3Ü—
’
˜3 Ó"ˆAß‰wÜ—’˜t˜s™f G¨©Ð-Ö.ñ ÷ Ü˜Ð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   