uki ZddlmZddlmZddlZddlmZGddejZy)) annotations)clustersN find_specceZdZUdZded<dZded<ed dZeddZedd Z edd Z edd Z y ) Mpi4pyClustermpi4pystrnameTboolopt_in_only_methodctdduS)Nr r)clss [/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/jax/_src/clusters/mpi4py_cluster.pyis_env_presentzMpi4pyCluster.is_env_presents X d **cddlm}|j}|jdk(r;t j }|r|}nt t|dzdz}|d|}nd}|j|d}|S)NrMPIii:None)root) r r COMM_WORLDGet_ranksocket gethostnamer hashbcast)r timeout_secsoverride_coordinator_portrrhostnameport_ids rget_coordinator_addressz%Mpi4pyCluster.get_coordinator_address#sJ!%%' $/G$x.504EFGGZq * q1H OrcTddlm}t|jj SNrr)r rintrGet_sizerrs rget_process_countzMpi4pyCluster.get_process_countH s~~&&( ))rcTddlm}t|jj Sr%)r rr&rrr(s rget_process_idzMpi4pyCluster.get_process_idMr*rcddlm}|j}|j|j}t |j Sr%)r rr Split_typeCOMM_TYPE_SHAREDr&r)rrrnew_comms rget_local_process_idz"Mpi4pyCluster.get_local_process_idRs> J$$S%9%9:H x  " ##rN)returnr )r int | Noner z str | Noner2r )r2r&)r2r3) __name__ __module__ __qualname__r __annotations__r classmethodrr#r)r,r1rrrrs|$!d!++ !!H**** $ $rr) __future__rjax._srcrrimportlib.utilr ClusterEnvrr9rrr>s'# $I$H''I$r