@@ -24,7 +24,7 @@ export TransportMode, MPI_ON_WORKERS, TCP_TRANSPORT_ALL, MPI_TRANSPORT_ALL
2424
2525@enum TransportMode MPI_ON_WORKERS MPI_TRANSPORT_ALL TCP_TRANSPORT_ALL
2626
27- type MPIManager <: ClusterManager
27+ mutable struct MPIManager <: ClusterManager
2828 np:: Int # number of worker processes (excluding the manager process)
2929 mpi2j:: Dict{Int,Int} # map MPI ranks to Julia processes
3030 j2mpi:: Dict{Int,Int} # map Julia to MPI ranks
@@ -139,7 +139,7 @@ function launch(mgr::MPIManager, params::Dict,
139139 else
140140 cookie = ` nothing`
141141 end
142- setup_cmds = ` using MPI;MPI.setup_worker( $(getipaddr (). host) ,$(mgr. port) ,$cookie ) `
142+ setup_cmds = ` using MPI\ ; MPI.setup_worker'(' $(getipaddr (). host) ,$(mgr. port) ,$cookie ')' `
143143 mpi_cmd = ` $(mgr. mpirun_cmd) $(params[:exename ]) -e $(Base. shell_escape (setup_cmds)) `
144144 open (detach (mpi_cmd))
145145 mgr. launched = true
@@ -475,7 +475,7 @@ function mpi_do(mgr::MPIManager, expr)
475475 ! mgr. initialized && wait (mgr. cond_initialized)
476476 jpids = keys (mgr. j2mpi)
477477 refs = Array {Any} (length (jpids))
478- for (i,p) in enumerate (filter (x -> x != myid (), jpids))
478+ for (i,p) in enumerate (Iterators . filter (x -> x != myid (), jpids))
479479 refs[i] = remotecall (expr, p)
480480 end
481481 # Execution on local process should be last, since it can block the main
0 commit comments