Changeset 300 for XMLIO_V2/dev/common/src/object_template_impl.hpp

Timestamp:

02/13/12 19:35:25 (12 years ago)

Author:

ymipsl

Message:

nouvelle version de developpement de xios

• nouvelle interface fortran
• recodage complet de la couche de communication
• et bien d'autres choses...

YM

File:

• XMLIO_V2/dev/common/src/object_template_impl.hpp (modified) (2 diffs)

XMLIO_V2/dev/common/src/object_template_impl.hpp

@@ -1 +1 @@
 #ifndef __XMLIO_CObjectTemplate_impl__
 #define __XMLIO_CObjectTemplate_impl__
+
+#include "object_factory.hpp"
+#include "context.hpp"
+#include "transfert_parameters.hpp"
+#include "buffer_in.hpp"
+#include "attribute.hpp"
+#include "event_client.hpp"
+#include "context_client.hpp"
+#include "object_template.hpp"
 
 namespace xmlioserver
@@ -137 +146 @@
    }
 
-   ///--------------------------------------------------------------
-
+   template <class T>
+   void CObjectTemplate<T>::sendAttributToServer(const string& id)
+   {
+      CAttributeMap & attrMap = *this;
+      CAttribute* attr=attrMap[id] ;
+      sendAttributToServer(*attr) ;
+   }
+
+   template <class T>
+   void CObjectTemplate<T>::sendAttributToServer(tree::CAttribute& attr)
+   {
+     shared_ptr<CContext> context=CObjectFactory::GetObject<CContext>(CObjectFactory::GetCurrentContextId()) ;
+     
+    if (!context->hasServer)
+    {
+       CContextClient* client=context->client ;
+
+       CEventClient event(getType(),EVENT_ID_SEND_ATTRIBUTE) ;   
+       if (client->isServerLeader())
+       {
+         CMessage msg ;
+         msg<<this->getId() ;
+         msg<<attr.getName() ;
+         msg<<attr ;
+         event.push(client->getServerLeader(),1,msg) ;
+         client->sendEvent(event) ;
+       }
+       else client->sendEvent(event) ;
+    }
+      
+   }
+   
+   template <class T>
+   void CObjectTemplate<T>::recvAttributFromClient(CEventServer& event)
+   {
+      
+      CBufferIn* buffer=event.subEvents.begin()->buffer;
+      string id,attrId;
+      *buffer>>id ;
+      CAttributeMap & attrMap = *get(id);
+      *buffer>>attrId ;
+      CAttribute* attr=attrMap[attrId] ;
+      info(50)<<"attribut recu "<<attrId<<"  " ;
+      if (attr->isEmpty()) info(50)<<"--> empty"<<endl ;
+      else info(50) /*<attr->getValue()*/<<endl ;
+      *buffer>>*attr ;
+       info(50)<<"attribut recu "<<attrId<<"  " ;
+      if (attr->isEmpty()) info(50)<<"--> empty"<<endl ;
+      else info(50) /*attr->getValue()*/<<endl ;
+  }
+
+   template <class T>
+   bool CObjectTemplate<T>::dispatchEvent(CEventServer& event)
+   {
+      switch(event.type)
+      {
+         case EVENT_ID_SEND_ATTRIBUTE :
+           recvAttributFromClient(event) ;
+           return true ;
+           break ;
+       
+         default :
+         return false ;
+//           ERROR("void CObjectTemplate<T>::recvEvent(CEventServer& event)",
+//                 <<"Unknown Event") ;
+      }
+   }
+   
+   template <typename T>
+   bool CObjectTemplate<T>::has(const string & id)
+   {
+     return CObjectFactory::HasObject<T>(id) ;
+   }
+
+   template <typename T>
+   boost::shared_ptr<T> CObjectTemplate<T>::get(const string & id)
+   {
+     return CObjectFactory::GetObject<T>(id) ;
+   }
+
+   template <typename T>
+   boost::shared_ptr<T> CObjectTemplate<T>::create(const string & id)
+   {
+     return CObjectFactory::CreateObject<T>(id) ;
+   }   ///--------------------------------------------------------------
+
+  template <typename T>
+  boost::shared_ptr<T> CObjectTemplate<T>::get(void)
+  {
+    return CObjectFactory::GetObject<T>((T*)this) ;
+  }
+  
+
+  
 } // namespace xmlioserver