Merge pull request #72 from JuliaParallel/amitm/expt

Fix distribute function
JuliaParallel · Jul 7, 2016 · 1a31742 · 1a31742
2 parents ec9ab98 + 28707f5
commit 1a31742
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/DistributedArrays.jl b/src/DistributedArrays.jl
@@ -11,6 +11,7 @@ end
 
 if VERSION < v"0.5.0-"
  typealias Future RemoteRef
+ typealias RemoteChannel RemoteRef
 end
 
 importall Base
@@ -491,7 +492,7 @@ function distribute(A::AbstractArray;
  dist = defaultdist(size(A), procs))
 
  owner = myid()
- rr = Future()
+ rr = RemoteChannel()
  put!(rr, A)
  d = DArray(size(A), procs, dist) do I
  remotecall_fetch(() -> fetch(rr)[I...], owner)