Changeset 489 for XIOS/trunk/src/node/variable.cpp

Timestamp:

09/22/14 14:17:33 (10 years ago)

Author:

mhnguyen

Message:

Ticket 50: Implementing the getting/setting methods for Fortran interface

+) Add some C and Fortran functions to set and get data to/from CVariable with an id
+) Add method to send, receive and dispatch in CVariable
+) Add dispatch method in server class

Test
-) On Curie
-) Test data: integer, float, double, boolean, string
-) File: one and multiple, using_server: ON and OFF
+) All test cases passed and had correct results

File:

• XIOS/trunk/src/node/variable.cpp (modified) (4 diffs)

XIOS/trunk/src/node/variable.cpp

@@ -7 +7 @@
 #include "xmlioserver_spl.hpp"
 #include "type.hpp"
+#include "context.hpp"
+#include "context_client.hpp"
 #include <boost/algorithm/string.hpp>
 
@@ -48 +50 @@
    {
       return (this->content);
+   }
+
+   void CVariable::setContent(const StdString& contentStr)
+   {
+     this->content = contentStr;
    }
 
@@ -61 +68 @@
       oss << "</" << CVariable::GetName() << " >";
       return (oss.str());
-   } 
-   
+   }
+
    CVariable::EVarType CVariable::getVarType(void) const
    {
      EVarType ret ;
-     
+
      if (type.isEmpty()) ret=t_undefined ;
      else
@@ -83 +90 @@
      return ret ;
    }
-       
+
+   /*
+   *\brief Sending value of a variable with its id from client to server
+   *
+   */
+   void CVariable::sendValue()
+   {
+     CContext* context=CContext::getCurrent() ;
+     if (!context->hasServer)
+     {
+       CContextClient* client=context->client ;
+
+       CEventClient event(this->getType(),EVENT_ID_VARIABLE_VALUE) ;
+       if (client->isServerLeader())
+       {
+         CMessage msg ;
+         msg<<this->getId() ;
+         msg<<content ;
+         event.push(client->getServerLeader(),1,msg) ;
+         client->sendEvent(event) ;
+       }
+       else client->sendEvent(event) ;
+    }
+   }
+
+   /*
+   *\brief Receive value of a variable with its id from client to server
+   *
+   */
+   void CVariable::recvValue(CEventServer& event)
+   {
+      CBufferIn* buffer=event.subEvents.begin()->buffer;
+      string id;
+      *buffer>>id ;
+      get(id)->recvValue(*buffer);
+   }
+
+
+   /*
+   *\brief Receive value of a variable with its id from client to server
+   *
+   */
+   void CVariable::recvValue(CBufferIn& buffer)
+   {
+      string str ;
+      buffer>>str;
+      setContent(str);
+   }
+
+   bool CVariable::dispatchEvent(CEventServer& event)
+   {
+    if (SuperClass::dispatchEvent(event)) return true ;
+    else
+    {
+      switch(event.type)
+      {
+        case EVENT_ID_VARIABLE_VALUE :
+          recvValue(event) ;
+          return true ;
+          break ;
+
+        default :
+          ERROR("bool CVariable::dispatchEvent(CEventServer& event)",<<"Unknown Event") ;
+          return false ;
+      }
+    }
+   }
+
 /*
    void CVariable::toBinary(StdOStream & os) const