§ f‚jم َ`—UddlZddlZddlZddlZddlmZddlmZddlm Z m Z ddlmZm Z eje¦«ZeGd„d¦«¦«Ze¦«Ze eefed<ej¦«Zedd ede eddffd„¦«Zd „Zd„Zdd„Zd„Zd edefd„Zdefd„ZdS)éN)عcontextmanager)ع dataclass)عDictع Generator)عrequest_data_storageعsafe_id_patterncَH—eZdZUdZejed<eed<ed„¦«Z dS)عTaskCounterStoragezH Typing that has lock and value storage with some syntax sugar. عlockعnext_request_idcَ—|jdz S)Né)r)عselfs ْS/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/internal/local_counters.pyعprocessed_requestsz%TaskCounterStorage.processed_requestss€àش# aر'ذ'َN) ع__name__ع __module__ع__qualname__ع__doc__ع threadingعLockع__annotations__عintعpropertyr©rrr r sU€€€€€€ًًًŒ.ذذرطذذرà ً(ً(ٌ„Xً(ً(ً(rr ع_request_id_storageFعfake_task_idعreturnc#َK—t d|¦«t|¦«}|j5|V—|r+t d|¦«t||¦«ddd¦«dS#1swxYwYdS)zة Open local task information storage. @param fake_task_id: unique string, usually obtained as task.fake_id @param flush: whether to save data to file right after update zOpening storage %sz)Updating task %s requests counter in fileN)عloggerعdebugع_get_or_create_recordrعinfoع_save_data_to_file)rعflushعstorages rعopen_local_storager(%sجèè€ُ‡L‚Lذ% |ر4ش4ذ4ف# Lر1ش1€Gط Œً6ً6طˆ ˆ ˆ àً 6فڈKٹKذCہ\رRشRذRفک|¨Wر5ش5ذ5ً6ً6ً6ٌ6ô6ً6ً6ً6ً6ً6ً6ً6ًّّّ6ً6ً6ً6ً6ً6s´2A3ء3A7ء:A7cَ‍—t d|¦«t5|tvrt|=ddd¦«dS#1swxYwYdS)zw Remove local storage record. @param fake_task_id: unique string, usually obtained as task.fake_id z#Removing memory storage for task %sN)r!r$ع_global_storage_lockr)rs rعremove_local_storager+8s—€ُ‡K‚Kذ5°|رDشDذDف ً2ً2طص.ذ.ذ.ف# Lذ1ً2ً2ً2ٌ2ô2ً2ً2ً2ً2ً2ً2ً2ًّّّ2ً2ً2ً2ً2ً2s£AءAء Acَ*—tt¦«S)ْ8 List all fake task ids saved in local storage. )عlistrrrrعget_task_idsr/Ds€ُص#ر$ش$ذ$rTcَ—tt ¦«¦«D]^}t d|¦«t|¦«5}t ||¦«|rt|=ddd¦«n#1swxYwYŒ_dS)r-zFlushing task id %s on diskN)r.rعkeysr!r$r(r%)عremoverr's rعflush_memory_storager3Ksب€ُص0×5ز5ر7ش7ر8ش8ً6ً6ˆفڈٹذ1°<ر@ش@ذ@ف ر -ش -ً 6°فک|¨Wر5ش5ذ5طً 6ف'¨ذ5ً 6ً 6ً 6ٌ 6ô 6ً 6ً 6ً 6ً 6ً 6ً 6ًّّّ 6ً 6ً 6ً 6ًّ6ً6sءA:ء:A> آA> cَH—tj||tjzd¦«S)Ni€)عosعopenع O_NOFOLLOW)عpathعflagss rع_nofollow_openerr:Ws€ف Œ7گ4ک¥¤ر.°ر6ش6ذ6rr'cَâ—|rtj|¦«std|›‌¦«‚tj t|¦«} t|dt¬¦«5}| t|j¦«¦«ddd¦«dS#1swxYwYdS#t$r<}|j tjkr!t d|¦«Yd}~dS‚d}~wwxYw)z1 Saves storage data from memory to file. zInvalid task_id format: عw©عopenerNْRefusing to follow symlink: %s)rعmatchع ValueErrorr5r8عjoinrr6r:عwriteعstrrعOSErrorعerrnoعELOOPr!عwarning©rr'عreq_id_fileعfعes rr%r%[s9€ًًD‌ش4°\رBشBًDفذB°LذBذBرCشCذCف”'—,’,ص3°\رBشB€Kًف گ+کsص+;ذ <ر <ش <ً 2ہط ڈGٹG•Cکش/ر0ش0ر1ش1ذ1ً 2ً 2ً 2ٌ 2ô 2ً 2ً 2ً 2ً 2ً 2ً 2ً 2ًّّّ 2ً 2ً 2ً 2ً 2ً 2ّهًًًطŒ7•e”kز!ذ!فڈNٹNذ;¸[رIشIذIطˆFˆFˆFˆFˆFط ًّّّّ ّّّsBءB(ء&(BآB(آBآB(آ"Bآ#B(آ( C.آ20C)أ(C)أ)C.cَج—t5|tvگr-ttj¦«d¬¦«t|<t|}t j t|¦«} t|dt¬¦«5}t| ¦«¦«|_ ddd¦«n#1swxYwYn‡#t$rYn{t$rt d|¦«YnUt$$r<}|jt&jkrt d|¦«n‚Yd}~nd}~wwxYwt|}ddd¦«n#1swxYwY|S)zO Takes record from local storage or creates new one and returns object r)rrعrr=Nz8Corrupted counter file for task %s, resetting to defaultr?)r*rr rrr5r8rBrr6r:rعreadrعFileNotFoundErrorrAr!rHrErFrGrIs rr#r#ls€ُ ً8ً8طص2ذ2ر2ف0Bف”^ر%ش%ط !ً1ٌ1ô1ص ر-ُ *¨,ش7ˆGهœ'ں,ڑ,ص';¸\رJشJˆKً فک+ sص3CذDرDشDً<بف.1°!·&²&±(´(©m¬mگGش+ً<ً<ً<ٌ<ô<ً<ً<ً<ً<ً<ً<ًّّّ<ً<ً<ً<ّّه$ً ً ً طگفً Eً Eً Eف—’ً 6ط7CٌEôEًEًEًEهً ً ً ط”7‌eœkز)ذ)ف—N’Nذ#Cط#.ٌ0ô0ً0ً0ًً0ً0ً0ً0ً0ًّّّّ ُّّّ*¨,ش7ˆGً38ً8ً8ٌ8ô8ً8ً8ً8ً8ً8ً8ًّّّ8ً8ً8ً8ً4€NsxˆA'Eء0Cآ'B:آ.Cآ:B> آ>CأB> أCأEأ D=أEأ$D=أ6Eأ8 D=ؤ2D8ؤ3Eؤ8D=ؤ=EإEإ E)F)T)rFعloggingr5rع contextlibrعdataclassesrعtypingrrعxray.internal.constantsrrع getLoggerrr!r عdictrrDrrr*r(r+r/r3r:r%r#rrrْrXsتًً €€€€ط€€€ط € € € طذذذط%ذ%ذ%ذ%ذ%ذ%ط!ذ!ذ!ذ!ذ!ذ!ط"ذ"ذ"ذ"ذ"ذ"ذ"ذ"àIذIذIذIذIذIذIذIà ˆش ک8ر $ش $€ًً (ً (ً (ً (ً (ٌ (ô (ٌ„ً (ً6:°T±V´VذگTک#ذ1ذ1ش2ذ;ذ;ر;ط%گy”~ر'ش'ذًً6ً6 Sً6¸)ذDVذX\ذ^bذDbش:cً6ً6ً6ٌ„ً6ً$ 2ً 2ً 2ً%ً%ً%ً 6ً 6ً 6ً 6ً7ً7ً7ً Sًذ3Eًًًًً"ذ+=ًًًًًًr