From 7ccd29b03872c388823d5113a422617c48ef86f4 Mon Sep 17 00:00:00 2001
From: Berenger Bramas <Berenger.Bramas@inria.fr>
Date: Fri, 28 Mar 2025 14:06:45 +0100
Subject: [PATCH] Add arbiter in starpu
---
Benchmark/particles_starpu/particles-simu-starpu.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/Benchmark/particles_starpu/particles-simu-starpu.cpp b/Benchmark/particles_starpu/particles-simu-starpu.cpp
index d4b7c47..51a1837 100644
--- a/Benchmark/particles_starpu/particles-simu-starpu.cpp
+++ b/Benchmark/particles_starpu/particles-simu-starpu.cpp
@@ -552,11 +552,14 @@ auto BenchCore( const int NbLoops, const int MinPartsPerGroup, const int MaxPart
for(int idxLoop = 0 ; idxLoop < NbLoops ; ++idxLoop){
starpu_init(NULL);
+ starpu_arbiter_t arbiter = starpu_arbiter_create();
+
std::vector<starpu_data_handle_t> handles;
for(auto& group : particleGroups){
starpu_data_handle_t handle;
starpu_vector_data_register(&handle, 0, reinterpret_cast<uintptr_t>(group.getRawPtr()),
ParticlesGroup::NB_VALUE_TYPES*group.getNbParticles(), sizeof(double));
+ starpu_data_assign_arbiter(handle, arbiter);
handles.push_back(handle);
}
@@ -587,6 +590,7 @@ auto BenchCore( const int NbLoops, const int MinPartsPerGroup, const int MaxPart
starpu_data_unregister(handle);
}
+ starpu_arbiter_destroy(arbiter);
starpu_shutdown();
minMaxAvg[0] = std::min(minMaxAvg[0], timer.getElapsed());
--
GitLab