§ N’j<ãó0—ddlZddlZGd„d¦«ZdS)éNcól—eZdZdZd d„Zdejddfd„Zdejdzfd„Zdejdzfd„Z dS) Ú_FreeEventQueuezâ This tracks all pending frees corresponding to inflight all-gathers. The queueing pattern is iterative enqueues with a single dequeue per iteration once the limit ``_max_num_inflight_all_gathers`` is reached. ÚreturnNcóD—tj¦«|_d|_dS)Né)Ú collectionsÚdequeÚ_queueÚ_max_num_inflight_all_gathers©Úselfs úSC:\Projects\DSCons\.venv\Lib\site-packages\torch\distributed\fsdp\_limiter_utils.pyÚ__init__z_FreeEventQueue.__init__ s €Ý6AÔ6GÑ6IÔ6IˆŒ Ø-.ˆÔ*Ð*Ð*óÚ free_eventcó:—|j |¦«dS)zEnqueues a free event.N)r Úappend)r rs rÚenqueuez_FreeEventQueue.enqueues€à Œ ×Ò˜:Ñ&Ô&Ð&Ð&Ð&rcóh—t|j¦«|jkr| ¦«SdS)z0Dequeues a single event if the limit is reached.N)Úlenr r Ú_dequeuer s rÚdequeue_if_neededz!_FreeEventQueue.dequeue_if_neededs-€å ˆtŒ{Ñ Ô ˜tÔAÒ AÐ AØ—=’=‘?”?Ð "؈trcóJ—|jr|j ¦«}|SdS)z"Dequeues a free event if possible.N)r Úpopleft)r Úevents rrz_FreeEventQueue._dequeues)€à Œ;ð Ø”K×'Ò'Ñ)Ô)ˆE؈L؈tr)rN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚtorchÚEventrrr©rrrrsš€€€€€ððð /ð/ð/ð/ð' %¤+ð'°$ð'ð'ð'ð'ð 5¤;°Ñ#5ððððð ˜%œ+¨Ñ,ððððððrr)rr rr"rrúr#sLðØÐÐÐà € € € ðððððñôðððr