1 files changed, 171 insertions, 0 deletions
diff --git a/rasmgr/rasmgr_dbm.hh b/rasmgr/rasmgr_dbm.hh
new file mode 100644
index 0000000..78e7a8c
--- /dev/null
+++ b/rasmgr/rasmgr_dbm.hh
@@ -0,0 +1,171 @@
+/*
+* This file is part of rasdaman community.
+*
+* Rasdaman community 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 3 of the License, or
+* (at your option) any later version.
+*
+* Rasdaman community 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 rasdaman community.  If not, see <http://www.gnu.org/licenses/>.
+*
+* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
+rasdaman GmbH.
+*
+* For more information please see <http://www.rasdaman.org>
+* or contact Peter Baumann via <baumann@rasdaman.com>.
+/
+/**
+ * SOURCE: rasmgr_dbm.hh
+ *
+ * MODULE: rasmgr
+ * CLASS:  DatabaseHost, DatabaseHostManager, Database, DatabaseManager
+ *
+ * COMMENTS:
+ *   none
+ *
+*/
+
+#ifndef RASMGR_DBM_HH
+#define RASMGR_DBM_HH
+
+#include "rasmgr.hh"
+#include "rasmgr_config.hh"
+//#include "rasmgr_srv.hh"
+
+class DatabaseHost 
+  {
+    public:
+      DatabaseHost();
+      ~DatabaseHost();
+      
+      void  init(const char* hostName,const char *connectString);      
+      
+      const char* getName();
+      const char* getConnectionString();
+      void  changeConnectionString(const char *connectString);
+      void  changeName(const char *newName);
+      void  regStartServer();
+      void  regDownServer();
+      //void  incrConnServers();
+      //void  decrConnServers();
+      //void  incrConnDatabases();
+      //void  decrConnDatabases();
+      bool  prepareToBeRemoved();
+      bool  isBusy();
+      bool  isValid();
+    private:
+      char hostName[100];
+      char connectString[100];
+      int  activServers;
+      //int  connServers;
+      //int  connDatabases;
+      bool valid;
+   };
+
+class DatabaseHostManager
+  { 
+    public:
+      DatabaseHostManager();
+      ~DatabaseHostManager();
+      bool insertNewHost(const char* hostName,const char* connectString);
+      bool removeHost(const char* hostName);
+      int  countHosts();
+      DatabaseHost& operator[](int);
+      DatabaseHost& operator[](const char* hostName);
+      bool reset();
+      bool acceptChangeName(const char *oldName,const char *newName);      
+    private:
+      bool testUniqueness(const char* hostName);
+      list<DatabaseHost> hostList;
+      DatabaseHost       protElem;      
+   };
+   
+extern DatabaseHostManager dbHostManager;
+
+
+//*****************************************************
+
+class RasServer;
+
+class Database 
+  {
+    public:
+      Database();
+      ~Database();
+      
+      void  init(const char* databaseName);      
+      const char* getName();
+      void  changeName(const char* databaseName);
+      
+      static const char* getDescriptionHeader(char *destBuffer);
+             const char* getDescription(char *destBuffer);
+
+      bool  connectToDBHost(const char* hostName);
+      bool  disconnectFromDBHost(const char* hostName);
+      bool  isConnectedToDBHost(const char* hostName);
+      int   countConnectionsToDBHosts();
+      const char* getDBHostName(int);
+      
+      bool  connectToRasServer(const char *serverName);
+      bool  disconnectFromRasServer(const char *serverName);
+      bool  isConnectedToRasServer(const char *serverName);
+      int   countConnectionsToRasServers();
+      const char* getRasServerName(int);
+      
+      void  disconnectForRemove();
+      
+      void startWriteTransaction();
+      void endWriteTransaction();
+      void startReadTransaction();
+      void endReadTransaction();
+      
+      int  getWriteTransactionCount();
+      int  getReadTransactionCount();
+      bool isBusy();
+      
+      void setTraceWriteTrans(bool);
+      
+      bool isValid();
+    private:
+      bool checkConnection(DatabaseHost &);
+      bool checkConnection(RasServer &);
+      char databaseName[100];
+      list<DatabaseHost*> hostPtrList;
+      list<RasServer*>    rasPtrList;
+      
+      bool traceWT;
+      int countWriteTransactions;
+      int countReadTransactions;
+      
+      bool valid;  
+   };
+
+class DatabaseManager
+  { 
+    public:
+      DatabaseManager();
+      ~DatabaseManager();
+      bool insertNewDatabase(const char* databaseName);
+      bool removeDatabase(const char* databaseName);
+      int  countDatabases();
+      Database& operator[](int);
+      Database& operator[](const char*);
+      void disconnectAllDatabasesFromDBH(const char* dbhName);
+      bool reset();
+      bool acceptChangeName(const char *oldName,const char *newName);      
+    private:
+      bool testUniqueness(const char* dbName);
+      list<Database> dtbList;      
+      Database      protElem; 
+   };
+   
+extern DatabaseManager dbManager;
+
+
+#endif