
    hB                     <    S SK r S SKJr  S rS rS rS rS rS r	g)    Nc                  N   S[         R                  ;   ak  [        [         R                  S   5        [        [         R                  S   5      n [        [         R                  S   5      n[        R                  " SSXS9  g S[         R                  ;   a  [        [         R                  R                  SS5      5        [        [         R                  R                  S	S5      5      n [        [         R                  R                  S
S5      5      n[        R                  " SSXS9  g g )N
LOCAL_RANKRANK
WORLD_SIZEncclztcp://127.0.0.1:7645)init_method
world_sizerankOMPI_COMM_WORLD_LOCAL_RANK0OMPI_COMM_WORLD_RANKOMPI_COMM_WORLD_SIZE1ztcp://127.0.0.1:7647)osenvironintdistinit_process_groupget)r
   r	   s     m/var/www/fran/franai/venv/lib/python3.13/site-packages/onnxruntime/transformers/models/llama/dist_settings.py	init_distr      s    rzz!BJJ|$%2::f%&L12
4JWam	%	3BJJNN7=>2::>>"8#>?(>DE
4JWam 	    c                  L     SSK Jn   U R                  nU$ ! [         a     g f = f)Nr   )MPI)mpi4pyr   
COMM_WORLDImportError)r   comms     r   	_get_commr      s*    ~~ s    
##c                  @    [        5       n U b  U R                  5       $ S$ Nr   )r   Get_rankr   s    r   get_rankr$   '       ;D".4==?5A5r   c                  @    [        5       n U b  U R                  5       $ S$ )N   )r   Get_sizer#   s    r   get_sizer)   ,   r%   r   c                  @    [        5       n U b  U R                  5         g g )N)r   Barrierr#   s    r   barrierr,   1   s    ;D r   c                  2    [        5       S:X  a	  [        U 6   g g r!   )r$   print)argss    r   	print_outr0   7   s    zQt r   )
r   torch.distributeddistributedr   r   r   r$   r)   r,   r0    r   r   <module>r4      s+    
  $6
6
r   