§ &Vji>ãó<—ddlZddlmZddlZGd„d¦«ZdS)éN)ÚOptionalcóx—eZdZdZd d„Zdejddfd„Zdeejfd„Z deejfd„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 ú_/root/voice-cloning/.venv/lib/python3.11/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)rrs 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ÚEventrrrr©rrrrsš€€€€€ððð /ð/ð/ð/ð' %¤+ð'°$ð'ð'ð'ð'ð 8¨E¬KÔ#8ððððð ˜( 5¤;Ô/ððððððrr)r Útypingrr!rr#rrúr%s^ðØÐÐÐØÐÐÐÐÐà € € € ðððððñôðððr