yacsSrv.cxx File Reference

#include <Python.h>
#include <yacs.hh>
#include "RuntimeSALOME.hxx"
#include "Proc.hxx"
#include "Exception.hxx"
#include "Executor.hxx"
#include "Dispatcher.hxx"
#include "parsers.hxx"
#include <iostream>
#include <sstream>
#include <set>
#include "YacsTrace.hxx"

Include dependency graph for yacsSrv.cxx:

Go to the source code of this file.

Classes
class	MyDispatcher
class	Yacs_i
class	Proc_i

Functions
static CORBA::Boolean	bindObjectToName (CORBA::ORB_ptr, CORBA::Object_ptr, const char *)
static ostream &	operator<< (ostream &os, const CORBA::Exception &e)
int	main (int argc, char **argv)

Variables
YACS::YACSLoader::YACSLoader *	loader
CORBA::ORB_ptr	orb
YACS_ORB::YACS_Gen_var	myyacsref

Function Documentation

bindObjectToName()

static CORBA::Boolean bindObjectToName ( CORBA::ORB_ptr  orb, CORBA::Object_ptr  objref, const char *  name  )

static

Definition at line 220 of file yacsSrv.cxx.

{
  CosNaming::NamingContext_var rootContext;
 
  try {
    // Obtain a reference to the root context of the Name service:
    CORBA::Object_var obj;
    obj = orb->resolve_initial_references("NameService");
 
    // Narrow the reference returned.
    rootContext = CosNaming::NamingContext::_narrow(obj);
    if( CORBA::is_nil(rootContext) ) {
      DEBTRACE("Failed to narrow the root naming context.");
      return 0;
    }
  }
  catch(CORBA::ORB::InvalidName& ex) {
    // This should not happen!
    DEBTRACE("Service required is invalid [does not exist]." );
    return 0;
  }
 
  try {
    // Bind a context called "test" to the root context:
 
    CosNaming::Name contextName;
    contextName.length(1);
    contextName[0].id   = (const char*) "test";       // string copied
    contextName[0].kind = (const char*) "my_context"; // string copied
    // Note on kind: The kind field is used to indicate the type
    // of the object. This is to avoid conventions such as that used
    // by files (name.type -- e.g. test.ps = postscript etc.)
 
    CosNaming::NamingContext_var testContext;
    try {
      // Bind the context to root.
      testContext = rootContext->bind_new_context(contextName);
    }
    catch(CosNaming::NamingContext::AlreadyBound& ex) {
      // If the context already exists, this exception will be raised.
      // In this case, just resolve the name and assign testContext
      // to the object returned:
      CORBA::Object_var obj;
      obj = rootContext->resolve(contextName);
      testContext = CosNaming::NamingContext::_narrow(obj);
      if( CORBA::is_nil(testContext) ) {
        DEBTRACE("Failed to narrow naming context.");
        return 0;
      }
    }
 
    // Bind objref with name name to the testContext:
    CosNaming::Name objectName;
    objectName.length(1);
    objectName[0].id   = name;   // string copied
    objectName[0].kind = (const char*) "Object"; // string copied
 
    try {
      testContext->bind(objectName, objref);
    }
    catch(CosNaming::NamingContext::AlreadyBound& ex) {
      testContext->rebind(objectName, objref);
    }
  }
  catch(CORBA::COMM_FAILURE& ex) {
    DEBTRACE("Caught system exception COMM_FAILURE -- unable to contact the "
             << "naming service.");
    return 0;
  }
  catch(CORBA::SystemException&) {
    DEBTRACE("Caught a CORBA::SystemException while using the naming service.");
    return 0;
  }
 
  return 1;
}

References DEBTRACE, testCppPluginInvokation::ex, and orb.

Referenced by main().

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 161 of file yacsSrv.cxx.

