---

orb.hh

/*
*  Name:      orb.hh
*  Author:    Rafael Jesus Alcantara Perez
*  Summary:   CORBA ORB class
*  Date:      $Date: 2003/04/14 00:18:31 $
*  Revision:  $Revision: 1.1 $
*
*  Copyright (C) 2001-2002  Rafael Jesus Alcantara Perez <rafa@dedalo-ing.com>
*
*  This program is free software; you can redistribute it and/or modify
*  it under the terms of the GNU General Public License as published by
*  the Free Software Foundation; either version 2 of the License, or
*  (at your option) any later version.
*
*  This program 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 General Public License for more details.
*
*  You should have received a copy of the GNU General Public License
*  along with this program; if not, write to the Free Software
*  Foundation, Inc., 59 Temple Place, Suite 330, Boston,
*  MA 02111-1307, USA.
*/

#ifndef _MPCL_NET_CORBA_ORB__
#define _MPCL_NET_CORBA_ORB__

#include <algorithm>
#include <list>
#include "../../text/string.hh"
#include CORBA_H


namespace mpcl
{

  namespace net
  {

    namespace corba
    {

      using text::TString;

      class TOrb
      {

        private:

          bool   gIsColocated;

          bool   gHasNameService;

          CORBA::ORB_var   qtOrb;

          PortableServer::POA_var   qtPoa;

          PortableServer::POAManager_var   qtPoaManager;

          CosNaming::NamingContext_var   qtRootNamingContext;


        private:

          //
          //  C O N S T R U C T O R S
          //

          CosNaming::NamingContext_var bindContext ( CosNaming::NamingContext_var& rqtNAMING_CONTEXT ,
                                                     const TString&                rkyCONTEXT_NAME   );

          CosNaming::NamingContext_var bindContext (const TString& rkyCONTEXT_NAME)
          {
            return bindContext (qtRootNamingContext, rkyCONTEXT_NAME);
          }


        public:

          //
          //  C O N S T R U C T O R S
          //

          TOrb (int iPARAMETER_COUNT, const char** ppkcPARAMETERS);

          ~TOrb (void)
          {
            qtOrb->destroy();
          }

          template <typename TObject, typename TObjectReference>
          TObjectReference enrol (TObject* ptOBJECT)
          {
            TObjectReference   qtObject;

            qtPoa->activate_object (ptOBJECT);
            qtObject = ptOBJECT->_this();
            ptOBJECT->_remove_ref();
            return qtObject;
          }

          template <typename TObject, typename TObjectReference>
          TObjectReference enrol (TObject* ptOBJECT, const TString& rkyCOMPOUND_NAME)
          {
            //
            //  To clarify declarations.
            //
            typedef
              std::list<TString>
              TStringList;

            TStringList::const_iterator    I;
            TObjectReference               qtObject;
            TStringList                    tContextList;
            CosNaming::Name                tObjectName;
            CosNaming::NamingContext_var   qtCurrentContext;
            CosNaming::NamingContext_var   qtNewContext;
            TString                        yObjectId;
            TString                        yObjectIdAndKind;
            TString                        yObjectKind;
            TString::size_type             zDotPosition;

  // <FIXME comment="is this needed?">
            qtObject = enrol<TObject, TObjectReference> (ptOBJECT);
  // </FIXME>
            Split ( rkyCOMPOUND_NAME.begin()                              ,
                    rkyCOMPOUND_NAME.end()                                ,
                    '/'                                                   ,
                    std::back_insert_iterator<TStringList> (tContextList) );
            qtCurrentContext = qtRootNamingContext;
            yObjectIdAndKind = tContextList.back();
            tContextList.pop_back();
            for (I = tContextList.begin(); ( I != tContextList.end() ) ;++I)
            {
              qtNewContext     = bindContext (qtCurrentContext, *I);
              qtCurrentContext = qtNewContext;
            }

            //
            //  Binds the new object into current context.
            //
            zDotPosition = yObjectIdAndKind.find ('.');
            if ( !zDotPosition )
            {
              yObjectId = yObjectIdAndKind;
            }
            else
            {
              yObjectId   = yObjectIdAndKind.substr (0, zDotPosition);
              yObjectKind = yObjectIdAndKind.substr (zDotPosition + 1);
            }
            tObjectName.length(1);
            tObjectName [0].id   = yObjectId.c_str();
            tObjectName [0].kind = yObjectKind.c_str();
            try
            {
              qtCurrentContext->bind (tObjectName, qtObject);
            }
            catch (const CosNaming::NamingContext::AlreadyBound&)
            {
              qtCurrentContext->rebind (tObjectName, qtObject);
            }
            return qtObject;
          }

          void finish (void)
          {
            qtOrb->shutdown (false);
          }

          template <typename TObject, typename TObjectReference>
          TObjectReference request (const TString& rkyOBJECT_IDENTIFIER)
          {
            CORBA::Object_var   qtObject = qtOrb->string_to_object (rkyOBJECT_IDENTIFIER.c_str());

            return TObject::_narrow (qtObject);
          }

          template <typename TObject, typename TObjectReference>
          TObjectReference request (const char* pkcOBJECT_IDENTIFIER)
          {
            CORBA::Object_var   qtObject = qtOrb->string_to_object (pkcOBJECT_IDENTIFIER);

            return TObject::_narrow (qtObject);
          }

          void setColocated (bool gCOLOCATED)
          {
            gIsColocated = gCOLOCATED;
          }

          int start (void)
          {
            qtPoaManager->activate();
            if ( !gIsColocated )
            {
              qtOrb->run();
            }
            return 0;
          }


        public:

          //
          //  S E L E C T O R S
          //

          template <typename TObjectReference>
          TString name (TObjectReference qtOBJECT)
          {
            return qtOrb->object_to_string (qtOBJECT);
          }

      };  // class TOrb

    }  // namespace corba

  }  // namespace net

}  // namespace mpcl


#endif  // not _MPCL_NET_CORBA_ORB__

---