hasinput = DataFlowEditor()->HasInput( anInPort->PortName() ) ;
}
if ( hasinput ) {
- const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+ const CORBA::Any anAny = anInPort->GetOutPort()->Value() ;
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
// ServiceParameterName ,
(GraphBase::Port * ) anInPort ,
true ,
- anAny ) ;
+ &anAny ) ;
}
else {
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
beginService( "CNode_Impl::Port" );
begin = false ;
}
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
// ServiceParameterName ,
(GraphBase::Port * ) anOutPort ,
false ,
- anAny ) ;
+ &anAny ) ;
PortableServer::ObjectId * id = myPort->getId() ;
CORBA::Object_var obj = _poa->id_to_reference(*id);
iobject = SUPERV::Port::_narrow(obj) ;
if ( anOutPort && !anOutPort->IsDataStream() ) {
Outobject = anOutPort->ObjRef() ;
if ( CORBA::is_nil( Outobject ) ) {
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
myOutPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anOutPort ,
false ,
- anAny ) ;
+ &anAny ) ;
if ( myOutPort ) {
PortableServer::ObjectId * id = myOutPort->getId() ;
CORBA::Object_var obj = _poa->id_to_reference(*id) ;
if ( anOutPort && anOutPort->IsDataStream() ) {
Outobject = SUPERV::StreamPort::_narrow( anOutPort->ObjRef() ) ;
if ( CORBA::is_nil( Outobject ) ) {
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
myOutStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anOutPort ,
false ,
- anAny ) ;
+ &anAny ) ;
if ( myOutStreamPort ) {
PortableServer::ObjectId * id = myOutStreamPort->getId() ;
CORBA::Object_var obj = _poa->id_to_reference(*id) ;
// << "/" << anInPort->IsNotConnected() ) ;
Port_Impl * myPort ;
if ( DataFlowNode()->HasInput( anInPort->PortName() ) ) {
- const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+ const CORBA::Any anAny = anInPort->GetOutPort()->Value() ;
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anInPort ,
true ,
- anAny ) ;
+ &anAny ) ;
}
else {
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
}
else if ( CORBA::is_nil( anOutPort->ObjRef() ) ) {
// MESSAGE( "OutPort " << i << " " << anOutPort->PortName() << " of Node " << Name() ) ;
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
Port_Impl * myPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anOutPort ,
false ,
- anAny ) ;
+ &anAny ) ;
PortableServer::ObjectId * id = myPort->getId() ;
CORBA::Object_var obj = _poa->id_to_reference(*id);
SUPERV::Port_var iobject ;
}
Port_Impl * myPort ;
if ( anOutPort->IsDataConnected() ) {
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anOutPort ,
true ,
- anAny ) ;
+ &anAny ) ;
}
else {
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
}
Port_Impl * myPort ;
if ( anInPort->IsDataConnected() ) {
- const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+ const CORBA::Any anAny = anInPort->GetOutPort()->Value() ;
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anInPort ,
false ,
- anAny ) ;
+ &anAny ) ;
}
else {
myPort = new Port_Impl( _Orb , _Poa , _ContId ,
<< "/" << anInPort->IsNotConnected() ) ;
StreamPort_Impl * myStreamPort ;
if ( DataFlowNode()->HasInput( anInPort->PortName() ) ) {
- const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+ const CORBA::Any anAny = anInPort->GetOutPort()->Value() ;
myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anInPort ,
true ,
- anAny ) ;
+ &anAny ) ;
}
else {
myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
}
else if ( CORBA::is_nil( anOutPort->ObjRef() ) ) {
MESSAGE( "OutStreamPort " << i << " " << anOutPort->PortName() << " of Node " << Name() ) ;
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
StreamPort_Impl * myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anOutPort ,
false ,
- anAny ) ;
+ &anAny ) ;
PortableServer::ObjectId * id = myStreamPort->getId() ;
CORBA::Object_var obj = _poa->id_to_reference(*id);
SUPERV::StreamPort_var iobject ;
}
StreamPort_Impl * myStreamPort ;
if ( anOutPort->IsDataConnected() ) {
- const CORBA::Any * anAny = anOutPort->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anOutPort->Value() ;
+ const CORBA::Any anAny = anOutPort->Value() ;
myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anOutPort ,
true ,
- anAny ) ;
+ &anAny ) ;
}
else {
myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
}
StreamPort_Impl * myStreamPort ;
if ( anInPort->IsDataConnected() ) {
- const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+//JR 30.03.2005 const CORBA::Any * anAny = anInPort->GetOutPort()->Value() ;
+ const CORBA::Any anAny = anInPort->GetOutPort()->Value() ;
myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
instanceName() , interfaceName() ,
DataFlowEditor() ,
DataFlowNode() ,
(GraphBase::Port * ) anInPort ,
false ,
- anAny ) ;
+ &anAny ) ;
}
else {
myStreamPort = new StreamPort_Impl( _Orb , _Poa , _ContId ,
}
CORBA::Any * Value_Impl::ToAny() {
+ beginService( "Value_Impl::ToAny" );
CORBA::Any * anAny ;
if ( _DataFlowEditor ) {
char * name ;
else {
name = _DataFlowEditor->Graph()->Name() ;
}
+ MESSAGE( "ToAny " << name<< "( " << _ParameterName << " )" ) ;
if ( _InputPort ) {
if ( _DataFlowNode ) {
_InputValue = _DataFlowNode->HasInput( _ParameterName ) ;
}
GraphExecutor::DataFlow * _DataFlowExecutor = _DataFlowEditor->Executor() ;
if ( _DataFlowExecutor ) {
- anAny = new CORBA::Any( * _DataFlowExecutor->GetInData( name ,
- _ParameterName ) ) ;
+//JR 30.03.2005 anAny = new CORBA::Any( * _DataFlowExecutor->GetInData( name ,
+ anAny = new CORBA::Any( _DataFlowExecutor->GetInData( name ,
+ _ParameterName ) ) ;
}
else if ( _InputValue ) {
- anAny = new CORBA::Any( * _DataFlowEditor->GetInData( name ,
- _ParameterName ) ) ;
+//JR 30.03.2005 anAny = new CORBA::Any( * _DataFlowEditor->GetInData( name ,
+ anAny = new CORBA::Any( _DataFlowEditor->GetInData( name ,
+ _ParameterName ) ) ;
}
else {
anAny = new CORBA::Any( *_Any ) ;
else {
GraphExecutor::DataFlow * _DataFlowExecutor = _DataFlowEditor->Executor() ;
if ( _DataFlowExecutor ) {
- anAny = new CORBA::Any( * _DataFlowExecutor->GetOutData( name ,
- _ParameterName ) ) ;
+//JR 30.03.2005 anAny = new CORBA::Any( * _DataFlowExecutor->GetOutData( name ,
+ anAny = new CORBA::Any( _DataFlowExecutor->GetOutData( name ,
+ _ParameterName ) ) ;
}
else {
anAny = new CORBA::Any( *_Any ) ;
else {
anAny = new CORBA::Any( *_Any ) ;
}
+ endService( "Value_Impl::ToAny" );
return anAny ;
}
char * Value_Impl::ToString() {
// beginService( "Value_Impl::ToString" );
- CORBA::Any anAny = *ToAny() ;
+//JR 22.03.2005 Memory Leak CORBA::Any anAny = *ToAny() ;
+ CORBA::Any anAny ;
if ( _DataFlowEditor ) {
char * name ;
if ( _DataFlowNode ) {
else {
name = _DataFlowEditor->Graph()->Name() ;
}
-// cout << "Value_Impl::ToString " << name << " " << _ParameterName << " " ;
+// MESSAGE( "ToString " << name<< "( " << _ParameterName << " )" ) ;
if ( _InputPort ) {
if ( _DataFlowNode ) {
_InputValue = _DataFlowNode->HasInput( _ParameterName ) ;
}
GraphExecutor::DataFlow * _DataFlowExecutor = _DataFlowEditor->Executor() ;
if ( _DataFlowExecutor ) {
-// cout << "_DataFlowExecutor->GetInData" << endl ;
- anAny = * _DataFlowExecutor->GetInData( name ,
- _ParameterName ) ;
+// cout << "-->_DataFlowExecutor->GetInData " << name << " " << _ParameterName << endl ;
+//JR 30.03.2005 const CORBA::Any * AnyPtr = _DataFlowExecutor->GetInData( name ,
+ const CORBA::Any AnyRef = _DataFlowExecutor->GetInData( name ,
+ _ParameterName ) ;
+//JR 30.03.2005 cout << "<--_DataFlowExecutor->GetInData " << AnyPtr << endl ;
+//JR 30.03.2005 anAny = * AnyPtr ;
+ anAny = AnyRef ;
}
else if ( _InputValue ) {
// cout << "_DataFlowEditor->GetInData _DataFlowNode " << _DataFlowNode
// << " _InputValue " << _InputValue << endl ;
- anAny = * _DataFlowEditor->GetInData( name ,
- _ParameterName ) ;
+//JR 30.03.2005 anAny = * _DataFlowEditor->GetInData( name ,
+ anAny = _DataFlowEditor->GetInData( name ,
+ _ParameterName ) ;
}
else {
anAny = *_Any ;
else {
GraphExecutor::DataFlow * _DataFlowExecutor = _DataFlowEditor->Executor() ;
if ( _DataFlowExecutor ) {
- anAny = * _DataFlowExecutor->GetOutData( name ,
- _ParameterName ) ;
+// cout << "-->_DataFlowExecutor->GetOutData " << name << " " << _ParameterName << endl ;
+//JR 30.03.2005 const CORBA::Any * AnyPtr = _DataFlowExecutor->GetOutData( name ,
+ const CORBA::Any AnyRef = _DataFlowExecutor->GetOutData( name ,
+ _ParameterName ) ;
+//JR 30.03.2005 cout << "<--_DataFlowExecutor->GetOutData " << AnyPtr << endl ;
+//JR 30.03.2005 anAny = * AnyPtr ;
+ anAny = AnyRef ;
}
else {
anAny = *_Any ;
_InputValue = _DataFlowEditor->HasInput( _ParameterName ) ;
}
if ( _InputValue && _DataFlowEditor->IsEditing() ) {
- anAny = * _DataFlowEditor->GetInData( name ,
- _ParameterName ) ;
+//JR 30.03.2005 anAny = * _DataFlowEditor->GetInData( name ,
+ anAny = _DataFlowEditor->GetInData( name ,
+ _ParameterName ) ;
}
else {
GraphExecutor::DataFlow * _DataFlowExecutor = _DataFlowEditor->Executor() ;
if ( _DataFlowExecutor ) {
- anAny = * _DataFlowExecutor->GetInData( name ,
- _ParameterName ) ;
+//JR 30.03.2005 anAny = * _DataFlowExecutor->GetInData( name ,
+ anAny = _DataFlowExecutor->GetInData( name ,
+ _ParameterName ) ;
}
}
}
else {
if ( _InputValue && _DataFlowEditor->IsEditing() ) {
- anAny = * _DataFlowEditor->GetOutData( name ,
- _ParameterName ) ;
+//JR 30.03.2005 anAny = * _DataFlowEditor->GetOutData( name ,
+ anAny = _DataFlowEditor->GetOutData( name ,
+ _ParameterName ) ;
}
else {
GraphExecutor::DataFlow * _DataFlowExecutor = _DataFlowEditor->Executor() ;
if ( _DataFlowExecutor ) {
- anAny = * _DataFlowExecutor->GetOutData( name ,
- _ParameterName ) ;
+//JR 30.03.2005 anAny = * _DataFlowExecutor->GetOutData( name ,
+ anAny = _DataFlowExecutor->GetOutData( name ,
+ _ParameterName ) ;
}
}
}