An error occurred fetching the project authors.
  1. 31 Dec, 2004 1 commit
  2. 23 Dec, 2004 1 commit
    • unknown's avatar
      Impl 2 of WL2278 - Dynamic port allocation of cluster nodes. · 233a33da
      unknown authored
      In "client connect thread", let the client read the port to connect to using
      ndb_mgm_get_connection_int_parameter.
      
      The request for the port is resent on every connect attempt.
      
      
      ndb/include/mgmapi/mgmapi_debug.h:
        Make ndb_mgm_get_connection_int_parameter return a Uint32 value - this is what Properties etc use, so we'll be consistent.
      ndb/include/transporter/TransporterRegistry.hpp:
        Add NdbMgmHandle to constructor. This is used to get the port number
        to connect to from mgmd. Defaults to NULL, although things will go badly
        if you don't change this (by calling the new set_mgm_handle method) pretty
        quickly.
        
        Add set_mgm_handle(NdbMgmHandle) method.
         - sets the MgmHandle to use when requesting from mgmd what port to connect to a node on.
      ndb/src/common/transporter/Transporter.hpp:
        Make remote port not a const.
        Add method to set remote port - set_r_port(unsigned int)
        
        Make getLocalNodeId return localNodeId, not remoteNodeId.
      ndb/src/common/transporter/TransporterRegistry.cpp:
        TransporterRegistry::TransporterRegistry()
         - accept NdbMgmHandle parameter
         - set m_mgm_handle to this
        
        TransporterRegistry::start_clients_thread()
         - If we're connecting to a node, and the server_port (from the config) is <=0,
        	we request the port number to connect to from mgmd.
        
        (note: in testing, the <=0 check was commented out so the code was run.
        There is no harm in always running it, it's just an extra round-trip to mgmd
        that we may not need).
      ndb/src/kernel/main.cpp:
        Set the mgm_handle for globalTransporterRegistry soon after we have set up theConfig (which sets up the mgmHandle).
      ndb/src/mgmapi/mgmapi.cpp:
        - Remove dead #else on #if 1
        
        - Print an error message and warning if the parser returns NULL.
          this will no longer silently fail, it will give output with
          information to help the programmer find out where things went wrong.
          In normal operation, this codepath should never be hit.
        
        - fix handlers for 'get|set connection parameter' calls.
      ndb/src/mgmsrv/MgmtSrvr.cpp:
        - Create TransporterFacade with the mgmHandle.
        - Don't worry about the order of node1 and node2 in getConnectionDbParameter
        - use a proper DBUG_RETURN in getConnectionParameter
      ndb/src/mgmsrv/Services.cpp:
        - fix reply to 'get connection parameter'
        - optimise reply size.
      ndb/src/ndbapi/TransporterFacade.cpp:
        - create TransporterRegistry with m_mgm_handle
        - set m_mgm_handle in constructor
      ndb/src/ndbapi/TransporterFacade.hpp:
        Introduce m_mgm_handle member.
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        create TransporterFacade (with mgmHandle) after the ConfigRetriever has been created
      233a33da
  3. 20 Dec, 2004 1 commit
    • unknown's avatar
      added config parameter Group on connection · 8c01aba7
      unknown authored
          moved NdbWaiter, m_ndb_cluster_connection, to impl class
          moved node selection things to cluster connection
          moved all private things to impl class
          added opts for shared memory and node selection
          changed opts handling somewhat; introduced enum for options and common handling of option variables
          added checks for transporter support
          automatic addition of shared mem transporters
          moved wait_until_ready code to cluster connection
          added control of usage of new node selection method
      
      
      ndb/include/mgmapi/mgmapi_config_parameters.h:
        added config parameter Group on connection
      ndb/include/ndbapi/Ndb.hpp:
        moved NdbWaiter, m_ndb_cluster_connection, to impl class
        moved node selection things to cluster connection
      ndb/include/ndbapi/ndb_cluster_connection.hpp:
        moved all private things to impl class
      ndb/include/util/ndb_opts.h:
        added opts for shared memory and node selection
      ndb/src/kernel/vm/Configuration.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/src/mgmclient/main.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/src/mgmsrv/ConfigInfo.cpp:
        added checks for transporter support
        automatic addition of shared mem transporters
      ndb/src/mgmsrv/MgmtSrvr.cpp:
        in alloc node id first choose connection with specified hostname
      ndb/src/mgmsrv/main.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/src/ndbapi/DictCache.hpp:
        added include file
      ndb/src/ndbapi/Ndb.cpp:
        enabled using new node selection method
        moved wait_until_ready code to cluster connection
        moved node selection (hint) to cluster connection
        removed start transaction dgroup
      ndb/src/ndbapi/NdbDictionaryImpl.hpp:
        removed and added inclusde files
      ndb/src/ndbapi/NdbImpl.hpp:
        moved things from Ndb into Impl class
        moved waiter things to new file NdbWaiter.hpp
      ndb/src/ndbapi/NdbScanOperation.cpp:
        ndbwaiter is no in impl class
      ndb/src/ndbapi/Ndbif.cpp:
        ndbwaiter is no in impl class
      ndb/src/ndbapi/Ndbinit.cpp:
        moved some Ndb things into impl class
      ndb/src/ndbapi/TransporterFacade.hpp:
        changed friend declaration
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        moved node selection things to cluster connection
        moved things from cluster connection to cluster connection impl class
      ndb/test/ndbapi/testNdbApi.cpp:
        removed start transaction dgroup
      ndb/tools/delete_all.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/desc.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/drop_index.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/drop_tab.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/listTables.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/restore/restore_main.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/select_all.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/select_count.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      ndb/tools/waiter.cpp:
        changed opts handling somewhat; introduced enum for options and common handling of option variables
      sql/ha_ndbcluster.cc:
        added control of usage of new node selection method
      sql/mysqld.cc:
        added control of usage of new node selection method
      8c01aba7
  4. 17 Dec, 2004 1 commit
  5. 16 Dec, 2004 1 commit
    • unknown's avatar
      Further work on WL2278 · ff99dce1
      unknown authored
      Add calls to mgmd after setting up connections.
      (not fully functional yet, checkin for pull)
      
      
      ndb/include/mgmcommon/ConfigRetriever.hpp:
        add get_mgmHandle() member function
      ndb/include/transporter/TransporterRegistry.hpp:
        Add remoteNodeId parameter to add_transporter interface
        
        add get_transporter() and get_localNodeID()
        
        these are required for getting the right information out of TransporterRegistry to inform mgmd of what ports we use to connect to other nodes.
      ndb/src/common/mgmcommon/IPCConfig.cpp:
        call add_transporter_interface with the new nodeId2 parameter
      ndb/src/common/transporter/TransporterRegistry.cpp:
        Implement additional (remoteNodeId) parameter in add_transporter_interface
        
        Implement get_transporter()
      ndb/src/kernel/main.cpp:
        Call ndb_mgm_set_connection_int_parameter() to tell mgmd what ports we use to connect to other nodes.
      ndb/src/kernel/vm/Configuration.hpp:
        add get_config_retriever()
      ndb/src/mgmapi/mgmapi.cpp:
        Add DBUG_ENTER call to ndb_mgm_set_connection_int_parameter
      ndb/src/ndbapi/TransporterFacade.hpp:
        Add get_registry()
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        Add call to ndb_mgm_set_connection_int_parameter to tell mgmd what ports we use to connect to other nodes.
      ff99dce1
  6. 30 Nov, 2004 2 commits
    • unknown's avatar
      fixed error in test result · be733ad1
      unknown authored
          added extra calls to retrieve connectstring used
          reengineered connect somewhat to make retries etc explicit
      
      
      mysql-test/r/ndb_index_unique.result:
        fixed error in test result
      ndb/include/mgmapi/mgmapi.h:
        added extra calls to retrieve connectstring used
      ndb/include/mgmcommon/ConfigRetriever.hpp:
        added extra calls to retrieve connectstring used
      ndb/include/ndbapi/ndb_cluster_connection.hpp:
        added extra calls to retrieve connectstring used
        reengineered connect somewhat to make retries etc explicit
      ndb/src/common/mgmcommon/ConfigRetriever.cpp:
        added extra calls to retrieve connectstring used
      ndb/src/mgmapi/mgmapi.cpp:
        added extra calls to retrieve connectstring used
      ndb/src/mgmclient/CommandInterpreter.cpp:
        moved parse of quit to avoid connect before
      ndb/src/ndbapi/Ndbinit.cpp:
        reengineered connect somewhat to make retries etc explicit
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        added extra calls to retrieve connectstring used
        reengineered connect somewhat to make retries etc explicit
      ndb/tools/listTables.cpp:
        reengineered connect somewhat to make retries etc explicit
      sql/ha_ndbcluster.cc:
        added extra calls to retrieve connectstring used
        reengineered connect somewhat to make retries etc explicit
      be733ad1
    • unknown's avatar
      fixed bug/compiler warning · 45968d1f
      unknown authored
          rewrote safer
          added return value to shutdown
          nicer printouts
          removed exit at shutdown
      
      
      ndb/src/common/logger/Logger.cpp:
        fixed bug/compiler warning
      ndb/src/mgmapi/LocalConfig.cpp:
        removed compiler warning
        rewrote safer
      ndb/src/mgmclient/CommandInterpreter.cpp:
        added return value to shutdown
        nicer printouts
        removed exit at shutdown
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        fixed compiler warning
      45968d1f
  7. 18 Nov, 2004 1 commit
    • unknown's avatar
      changed mysqladmin.c to mysqladmin.cc · 22b56d23
      unknown authored
          no need for dvlags to have DEFINE_CXA_PURE_VIRTUAL anymore
          aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
          removed all dependencies of LocalConfig, except for mgmapi internals
          enabled multiple management servrs to fetch data configurations from eachother
      
      
      client/Makefile.am:
        changed mysqladmin.c to mysqladmin.cc
      client/mysqladmin.cc:
        changed mysqladmin.c to mysqladmin.cc
      configure.in:
        no need for dvlags to have DEFINE_CXA_PURE_VIRTUAL anymore
      ndb/include/mgmapi/mgmapi.h:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/include/mgmcommon/ConfigRetriever.hpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/include/ndbapi/ndb_cluster_connection.hpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/common/mgmcommon/ConfigRetriever.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/kernel/main.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/kernel/vm/Configuration.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
        changed to config setting to always use noOfMetaTables to make sure we don't overflow arrays
      ndb/src/kernel/vm/Configuration.hpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmapi/LocalConfig.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmapi/LocalConfig.hpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmapi/mgmapi.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmclient/CommandInterpreter.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmclient/main.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmclient/ndb_mgmclient.hpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmclient/ndb_mgmclient.h:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmsrv/MgmtSrvr.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
        enabled multiple management servrs to fetch data configurations from eachother
      ndb/src/mgmsrv/MgmtSrvr.hpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmsrv/MgmtSrvrConfig.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/mgmsrv/main.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      ndb/tools/waiter.cpp:
        aligned the parsing of connectstring, retries for connect, allocation of nodeid for all cluster nodes
        removed all dependencies of LocalConfig, except for mgmapi internals
      22b56d23
  8. 25 Oct, 2004 1 commit
  9. 27 Sep, 2004 1 commit
    • unknown's avatar
      removed init on ConfigRetriever · a6b64d28
      unknown authored
          added some debug printouts
          some changes in ndbcluster_init to make start of mysqld first work
      
      
      ndb/include/mgmcommon/ConfigRetriever.hpp:
        removed init on ConfigRetriever
      ndb/src/common/mgmcommon/ConfigRetriever.cpp:
        removed init on ConfigRetriever
        added some debug printouts
      ndb/src/kernel/vm/Configuration.cpp:
        removed init on ConfigRetriever
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        removed init on ConfigRetriever
        added sleep in retry
      sql/ha_ndbcluster.cc:
        some changes in ndbcluster_init to make start of mysqld first work
      a6b64d28
  10. 25 Sep, 2004 2 commits
  11. 13 Sep, 2004 1 commit
  12. 09 Sep, 2004 1 commit
    • unknown's avatar
      improved show command · 0a7f9e24
      unknown authored
      fixed some mutex locks for Ndb objects
      moved TranspoterFacade::stop_instance to cluster connection
      moved Socket Server::start_server outside the TransporterFacade::start_instance thread
      
      
      ndb/include/mgmapi/mgmapi.h:
        improved show command
      ndb/src/mgmapi/mgmapi.cpp:
        improved show command
      ndb/src/mgmclient/CommandInterpreter.cpp:
        improved show command
      ndb/src/mgmsrv/MgmtSrvr.cpp:
        improved show command
      ndb/src/mgmsrv/MgmtSrvr.hpp:
        improved show command
      ndb/src/mgmsrv/Services.cpp:
        improved show command
      ndb/src/ndbapi/Ndbinit.cpp:
        fixed some mutex locks for Ndb objects
        moved TranspoterFacade::stop_instance to cluster connection
      ndb/src/ndbapi/TransporterFacade.cpp:
        movet Socket Server::start_server outside the TransporterFacade::start_instance thread
      ndb/src/ndbapi/TransporterFacade.hpp:
        movet Socket Server::start_server outside the TransporterFacade::start_instance thread
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        movet Socket Server::start_server outside the TransporterFacade::start_instance thread
      0a7f9e24
  13. 06 Sep, 2004 3 commits
    • unknown's avatar
      Fix braces wrt to DBUG_xxx · 6204a73c
      unknown authored
      6204a73c
    • unknown's avatar
      fixed so that ndbcluster and mysqld can be started independently · d90b95ed
      unknown authored
      fixed some error codes in Ndb so that 4009-cluster failure is returned when cluster is not up
      
      
      d90b95ed
    • unknown's avatar
      added ndb_mgm_destroy_configuration call · c7e942a8
      unknown authored
      fixed memory leak in object map
      fixed uninitialized value blobs_pending
      
      
      ndb/include/mgmapi/mgmapi.h:
        added ndb_mgm_destroy_configuration call
      ndb/src/mgmapi/mgmapi.cpp:
        added ndb_mgm_destroy_configuration call
      ndb/src/ndbapi/ObjectMap.hpp:
        fixed memory leak
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        added ndb_mgm_destroy_configuration call
      sql/ha_ndbcluster.cc:
        fixed uninitialized value blobs_pending
      c7e942a8
  14. 02 Sep, 2004 1 commit
    • unknown's avatar
      added connect thread to Ndb_cluster_connection + · 3b124d4f
      unknown authored
      some other small fixes
      
      
      ndb/include/mgmcommon/ConfigRetriever.hpp:
        added options to do_connect to contol how connects failures should be treated
      ndb/include/mgmcommon/NdbConfig.h:
        method to retrieve datadir path (to user for chdir)
      ndb/include/ndbapi/ndb_cluster_connection.hpp:
        Added connect thread
      ndb/src/common/mgmcommon/ConfigRetriever.cpp:
        added options to do_connect to contol how connects failures should be treated
      ndb/src/common/mgmcommon/NdbConfig.c:
        method to retrieve datadir path (to user for chdir)
      ndb/src/kernel/main.cpp:
        ndbd to do chdir
      ndb/src/kernel/vm/WatchDog.cpp:
        added my_thread_init for debug
      ndb/src/ndbapi/ClusterMgr.cpp:
        added my_thread_init for debug
      ndb/src/ndbapi/TransporterFacade.cpp:
        removed call to atexit
      ndb/src/ndbapi/ndb_cluster_connection.cpp:
        added connect thread
      3b124d4f
  15. 01 Sep, 2004 1 commit