/* Copyright (C) 2003 MySQL AB 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 ConfigRetriever_H #define ConfigRetriever_H #include #include /** * @class ConfigRetriever * @brief Used by nodes (DB, MGM, API) to get their config from MGM server. */ class ConfigRetriever { public: ConfigRetriever(); ConfigRetriever(const int id, const char* remoteHost, const int port); ~ConfigRetriever(); /** * Read local config * @return Own node id, -1 means fail */ int init(bool onlyNodeId = false); /** * Get configuration for current (nodeId given in local config file) node. * * Configuration is fetched from one MGM server configured in local config * file. The method loops over all the configured MGM servers and tries * to establish a connection. This is repeated until a connection is * established, so the function hangs until a connection is established. * * @return Properties object if succeeded, * NULL if erroneous local config file or configuration error. */ class Properties * getConfig(const char * nodeType, int versionId); const char * getErrorString(); /** * Sets connectstring which can be used instead of local config file */ void setConnectString(const char * connectString); /** * Sets name of local config file (usually not needed) */ void setLocalConfigFileName(const char * connectString); /** * Sets connectstring which can be used instead of local config file * environment variables and Ndb.cfg has precidence over this */ void setDefaultConnectString(const char * defaultConnectString); /** * @return Node id of this node (as stated in local config or connectString) */ inline Uint32 getOwnNodeId() { return _ownNodeId; } /** * Get configuration object */ class Properties * getConfig(int versionId); /** * Get config using socket */ class Properties * getConfig(const char * mgmhost, unsigned int port, Uint32 nodeId, int versionId); /** * Get config from file */ class Properties * getConfig(const char * filename, Uint32 nodeId, int versionId); private: char * errorString; enum ErrorType { CR_ERROR = 0, CR_RETRY = 1 }; ErrorType latestErrorType; void setError(ErrorType, const char * errorMsg); /** * Verifies that received configuration is correct */ bool verifyProperties(const char* nodeType, Properties *p, Uint32 nodeId, int versionId); char * _localConfigFileName; struct LocalConfig * _localConfig; int _ownNodeId; char * m_connectString; char * m_defaultConnectString; }; #endif