{
  YACS::ENGINE::RuntimeSALOME::setRuntime();
  loader= new YACS::YACSLoader::YACSLoader();
  MyDispatcher* disp=new MyDispatcher();
  YACS::ENGINE::Dispatcher::setDispatcher(disp);
 
  try 
  {
    orb = CORBA::ORB_init(argc, argv);
 
    {
      CORBA::Object_var obj = orb->resolve_initial_references("RootPOA");
      PortableServer::POA_var root_poa = PortableServer::POA::_narrow(obj);
      // POA manager
      PortableServer::POAManager_var poa_man = root_poa->the_POAManager();
      poa_man->activate();
 
      // Create and activate servant
      Yacs_i* myyacs = new Yacs_i();
      // Obtain a reference to the object, and print it out as a
      // stringified IOR.
      obj = myyacs->_this();
      CORBA::String_var sior(orb->object_to_string(obj));
      DEBTRACE("'" << (char*)sior << "'");
      myyacsref = YACS_ORB::YACS_Gen::_narrow(obj);
 
      if( !bindObjectToName(orb, myyacsref,"Yacs") ) return 1;
 
      // Decrement the reference count of the object implementation, so
      // that it will be properly cleaned up when the POA has determined
      // that it is no longer needed.
      myyacs->_remove_ref();
    }
    orb->run();
  }
  catch(CORBA::SystemException&) {
    DEBTRACE("Caught CORBA::SystemException.");
  }
  catch(CORBA::Exception& ex) {
    DEBTRACE("Caught CORBA::Exception." << ex);
  }
  catch(omniORB::fatalException& fe) {
    DEBTRACE("Caught omniORB::fatalException:");
    DEBTRACE("  file: " << fe.file());
    DEBTRACE("  line: " << fe.line());
    DEBTRACE("  mesg: " << fe.errmsg());
  }
  catch(...) {
    DEBTRACE("Caught unknown exception." );
  }
 
  return 0;
}

References bindObjectToName(), DEBTRACE, testCppPluginInvokation::ex, loader, myyacsref, orb, YACS::ENGINE::Dispatcher::setDispatcher(), YACS::ENGINE::RuntimeSALOME::setRuntime(), and YACS::YACSLoader::YACSLoader().

operator<<()

static ostream & operator<< ( ostream &  os, const CORBA::Exception &  e  )

static

Definition at line 297 of file yacsSrv.cxx.

{
  CORBA::Any tmp;
  tmp<<= e;
  CORBA::TypeCode_var tc = tmp.type();
  const char *p = tc->name();
  if ( *p != '\0' ) {
    os<<p;
  }
  else  {
    os << tc->id();
  }
  return os;
}

References p.

Variable Documentation

loader

YACS::YACSLoader::YACSLoader* loader

Definition at line 38 of file yacsSrv.cxx.

Referenced by Yacs_i::Load(), and main().

myyacsref

YACS_ORB::YACS_Gen_var myyacsref

Definition at line 40 of file yacsSrv.cxx.

Referenced by main().

orb

CORBA::ORB_ptr orb

Definition at line 39 of file yacsSrv.cxx.

Referenced by bindObjectToName(), YACS::ENGINE::convertFromYacsStruct< CORBAImpl, CORBA::Any * >::convert(), YACS::ENGINE::convertFromYacsSequence< CORBAImpl, CORBA::Any * >::convert(), YACS::ENGINE::PythonNode::executeRemote(), YACS::HMI::GenericGui::GenericGui(), YACS::ENGINE::RuntimeSALOME::getCatalogOfComputeNodes(), YACS::HMI::GenericGui::getMachineList(), YACS::ENGINE::SalomeContainerTools::getResourceProperties(), YACS::HMI::BatchJobsListDialog::getSalomeLauncher(), SALOME_NamingService_Wrapper::init_orb(), YACS::ENGINE::SessionCataLoader::loadCata(), main(), YACS::ENGINE::InputStudyPort::putDataInStudy(), shutdownServers(), YACS::ENGINE::SalomeContainerToolsBase::Start(), and YACS::HMI::GuiExecutor::startResumeDataflow().