source: XMLIO_V2/dev/common/src/xmlio/client.cpp @ 286

Last change on this file since 286 was 286, checked in by ymipsl, 13 years ago

reprise en main de la version de H. Ozdoba. Correction de différentes erreurs de conception et bug.
Version NEMO operationnel en client/server, interoperabilita avec OASIS, reconstition de fichiers via netcdf4/HDF5

YM
File size: 4.6 KB
Line 
1#include "client.hpp"
2
3#include "linear_buffer_impl.hpp"
4
5namespace xmlioserver {
6namespace comm {
7
8   /// ////////////////////// Définitions ////////////////////// ///
9   
10   CClient::CClient(MPI_Comm comm_client_server)
11      : bpair(comm_client_server)
12   { 
13      this->initialize();
14   } 
15       
16   CClient::~CClient(void)
17   { 
18      //this->finalize();
19   } 
20   
21   ///--------------------------------------------------------------
22
23   boost::shared_ptr<CClient> CClient::Client;
24
25   ///--------------------------------------------------------------
26
27   boost::shared_ptr<CClient> CClient::CreateClient(MPI_Comm comm_client_server)
28   {
29      if (CClient::Client.get() == NULL)
30         CClient::Client = boost::shared_ptr<CClient>(new CClient(comm_client_server));
31      return (CClient::GetClient());
32   }
33
34   ///--------------------------------------------------------------
35
36   boost::shared_ptr<CClient> CClient::GetClient(void)
37   {
38      return (CClient::Client);
39   }
40
41   ///--------------------------------------------------------------
42   
43   const CBufferPair & CClient::getBufferPair(void) const 
44   {
45      return (this->bpair);
46   }   
47   
48   //---------------------------------------------------------------
49
50   void CClient::initialize(void)
51   {
52      this->bpair.prepareRequest(0, 0, CLinearBuffer::NULL_ARG,
53                                       CLinearBuffer::NULL_ARG,
54                                       CLinearBuffer::NULL_ARG,
55                                       CLinearBuffer::NULL_ARG);
56      // Pas d'argument à ajouter.
57   }
58   
59   //---------------------------------------------------------------
60   
61   void CClient::finalize(void)
62   {
63      this->bpair.prepareRequest(0, 1, CLinearBuffer::NULL_ARG,
64                                       CLinearBuffer::NULL_ARG,
65                                       CLinearBuffer::NULL_ARG,
66                                       CLinearBuffer::NULL_ARG);
67      // Pas d'argument à ajouter.
68      this->bpair.sendCurrentBuffer();
69      comm::CMPIManager::Barrier(CMPIManager::GetCommClientServer());
70   }
71   
72   //---------------------------------------------------------------
73   
74   void CClient::setContext(const StdString & idContext)
75   {
76      this->bpair.prepareRequest(1, 0, &idContext,
77                                       CLinearBuffer::NULL_ARG,
78                                       CLinearBuffer::NULL_ARG,
79                                       CLinearBuffer::NULL_ARG);
80      this->bpair.getCurrentBuffer().appendString(idContext);
81   }
82   
83   //---------------------------------------------------------------
84   
85   void CClient::updateCalendar(long int timestep)
86   {
87       this->bpair.prepareRequest(1, 1, &timestep,
88                                       CLinearBuffer::NULL_ARG,
89                                       CLinearBuffer::NULL_ARG,
90                                       CLinearBuffer::NULL_ARG);
91      this->bpair.getCurrentBuffer().appendInt(timestep);
92   }
93
94   //---------------------------------------------------------------
95
96   void CClient::setTimestep(const date::CDuration & duration)
97   {
98      StdString durationstr = duration.toString();
99      this->bpair.prepareRequest(1, 2, &durationstr,
100                                       CLinearBuffer::NULL_ARG,
101                                       CLinearBuffer::NULL_ARG,
102                                       CLinearBuffer::NULL_ARG);
103      this->bpair.getCurrentBuffer().appendString(durationstr);
104   }
105   
106   //---------------------------------------------------------------
107   
108   void CClient::sendData
109      (const StdString & fieldId, const StdString & fileId, const ARRAY(float, 1) dataArray)
110   {
111      this->bpair.prepareRequest(2, 0, &fieldId, &fileId, &dataArray,
112                                       CLinearBuffer::NULL_ARG);
113      this->bpair.getCurrentBuffer().appendString(fieldId);
114      this->bpair.getCurrentBuffer().appendString(fileId);
115      this->bpair.getCurrentBuffer().appendFloatArray(dataArray);
116   }
117   
118   //---------------------------------------------------------------
119   
120   void CClient::sendData
121      (const StdString & fieldId, const StdString & fileId, const ARRAY(double, 1) dataArray)
122   {
123      this->bpair.prepareRequest(2, 1, &fieldId, &fileId, &dataArray,
124                                       CLinearBuffer::NULL_ARG);
125      this->bpair.getCurrentBuffer().appendString(fieldId);
126      this->bpair.getCurrentBuffer().appendString(fileId);
127      this->bpair.getCurrentBuffer().appendDoubleArray(dataArray);
128   }
129
130   ///--------------------------------------------------------------
131
132} // namespace comm
133} // namespace xmlioserver
Note: See TracBrowser for help on using the repository browser.