From d7ea641df39e193dec535c3b4ac443be56bbb4be Mon Sep 17 00:00:00 2001 From: JordiManyer Date: Tue, 30 Jul 2024 15:40:56 +1000 Subject: [PATCH] Fixes --- src/CellData.jl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/CellData.jl b/src/CellData.jl index 36f0787..6befc88 100644 --- a/src/CellData.jl +++ b/src/CellData.jl @@ -400,7 +400,7 @@ function Arrays.return_cache(I::DistributedInterpolable{Tx,Ty},x::AbstractVector end function Arrays.evaluate!(cache,I::DistributedInterpolable{Tx,Ty},x::AbstractVector{<:Point}) where {Tx,Ty} - _allgather(x) = getdata(getany(gather(x;destination=:all))) + _allgather(x) = PartitionedArrays.getdata(getany(gather(x;destination=:all))) # Evaluate in local portions of the domain. Only keep points inside the domain. nx = length(x) @@ -425,7 +425,7 @@ function Arrays.evaluate!(cache,I::DistributedInterpolable{Tx,Ty},x::AbstractVec resize!(ids,k-1) resize!(vals,k-1) return ids, vals - end + end |> tuple_of_arrays # Communicate results, so that every (id,value) pair is known by every process if Ty <: VectorValue @@ -435,7 +435,7 @@ function Arrays.evaluate!(cache,I::DistributedInterpolable{Tx,Ty},x::AbstractVec my_vals_d = map(y_p -> map(y_p_i -> y_p_i[d],y_p),my_vals) vals_d[d] = _allgather(my_vals_d) end - vals = map(VectorValue,w_d...) + vals = map(VectorValue,vals_d...) else vals = _allgather(my_vals) end