From: Date: August 22 2007 1:12am
Subject: bk commit into 5.1 tree (tsmith:1.2565) BUG#30389
List-Archive: http://lists.mysql.com/commits/32848
X-Bug: 30389
Message-Id: <20070821231257.8B735F803E@ramayana.hindu.god>

Below is the list of changes that have just been committed into a local
5.1 repository of tsmith. When tsmith does a push these changes will
be propagated to the main repository and, within 24 hours after the
push, to the public repository.
For information on how to access the public repository
see http://dev.mysql.com/doc/mysql/en/installing-source-tree.html

ChangeSet@stripped, 2007-08-21 17:12:53-06:00, tsmith@stripped +5 -0
  Bug #30389: connection_id() always return 0 in embedded server
  
  Initialize thd->variables.pseudo_thread_id when a new embedded
  thd is created.

  libmysqld/lib_sql.cc@stripped, 2007-08-21 17:12:51-06:00, tsmith@stripped +12 -1
    Initialize thd->variables.pseudo_thread_id when a new
    embedded thd is created.

  mysql-test/r/func_misc.result@stripped, 2007-08-21 17:12:51-06:00, tsmith@stripped +4 -0
    Update test results

  mysql-test/t/func_misc.test@stripped, 2007-08-21 17:12:51-06:00, tsmith@stripped +8 -0
    New test case for bug #30389

  sql/mysqld.cc@stripped, 2007-08-21 17:12:51-06:00, tsmith@stripped +5 -0
    Add comment warning of the duplication of code between create_new_thread()
    and create_embedded_thd()

  sql/sql_connect.cc@stripped, 2007-08-21 17:12:51-06:00, tsmith@stripped +5 -0
    Add comment warning of the duplication of code between
    prepare_new_connection_state() and create_embedded_thd()

diff -Nrup a/libmysqld/lib_sql.cc b/libmysqld/lib_sql.cc
--- a/libmysqld/lib_sql.cc	2007-08-02 07:26:18 -06:00
+++ b/libmysqld/lib_sql.cc	2007-08-21 17:12:51 -06:00
@@ -564,10 +564,21 @@ void init_embedded_mysql(MYSQL *mysql, i
   init_alloc_root(&mysql->field_alloc, 8192, 0);
 }
 
+/**
+  @brief Initialize a new THD for a connection in the embedded server
+
+  @param client_flag  Client capabilities which this thread supports
+  @return pointer to the created THD object
+
+  @todo
+  This function copies code from several places in the server, including
+  create_new_thread(), and prepare_new_connection_state().  This should
+  be refactored to avoid code duplication.
+*/
 void *create_embedded_thd(int client_flag)
 {
   THD * thd= new THD;
-  thd->thread_id= thread_id++;
+  thd->thread_id= thd->variables.pseudo_thread_id= thread_id++;
 
   thd->thread_stack= (char*) &thd;
   if (thd->store_globals())
diff -Nrup a/mysql-test/r/func_misc.result b/mysql-test/r/func_misc.result
--- a/mysql-test/r/func_misc.result	2007-05-31 08:45:16 -06:00
+++ b/mysql-test/r/func_misc.result	2007-08-21 17:12:51 -06:00
@@ -191,3 +191,7 @@ drop table table_26093;
 drop function func_26093_a;
 drop function func_26093_b;
 End of 5.0 tests
+select connection_id() > 0;
+connection_id() > 0
+1
+End of tests
diff -Nrup a/mysql-test/t/func_misc.test b/mysql-test/t/func_misc.test
--- a/mysql-test/t/func_misc.test	2007-06-04 17:14:59 -06:00
+++ b/mysql-test/t/func_misc.test	2007-08-21 17:12:51 -06:00
@@ -198,3 +198,11 @@ drop function func_26093_a;
 drop function func_26093_b;
 
 --echo End of 5.0 tests
+
+#
+# Bug #30389: connection_id() always return 0 in embedded server
+#
+
+select connection_id() > 0;
+
+--echo End of tests
diff -Nrup a/sql/mysqld.cc b/sql/mysqld.cc
--- a/sql/mysqld.cc	2007-08-10 14:35:19 -06:00
+++ b/sql/mysqld.cc	2007-08-21 17:12:51 -06:00
@@ -4354,6 +4354,11 @@ static void create_new_thread(THD *thd)
     DBUG_VOID_RETURN;
   }
   pthread_mutex_lock(&LOCK_thread_count);
+  /*
+    The initialization of thread_id is done in create_embedded_thd() for
+    the embedded library.
+    TODO: refactor this to avoid code duplication there
+  */
   thd->thread_id= thd->variables.pseudo_thread_id= thread_id++;
 
   /* Start a new thread to handle connection */
diff -Nrup a/sql/sql_connect.cc b/sql/sql_connect.cc
--- a/sql/sql_connect.cc	2007-07-30 02:33:44 -06:00
+++ b/sql/sql_connect.cc	2007-08-21 17:12:51 -06:00
@@ -1008,6 +1008,11 @@ void prepare_new_connection_state(THD* t
   if (thd->client_capabilities & CLIENT_COMPRESS)
     thd->net.compress=1;				// Use compression
 
+  /*
+    Much of this is duplicated in create_embedded_thd() for the
+    embedded server library.
+    TODO: refactor this to avoid code duplication there
+  */
   thd->version= refresh_version;
   thd->proc_info= 0;
   thd->command= COM_SLEEP;