client/protocol/corba/CorbaDriverFactory.h

Go to the documentation of this file.

/*------------------------------------------------------------------------------
Name:      CorbaDriverFactory.h
Project:   xmlBlaster.org
Copyright: xmlBlaster.org, see xmlBlaster-LICENSE file
Comment:   The Factory for the client driver for the corba protocol
------------------------------------------------------------------------------*/

#ifndef _CLIENT_PROTOCOL_CORBA_CORBADRIVERFACTORY
#define _CLIENT_PROTOCOL_CORBA_CORBADRIVERFACTORY

#include <util/xmlBlasterDef.h>
#include <client/protocol/corba/CorbaDriver.h>
#include <util/objman.h> // for managed objects






namespace org {
 namespace xmlBlaster {
  namespace client {
   namespace protocol {
    namespace corba {

typedef std::pair<CorbaDriver*, int>  DriverEntry;
typedef std::map<org::xmlBlaster::util::Global*, DriverEntry> DriversMap;

class Dll_Export CorbaDriverFactory : public org::xmlBlaster::util::thread::Thread
{
friend CorbaDriverFactory& getFactory(org::xmlBlaster::util::Global& global, CORBA::ORB_ptr orb=NULL);

// required for the managed objects
friend class Object_Lifetime_Manager;
friend class ManagedObject;

private:
   const std::string   ME;
   //org::xmlBlaster::util::Global&        global_;
   //org::xmlBlaster::util::I_Log&           log_;
   DriversMap     drivers_;         // the std::map containing all drivers created by this factory
   bool           doRun_;           // the command: if set to 'false' the thread will stop.
   bool           isRunning_;       // the status: if the thread is running it is 'true'
   org::xmlBlaster::util::thread::Mutex          mutex_,           // the mutex passed to all CorbaDriver instances (for singlethreaded)
                  getterMutex_;     // the mutex used for creating/deleting CorbaDriver instances
   bool           orbIsThreadSafe_; // flag telling if the orb is a singletheraded or multithreaded orb
   CORBA::ORB_ptr orb_;             // the orb used (either created here or passed in constructor
   bool           isOwnOrb_;        // 'true' if the orb has been created by this factory.

   static CorbaDriverFactory* factory_;

   void run();

   bool orbRun();

   CorbaDriverFactory(org::xmlBlaster::util::Global& global, CORBA::ORB_ptr orb=NULL);

   CorbaDriverFactory(const CorbaDriverFactory& factory);
   CorbaDriverFactory& operator =(const CorbaDriverFactory& factory);

public:
   ~CorbaDriverFactory(); // Should be private, VC7 is ok with private, g++ 3.3 does not like it

   static CorbaDriverFactory& getFactory(org::xmlBlaster::util::Global& global, CORBA::ORB_ptr orb=NULL);

   CorbaDriver& getDriverInstance(org::xmlBlaster::util::Global* global);

   int killDriverInstance(org::xmlBlaster::util::Global* global);

};

}}}}} // namespaces

#endif