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

into mysql.com:/home/jonas/src/mysql-4.1

ndb/test/run-test/main.cpp

@@ -458,7 +458,7 @@ setup_config(atrt_config& config){
 	proc.m_type = atrt_process::NDB_MGM;
 	proc.m_proc.m_name.assfmt("%d-%s", index, "ndb_mgmd");
 	proc.m_proc.m_path.assign(dir).append("/libexec/ndb_mgmd");
-	proc.m_proc.m_args = "-n -c initconfig.txt";
+	proc.m_proc.m_args = "--nodaemon -c initconfig.txt";
 	proc.m_proc.m_cwd.appfmt("%d.ndb_mgmd", index);
 	connect_string.appfmt("host=%s:%d;", 
 			      proc.m_hostname.c_str(), proc.m_ndb_mgm_port);

sql/ha_ndbcluster.cc

@@ -3492,7 +3492,7 @@ int ndb_discover_tables()
   dict= g_ndb->getDictionary();
   if (dict->listObjects(list, 
 			NdbDictionary::Object::UserTable) != 0)
-    ERR_RETURN(g_ndb->getNdbError());
+    ERR_RETURN(dict->getNdbError());
   
   for (i= 0 ; i < list.count ; i++)
   {
@@ -3514,6 +3514,7 @@ int ndb_discover_tables()
 
 bool ndbcluster_init()
 {
+  int res;
   DBUG_ENTER("ndbcluster_init");
   // Set connectstring if specified
   if (ndbcluster_connectstring != 0)
@@ -3524,11 +3525,7 @@ bool ndbcluster_init()
     DBUG_PRINT("error",("Ndb_cluster_connection(%s)",ndbcluster_connectstring));
     DBUG_RETURN(TRUE);
   }
-  if (g_ndb_cluster_connection->start_connect_thread())
-  {
-    DBUG_PRINT("error", ("g_ndb_cluster_connection->start_connect_thread()"));
-    DBUG_RETURN(TRUE);
-  }
+
   // Create a Ndb object to open the connection  to NDB
   g_ndb= new Ndb(g_ndb_cluster_connection, "sys");
   if (g_ndb->init() != 0)
@@ -3536,6 +3533,23 @@ bool ndbcluster_init()
     ERR_PRINT (g_ndb->getNdbError());
     DBUG_RETURN(TRUE);
   }
+
+  if ((res= g_ndb_cluster_connection->connect(1)) == 0)
+  {
+    g_ndb->waitUntilReady(10);
+  } 
+  else if(res == 1 && g_ndb_cluster_connection->start_connect_thread())
+  {
+    DBUG_PRINT("error", ("g_ndb_cluster_connection->start_connect_thread()"));
+    DBUG_RETURN(TRUE);
+  }
+  else 
+  {
+    DBUG_ASSERT(res == -1);
+    DBUG_PRINT("error", ("permanent error"));
+    DBUG_RETURN(TRUE);
+  }
+  
   (void) hash_init(&ndbcluster_open_tables,system_charset_info,32,0,0,
                    (hash_get_key) ndbcluster_get_key,0,0);
   pthread_mutex_init(&ndbcluster_mutex,MY_MUTEX_INIT_FAST);
@@ -3558,6 +3572,7 @@ bool ndbcluster_end()
 {
   DBUG_ENTER("ndbcluster_end");
 
+  if(g_ndb)
     delete g_ndb;
   g_ndb= NULL;
   if (g_ndb_cluster_connection)