/* 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 #include /** * @class ConfigRetriever * @brief Used by nodes (DB, MGM, API) to get their config from MGM server. */ class ConfigRetriever { public: ConfigRetriever(const char * _connect_string, Uint32 version, Uint32 nodeType); ~ConfigRetriever(); int do_connect(int no_retries, int retry_delay_in_seconds, int verbose); /** * Get configuration for current 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 ndb_mgm_configuration object if succeeded, * NULL if erroneous local config file or configuration error. */ struct ndb_mgm_configuration * getConfig(); void resetError(); int hasError(); const char * getErrorString(); /** * @return Node id of this node (as stated in local config or connectString) */ Uint32 allocNodeId(int no_retries, int retry_delay_in_seconds); /** * Get config using socket */ struct ndb_mgm_configuration * getConfig(NdbMgmHandle handle); /** * Get config from file */ struct ndb_mgm_configuration * getConfig(const char * file); /** * Verify config */ bool verifyConfig(const struct ndb_mgm_configuration *, Uint32 nodeid); Uint32 get_mgmd_port() const; const char *get_mgmd_host() const; const char *get_connectstring(char *buf, int buf_sz) const; NdbMgmHandle get_mgmHandle() { return m_handle; }; Uint32 get_configuration_nodeid() const; private: BaseString errorString; enum ErrorType { CR_NO_ERROR = 0, CR_ERROR = 1, CR_RETRY = 2 }; ErrorType latestErrorType; void setError(ErrorType, const char * errorMsg); Uint32 _ownNodeId; /* Uint32 m_mgmd_port; const char *m_mgmd_host; */ Uint32 m_version; Uint32 m_node_type; NdbMgmHandle m_handle; }; #endif