[arcane,accelerator] Ajoute méthode 'RunQueueEvent::hasPendingWork()' pour savoir si les RunQueue associées à un évènement ont du travail.

Cette méthode encapsule 'cudaQueryEvent()' ou 'hipQueryEvent()'.

Author: grospelliergilles

arcane/src/arcane/accelerator/core/RunQueueEvent.cc

@@ -142,6 +142,17 @@ wait()
 /*---------------------------------------------------------------------------*/
 /*---------------------------------------------------------------------------*/
 
+bool RunQueueEvent::
+hasPendingWork() const
+{
+  if (m_p)
+    return m_p->m_impl->hasPendingWork();
+  return false;
+}
+
+/*---------------------------------------------------------------------------*/
+/*---------------------------------------------------------------------------*/
+
 impl::IRunQueueEventImpl* RunQueueEvent::
 _internalEventImpl() const
 {

arcane/src/arcane/accelerator/core/RunQueueEvent.h

@@ -74,6 +74,14 @@ class ARCANE_ACCELERATOR_CORE_EXPORT RunQueueEvent
   //! Bloque tant que les files associées à cet évènement n'ont pas fini leur travail.
   void wait();
 
+  /*!
+   * \brief Indique si les RunQueue associées à cet évènement ont fini leur travail.
+   *
+   * Retourne \a false si les RunQueue enregistrées via RunQueue::recordEvent() ont
+   * fini leur travail. Retourn \a true sinon.
+   */
+  bool hasPendingWork() const;
+
  private:
 
   impl::IRunQueueEventImpl* _internalEventImpl() const;

arcane/src/arcane/accelerator/core/RunQueueRuntime.cc

@@ -1,11 +1,11 @@
 // -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
 //-----------------------------------------------------------------------------
-// Copyright 2000-2024 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
+// Copyright 2000-2025 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
 // See the top-level COPYRIGHT file for details.
 // SPDX-License-Identifier: Apache-2.0
 //-----------------------------------------------------------------------------
 /*---------------------------------------------------------------------------*/
-/* RunQueueRuntime.cc                                          (C) 2000-2024 */
+/* RunQueueRuntime.cc                                          (C) 2000-2025 */
 /*                                                                           */
 /* Implémentation d'un RunQueue pour une cible donnée.                       */
 /*---------------------------------------------------------------------------*/
@@ -83,6 +83,7 @@ class ARCANE_ACCELERATOR_CORE_EXPORT HostRunQueueEvent
   }
   void wait() final {}
   void waitForEvent(IRunQueueStream*) final {}
+  bool hasPendingWork() final { return false; }
   Int64 elapsedTime(IRunQueueEventImpl* start_event) final
   {
     ARCANE_CHECK_POINTER(start_event);

arcane/src/arcane/accelerator/core/internal/IRunQueueEventImpl.h

@@ -1,11 +1,11 @@
 // -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
 //-----------------------------------------------------------------------------
-// Copyright 2000-2024 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
+// Copyright 2000-2025 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
 // See the top-level COPYRIGHT file for details.
 // SPDX-License-Identifier: Apache-2.0
 //-----------------------------------------------------------------------------
 /*---------------------------------------------------------------------------*/
-/* IRunQueueEventImpl.h                                        (C) 2000-2024 */
+/* IRunQueueEventImpl.h                                        (C) 2000-2025 */
 /*                                                                           */
 /* Interface de l'implémentation d'un évènement.                             */
 /*---------------------------------------------------------------------------*/
@@ -42,6 +42,8 @@ class ARCANE_ACCELERATOR_CORE_EXPORT IRunQueueEventImpl
 
   //! Temps écoulé (en nanoseconde) entre l'évènement \a from_event et cet évènement.
   virtual Int64 elapsedTime(IRunQueueEventImpl* from_event) = 0;
+
+  virtual bool hasPendingWork() =0;
 };
 
 /*---------------------------------------------------------------------------*/

arcane/src/arcane/accelerator/cuda/runtime/CudaAcceleratorRuntime.cc

@@ -232,6 +232,15 @@ class CudaRunQueueEvent
     return nano_time;
   }
 
+  bool hasPendingWork() final
+  {
+    cudaError_t v = cudaEventQuery(m_cuda_event);
+    if (v == cudaErrorNotReady)
+      return true;
+    ARCANE_CHECK_CUDA(v);
+    return false;
+  }
+
  private:
 
   cudaEvent_t m_cuda_event;

arcane/src/arcane/accelerator/hip/runtime/HipAcceleratorRuntime.cc

@@ -1,11 +1,11 @@
 // -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
 //-----------------------------------------------------------------------------
-// Copyright 2000-2024 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
+// Copyright 2000-2025 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
 // See the top-level COPYRIGHT file for details.
 // SPDX-License-Identifier: Apache-2.0
 //-----------------------------------------------------------------------------
 /*---------------------------------------------------------------------------*/
-/* HipAcceleratorRuntime.cc                                    (C) 2000-2024 */
+/* HipAcceleratorRuntime.cc                                    (C) 2000-2025 */
 /*                                                                           */
 /* Runtime pour 'HIP'.                                                       */
 /*---------------------------------------------------------------------------*/
@@ -187,6 +187,15 @@ class HipRunQueueEvent
     return nano_time;
   }
 
+  bool hasPendingWork() final
+  {
+    hipError_t v = hipEventQuery(m_hip_event);
+    if (v == hipErrorNotReady)
+      return true;
+    ARCANE_CHECK_HIP(v);
+    return false;
+  }
+
  private:
 
   hipEvent_t m_hip_event;

arcane/src/arcane/accelerator/sycl/runtime/SyclAcceleratorRuntime.cc

@@ -1,11 +1,11 @@
 // -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
 //-----------------------------------------------------------------------------
-// Copyright 2000-2024 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
+// Copyright 2000-2025 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
 // See the top-level COPYRIGHT file for details.
 // SPDX-License-Identifier: Apache-2.0
 //-----------------------------------------------------------------------------
 /*---------------------------------------------------------------------------*/
-/* SyclAcceleratorRuntime.cc                                   (C) 2000-2024 */
+/* SyclAcceleratorRuntime.cc                                   (C) 2000-2025 */
 /*                                                                           */
 /* Runtime pour 'SYCL'.                                                      */
 /*---------------------------------------------------------------------------*/
@@ -16,6 +16,7 @@
 
 #include "arcane/utils/PlatformUtils.h"
 #include "arcane/utils/NotSupportedException.h"
+#include "arcane/utils/NotImplementedException.h"
 #include "arcane/utils/FatalErrorException.h"
 #include "arcane/utils/IMemoryRessourceMng.h"
 #include "arcane/utils/internal/IMemoryRessourceMngInternal.h"
@@ -216,6 +217,11 @@ class SyclRunQueueEvent
     return (end - start);
   }
 
+  bool hasPendingWork() final
+  {
+    ARCANE_THROW(NotImplementedException,"hasPendingWork()");
+  }
+
  private:
 
   sycl::event m_sycl_event;