Add deepcopy and tests.

`deepcopy(::DArray)` calls `similar` and deepcopies the localparts.
Tests to ensure that `copy` makes a shadllow copy and `deepcopy`
makes a deep copy.

Author: traktofon

src/darray.jl

@@ -564,6 +564,16 @@ Base.copyto!(dest::SubOrDArray, src::SubOrDArray) = begin
 end
 Base.copy!(dest::SubOrDArray, src::SubOrDArray) = copyto!(dest, src)
 
+function Base.deepcopy(src::DArray)
+    dest = similar(src)
+    asyncmap(procs(src)) do p
+        remotecall_fetch(p) do
+            dest[:L] = deepcopy(src[:L])
+        end
+    end
+    return dest
+end
+
 # local copies are obtained by convert(Array, ) or assigning from
 # a SubDArray to a local Array.
 

test/darray.jl

@@ -61,21 +61,51 @@ end
 
 check_leaks()
 
-@testset "test DArray equality" begin
+@testset "test DArray equality/copy/deepcopy" begin
     D = drand((200,200), [MYID, OTHERIDS])
-    DC = copy(D)
 
     @testset "test isequal(::DArray, ::DArray)" begin
+        DC = copy(D)
         @test D == DC
+        close(DC)
     end
 
-    @testset "test copy(::DArray) does a copy of each localpart" begin
+    @testset "test [deep]copy(::DArray) does a copy of each localpart" begin
+        DC = copy(D)
         @spawnat OTHERIDS localpart(DC)[1] = 0
         @test fetch(@spawnat OTHERIDS localpart(D)[1] != 0)
+        DD = deepcopy(D)
+        @spawnat OTHERIDS localpart(DD)[1] = 0
+        @test fetch(@spawnat OTHERIDS localpart(D)[1] != 0)
+        close(DC)
+        close(DD)
+    end
+
+    @testset "test copy(::DArray) is shallow" begin
+        DA = @DArray [rand(100) for i=1:10]
+        DC = copy(DA)
+        id = procs(DC)[1]
+        @test DA == DC
+        fetch(@spawnat id localpart(DC)[1] .= -1.0)
+        @test DA == DC
+        @test fetch(@spawnat id all(localpart(DA)[1] .== -1.0))
+        close(DA)
+        close(DC)
+    end
+
+    @testset "test deepcopy(::DArray) is not shallow" begin
+        DA = @DArray [rand(100) for i=1:10]
+        DC = deepcopy(DA)
+        id = procs(DC)[1]
+        @test DA == DC
+        fetch(@spawnat id localpart(DC)[1] .= -1.0)
+        @test DA != DC
+        @test fetch(@spawnat id all(localpart(DA)[1] .>= 0.0))
+        close(DA)
+        close(DC)
     end
 
     close(D)
-    close(DC)
 end
 
 check_leaks()