Distributed.jl -> Multicluster.jl

Author: decarvalhojunior-fh

Project.toml

@@ -1,25 +1,27 @@
-name = "Distributed"
-uuid = "8ba89e20-285c-5b6f-9357-94700520ee1b"
+name = "Multicluster"
+uuid = "236308dc-ae00-46af-a4e9-4f62f68ef0a5"
 version = "1.11.0"
 
 [deps]
+MPIClusterManagers = "e7922434-ae4b-11e9-05c5-9780451d2c66"
 Random = "9a3f8284-a2c9-5f02-9a11-845980a1fd5c"
 Serialization = "9e88b42a-f829-5b0c-bbe9-9e923198166b"
 Sockets = "6462fe0b-24de-5631-8697-dd941f90decc"
 
-[extras]
-Aqua = "4c88cf16-eb10-579e-8560-4a9242c79595"
-LinearAlgebra = "37e2e46d-f89d-539d-b4ee-838fcccc9c8e"
-Test = "8dfed614-e22c-5e08-85e1-65c5234f0b40"
-
-[targets]
-test = ["Aqua", "LinearAlgebra", "Test"]
-
 [compat]
 Aqua = "0.8.10"
 LinearAlgebra = "1"
+MPIClusterManagers = "0.2.4"
 Random = "1"
 Serialization = "1"
 Sockets = "1"
 Test = "1"
 julia = "1"
+
+[extras]
+Aqua = "4c88cf16-eb10-579e-8560-4a9242c79595"
+LinearAlgebra = "37e2e46d-f89d-539d-b4ee-838fcccc9c8e"
+Test = "8dfed614-e22c-5e08-85e1-65c5234f0b40"
+
+[targets]
+test = ["Aqua", "LinearAlgebra", "Test"]

docs/make.jl

@@ -1,16 +1,16 @@
-using Distributed
+using Multicluster
 using Documenter: DocMeta, makedocs, deploydocs
 
-DocMeta.setdocmeta!(Distributed, :DocTestSetup, :(using Distributed); recursive=true)
+DocMeta.setdocmeta!(Multicluster, :DocTestSetup, :(using Multicluster); recursive=true)
 
 makedocs(;
-    modules = [Distributed],
-    sitename = "Distributed",
+    modules = [Multicluster],
+    sitename = "Multicluster",
     pages = Any[
-        "Distributed" => "index.md",
+        "Multicluster" => "index.md",
     ],
     checkdocs = :exports,
     warnonly = [:cross_references],
 )
 
-deploydocs(repo = "github.com/JuliaLang/Distributed.jl.git")
+deploydocs(repo = "github.com/JuliaLang/Multicluster.jl.git")

src/Distributed.jl

@@ -46,7 +46,7 @@ julia> fetch(f)
 function check_args_2(args...)
     na = length(args)
     if na==1
-        role = :(role = :default)
+        role = Expr(:kw, :role, :(:defaut)) #:(role = :default)
         expr = args[1]
     elseif na==2 
         role = args[1]
@@ -107,7 +107,7 @@ julia> fetch(f)
 function check_args_3a(args...)
     na = length(args)
     if na==2
-        role = :(role = :default)
+        role = Expr(:kw, :role, :(:defaut)) #:(role = :default)
         p = args[1]
         expr = args[2]
     elseif na==3 
@@ -247,7 +247,7 @@ function check_args_3b(args...)
 
     na = length(args)
     if na==1
-        rolearg = :(role = :default)
+        rolearg = Expr(:kw, :role, :(:defaut)) #:(role = :default)
         reducer = nothing
         loop = args[1]
     elseif na==2
@@ -256,7 +256,7 @@ function check_args_3b(args...)
             reducer = nothing
             loop = args[2]
         else
-            rolearg = :(role = :default)
+            rolearg = Expr(:kw, :role, :(:defaut)) #:(role = :default)
             reducer = args[1]
             loop = args[2]
         end
@@ -277,7 +277,7 @@ macro everywhere(args...)
 
     if isnothing(procs)
         procs = GlobalRef(@__MODULE__, :procs)
-        return esc(:($(Distributed).@everywhere $rolearg $procs(;$rolearg) $ex))
+        return esc(:($(Multicluster).@everywhere $rolearg $procs(;$rolearg) $ex))
     else
         imps = extract_imports(ex)
         return quote

src/macros.jl

@@ -494,7 +494,7 @@ function launch(manager::LocalManager, params::Dict, launched::Array, c::Conditi
 
     # TODO: Maybe this belongs in base/initdefs.jl as a package_environment() function
     #       together with load_path() etc. Might be useful to have when spawning julia
-    #       processes outside of Distributed.jl too.
+    #       processes outside of Multicluster.jl too.
     # JULIA_(LOAD|DEPOT)_PATH are used to populate (LOAD|DEPOT)_PATH on startup,
     # but since (LOAD|DEPOT)_PATH might have changed they are re-serialized here.
     # Users can opt-out of this by passing `env = ...` to addprocs(...).

src/managers.jl

@@ -240,7 +240,7 @@ Return `head`: the first `n` elements of `c`;
 and `tail`: an iterator over the remaining elements.
 
 ```jldoctest
-julia> b, c = Distributed.head_and_tail(1:10, 3)
+julia> b, c = Multicluster.head_and_tail(1:10, 3)
 ([1, 2, 3], Base.Iterators.Rest{UnitRange{Int64}, Int64}(1:10, 3))
 
 julia> collect(c)

src/pmap.jl

@@ -1,12 +1,12 @@
-precompile(Tuple{typeof(Distributed.remotecall),Function,Int,Module,Vararg{Any, 100}})
-precompile(Tuple{typeof(Distributed.procs)})
-precompile(Tuple{typeof(Distributed.finalize_ref), Distributed.Future})
+precompile(Tuple{typeof(Multicluster.remotecall),Function,Int,Module,Vararg{Any, 100}})
+precompile(Tuple{typeof(Multicluster.procs)})
+precompile(Tuple{typeof(Multicluster.finalize_ref), Multicluster.Future})
 # This is disabled because it doesn't give much benefit
-# and the code in Distributed is poorly typed causing many invalidations
-# TODO: Maybe reenable now that Distributed is not in sysimage.
+# and the code in Multicluster is poorly typed causing many invalidations
+# TODO: Maybe reenable now that Multicluster is not in sysimage.
 #=
     precompile_script *= """
-    using Distributed
+    using Multicluster
     addprocs(2)
     pmap(x->iseven(x) ? 1 : 0, 1:4)
     @distributed (+) for i = 1:100 Int(rand(Bool)) end

src/precompile.jl

@@ -1,8 +1,8 @@
 using Aqua
-using Distributed
+using Multicluster
 Aqua.test_all(
-    Distributed,
+    Multicluster,
     # This should be excluded, but it's not clear how to do that on Aqua's API
     # given it's not-defined. (The Julia Base ambiguity test does it something like this)
-    # ambiguities=(exclude=[GlobalRef(Distributed, :cluster_manager)])
+    # ambiguities=(exclude=[GlobalRef(Multicluster, :cluster_manager)])
 )