SMDBServer.h

#ifndef _SMDBServer_H_
#define _SMDBServer_H_
// -----------------------------------------------------------------------------
#include "DBServer_MySQL.h"
#include "SMInterface.h"
#include "SharedMemory.h"
// -----------------------------------------------------------------------------
class SMDBServer:
    public DBServer_MySQL
{
    public:
        SMDBServer( UniSetTypes::ObjectId objId, UniSetTypes::ObjectId shmID, SharedMemory* ic=0,
                    const std::string prefix="dbserver" );
        virtual ~SMDBServer();
    
        static SMDBServer* init_smdbserver( int argc, const char* const* argv, 
                            UniSetTypes::ObjectId shmID, SharedMemory* ic=0,
                            const std::string prefix="dbserver" );

        static void help_print( int argc, const char* const* argv );

    protected:
        SMDBServer();

        virtual void initDB(DBInterface *db);
        void waitSMReady();
        void step();

        SMInterface* shm;

    private:
        bool aiignore;

        PassiveTimer ptHeartBeat;
        UniSetTypes::ObjectId sidHeartBeat;
        int maxHeartBeat;
        IOController::AIOStateList::iterator aitHeartBeat;
        UniSetTypes::ObjectId test_id;

        std::string db_locale;
        std::string prefix;
};
// -----------------------------------------------------------------------------
#endif // _SMDBServer_H_
// -----------------------------------------------------------------------------