1 // Copyright (C) 2007-2013 CEA/DEN, EDF R&D, OPEN CASCADE
3 // This library is free software; you can redistribute it and/or
4 // modify it under the terms of the GNU Lesser General Public
5 // License as published by the Free Software Foundation; either
6 // version 2.1 of the License.
8 // This library is distributed in the hope that it will be useful,
9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 // Lesser General Public License for more details.
13 // You should have received a copy of the GNU Lesser General Public
14 // License along with this library; if not, write to the Free Software
15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
20 // File : CalciumCxxInterface.hxx
21 // Author : Eric Fayolle (EDF)
23 // Modified by : $LastChangedBy$
24 // Date : $LastChangedDate: 2007-03-01 13:27:58 +0100 (jeu, 01 mar 2007) $
27 #ifndef _CALCIUM_CXXINTERFACE_HXX_
28 #define _CALCIUM_CXXINTERFACE_HXX_
30 #if defined(__CONST_H) || defined(__CALCIUM_H)
31 #error "The header CalciumCxxInterface.hxx must be included before calcium.h"
37 #include "Superv_Component_i.hxx"
38 #include "CalciumException.hxx"
39 #include "CalciumTypes.hxx"
40 #include "CalciumGenericUsesPort.hxx"
41 #include "Copy2UserSpace.hxx"
42 #include "Copy2CorbaSpace.hxx"
43 #include "CalciumPortTraits.hxx"
49 template <typename T1, typename T2>
51 static const bool value = false;
53 template <typename T1>
54 struct IsSameType<T1,T1> {
55 static const bool value = true;
58 extern const char * CPMESSAGE[];
62 #include <boost/type_traits/remove_all_extents.hpp>
64 namespace CalciumInterface {
66 /********************* CONNECTION INTERFACE *****************/
69 ecp_cd (Superv_Component_i & component, std::string & instanceName)
71 /* TODO : Trouver le nom de l'instance SALOME*/
72 CORBA::String_var componentName=component.instanceName();
73 std::string containerName=component.getContainerName();
74 if (instanceName.empty()) instanceName=componentName;
75 Engines_DSC_interface::writeEvent("CP_CD",containerName,componentName,"","","");
79 ecp_fin (Superv_Component_i & component, bool provideLastGivenValue)
81 CORBA::String_var componentName=component.instanceName();
82 std::string containerName=component.getContainerName();
83 Engines_DSC_interface::writeEvent("CP_FIN",containerName,componentName,"","","");
85 std::vector<std::string> usesPortNames;
86 std::vector<std::string>::const_iterator it;
87 component.get_uses_port_names(usesPortNames);
89 //Récupérer le type de réel du port est un peu difficile
90 //car l'interface ne donne aucune indication
92 // uses_port *myUsesPort;
93 calcium_uses_port* myCalciumUsesPort;
95 for (it=usesPortNames.begin(); it != usesPortNames.end(); ++it)
99 myCalciumUsesPort= component.Superv_Component_i::get_port< calcium_uses_port >((*it).c_str());
101 // component.Superv_Component_i::get_port(myUsesPort,(*it).c_str());
102 // calcium_uses_port* myCalciumUsesPort=
103 // dynamic_cast<calcium_uses_port*>(myUsesPort);
106 std::cerr << "-------- CalciumInterface(ecp_fin) MARK 1 -|"<< *it <<"|----"<<
107 // typeid(myUsesPort).name() <<"-------------" <<
108 typeid(myCalciumUsesPort).name() <<"-------------" << std::endl;
111 // if ( !myCalciumUsesPort )
112 // throw Superv_Component_i::BadCast(LOC(OSS()<<"Impossible de convertir le port "
113 // << *it << " en port de type calcium_uses_port." ));
115 myCalciumUsesPort->disconnect(provideLastGivenValue);
117 catch ( const Superv_Component_i::BadCast & ex)
119 Engines_DSC_interface::writeEvent("CP_FIN",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
120 throw (CalciumException(CalciumTypes::CPTPVR,ex));
122 catch ( const DSC_Exception & ex)
124 Engines_DSC_interface::writeEvent("CP_FIN",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPOK],ex.what());
125 // Exception venant de SupervComponent :
126 // PortNotDefined(CPNMVR), PortNotConnected(CPLIEN)
127 // ou du port uses : Dsc_Exception
128 // On continue à traiter la deconnexion des autres ports uses
132 Engines_DSC_interface::writeEvent("CP_FIN",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPATAL],"Unexpected exception");
133 throw (CalciumException(CalciumTypes::CPATAL,"Unexpected exception"));
134 // En fonction du mode de gestion des erreurs throw;
140 /********************* INTERFACES DE DESALLOCATION *****************/
142 // Uniquement appelé par l'utilisateur s'il utilise la 0 copie
143 // ( pointeur de données data==NULL à l'appel de ecp_lecture )
144 // Une désallocation aura lieu uniquement si un buffer intermédiaire
145 // était necessaire (type utilisateur et corba diffférent)
146 // La propriété du buffer est rendue à CORBA sinon
147 template <typename T1, typename T2> static void
148 ecp_free ( T1 * dataPtr )
150 typedef typename ProvidesPortTraits<T2>::PortType PortType;
151 typedef typename PortType::DataManipulator DataManipulator;
152 typedef typename DataManipulator::Type DataType; // Attention != T1
153 typedef typename DataManipulator::InnerType InnerType;
155 DeleteTraits<IsSameType<T1,InnerType>::value, DataManipulator >::apply(dataPtr);
158 template <typename T1> static void
159 ecp_free ( T1 * dataPtr )
161 ecp_free<T1,T1> ( dataPtr );
165 /********************* READING INTERFACE *****************/
168 // T1 est le type de données
169 // T2 est un <nom> de type Calcium permettant de sélectionner le port CORBA correspondant
170 // T1 et T2 sont dissociés pour discriminer par exemple le cas des nombres complexes
171 // -> Les données des nombres complexes sont de type float mais
172 // le port à utiliser est le port cplx
173 template <typename T1, typename T2 > static void
174 ecp_lecture ( Superv_Component_i & component,
175 int const & dependencyType,
179 const std::string & nomVar,
186 CORBA::String_var componentName=component.instanceName();
187 std::string containerName=component.getContainerName();
189 typedef typename ProvidesPortTraits<T2>::PortType PortType;
190 typedef typename PortType::DataManipulator DataManipulator;
191 typedef typename DataManipulator::Type CorbaDataType; // Attention != T1
192 typedef typename DataManipulator::InnerType InnerType;
193 CalciumTypes::DependencyType _dependencyType=
194 static_cast<CalciumTypes::DependencyType>(dependencyType);
196 CorbaDataType corbaData;
199 std::cerr << "-------- CalciumInterface(ecp_lecture) MARK 1 ------------------" << std::endl;
204 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPNMVR],"");
205 throw CalciumException(CalciumTypes::CPNMVR, LOC("Empty variable name"));
209 std::cout << "-------- CalciumInterface(lecture) MARK 2 --"<<typeid(port).name()<<"----------------" << std::endl;
212 std::cout << "-------- CalciumInterface(lecture) MARK 2b1 -----" << typeid(t1).name() << "-------------" << std::endl;
213 std::cout << "-------- CalciumInterface(lecture) MARK 2b2 -----" << typeid(t2).name() << "-------------" << std::endl;
218 port = component.Superv_Component_i::get_port< PortType > (nomVar.c_str());
220 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 3 ------------------" << std::endl;
223 catch ( const Superv_Component_i::PortNotDefined & ex)
225 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNMVR],ex.what());
226 throw (CalciumException(CalciumTypes::CPNMVR,ex));
228 catch ( const Superv_Component_i::PortNotConnected & ex)
230 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPLIEN],ex.what());
231 throw (CalciumException(CalciumTypes::CPLIEN,ex));
232 // VERIFIER LES CAS DES CODES : CPINARRET, CPSTOPSEQ, CPCTVR, CPLIEN
234 catch ( const Superv_Component_i::BadCast & ex)
236 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
237 throw (CalciumException(CalciumTypes::CPTPVR,ex));
240 // mode == mode du port
241 CalciumTypes::DependencyType portDependencyType = port->getDependencyType();
243 if ( portDependencyType == CalciumTypes::UNDEFINED_DEPENDENCY )
245 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],"Dependency mode is undefined");
246 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode of variable " << nomVar << " is undefined."));
249 if ( ( portDependencyType != _dependencyType ) && ( _dependencyType != CalciumTypes::SEQUENCE_DEPENDENCY ) )
251 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],
252 "Dependency mode is not the same as the required one");
253 throw CalciumException(CalciumTypes::CPITVR, LOC(OSS()<<"Dependency mode of variable " << nomVar << ": "
254 << portDependencyType << " is not the same as the required one."));
258 std::stringstream msgout,msg;
259 if ( _dependencyType == CalciumTypes::TIME_DEPENDENCY )
264 msg << "ti=" << ti << ", tf=" << tf ;
265 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),"",msg.str().c_str());
266 corbaData = port->get(tt,tf, 0);
267 msgout << "read t=" << tt ;
269 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 5 ------------------" << std::endl;
272 catch ( const DSC_Exception & ex)
274 Engines_DSC_interface::writeEvent("END_READ",containerName,componentName,nomVar.c_str(),"",ex.what());
278 else if ( _dependencyType == CalciumTypes::ITERATION_DEPENDENCY )
283 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),"",msg.str().c_str());
284 corbaData = port->get(0, i);
285 msgout << "read i=" << i ;
287 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 6 ------------------" << std::endl;
290 catch ( const DSC_Exception & ex)
292 Engines_DSC_interface::writeEvent("END_READ",containerName,componentName,nomVar.c_str(),"",ex.what());
302 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 7 ------------------" << std::endl;
304 Engines_DSC_interface::writeEvent("BEGIN_READ",containerName,componentName,nomVar.c_str(),"","Sequential read");
305 corbaData = port->next(ti,i);
307 if(i==0)msgout<< "t=" <<ti;
308 else msgout<< "i=" <<i;
310 catch ( const DSC_Exception & ex)
312 Engines_DSC_interface::writeEvent("END_READ",containerName,componentName,nomVar.c_str(),"",ex.what());
318 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 8 ------------------" << std::endl;
320 size_t corbaDataSize = DataManipulator::size(corbaData);
322 std::cout << "-------- CalciumInterface(ecp_lecture) corbaDataSize : " << corbaDataSize << std::endl;
325 // Vérifie si l'utilisateur demande du 0 copie
328 if ( bufferLength != 0 )
330 MESSAGE("bufferLength devrait valoir 0 pour l'utilisation du mode sans copie (data==NULL)");
332 nRead = corbaDataSize;
333 // Si les types T1 et InnerType sont différents, il faudra effectuer tout de même une recopie
334 if (!IsSameType<T1,InnerType>::value) data = new T1[nRead];
336 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 9 ------------------" << std::endl;
338 // On essaye de faire du 0 copy si les types T1 et InnerType sont les mêmes.
340 // La raison d'être du foncteur Copy2UserSpace est qu'il n'est pas possible de compiler
341 // une expression d'affectation sur des types incompatibles ; même
342 // si cette expression se trouve dans une branche non exécuté d'un test
343 // portant sur la compatibilité des types.
344 // En utilisant le foncteur Copy2UserSpace, seule la spécialisation en adéquation
345 // avec la compatibilité des types sera compilée
346 Copy2UserSpace< IsSameType<T1,InnerType>::value, DataManipulator >::apply(data,corbaData,nRead);
348 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 10 ------------------" << std::endl;
350 // Attention : Seul CalciumCouplingPolicy via eraseDataId doit décider de supprimer ou non
351 // la donnée corba associée à un DataId ! Ne pas effectuer la desallocation suivante :
352 // DataManipulator::delete_data(corbaData);
353 // ni DataManipulator::getPointer(corbaData,true); qui détruit la sequence lorsque l'on
354 // prend la propriété du buffer
355 // old : Dans les deux cas la structure CORBA n'est plus utile
356 // old : Si !IsSameType<T1,InnerType>::value l'objet CORBA est détruit avec son contenu
357 // old : Dans l'autre cas seul la coquille CORBA est détruite
358 // L'utilisateur devra appeler ecp_free qui déterminera s'il est necessaire
359 // de désallouer un buffer intermédiaire ( types différents) ou de rendre la propriété
363 nRead = std::min < size_t > (corbaDataSize,bufferLength);
365 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 11 ------------------" << std::endl;
367 Copy2UserSpace<false, DataManipulator >::apply(data,corbaData,nRead);
368 //Déjà fait ci-dessus :
369 //DataManipulator::copy(corbaData,data,nRead);
371 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 12 ------------------" << std::endl;
375 std::cout << "-------- CalciumInterface(ecp_lecture), Valeur de data : " << std::endl;
376 std::copy(data,data+nRead,std::ostream_iterator<T1>(std::cout," "));
377 std::cout << "Ptr :" << data << std::endl;
378 std::cout << "-------- CalciumInterface(ecp_lecture) MARK 13 ------------------" << std::endl;
380 Engines_DSC_interface::writeEvent("END_READ",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPOK],msgout.str().c_str());
384 // T1 is the data type
385 template <typename T1 > static void
386 ecp_lecture ( Superv_Component_i & component,
387 int const & dependencyType,
391 const std::string & nomVar,
396 ecp_lecture<T1,T1> (component,dependencyType,ti,tf,
397 i,nomVar,bufferLength,nRead,data);
401 /********************* WRITING INTERFACE *****************/
405 template <typename T1, typename T2> static void
406 ecp_ecriture ( Superv_Component_i & component,
407 int const & dependencyType,
410 const std::string & nomVar,
416 CORBA::String_var componentName=component.instanceName();
417 std::string containerName=component.getContainerName();
419 //typedef typename StarTrait<TT>::NonStarType T;
420 typedef typename boost::remove_all_extents< T1 >::type T1_without_extent;
421 typedef typename boost::remove_all_extents< T2 >::type T2_without_extent;
422 typedef typename UsesPortTraits <T2_without_extent>::PortType UsesPortType;
423 typedef typename ProvidesPortTraits<T2_without_extent>::PortType ProvidesPortType;// pour obtenir un manipulateur de données
424 typedef typename ProvidesPortType::DataManipulator DataManipulator;
425 // Verifier que l'on peut définir UsesPortType::DataManipulator
426 // typedef typename PortType::DataManipulator DataManipulator;
427 typedef typename DataManipulator::Type CorbaDataType; // Attention != T1
428 typedef typename DataManipulator::InnerType InnerType;
430 T1_without_extent const & _data = data;
432 CalciumTypes::DependencyType _dependencyType=
433 static_cast<CalciumTypes::DependencyType>(dependencyType);
436 std::cerr << "-------- CalciumInterface(ecriture) MARK 1 ------------------" << std::endl;
438 if ( nomVar.empty() )
440 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPNMVR],"");
441 throw CalciumException(CalciumTypes::CPNMVR, LOC("Empty variable name"));
445 std::cout << "-------- CalciumInterface(ecriture) MARK 2 ---"<<typeid(port).name()<<"---------------" << std::endl;
448 std::cout << "-------- CalciumInterface(ecriture) MARK 2b1 -----" << typeid(t1).name() << "-------------" << std::endl;
449 std::cout << "-------- CalciumInterface(ecriture) MARK 2b2 -----" << typeid(t2).name() << "-------------" << std::endl;
454 port = component.Superv_Component_i::get_port< UsesPortType > (nomVar.c_str());
456 std::cout << "-------- CalciumInterface(ecriture) MARK 3 ------------------" << std::endl;
459 catch ( const Superv_Component_i::PortNotDefined & ex)
461 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNMVR],ex.what());
462 throw (CalciumException(CalciumTypes::CPNMVR,ex));
464 catch ( const Superv_Component_i::PortNotConnected & ex)
466 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPLIEN],ex.what());
467 throw (CalciumException(CalciumTypes::CPLIEN,ex));
468 // VERIFIER LES CAS DES CODES : CPINARRET, CPSTOPSEQ, CPCTVR, CPLIEN
470 catch ( const Superv_Component_i::BadCast & ex)
472 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
473 throw (CalciumException(CalciumTypes::CPTPVR,ex));
476 // mode == mode du port
477 // On pourrait créer la méthode CORBA dans le mode de Couplage CALCIUM.
478 // et donc ajouter cette cette méthode uniquement dans l'IDL calcium !
480 // CalciumTypes::DependencyType portDependencyType;
482 // portDependencyType = port->getDependencyType();
483 // std::cout << "-------- CalciumInterface(ecriture) MARK 4 ------------------" << std::endl;
484 // } catch ( const DSC_Exception & ex ) {
485 // std::cerr << ex.what() << std::endl;;
486 // throw (CalciumException(CalciumTypes::CPIT,ex));
489 if ( _dependencyType == CalciumTypes::UNDEFINED_DEPENDENCY )
491 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],"Dependency mode is undefined");
492 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode of variable " << nomVar << " is undefined."));
495 if ( _dependencyType == CalciumTypes::SEQUENCE_DEPENDENCY )
497 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],
498 "SEQUENCE_DEPENDENCY mode is not possible when writing");
499 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode SEQUENCE_DEPENDENCY for variable " << nomVar
500 << " is not possible when writing."));
503 // Il faudrait que le port provides génère une exception si le mode donnée n'est pas
504 // le bon. La seule façon de le faire est d'envoyer -1 en temps si on n'est en itération
505 // et vice-versa pour informer les provides port du mode dans lequel on est. Sinon il faut
506 // modifier l'interface IDL pour y ajouter un mode de dépendance !
508 // if ( portDependencyType != _dependencyType )
509 // throw CalciumException(CalciumTypes::CPITVR,
510 // LOC(OSS()<<"Le mode de dépendance de la variable "
511 // << nomVar << " ne correspond pas au mode demandé."));
514 if ( bufferLength < 1 )
516 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNTNULL],"Buffer to send is empty");
517 throw CalciumException(CalciumTypes::CPNTNULL, LOC(OSS()<<"Buffer to send is empty"));
520 CorbaDataType corbaData;
522 std::cout << "-------- CalciumInterface(ecriture) MARK 4 ------------------" << std::endl;
525 // Si les types Utilisateurs et CORBA sont différents
526 // il faut effectuer une recopie sinon on utilise directement le
527 // buffer data pour constituer la séquence
529 // - Attention en mode asynchrone il faudra eventuellement
530 // faire une copie des données même si elles sont de même type.
531 // - OLD : En cas de collocalisation (du port provide et du port uses)
532 // OLD : il est necessaire d'effectuer une recopie du buffer car la
533 // OLD : séquence est envoyée au port provide par une référence sur
534 // OLD : la séquence locale. Or la méthode put récupère le buffer directement
535 // OLD : qui est alors le buffer utilisateur. Il pourrait alors arriver que :
536 // OLD : * Le recepteur efface le buffer emetteur
537 // OLD : * Le port lui-même efface le buffer de l'utilisateur !
538 // OLD : Cette copie est effectuée dans GenericPortUses::put
539 // OLD : en fonction de la collocalisation ou non.
540 // - OLD :En cas de connection multiples d'un port uses distant vers plusieurs port provides
541 // OLD : collocalisés les ports provides partagent la même copie de la donnée !
542 // OLD : Il faut effectuer une copie dans le port provides.
543 // OLD : Cette copie est effectuée dans GenericPortUses::put
544 // OLD : en fonction de la collocalisation ou non.
546 T1_without_extent t1b;
548 std::cout << "-------- CalciumInterface(ecriture) MARK 4b1 -----" << typeid(t1b).name() << "-------------" << std::endl;
549 std::cout << "-------- CalciumInterface(ecriture) MARK 4b2 -----" << typeid(t2b).name() << "-------------" << std::endl;
552 Copy2CorbaSpace<IsSameType<T1_without_extent,InnerType>::value, DataManipulator >::apply(corbaData,_data,bufferLength);
554 //TODO : GERER LES EXCEPTIONS ICI : ex le port n'est pas connecte
555 if ( _dependencyType == CalciumTypes::TIME_DEPENDENCY )
559 port->put(*corbaData,t, -1);
560 std::stringstream msg;
562 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPOK],msg.str().c_str());
564 catch ( const DSC_Exception & ex)
566 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPATAL],ex.what());
567 throw (CalciumException(CalciumTypes::CPATAL,ex.what()));
569 //Le -1 peut être traité par le cst DataIdContainer et transformé en 0
570 //Etre obligé de mettre une étoile ds (*corbadata) va poser des pb pour les types <> seq
572 std::cout << "-------- CalciumInterface(ecriture) MARK 5 ------------------" << std::endl;
575 else if ( _dependencyType == CalciumTypes::ITERATION_DEPENDENCY )
579 port->put(*corbaData,-1, i);
580 std::stringstream msg;
582 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPOK],msg.str().c_str());
584 catch ( const DSC_Exception & ex)
586 Engines_DSC_interface::writeEvent("WRITE",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPATAL],ex.what());
587 throw (CalciumException(CalciumTypes::CPATAL,ex.what()));
590 std::cout << "-------- CalciumInterface(ecriture) MARK 6 ------------------" << std::endl;
595 std::cout << "-------- CalciumInterface(ecriture), Valeur de corbaData : " << std::endl;
596 for (int i = 0; i < corbaData->length(); ++i)
597 std::cout << "-------- CalciumInterface(ecriture), corbaData[" << i << "] = " << (*corbaData)[i] << std::endl;
600 // if ( !IsSameType<T1,InnerType>::value ) delete corbaData;
601 // Supprime l'objet CORBA avec eventuellement les données qu'il contient (cas de la recopie)
605 std::cout << "-------- CalciumInterface(ecriture) MARK 7 ------------------" << std::endl;
611 template <typename T1> static void
612 ecp_ecriture ( Superv_Component_i & component,
613 int const & dependencyType,
616 const std::string & nomVar,
620 ecp_ecriture<T1,T1> (component,dependencyType,t,i,nomVar,bufferLength,data);
624 ecp_fini(Superv_Component_i & component,const std::string & nomVar,long const & i)
626 CORBA::String_var componentName=component.instanceName();
627 std::string containerName=component.getContainerName();
631 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPNMVR],"");
632 throw CalciumException(CalciumTypes::CPNMVR, LOC("Empty variable name"));
635 calcium_provides_port* port;
639 port = component.Superv_Component_i::get_port< calcium_provides_port >(nomVar.c_str());
641 catch ( const Superv_Component_i::PortNotDefined & ex)
643 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNMVR],ex.what());
644 throw (CalciumException(CalciumTypes::CPNMVR,ex));
646 catch ( const Superv_Component_i::PortNotConnected & ex)
648 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPLIEN],ex.what());
649 throw (CalciumException(CalciumTypes::CPLIEN,ex));
651 catch ( const Superv_Component_i::BadCast & ex)
653 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
654 throw (CalciumException(CalciumTypes::CPTPVR,ex));
657 // get dependency mode
658 CalciumTypes::DependencyType portDependencyType = port->getDependencyType();
660 if ( portDependencyType == CalciumTypes::UNDEFINED_DEPENDENCY )
662 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],"Dependency mode is undefined");
663 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode of variable " << nomVar << " is undefined."));
666 if ( portDependencyType != CalciumTypes::ITERATION_DEPENDENCY )
668 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],
669 "Dependency mode must be iteration mode");
670 throw CalciumException(CalciumTypes::CPITVR, LOC(OSS()<<"Dependency mode of variable " << nomVar << ": "
671 << portDependencyType << " must be iteration mode."));
674 port->calcium_erase(0., i,true);
676 std::stringstream msg;
678 Engines_DSC_interface::writeEvent("CP_FINI",containerName,componentName,nomVar.c_str(),"",msg.str().c_str());
683 ecp_fint(Superv_Component_i & component,const std::string & nomVar,double const & t)
685 CORBA::String_var componentName=component.instanceName();
686 std::string containerName=component.getContainerName();
690 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPNMVR],"");
691 throw CalciumException(CalciumTypes::CPNMVR, LOC("Empty variable name"));
694 calcium_provides_port* port;
698 port = component.Superv_Component_i::get_port< calcium_provides_port >(nomVar.c_str());
700 catch ( const Superv_Component_i::PortNotDefined & ex)
702 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNMVR],ex.what());
703 throw (CalciumException(CalciumTypes::CPNMVR,ex));
705 catch ( const Superv_Component_i::PortNotConnected & ex)
707 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPLIEN],ex.what());
708 throw (CalciumException(CalciumTypes::CPLIEN,ex));
710 catch ( const Superv_Component_i::BadCast & ex)
712 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
713 throw (CalciumException(CalciumTypes::CPTPVR,ex));
716 // get dependency mode
717 CalciumTypes::DependencyType portDependencyType = port->getDependencyType();
719 if ( portDependencyType == CalciumTypes::UNDEFINED_DEPENDENCY )
721 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],"Dependency mode is undefined");
722 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode of variable " << nomVar << " is undefined."));
725 if ( portDependencyType != CalciumTypes::TIME_DEPENDENCY )
727 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],
728 "Dependency mode must be time mode");
729 throw CalciumException(CalciumTypes::CPITVR, LOC(OSS()<<"Dependency mode of variable " << nomVar << ": "
730 << portDependencyType << " must be time mode."));
733 port->calcium_erase(t, 0,true);
735 std::stringstream msg;
737 Engines_DSC_interface::writeEvent("CP_FINT",containerName,componentName,nomVar.c_str(),"",msg.str().c_str());
742 ecp_effi(Superv_Component_i & component,const std::string & nomVar,long const & i)
744 CORBA::String_var componentName=component.instanceName();
745 std::string containerName=component.getContainerName();
749 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPNMVR],"");
750 throw CalciumException(CalciumTypes::CPNMVR, LOC("Empty variable name"));
753 calcium_provides_port* port;
757 port = component.Superv_Component_i::get_port< calcium_provides_port >(nomVar.c_str());
759 catch ( const Superv_Component_i::PortNotDefined & ex)
761 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNMVR],ex.what());
762 throw (CalciumException(CalciumTypes::CPNMVR,ex));
764 catch ( const Superv_Component_i::PortNotConnected & ex)
766 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPLIEN],ex.what());
767 throw (CalciumException(CalciumTypes::CPLIEN,ex));
769 catch ( const Superv_Component_i::BadCast & ex)
771 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
772 throw (CalciumException(CalciumTypes::CPTPVR,ex));
775 // get dependency mode
776 CalciumTypes::DependencyType portDependencyType = port->getDependencyType();
778 if ( portDependencyType == CalciumTypes::UNDEFINED_DEPENDENCY )
780 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],"Dependency mode is undefined");
781 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode of variable " << nomVar << " is undefined."));
784 if ( portDependencyType != CalciumTypes::ITERATION_DEPENDENCY )
786 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],
787 "Dependency mode must be iteration mode");
788 throw CalciumException(CalciumTypes::CPITVR, LOC(OSS()<<"Dependency mode of variable " << nomVar << ": "
789 << portDependencyType << " must be iteration mode."));
792 port->calcium_erase(0., i,false);
794 std::stringstream msg;
796 Engines_DSC_interface::writeEvent("CP_EFFI",containerName,componentName,nomVar.c_str(),"",msg.str().c_str());
801 ecp_efft(Superv_Component_i & component,const std::string & nomVar,double const & t)
803 CORBA::String_var componentName=component.instanceName();
804 std::string containerName=component.getContainerName();
808 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,"",CPMESSAGE[CalciumTypes::CPNMVR],"");
809 throw CalciumException(CalciumTypes::CPNMVR, LOC("Empty variable name"));
812 calcium_provides_port* port;
816 port = component.Superv_Component_i::get_port< calcium_provides_port >(nomVar.c_str());
818 catch ( const Superv_Component_i::PortNotDefined & ex)
820 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPNMVR],ex.what());
821 throw (CalciumException(CalciumTypes::CPNMVR,ex));
823 catch ( const Superv_Component_i::PortNotConnected & ex)
825 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPLIEN],ex.what());
826 throw (CalciumException(CalciumTypes::CPLIEN,ex));
828 catch ( const Superv_Component_i::BadCast & ex)
830 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPTPVR],ex.what());
831 throw (CalciumException(CalciumTypes::CPTPVR,ex));
834 // get dependency mode
835 CalciumTypes::DependencyType portDependencyType = port->getDependencyType();
837 if ( portDependencyType == CalciumTypes::UNDEFINED_DEPENDENCY )
839 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],"Dependency mode is undefined");
840 throw CalciumException(CalciumTypes::CPIT, LOC(OSS()<<"Dependency mode of variable " << nomVar << " is undefined."));
843 if ( portDependencyType != CalciumTypes::TIME_DEPENDENCY )
845 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,nomVar.c_str(),CPMESSAGE[CalciumTypes::CPIT],
846 "Dependency mode must be time mode");
847 throw CalciumException(CalciumTypes::CPITVR, LOC(OSS()<<"Dependency mode of variable " << nomVar << ": "
848 << portDependencyType << " must be time mode."));
851 port->calcium_erase(t, 0,false);
853 std::stringstream msg;
855 Engines_DSC_interface::writeEvent("CP_EFFT",containerName,componentName,nomVar.c_str(),"",msg.str().c_str());