src/runtime/Test/echo_clt.cxx

   1 // Copyright (C) 2006-2022  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 //#define REFCNT
  21 //
  22 #ifdef REFCNT
  23 #define private public
  24 #define protected public
  25 #include <omniORB4/CORBA.h>
  26 #include <omniORB4/internal/typecode.h>
  27 #endif
  28
  29 #include <echo.hh>
  30 #include <iostream>
  31 #include <vector>
  32 #include <map>
  33
  34 //#define _DEVDEBUG_
  35 #include "YacsTrace.hxx"
  36
  37 int main(int argc, char** argv)
  38 {
  39   try
  40     {
  41       CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
  42       CORBA::Object_var obj = orb->string_to_object("corbaname:rir:#test.my_context/Echo.Object");
  43       eo::Echo_var echoref = eo::Echo::_narrow(obj);
  44       if( CORBA::is_nil(echoref) )
  45         {
  46           std::cerr << "Can't narrow reference to type Echo (or it was nil)." << std::endl;
  47           return 1;
  48         }
  49
  50       CORBA::String_var src = (const char*) "Hello!";
  51       CORBA::String_var dest = echoref->echoString(src);
  52       std::cerr << "I said, \"" << (char*)src << "\"." << std::endl
  53        << "The Echo object replied, \"" << (char*)dest <<"\"." << std::endl;
  54
  55       CORBA::Object_var ob = orb->string_to_object("corbaname:rir:#test.my_context/D.Object");
  56       eo::D_var Dref = eo::D::_narrow(ob);
  57       if( CORBA::is_nil(Dref) ) {
  58         std::cerr << "Can't narrow reference to type D (or it was nil)." << std::endl;
  59         return 1;
  60         }
  61       Dref->echoLong2(10);
  62
  63       eo::D_var dout;
  64       echoref->echoD(Dref,dout);
  65       std::cerr << dout->echoLong2(10) << std::endl;
  66
  67       eo::D_var ddout;
  68       echoref->echoD(dout,ddout);
  69       std::cerr << dout->echoLong2(10) << std::endl;
  70
  71       CORBA::Object_var oob = orb->string_to_object("corbaname:rir:#test.my_context/Obj.Object");
  72       eo::Obj_var Objref = eo::Obj::_narrow(oob);
  73       Objref->echoLong(10);
  74       eo::Obj_var Objout;
  75       echoref->echoObj2(Objref,Objout);
  76       std::cerr << Objout->echoLong(10) << std::endl;
  77
  78       CORBA::Object_var cob = orb->string_to_object("corbaname:rir:#test.my_context/C.Object");
  79       eo::C_var Cref = eo::C::_narrow(cob);
  80       eo::C_var Cout;
  81       echoref->echoC(Cref,Cout);
  82
  83       echoref->echoObj2(Cref,Objout);
  84       //echoref->echoC(Cref,Objout); compilation impossible
  85       //echoref->echoObj2(Cref,Cout);  compilation impossible
  86       //echoref->echoC(Objref,Cout); compilation impossible
  87
  88       CORBA::Object_var dobj = orb->resolve_initial_references("DynAnyFactory");
  89       DynamicAny::DynAnyFactory_var dynFactory = DynamicAny::DynAnyFactory::_narrow(dobj);
  90
  91       CORBA::TypeCode_var content_type=orb->create_interface_tc("IDL:eo/Obj:1.0","Obj");
  92
  93       std::vector<CORBA::Any*> v;
  94       std::vector<CORBA::Any*>::const_iterator iter;
  95
  96       CORBA::Any *any = new CORBA::Any();
  97       *any <<= cob;
  98       v.push_back(any);
  99       /*
 100       */
 101       CORBA::Any *any2 = new CORBA::Any();
 102       *any2 <<= oob;
 103       v.push_back(any2);
 104 #ifdef REFCNT
 105       std::cerr << "refcount: " << oob->_PR_getobj()->pd_refCount << std::endl;
 106 #endif
 107
 108       CORBA::Any *any3 = new CORBA::Any();
 109       *any3 <<= oob;
 110       v.push_back(any3);
 111 #ifdef REFCNT
 112       std::cerr << "refcount: " << oob->_PR_getobj()->pd_refCount << std::endl;
 113 #endif
 114
 115       eo::Obj_ptr xobj;
 116       *any2 >>= xobj;
 117 #ifdef REFCNT
 118       std::cerr << "refcount: " << xobj->_PR_getobj()->pd_refCount << std::endl;
 119 #endif
 120       eo::Obj_ptr yobj;
 121       *any2 >>= yobj;
 122 #ifdef REFCNT
 123       std::cerr << "refcount: " << yobj->_PR_getobj()->pd_refCount << std::endl;
 124 #endif
 125
 126       CORBA::Object_var zobj ;
 127       *any2 >>= CORBA::Any::to_object(zobj) ;
 128 #ifdef REFCNT
 129       std::cerr << "refcount: " << zobj->_PR_getobj()->pd_refCount << std::endl;
 130 #endif
 131
 132       // Build an Any from vector v
 133       int homog=1;
 134       CORBA::TypeCode_var tc;
 135
 136       if(v.size() != 0)
 137         {
 138           // Check if it's an homogeneous vector : all TypeCodes must be equivalent
 139           CORBA::TypeCode_var any_tc=v[0]->type();
 140           tc=orb->create_sequence_tc(0,any_tc);
 141
 142           for(iter=v.begin();iter!=v.end();iter++)
 143             {
 144               CORBA::Any* a=*iter;
 145               CORBA::TypeCode_var tc2=a->type();
 146               if(!tc2->equivalent(any_tc))
 147                 {
 148                   // It's a non homogeneous vector : create a sequence of any
 149                   tc=orb->create_sequence_tc(0,CORBA::_tc_any);
 150                   homog=0;
 151                   break;
 152                 }
 153             }
 154           // It's a homogeneous vector : create a sequence of the homogeneous type
 155         }
 156       else
 157         {
 158           // It's an empty vector : create a sequence of any
 159           tc=orb->create_sequence_tc(0,CORBA::_tc_any);
 160           homog=0;
 161         }
 162
 163       DynamicAny::DynAny_var dynany = dynFactory->create_dyn_any_from_type_code(tc);
 164       DynamicAny::DynSequence_var ds = DynamicAny::DynSequence::_narrow(dynany);
 165
 166       ds->set_length(v.size());
 167       for(iter=v.begin();iter!=v.end();iter++)
 168         {
 169           DynamicAny::DynAny_var temp=ds->current_component();
 170           CORBA::Any* a=*iter;
 171           if(homog)
 172             temp->from_any(*a);
 173           else
 174             ds->insert_any(*a);
 175           //delete intermediate any
 176           delete a;
 177           ds->next();
 178         }
 179       CORBA::Any_var seqany=ds->to_any();
 180       ds->destroy();
 181
 182       //DynStruct from map
 183       std::map<std::string,CORBA::Any*> m;
 184       CORBA::Any *any4 = new CORBA::Any();
 185       *any4 <<= oob;
 186       //*any4 <<= cob;
 187       m["ob"]=any4;
 188       CORBA::Any *any5 = new CORBA::Any();
 189       *any5 <<= 1.0;
 190       m["x"]=any5;
 191       CORBA::Any *any6 = new CORBA::Any();
 192       *any6 <<= (long)1;
 193       m["y"]=any6;
 194       CORBA::Any *any7 = new CORBA::Any();
 195       *any7 <<= (const char*)"coucou";
 196       m["s"]=any7;
 197       CORBA::Any *any8 = new CORBA::Any();
 198       *any8 <<= CORBA::Any::from_boolean(1);
 199       m["b"]=any8;
 200
 201 /*
 202   struct S3
 203   {
 204     double x;
 205     long y;
 206     string s;
 207     boolean b;
 208     Obj ob;
 209   };
 210 */
 211
 212       int nMember=5;
 213       CORBA::StructMemberSeq mseq;
 214       mseq.length(nMember);
 215       mseq[0].name=CORBA::string_dup("x");
 216       mseq[0].type=CORBA::TypeCode::_duplicate(CORBA::_tc_double);
 217       mseq[1].name=CORBA::string_dup("y");
 218       mseq[1].type=CORBA::TypeCode::_duplicate(CORBA::_tc_long);
 219       mseq[2].name=CORBA::string_dup("s");
 220       mseq[2].type=CORBA::TypeCode::_duplicate(CORBA::_tc_string);
 221       mseq[3].name=CORBA::string_dup("b");
 222       mseq[3].type=CORBA::TypeCode::_duplicate(CORBA::_tc_boolean);
 223       mseq[4].name=CORBA::string_dup("ob");
 224       mseq[4].type=content_type;
 225       for(int i=0;i<nMember;i++)
 226         {
 227           const char* name=mseq[i].name;
 228           std::cerr << mseq[i].name << std::endl;
 229           if(m.count(name) !=0)
 230             {
 231               std::cerr << "member: " << mseq[i].name << std::endl;
 232               mseq[i].type=m[name]->type();
 233             }
 234         }
 235       CORBA::TypeCode_var ts= orb->create_struct_tc("","",mseq);
 236       //CORBA::TypeCode_var ts= orb->create_struct_tc("IDL:eo/S3:1.0","S3",mseq);
 237       dynany = dynFactory->create_dyn_any_from_type_code(ts);
 238       DynamicAny::DynStruct_var dst = DynamicAny::DynStruct::_narrow(dynany);
 239
 240       for(int i=0;i<nMember;i++)
 241         {
 242           DynamicAny::DynAny_var temp=dst->current_component();
 243           const char* name=mseq[i].name;
 244           std::cerr << name << std::endl;
 245           CORBA::Any* a=m[name];
 246           temp->from_any(*a);
 247           //delete intermediate any
 248           delete a;
 249           dst->next();
 250         }
 251       CORBA::Any_var structany=dst->to_any();
 252       dst->destroy();
 253
 254       /*
 255       for(int i=0;i<nMember;i++)
 256         {
 257               const char * name=tst->memberName(i);
 258               //TypeCode* tm=tst->memberType(i);
 259               //do not test member presence : test has been done in ToYacs convertor
 260               CORBA::Any* a=m[name];
 261               members[i].id=CORBA::string_dup(name);
 262               members[i].value=*a;
 263               //delete intermediate any
 264               delete a;
 265          }
 266          */
 267
 268
 269       //DII invoke
 270       CORBA::TypeCode_var tcout=orb->create_sequence_tc(0,content_type);
 271
 272       CORBA::Request_var req = echoref->_request("echoStruct2");
 273       //CORBA::Request_var req = echoref->_request("echoObjectVec");
 274       CORBA::NVList_ptr arguments = req->arguments() ;
 275
 276       arguments->add_value( "s1" , structany , CORBA::ARG_IN ) ;
 277       //arguments->add_value( "s1" , seqany , CORBA::ARG_IN ) ;
 278
 279       CORBA::Any out;
 280       out.replace(ts, (void*) 0);
 281       //out.replace(tcout, (void*) 0);
 282       arguments->add_value( "s2" , out , CORBA::ARG_OUT );
 283
 284       req->set_return_type(CORBA::_tc_void);
 285       //user exceptions
 286       //req->exceptions()->add(eo::_tc_SALOME_Exception);
 287
 288       req->invoke();
 289       CORBA::Exception *exc =req->env()->exception();
 290       if( exc )
 291         {
 292           std::cerr << "The raised exception is of Type:" << exc->_name() << std::endl;
 293           if(strcmp(exc->_name(),"MARSHAL") == 0)
 294             {
 295               const char* ms = ((CORBA::MARSHAL*)exc)->NP_minorString();
 296               if (ms)
 297                 std::cerr << "(CORBA::MARSHAL: minor = " << ms << ")" << std::endl;
 298             }
 299         }
 300
 301       //DII on echoObj2
 302       std::cerr << "Before request" << std::endl;
 303       req = echoref->_request("echoObj2");
 304       std::cerr << "After request" << std::endl;
 305       req->add_in_arg() <<= Objref;
 306       std::cerr << "After add_in_arg" << std::endl;
 307       req->add_out_arg() <<= Objout;
 308       std::cerr << "After add_out_arg" << std::endl;
 309       req->set_return_type(CORBA::_tc_void);
 310       std::cerr << "After set_return_type" << std::endl;
 311       req->invoke();
 312       std::cerr << "After invoke" << std::endl;
 313       exc =req->env()->exception();
 314       if( exc )
 315         {
 316           std::cerr << "The raised exception is of Type:" << exc->_name() << std::endl;
 317         }
 318       //end of DII on echoObj2
 319
 320       //DII on echoObjVec
 321       req = echoref->_request("echoObjVec");
 322       CORBA::Any *aAny = new CORBA::Any();
 323       *aAny <<= oob;
 324
 325       CORBA::TypeCode_var any_tc2=aAny->type();
 326       CORBA::TypeCode_var tc2=orb->create_sequence_tc(0,any_tc2);
 327       DynamicAny::DynAny_var dynany2 = dynFactory->create_dyn_any_from_type_code(tc2);
 328       DynamicAny::DynSequence_var ds2 = DynamicAny::DynSequence::_narrow(dynany2);
 329       ds2->set_length(2);
 330       DynamicAny::DynAny_var temp=ds2->current_component();
 331       temp->from_any(*aAny);
 332       ds2->next();
 333       temp=ds2->current_component();
 334       CORBA::Any *aAny2 = new CORBA::Any();
 335       *aAny2 <<= cob;
 336       CORBA::Object_var zzobj ;
 337       *aAny2 >>= CORBA::Any::to_object(zzobj) ;
 338       temp->insert_reference(zzobj);
 339       ds2->next();
 340
 341       CORBA::Any_var seqany2=ds2->to_any();
 342       ds2->destroy();
 343
 344       arguments = req->arguments() ;
 345       arguments->add_value( "s1" , seqany2 , CORBA::ARG_IN ) ;
 346
 347       CORBA::Any out2;
 348       out2.replace(tc2, (void*) 0);
 349       arguments->add_value( "s2" , out2 , CORBA::ARG_OUT );
 350       req->set_return_type(CORBA::_tc_void);
 351       req->invoke();
 352
 353       CORBA::Exception *exc2 =req->env()->exception();
 354       if( exc2 )
 355         {
 356           std::cerr << "The raised exception is of Type:" << exc2->_name() << std::endl;
 357           if(strcmp(exc2->_name(),"MARSHAL") == 0)
 358             {
 359               const char* ms = ((CORBA::MARSHAL*)exc2)->NP_minorString();
 360               if (ms)
 361                 std::cerr << "(CORBA::MARSHAL: minor = " << ms << ")" << std::endl;
 362             }
 363         }
 364       else
 365         {
 366           CORBA::Any *ob=arguments->item(1)->value();
 367           DynamicAny::DynAny_var dynany= dynFactory->create_dyn_any(*ob);
 368           DynamicAny::DynSequence_ptr ds=DynamicAny::DynSequence::_narrow(dynany);
 369           DynamicAny::AnySeq_var as=ds->get_elements();
 370           int length=as->length();
 371           DEBTRACE(length);
 372           for(int i=0;i<length; i++)
 373             {
 374               CORBA::TypeCode_var t=as[i].type();
 375               DEBTRACE(t->id());
 376               eo::Obj_ptr xobj;
 377               as[i] >>= xobj;
 378               DEBTRACE(xobj->_PD_repoId);
 379               xobj->echoLong(12);
 380             };
 381         }
 382
 383       //end of DII on echoObjVec
 384
 385       // Delete allocated objects to remove memory leaks (valgrind tests)
 386
 387       orb->destroy();
 388     }
 389   catch(DynamicAny::DynAny::TypeMismatch& ex)
 390     {
 391       std::cerr << "Caught a DynamicAny::DynAny::TypeMismatch exception" << std::endl;
 392     }
 393   catch(DynamicAny::DynAny::InvalidValue& ex)
 394     {
 395       std::cerr << "Caught a DynamicAny::DynAny::InvalidValue exception" << std::endl;
 396     }
 397   catch(CORBA::COMM_FAILURE& ex)
 398     {
 399       std::cerr << "Caught system exception COMM_FAILURE -- unable to contact the object." << std::endl;
 400     }
 401   catch(CORBA::SystemException&)
 402     {
 403       std::cerr << "Caught a CORBA::SystemException." << std::endl;
 404     }
 405   catch(CORBA::Exception&)
 406     {
 407       std::cerr << "Caught CORBA::Exception." << std::endl;
 408     }
 409   catch(omniORB::fatalException& fe)
 410     {
 411       std::cerr << "Caught omniORB::fatalException:" << std::endl;
 412       std::cerr << "  file: " << fe.file() << std::endl;
 413       std::cerr << "  line: " << fe.line() << std::endl;
 414       std::cerr << "  mesg: " << fe.errmsg() << std::endl;
 415     }
 416   catch(...)
 417     {
 418       std::cerr << "Caught unknown exception." << std::endl;
 419     }
 420   return 0;
 421 }