Orb.h

Go to the documentation of this file.

//                            Package   : omniEvents
// Orb.h                      Created   : 2003/12/04
//                            Author    : Alex Tingle
//
//    Copyright (C) 2003-2005 Alex Tingle.
//
//    This file is part of the omniEvents application.
//
//    omniEvents is free software; you can redistribute it and/or
//    modify it under the terms of the GNU Lesser General Public
//    License as published by the Free Software Foundation; either
//    version 2.1 of the License, or (at your option) any later version.
//
//    omniEvents is distributed in the hope that it will be useful,
//    but WITHOUT ANY WARRANTY; without even the implied warranty of
//    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
//    Lesser General Public License for more details.
//
//    You should have received a copy of the GNU Lesser General Public
//    License along with this library; if not, write to the Free Software
//    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//

#ifndef OMNIEVENTS__ORB_H
#define OMNIEVENTS__ORB_H

#ifdef HAVE_CONFIG_H
#  include "config.h"
#endif

#include <list>

#ifdef HAVE_OMNIORB3
#  include <omniORB3/CORBA.h>
#endif

#ifdef HAVE_OMNIORB4
#  include <omniORB4/CORBA.h>
#endif

#ifdef HAVE_OMNIORB4
#  define IFELSE_OMNIORB4(omniORB4_code,default_code) omniORB4_code
#  define IF_OMNIORB4(omniORB4_code) omniORB4_code
#else
#  define IFELSE_OMNIORB4(omniORB4_code,default_code) default_code
#  define IF_OMNIORB4(omniORB4_code)
#endif

#define DB(l,x) \
  {if(omniORB::trace(l)){omniORB::logger log("omniEvents: ");log<<x<<"\n";}}

#define NP_MINORSTRING(systemException) \
  ((systemException).NP_minorString()?(systemException).NP_minorString():"??")

#define AS_STR_2(x) #x
#define AS_STR_1(x) AS_STR_2(x)

#define HERE __FILE__ ":" AS_STR_1(__LINE__)

#ifdef HAVE_STD_STL
using namespace std;
#endif

namespace OmniEvents {

class Callback;

class Orb
{
private:
  static Orb _inst;
  typedef pair<CORBA::Request_ptr,Callback*> RequestCallback_t;
  list<RequestCallback_t> _deferredRequests;
  omni_mutex _deferredRequestsLock;
  bool _shutdownRequested;
  Orb():_shutdownRequested(false){}
  friend void OmniEvents_Orb_shutdown(int);

public:
  inline static Orb& inst()
  {
    return _inst;
  }
  ~Orb();

  CORBA::ORB_var               _orb;
  PortableServer::POA_var      _RootPOA;
  PortableServer::POA_var      _omniINSPOA;
  CosNaming::NamingContext_var _NameService;
#ifdef HAVE_OMNIORB4
  PortableServer::Current_ptr  _POACurrent;
#endif

  void resolveInitialReferences();
  
  void run();
  
  void deferredRequest(CORBA::Request_ptr req, Callback* callback=NULL);

  void cancelCallback(const Callback* callback);

  void reportObjectFailure(
    const char*       here,
    CORBA::Object_ptr obj,
    CORBA::Exception* ex
  );

  void shutdown(int) { _shutdownRequested=true; }
}; // end class Orb


template<class T>
typename T::_ptr_type string_to_(const char* oidStr)
{
  CORBA::Object_var obj =Orb::inst()._orb->string_to_object(oidStr);
  if(CORBA::is_nil(obj.in()))
    throw CORBA::BAD_PARAM();

#ifdef HAVE_OMNIORB4
  typename T::_var_type result =T::_unchecked_narrow(obj);
#else
  typename T::_var_type result =T::_narrow(obj);
#endif
  if(CORBA::is_nil(result.in()))
    throw CORBA::BAD_PARAM();

  return result._retn();
}

}; // end namespace OmniEvents

#endif // OMNIEVENTS__ORB_H

---