N.XddlZddlZddlZddlmZmZmZmZmZGddZ dZ dZ y)N)errorhgobsoletescmutilutilc:eZdZdZdZdZdZdZdZdZ dZ y ) repoloaderzLoad repositories in background thread This is designed for a forking server. A cached repo cannot be obtained until the server fork()s a worker and the loader thread stops. c|j|_tj||_t j ||_d|_tj|_ d|_ y)N)max)maxlenF) copy_uir lrucachedict_cache collectionsdeque_inqueue _accepting threadingEvent _newentry_thread)selfuir s 7usr/lib/python3.12/site-packages/mercurial/repocache.py__init__zrepoloader.__init__sQ779''F3 $))8 "* c|jrJ|jjdk(ryd|_t j |j |_|jjy)NrT)target)rrr rrThread _mainloopstartrs rr#zrepoloader.start'sQ<< ==  1 $  ''t~~>  rc |jsyd|_|jj|jj d|_|j j |jj y)NF)rrrsetjoinrclearrr$s rstopzrepoloader.stop0sZ||      rcn|jj||jjy)z6Request to load the specified repository in backgroundN)rappendrr&rpaths rloadzrepoloader.load:s$ T" rc|jr/|jjrtjd|jj |dS)zReturn a cached repo if available This function must be called after fork(), where the loader thread is stopped. Otherwise, the returned repo might be updated by the loader thread. s0cannot obtain cached repo while loader is activeN)ris_aliverProgrammingErrorrpeekr,s rgetzrepoloader.get?sI <z&repoloader._mainloop..\sDJJt4Dr) rgccollectrwaitr(rpopleft IndexErrorr callcatchrr,s`@rr"zrepoloader._mainloopLsoo JJL NN   !//$$&==002D!!$((,DE //oo"s$B>> C  C ctj} |jj|}t||jjdd|tj|z |jj||y#t$r1t j |j|j}YwxYw)Ns repocaches&loaded repo into cache: %s (in %.3fs) ) rtimerrpopKeyErrorr repositoryr unfiltered _warmupcacherloginsert)rr-r#repos rr7zrepoloader._load^s  >;;??4(D T   6  JJL5  4& >==40;;=D >sB 7CCN) __name__ __module__ __qualname____doc__rr#r)r.r3r"r7rrr r s+  ,F$'rr cx|j|j|jj|jj|jj |jj tjD]}tj|||jj|yr6) invalidateall changelogobsstore_all successors predecessorschildrenr cachefuncsgetrevs _phasecache loadphaserevs)rHnames rrErEqs}NNMMMMMMMM##t$$""4(rcN|j}|j}d|vr6|dx|d<}|jx|j_|j_d|vr%|dx|d<}|j|j_d|vr&|dx|d<}|j|j_yy)z/Copy cached attributes from srcrepo to destrepos changelogsobsstores _phasecacheN) _filecachesvfsobjopener _realopener)srcrepodestrepo destfilecache srcfilecacheces r copycacherf~s''M%%L|#+7 +EE l#b-5]]: *l"*6{*CC k"Rmm %-9.-II n%  &r) rr9rrrrrrr rErfrMrrrhs1 W'W'v ) &r