Changeset 2556

Timestamp:

09/04/23 12:19:46 (8 months ago)

Author:

ymipsl

Message:

First version on the point to point transport protocol, activated by the variable : transport_protocol="p2p"

YM

Location:

XIOS3/trunk/src/transport

Files:

• context_client.cpp (modified) (3 diffs)
• context_client.hpp (modified) (2 diffs)
• context_server.cpp (modified) (3 diffs)
• context_server.hpp (modified) (2 diffs)
• p2p_client_buffer.cpp (added)
• p2p_client_buffer.hpp (added)
• p2p_context_client.cpp (added)
• p2p_context_client.hpp (added)
• p2p_context_server.cpp (added)
• p2p_context_server.hpp (added)
• p2p_cs_buffer_base.hpp (added)
• p2p_server_base.hpp (added)
• p2p_server_buffer.cpp (added)
• p2p_server_buffer.hpp (added)

XIOS3/trunk/src/transport/context_client.cpp

@@ -17 +17 @@
 #include <chrono>
 #include "one_sided_context_client.hpp"
+#include "p2p_context_client.hpp"
 #include "legacy_context_client.hpp"
 #include "online_context_client.hpp"
@@ -59 +60 @@
       string defaultProtocol = CXios::getin<string>("transport_protocol", "default") ;
       if (defaultProtocol=="one_sided") return getNew<CContextClient::oneSided>(parent, intraComm, interComm) ;
+      else if  (defaultProtocol=="p2p") return getNew<CContextClient::p2p>(parent, intraComm, interComm) ;
       else if  (defaultProtocol=="legacy") return getNew<CContextClient::legacy>(parent, intraComm, interComm) ;
       else if  (defaultProtocol=="online") return getNew<CContextClient::online>(parent, intraComm, interComm) ;
@@ -70 +72 @@
     { 
       return new COneSidedContextClient(parent, intraComm, interComm, parentServer); 
+    }
+
+    template<>
+    CContextClient* CContextClient::getNew<CContextClient::p2p>(CContext* parent, MPI_Comm intraComm, MPI_Comm interComm, CContext* parentServer)
+    { 
+      return new CP2pContextClient(parent, intraComm, interComm, parentServer); 
     }
 

XIOS3/trunk/src/transport/context_client.hpp

@@ -28 +28 @@
   {
     public:
-      enum ETransport { generic, legacy, oneSided, online}  ;
+      enum ETransport { generic, legacy, oneSided, p2p, online}  ;
       
       template<ETransport transport=generic> 
@@ -102 +102 @@
 
   template<>
+  CContextClient* CContextClient::getNew<CContextClient::p2p>(CContext* parent, MPI_Comm intraComm, MPI_Comm interComm, CContext* parentServer) ;
+
+  template<>
   CContextClient* CContextClient::getNew<CContextClient::legacy>(CContext* parent, MPI_Comm intraComm, MPI_Comm interComm, CContext* parentServer) ;
 

XIOS3/trunk/src/transport/context_server.cpp

@@ -22 +22 @@
 #include "timeline_events.hpp"
 #include "one_sided_context_server.hpp"
+#include "p2p_context_server.hpp"
 #include "legacy_context_server.hpp"
 
@@ -67 +68 @@
     string defaultProtocol = CXios::getin<string>("transport_protocol", "default") ;
     if (defaultProtocol=="one_sided") return new COneSidedContextServer(parent, intraComm, interComm) ;
+    else if  (defaultProtocol=="p2p") return new CP2pContextServer(parent, intraComm, interComm) ;
     else if  (defaultProtocol=="legacy") return new CLegacyContextServer(parent, intraComm, interComm) ;
     else if  (defaultProtocol=="default") return new CLegacyContextServer(parent, intraComm, interComm) ;
@@ -80 +82 @@
 
   template<>
+  CContextServer* CContextServer::getNew<CContextServer::p2p>(CContext* parent,MPI_Comm intraComm,MPI_Comm interComm) 
+  { 
+    return new CP2pContextServer(parent, intraComm, interComm) ; 
+  }
+
+  template<>
   CContextServer* CContextServer::getNew<CContextServer::legacy>(CContext* parent,MPI_Comm intraComm,MPI_Comm interComm) 
   { 

XIOS3/trunk/src/transport/context_server.hpp

@@ -16 +16 @@
     public:
     
-    enum ETransport { generic, legacy, oneSided}  ;
+    enum ETransport { generic, legacy, p2p, oneSided}  ;
       
     template<ETransport transport=generic> 
@@ -55 +55 @@
 
   template<>
+  CContextServer* CContextServer::getNew<CContextServer::p2p>(CContext* parent,MPI_Comm intraComm,MPI_Comm interComm) ;
+
+  template<>
   CContextServer* CContextServer::getNew<CContextServer::legacy>(CContext* parent,MPI_Comm intraComm,MPI_Comm interComm) ;