Changeset 198 for XMLIO_V2/dev/dev_rv/src/xmlio/server.cpp

Timestamp:

05/19/11 19:06:32 (13 years ago)

Author:

hozdoba

Message:

 

File:

• XMLIO_V2/dev/dev_rv/src/xmlio/server.cpp (modified) (4 diffs)

XMLIO_V2/dev/dev_rv/src/xmlio/server.cpp

@@ -26 +26 @@
       while (this->blist.recvRequests())
       {
-         long int managerId = 0, methodId  = 0, nbargs  = 0;
-         long int managerId_= 0, methodId_ = 0, nbargs_ = 0;
+         long int managerId = -1, methodId  = -1, nbargs  = -1;
+         long int managerId_= -1, methodId_ = -1, nbargs_ = -1;
          std::vector<CLinearBuffer> lbuffer;
          this->blist.getRequests(lbuffer);
+                 
          for (StdSize i = 0; i < lbuffer.size(); i++)
-         {
+         {           
             lbuffer[i].getRequestInfos(0, managerId, methodId, nbargs);
             if (((managerId_ != managerId) || (methodId_ != methodId) || (nbargs_ != nbargs)) && (i != 0 ))
             {
-               /*std::cout << managerId_ << "<->" << managerId << std::endl
-                           << methodId_  << "<->" << methodId  << std::endl
-                           << nbargs_    << "<->" << nbargs    << std::endl;*/
+               //std::cout << managerId_ << "<->" << managerId << std::endl
+               //          << methodId_  << "<->" << methodId  << std::endl
+               //          << nbargs_    << "<->" << nbargs    << std::endl;
                ERROR("CServer::run(void)", << "[" << i << "] Les requêtes ne sont pas synchronisées !");
             }
@@ -119 +120 @@
    {
       std::cout << "finalize called " << std::endl;
-   }
-   
+   }   
    
    //--------------------------------------------------------------
              
    void CServer::setContext(const std::vector<CLinearBuffer> & buffer) // manager 1, method 0
-   {
-      std::cout << "setContext called " << std::endl;
+   { 
+      StdString contextId;
+      for (StdSize i = 0; i < buffer.size(); i++)
+      {
+         StdString contextId_ = buffer[i].getString(3);
+         if (contextId.compare(contextId_) != 0 && (i != 0))
+         {
+            ERROR("CServer::setContext(const std::vector<CLinearBuffer> & buffer)", 
+                  << "[ contextId 1 = " << contextId   << ", "
+                  << "[ contextId 2 = " << contextId_  << "] "
+                  << " Changement de contexte désynchronisé !");
+         }
+         else contextId = contextId_;
+         
+      }
+      std::cout << "setContext called " << contextId << std::endl;
    }
    
@@ -133 +147 @@
    void CServer::updateCalendar(const std::vector<CLinearBuffer> & buffer) // manager 1, method 1
    {
-      std::cout << "updateCalendar called " << std::endl;
+      int timestep = -1;
+      for (StdSize i = 0; i < buffer.size(); i++)
+      {
+         int timestep_ = buffer[i].getInt(3);
+         if ((timestep_ != timestep)  && (i != 0))
+         {
+            ERROR("CServer::updateCalendar(const std::vector<CLinearBuffer> & buffer)", 
+                  << "[ timestep 1 = " << timestep   << ", "
+                  << "[ timestep 2 = " << timestep_  << "] "
+                  << " Mise à jour du calendrier désynchronisée !");
+         }
+         else timestep = timestep_;
+         
+      }
+      std::cout << "updateCalendar called " << timestep <<std::endl;
    }
    
@@ -140 +168 @@
    void CServer::writeData(const std::vector<CLinearBuffer> & buffer, int prec)  // manager 2, method 0 - 1
    {
-      std::cout << "writeData called " << std::endl;
+      StdString fieldId;
+      for (StdSize i = 0; i < buffer.size(); i++)
+      {
+         StdString fieldId_ = buffer[i].getString(3);
+         if (fieldId.compare(fieldId_) != 0 && (i != 0))
+         {           
+            ERROR("CServer::writeData(const std::vector<CLinearBuffer> & buffer, int prec)", 
+                  << "[fieldId 1 = " << fieldId   << ", "
+                  << " fieldId 2 = " << fieldId_  << "] "
+                  << " Ecriture des données désynchronisée !");
+         }
+         else fieldId = fieldId_;         
+      }
+      
+      if (prec == 4)
+      {
+         std::deque<ARRAY(float, 1)> dataArray(buffer.size());
+         for (StdSize i = 0; i < buffer.size(); i++)
+            dataArray[i] = buffer[i].getFloatArray(4);
+
+         std::cout << "writeData called (float) " << fieldId << ", " << dataArray[0] << std::endl;
+         return;
+      }      
+      else if (prec == 8)
+      {
+         std::deque<ARRAY(double, 1)> dataArray(buffer.size());
+         for (StdSize i = 0; i < buffer.size(); i++)
+            dataArray[i] = buffer[i].getDoubleArray(4);
+
+         std::cout << "writeData called (double) " << fieldId << ", " << dataArray[0]  << std::endl;
+         return;
+      }      
+      else
+      {
+         ERROR("CServer::writeData(const std::vector<CLinearBuffer> & buffer, int prec)", 
+               << " Précision des données invalide !");
+      }
    }