[arccore,message_passing_mpi] Implémente 'IControlDispatcher::createRequestListRef()' pour 'MpiControlDispatcher'.

Author: grospelliergilles

arccore/src/message_passing_mpi/arccore/message_passing_mpi/MpiControlDispatcher.cc

@@ -15,8 +15,11 @@
 
 #include "arccore/message_passing_mpi/MpiMessagePassingMng.h"
 #include "arccore/message_passing_mpi/internal/MpiAdapter.h"
+#include "arccore/message_passing_mpi/internal/MpiRequestList.h"
+
 #include "arccore/message_passing/Request.h"
-#include "arccore/base/NotImplementedException.h"
+#include "arccore/message_passing/IMessagePassingMng.h"
+#include "arccore/message_passing/Messages.h"
 
 /*---------------------------------------------------------------------------*/
 /*---------------------------------------------------------------------------*/
@@ -27,8 +30,9 @@ namespace Arcane::MessagePassing::Mpi
 /*---------------------------------------------------------------------------*/
 
 MpiControlDispatcher::
-MpiControlDispatcher(MpiAdapter* adapter)
+MpiControlDispatcher(MpiAdapter* adapter, IMessagePassingMng* mpm)
 : m_adapter(adapter)
+, m_message_passing_mng(mpm)
 {
 }
 
@@ -118,6 +122,15 @@ setProfiler(IProfiler* p)
 /*---------------------------------------------------------------------------*/
 /*---------------------------------------------------------------------------*/
 
+Ref<IRequestList> MpiControlDispatcher::
+createRequestListRef()
+{
+  return createRef<MpiRequestList>(m_adapter);
+}
+
+/*---------------------------------------------------------------------------*/
+/*---------------------------------------------------------------------------*/
+
 } // namespace Arccore::MessagePassing::Mpi
 
 /*---------------------------------------------------------------------------*/

arccore/src/message_passing_mpi/arccore/message_passing_mpi/MpiSerializeDispatcher.cc

@@ -583,7 +583,6 @@ Ref<ISerializeMessageList> MpiSerializeDispatcher::
 createSerializeMessageListRef()
 {
   ISerializeMessageList* x = new internal::SerializeMessageList(m_message_passing_mng);
-  //MpiSerializeMessageList(this);
   return makeRef(x);
 }
 

arccore/src/message_passing_mpi/arccore/message_passing_mpi/StandaloneMpiMessagePassingMng.cc

@@ -154,7 +154,7 @@ create(MPI_Comm mpi_comm, bool clean_comm)
   _createAndSetDispatcher<double>(dsp, mpm, adapter);
   _createAndSetDispatcher<long double>(dsp, mpm, adapter);
 
-  dsp->setDispatcher(new MpiControlDispatcher(adapter));
+  dsp->setDispatcher(new MpiControlDispatcher(adapter, mpm));
   dsp->setDispatcher(new MpiSerializeDispatcher(adapter, mpm));
 
   MPI_Datatype uint8_datatype = MpiBuiltIn::datatype(uint8_t{});

arccore/src/message_passing_mpi/arccore/message_passing_mpi/internal/MpiControlDispatcher.h

@@ -16,7 +16,6 @@
 
 #include "arccore/message_passing_mpi/MessagePassingMpiGlobal.h"
 #include "arccore/message_passing/IControlDispatcher.h"
-#include "arccore/base/NotImplementedException.h"
 
 /*---------------------------------------------------------------------------*/
 /*---------------------------------------------------------------------------*/
@@ -32,7 +31,7 @@ class ARCCORE_MESSAGEPASSINGMPI_EXPORT MpiControlDispatcher
 {
  public:
 
-  MpiControlDispatcher(MpiAdapter* adapter);
+  MpiControlDispatcher(MpiAdapter* adapter, IMessagePassingMng* message_passing_mng);
 
  public:
 
@@ -44,10 +43,7 @@ class ARCCORE_MESSAGEPASSINGMPI_EXPORT MpiControlDispatcher
   Request nonBlockingBarrier() override;
   MessageId probe(const PointToPointMessageInfo& message) override;
   MessageSourceInfo legacyProbe(const PointToPointMessageInfo& message) override;
-  Ref<IRequestList> createRequestListRef() override
-  {
-    ARCCORE_THROW(NotImplementedException,"");
-  }
+  Ref<IRequestList> createRequestListRef() override;
   IProfiler* profiler() const override;
   void setProfiler(IProfiler* p) override;
 
@@ -57,7 +53,8 @@ class ARCCORE_MESSAGEPASSINGMPI_EXPORT MpiControlDispatcher
 
  private:
 
-  MpiAdapter* m_adapter;
+  MpiAdapter* m_adapter = nullptr;
+  IMessagePassingMng* m_message_passing_mng;
 };
 
 /*---------------------------------------------------------------------------*/