§ Wèؤjرم َx—UddlZddlZddlZddlZddlmZddlmZddlm Z ddl mZmZej e¦«Ze Gd„d¦«¦«ZiZeeefed<ej¦«Zedd edeeddffd„¦«Zd „Zd„Zddeeeffd„Zd ededzfd„Zd„Zd edefd„Zdefd„ZdS)éN)ع Generator)عcontextmanager)ع dataclass)ع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|¦«}|j5t5t |¦«|ur ddd¦«ddd¦«ŒT ddd¦«n#1swxYwY|V—|r+t d|¦«t||¦« ddd¦«dS#1swxYwYŒ¶)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 %sTNz)Updating task %s requests counter in file) عloggerعdebugع_get_or_create_recordr ع_global_storage_lockrعgetعinfoع_save_data_to_file)rعflushعstorages rعopen_local_storager)$sژèè€ُ‡L‚Lذ% |ر4ش4ذ4ً ف'¨ر5ش5ˆط Œ\ً ً ف%ً ً ف&×*ز*¨<ر8ش8ہذGذGًً ً ً ٌ ô ً ً ً ً ٌ ô ً ً àGً ً ً ٌ ô ً ً ً ً ً ً ًّّّ ً ً ً ً ˆMˆMˆMàً :ف—’ذGبرVشVذVف" <°ر9ش9ذ9طً ً ً ٌ ô ً ً ً ً ً ً ً ًّّّ ً ً ً ً s:µC ½A?ءC ء3C ء?B آC آB آ5C أ C أC cَ|—t d|¦«t5t |¦«}ddd¦«n#1swxYwY|€dS|j5t5t |¦«|urt|=ddd¦«n#1swxYwYddd¦«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%r#rr$r )rr(s rعremove_local_storager+>sy€ُ‡K‚Kذ5°|رDشDذDف ً8ً8ف%×)ز)¨,ر7ش7ˆً8ً8ً8ٌ8ô8ً8ً8ً8ً8ً8ً8ًّّّ8ً8ً8ً8à€طˆà Œً2ً2ص+ً2ً2ف×"ز" <ر0ش0°Gذ;ذ;ف# Lذ1ً2ً2ً2ٌ2ô2ً2ً2ً2ً2ً2ً2ًّّّ2ً2ً2ً2ً2ً2ً2ٌ2ô2ً2ً2ً2ً2ً2ً2ً2ًّّّ2ً2ً2ً2ً2ً2sG£A ء AءAء B1ء(%Bآ B1آB آB1آ B آ!B1آ1B5آ8B5cَ*—tt¦«S)z8 List all fake task ids saved in local storage. )عlistrrrrعget_task_idsr.Os€ُص#ر$ش$ذ$rTcَ‍—i}tt ¦«¦«D]£}t d|¦«t|¦«5}t ||¦«|j||<|rCt5t |¦«|urt|=ddd¦«n#1swxYwYddd¦«n#1swxYwYŒ¤|S)zr Save all in-memory task counters on disk. Return the written values: {fake_task_id: next_request_id} zFlushing task id %s on diskN) r-rعkeysr r%r)r&rr#r$)عremoveعwrittenrr(s rعflush_memory_storager3VsM€ً €Gفص0×5ز5ر7ش7ر8ش8ً >ً >ˆفڈٹذ1°<ر@ش@ذ@ف ر -ش -ً >°فک|¨Wر5ش5ذ5ط$+ش$;ˆGگLر!طً >ُ*ً>ً>ف*×.ز.¨|ر<ش<ہذGذGف/°ذ=ً>ً>ً>ٌ>ô>ً>ً>ً>ً>ً>ً>ًّّّ>ً>ً>ً>ً >ً >ً >ٌ >ô >ً >ً >ً >ً >ً >ً >ًّّّ >ً >ً >ً >ًّ€Ns6ء$Cء9%B*آCآ*B.آ.Cآ1B.آ2CأC أC cَ$—tj|¦«sdStj t |¦«} t |dt¬¦«5}t| ¦«¦«cddd¦«S#1swxYwYdS#ttf$rYdSt$rc}|j tjkrt d|¦«n't d||j |j¦«Yd}~dSd}~wwxYw)zف Read the next_request_id saved on disk for the task, without creating an in-memory record. None if there is no (valid, readable) counter file: it never raises, the SIGUSR2 handler calls it before its ack Nعr©عopenerْRefusing to follow symlink: %sz-Unable to read counter file %s: errno %s (%s))rعmatchعosعpathعjoinrعopenع_nofollow_openerrعreadعFileNotFoundErrorع ValueErrorعOSErrorعerrnoعELOOPr عwarningعstrerror)rعreq_id_fileعfعes rعread_counter_filerJjsQ€ُش ر.ش.ًطˆtف”'—,’,ص3°\رBشB€Kً ف گ+کsص+;ذ <ر <ش <ً !ہفگq—v’v‘x”x‘=”=ً !ً !ً !ً !ٌ !ô !ً !ً !ً !ً !ً !ً !ًّّّ !ً !ً !ً !ً !ً !ّه‌zذ*ًًًطˆtˆtفًًًطŒ7•e”kز!ذ!فڈNٹNذ;¸[رIشIذIذIهڈNٹNذJبKذYZشY`ذbcشblرmشmذmطˆtˆtˆtˆtˆtًّّّّّّّsB½Bء!Bء5BآBآBآ Bآ BآDآ# Dآ,AD ؤ DcَH—tj||tjzd¦«S)Ni€)r:r=ع O_NOFOLLOW)r;عflagss rr>r>€s€ف Œ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: عwr6Nr8)rr9rAr:r;r<rr=r>عwriteعstrrrBrCrDr rE©rr(rGrHrIs 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 )r rr5r6Nz8Corrupted counter file for task %s, resetting to defaultr8)r#rr rrr:r;r<rr=r>rr?rr@rAr rErBrCrDrRs rr"r"•sو€ُ ً8ً8طص2ذ2ر2ف0Bح جرHXشHXذjkذ0lر0lش0lص ر-ه)¨,ش7ˆGهœ'ں,ڑ,ص';¸\رJشJˆKً فک+ sص3CذDرDشDً<بف.1°!·&²&±(´(©m¬mگGش+ً<ً<ً<ٌ<ô<ً<ً<ً<ً<ً<ً<ًّّّ<ً<ً<ً<ّّه$ً ً ً طگفً iً iً iف—’ذYذ[gرhشhذhذhذhفً ً ً ط”7‌eœkز)ذ)ف—N’Nذ#Cہ[رQشQذQذQàًRذQذQذQذQًّّّّ ُّّّ*¨,ش7ˆGً)8ً8ً8ٌ8ô8ً8ً8ً8ً8ً8ً8ًّّّ8ً8ً8ً8ً*€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) rCعloggingr:rعcollections.abcrع contextlibrعdataclassesrعxray.internal.constantsrrع getLoggerrr r rعdictrQrrr#r)r+r.rr3rJr>r&r"rrrْr[sًًّ €€€€ط€€€ط € € € طذذذط%ذ%ذ%ذ%ذ%ذ%ط%ذ%ذ%ذ%ذ%ذ%ط!ذ!ذ!ذ!ذ!ذ!àIذIذIذIذIذIذIذIà ˆش ک8ر $ش $€ًً (ً (ً (ً (ً (ٌ (ô (ٌ„ً (ً68ذگTک#ذ1ذ1ش2ذ7ذ7ر7ط%گy”~ر'ش'ذًًً Sً¸)ذDVذX\ذ^bذDbش:cًًًٌ„ًً22ً2ً2ً"%ً%ً%ًً¨¨c°3¨h¬ًًًًً( Cً¨C°$©Jًًًًً,7ً7ً7ً Sًذ3Eًًًًً"ذ+=ًًًًًًr