Changeset 267 for XMLIO_V2/dev/dev_rv/src4/xmlio

Timestamp:

09/07/11 14:25:56 (13 years ago)

Author:

hozdoba

Message:

 

Location:

XMLIO_V2/dev/dev_rv/src4/xmlio/mpi

Files:

• mpi_interface.cpp (modified) (1 diff)
• mpi_interface.hpp (modified) (1 diff)

XMLIO_V2/dev/dev_rv/src4/xmlio/mpi/mpi_interface.cpp

@@ -253 +253 @@
    // ------------------------- Communication 'complexe' -----------------------
          
-   //void SendLinearBuffer(MPIComm comm, int dest_rank, CLinearBuffer & buff, MPIRequest & request);
-   //void ReceiveLinearBuffer(MPIComm comm, int src_rank, CLinearBuffer & buff);
-   //boost::shared_ptr<CLinearBuffer> ReceiveLinearBuffer(MPIComm comm, int src_rank);
-   //void ReceiveCircularBuffer(MPIComm comm, int src_rank, CCircularBuffer & buff);
+   void CMPIManager::SendLinearBuffer(MPI_Comm _comm, int _dest_rank, CLinearBuffer & _lbuffer, MPI_Request & _request)
+   {
+      CMPIManager::Send(_comm, _dest_rank, _lbuffer, _lbuffer.getUsedSize(), _request);
+      buff.clear();
+   }
+   
+   void CMPIManager::ReceiveLinearBuffer(MPI_Comm _comm, int _src_rank, CLinearBuffer & _lbuffer)
+   {
+      CMPIManager::Receive(_comm, _src_rank, _lbuffer);
+      _lbuffer.computeBufferData();
+   }
+   
+   boost::shared_ptr<CLinearBuffer> CMPIManager::ReceiveLinearBuffer(MPI_Comm _comm, int _src_rank)
+   {
+      boost::shared_ptr<CLinearBuffer> buff_ptr
+         (new CLinearBuffer(CMPIManager::GetReceivedDataSize(_comm, _src_rank)));
+      CMPIManager::ReceiveLinearBuffer(_comm, _src_rank, *buff_ptr);
+      return (buff_ptr);
+   }
+   
+   void CMPIManager::ReceiveCircularBuffer(MPI_Comm _comm, int _src_rank, CCircularBuffer & _cbuffer)
+   {
+      std::size_t data_size  = CMPIManager::GetReceivedDataSize(_comm, _src_rank);
+      std::size_t data_begin = buff.prepareNextDataPosition(data_size);
+      CMPIManager::Receive(comm, src_rank, buff.getData(data_begin));
+      _cbuffer.updateNbRequests(data_begin, data_begin + data_size);
+   }
 
    // ---------------------- Mémoire (non fonctionnel ....) --------------------

XMLIO_V2/dev/dev_rv/src4/xmlio/mpi/mpi_interface.hpp

@@ -100 +100 @@
          public : // Communication 'complexe'
          
-            // static void SendLinearBuffer(MPIComm comm, int dest_rank, CLinearBuffer & buff, MPIRequest & request);
-            // static void ReceiveLinearBuffer(MPIComm comm, int src_rank, CLinearBuffer & buff);
-            // static boost::shared_ptr<CLinearBuffer> ReceiveLinearBuffer(MPIComm comm, int src_rank);
-            // static void ReceiveCircularBuffer(MPIComm comm, int src_rank, CCircularBuffer & buff);
+            static void SendLinearBuffer(MPI_Comm _comm, int _dest_rank, CLinearBuffer & _lbuffer, MPI_Request & _request);
+            static void ReceiveLinearBuffer(MPI_Comm _comm, int _src_rank, CLinearBuffer & _lbuffer);
+            static boost::shared_ptr<CLinearBuffer> ReceiveLinearBuffer(MPI_Comm _comm, int _src_rank);
+            static void ReceiveCircularBuffer(MPI_Comm _comm, int _src_rank, CCircularBuffer & _cbuffer);
 
          public : // Mémoire (non fonctionnel ....)