it_bus_pdk/db_config.h

#ifndef _IT_DB_CONFIG_H_
#define _IT_DB_CONFIG_H_

// @Copyright 2004 IONA Technologies, Plc. All Rights Reserved.
//

#ifndef IT_MINIMISE_INCLUDES
#include <it_bus/bus.h>
#endif

#include <it_dsa/vector.h>
#include <it_bus/types.h>
#include <it_bus/api_defines.h>
#include <it_bus/bus_type_alias.h>
#include <omg/orb.hh>
#include <orbix/configuration.hh>
#include <it_bus_pdk/db_exception.h>
#include <it_bus/logging_defs.h>

// Forward declare some required structures
//
struct __db;
typedef struct __db DB;
struct __db_env;
typedef struct __db_env DB_ENV;
struct __dbc;           
typedef struct __dbc DBC;

namespace IT_Bus
{   
    class DBEnv;
    class QName;
    class String;

    class IT_DBM_API DBConfig
    {
      public:           
        
        DBConfig(
            IT_Bus::Bus_ptr bus
        ) throw((DBException));

        virtual
        ~DBConfig();

        virtual void
        init_configuration();

        virtual void
        init_env();

        virtual DBEnv*
        get_env() 
        throw((DBException));

        virtual IT_Bus::Bus_ptr
        get_bus();

        // Configuration related functions

        virtual const char*
        get_env_home();

        virtual const char*
        get_env_name(); 

        virtual IT_Config::ConfigList*
        get_replica_list();     

        virtual IT_Bool
        is_replicated();

        virtual IT_Bool
        is_master();

        virtual unsigned int
        get_pre_sync_wait_period();

        virtual unsigned int
        get_sync_retry_attempts();

        virtual IT_Long
        get_priority();

        virtual IT_Long
        get_port();

        virtual const char*
        get_replica_name();     

        virtual unsigned int
        get_db_open_retry_attempts();

        virtual unsigned int
        get_inter_db_open_sleep_period();

        virtual unsigned int
        get_ping_retry_interval();

        virtual unsigned int
        get_max_ping_retries();

        virtual unsigned int
        get_ping_lifetime();

        virtual unsigned int
        get_roundtrip_timeout();

        virtual unsigned int
        get_election_timeout();

        virtual unsigned int
        get_cnxn_creation_timeout();

        virtual const char*
        get_errfile_name();

        virtual IT_Bool
        get_verbose_logging();

        virtual IT_Bool
        get_download_files();

        virtual unsigned long
        get_checkpoint_period();

        virtual unsigned long
        get_max_buffered_msgs();

        virtual unsigned long
        get_max_msg_buffer_size();

        virtual IT_Bool
        get_allow_minority_master();

        virtual IT_Bool
        get_use_shutdown_hook();

        virtual IT_Bool
        get_auto_demotion();

        virtual const char*
        get_orb_scope();

        void
        mark_as_write_operations(
            const IT_Vector<IT_Bus::String>&    operations,         
            const IT_Bus::QName&                service,
            const IT_Bus::String&               port,
            const IT_Bus::String&               wsdl_url
        ) throw((DBException));

      private:

        IT_Bus::Bus_var             m_bus;
        DBEnv*                      m_db_env;
        CORBA::String_var           m_db_home;
        CORBA::String_var           m_db_env_name;      
        CORBA::String_var           m_replica_name;
        CORBA::String_var           m_orb_scope;
        IT_Config::ConfigList_var   m_replicas_from_config;
        IT_Long                     m_priority;
        IT_Long                     m_port;
        IT_Long                     m_db_open_retry_attempts;
        IT_Long                     m_inter_db_open_sleep_period;
        IT_Long                     m_pre_sync_wait_period;
        IT_Long                     m_sync_retry_attempts;
        IT_Long                     m_max_ping_retries;
        IT_Long                     m_ping_lifetime;
        IT_Long                     m_ping_retry_interval;
        IT_Long                     m_roundtrip_timeout;
        IT_Long                     m_election_timeout;
        IT_Long                     m_cnxn_creation_timeout;
        CORBA::String_var           m_errfile_name;
        IT_Bool                     m_verbose_logging;
        IT_Bool                     m_allow_minority_master;
        IT_Bool                     m_use_shutdown_hook;
        IT_Bool                     m_auto_demotion;
        IT_Bool                     m_download_files;
        IT_Long                     m_checkpoint_period;
        IT_Long                     m_max_buffered_msgs;
        IT_Long                     m_max_msg_buffer_size;      

        // private and unimplemented to prevent copying
        DBConfig(const DBConfig&);
        void operator=(const DBConfig&);

        IT_DECLARE_BUS_LOGGER_MEM
    };
}

#endif  

---