src/engine/AnyInputPort.cxx

   1 // Copyright (C) 2006-2023  CEA/DEN, EDF R&D
   2 //
   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, or (at your option) any later version.
   7 //
   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.
  12 //
  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
  16 //
  17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
  18 //
  19
  20 #include "AnyInputPort.hxx"
  21 #include "TypeCode.hxx"
  22 #include "Mutex.hxx"
  23 #include "AutoLocker.hxx"
  24
  25 //#define _DEVDEBUG_
  26 #include "YacsTrace.hxx"
  27
  28 #include <iostream>
  29 #include <iomanip>
  30 #include <sstream>
  31
  32 using namespace YACS::ENGINE;
  33 using namespace std;
  34
  35 AnyInputPort::AnyInputPort(const std::string& name, Node *node, TypeCode* type, bool canBeNull)
  36   : InputPort(name, node, type, canBeNull),
  37     DataPort(name, node, type),
  38     Port(node),
  39     _value(0)
  40 {
  41 }
  42
  43 AnyInputPort::AnyInputPort(const AnyInputPort& other, Node *newHelder)
  44   : InputPort(other, newHelder),
  45     DataPort(other, newHelder),
  46     Port(other, newHelder),
  47     _value(0)
  48 {
  49   if(other._value)
  50     _value=other._value->clone();
  51 }
  52
  53 AnyInputPort::~AnyInputPort()
  54 {
  55   if(_value)
  56     {
  57       DEBTRACE("_value ref count: " << _value->getRefCnt());
  58       _value->decrRef();
  59     }
  60 }
  61
  62 //! Save the current data value for further reinitialization of the port
  63 /*!
  64  *
  65  */
  66 void AnyInputPort::exSaveInit()
  67 {
  68   if(_initValue) _initValue->decrRef();
  69   _initValue=_value;
  70   _initValue->incrRef();
  71 }
  72
  73 //! Restore the saved data value to current data value
  74 /*!
  75  * If no data has been saved (_initValue == 0) don't restore
  76  */
  77 void AnyInputPort::exRestoreInit()
  78 {
  79   if(!_initValue)
  80     return;
  81   if(_value)
  82     _value->decrRef();
  83   _value=_initValue;
  84   _value->incrRef();
  85 }
  86
  87 void AnyInputPort::releaseDataUnsafe()
  88 {
  89   if(_value)
  90     _value->decrRef();
  91   _value = nullptr;
  92 }
  93
  94 void AnyInputPort::releaseData()
  95 {
  96   YACS::BASES::AutoLocker<YACS::BASES::Mutex> lock(&_mutex);
  97   releaseDataUnsafe();
  98 }
  99
 100 void AnyInputPort::put(Any *data)
 101 {
 102   YACS::BASES::AutoLocker<YACS::BASES::Mutex> lock(&_mutex);
 103   releaseDataUnsafe();
 104   _value=data;
 105   if (_value)
 106     {
 107       _value->incrRef();
 108       DEBTRACE("value ref count: " << _value->getRefCnt());
 109     }
 110 }
 111
 112 bool AnyInputPort::isEmpty()
 113 {
 114   return !_value;
 115 }
 116
 117 void *AnyInputPort::get() const
 118 {
 119   return (void *)_value;
 120 }
 121
 122 std::string AnyInputPort::getAsString()
 123 {
 124   YACS::BASES::AutoLocker<YACS::BASES::Mutex> lock(&_mutex);
 125   return getRuntime()->convertNeutralAsString(edGetType(),_value);
 126 }
 127
 128 void AnyInputPort::put(const void *data)
 129 {
 130   put((Any *)data);
 131 }
 132
 133 InputPort *AnyInputPort::clone(Node *newHelder) const
 134 {
 135   return new AnyInputPort(*this,newHelder);
 136 }
 137
 138 std::string AnyInputPort::dump()
 139 {
 140   if(!_value)
 141     {
 142       std::string what="AnyInputPort::get : no value currently in input port with name \""; what+=_name; what+="\"";
 143       throw Exception(what);
 144     }
 145   stringstream xmldump;
 146   switch (_value->getType()->kind())
 147     {
 148     case Double:
 149       xmldump << "<value><double>" << setprecision(16) << _value->getDoubleValue() << "</double></value>" << endl;
 150       break;
 151     case Int:
 152       xmldump << "<value><int>" << _value->getIntValue() << "</int></value>" << endl;
 153       break;
 154     case Bool:
 155       xmldump << "<value><boolean>" << _value->getBoolValue() << "</boolean></value>" << endl;
 156       break;
 157     case String:
 158       xmldump << "<value><string>" << _value->getStringValue() << "</string></value>" << endl;
 159       break;
 160     default:
 161       xmldump << "<value><error> NO_SERIALISATION_AVAILABLE </error></value>" << endl;
 162       break;
 163     }
 164   return xmldump.str();
 165 }