Commit bbe0d7dd authored by unknown's avatar unknown
Browse files

Merge tulin@bk-internal.mysql.com:/home/bk/mysql-4.1 

into poseidon.ndb.mysql.com:/home/tomas/mysql-4.1-mysqladmin
parents f89b4dce f3374eec

client/Makefile.am

+1 −0
Original line number Diff line number Diff line
@@ -29,6 +29,7 @@ noinst_HEADERS = sql_string.h completion_hash.h my_readline.h \ 
				client_priv.h

mysqladmin_SOURCES =		mysqladmin.cc

mysql_SOURCES =			mysql.cc readline.cc sql_string.cc completion_hash.cc

mysqladmin_SOURCES =		mysqladmin.cc

mysql_LDADD =			@readline_link@ @TERMCAP_LIB@ $(LDADD) $(CXXLDFLAGS)

mysqlbinlog_LDADD =		$(LDADD) $(CXXLDFLAGS)

mysql_DEPENDENCIES=		$(LIBRARIES) $(pkglib_LTLIBRARIES) $(DEPLIB)

ndb/include/Makefile.am

+0 −1
Original line number Diff line number Diff line
@@ -28,7 +28,6 @@ ndbapi/NdbIndexScanOperation.hpp \ 
ndbapi/ndberror.h



mgmapiinclude_HEADERS = \

mgmapi/LocalConfig.hpp \

mgmapi/mgmapi.h \

mgmapi/mgmapi_debug.h

ndb/include/mgmapi/mgmapi.h

+22 −8
Original line number Diff line number Diff line
@@ -356,11 +356,28 @@ extern "C" { 
  /** 

   * Create a handle to a management server

   *

   * @param   connect_string Connect string to the management server, 

   *

   * @return                 A management handle<br>

   *                         or NULL if no management handle could be created. 

   */

  NdbMgmHandle ndb_mgm_create_handle();

  

  /** 

   * Set connecst string to management server

   *

   * @param   handle         Management handle

   * @param   connect_string Connect string to the management server, 

   *

   * @return                -1 on error.

   */

  int ndb_mgm_set_connectstring(NdbMgmHandle handle,

				const char *connect_string);



  int ndb_mgm_get_configuration_nodeid(NdbMgmHandle handle);

  int ndb_mgm_get_connected_port(NdbMgmHandle handle);

  const char *ndb_mgm_get_connected_host(NdbMgmHandle handle);



  /**

   * Destroy a management server handle

   *
@@ -378,11 +395,10 @@ extern "C" { 
   * Connect to a management server

   *

   * @param   handle        Management handle.

   * @param   mgmsrv        Hostname and port of the management server, 

   *                        "hostname:port".

   * @return                -1 on error.

   */

  int ndb_mgm_connect(NdbMgmHandle handle, const char * mgmsrv);

  int ndb_mgm_connect(NdbMgmHandle handle, int no_retries,

		      int retry_delay_in_seconds, int verbose);

  

  /**

   * Disconnect from a management server
@@ -709,9 +725,7 @@ extern "C" { 
  void ndb_mgm_destroy_configuration(struct ndb_mgm_configuration *);



  int ndb_mgm_alloc_nodeid(NdbMgmHandle handle,

			   unsigned version,

			   unsigned *pnodeid,

			   int nodetype);

			   unsigned version, int nodetype);

  /**

   * Config iterator

   */

ndb/include/mgmcommon/ConfigRetriever.hpp

+16 −10
Original line number Diff line number Diff line
@@ -20,7 +20,6 @@ 
#include <ndb_types.h>

#include <mgmapi.h>

#include <BaseString.hpp>

#include <LocalConfig.hpp>



/**

 * @class ConfigRetriever
@@ -28,10 +27,11 @@ 
 */

class ConfigRetriever {

public:

  ConfigRetriever(LocalConfig &local_config, Uint32 version, Uint32 nodeType);

  ConfigRetriever(const char * _connect_string,

		  Uint32 version, Uint32 nodeType);

  ~ConfigRetriever();



  int do_connect(int exit_on_connect_failure= false);

  int do_connect(int no_retries, int retry_delay_in_seconds, int verbose);

  

  /**

   * Get configuration for current node.
@@ -46,12 +46,14 @@ public: 
   */

  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();

  Uint32 allocNodeId(int no_retries, int retry_delay_in_seconds);



  /**

   * Get config using socket
@@ -68,22 +70,26 @@ public: 
   */

  bool verifyConfig(const struct ndb_mgm_configuration *, Uint32 nodeid);



  Uint32 get_mgmd_port() const {return m_mgmd_port;};

  const char *get_mgmd_host() const {return m_mgmd_host;};

  Uint32 get_mgmd_port() const;

  const char *get_mgmd_host() const;



  Uint32 get_configuration_nodeid() const;

private:

  BaseString errorString;

  enum ErrorType {

    CR_ERROR = 0,

    CR_RETRY = 1

    CR_NO_ERROR = 0,

    CR_ERROR = 1,

    CR_RETRY = 2

  };

  ErrorType latestErrorType;

  

  void setError(ErrorType, const char * errorMsg);

  

  struct LocalConfig&   _localConfig;

  Uint32      _ownNodeId;

  /*

  Uint32      m_mgmd_port;

  const char *m_mgmd_host;

  */



  Uint32 m_version;

  Uint32 m_node_type;

ndb/include/ndbapi/ndb_cluster_connection.hpp

+0 −2
Original line number Diff line number Diff line
@@ -19,7 +19,6 @@ 
#define CLUSTER_CONNECTION_HPP



class TransporterFacade;

class LocalConfig;

class ConfigRetriever;

class NdbThread;
@@ -38,7 +37,6 @@ private: 
  void connect_thread();

  char *m_connect_string;

  TransporterFacade *m_facade;

  LocalConfig *m_local_config;

  ConfigRetriever *m_config_retriever;

  NdbThread *m_connect_thread;

  int (*m_connect_callback)(void);