Fixed temp tables to work with replication. It will not work if you stop the slave

while slave thread has temp tables - not hard to fix though, but it is time to go to bed

added a new test case for temp table replication and Slave_open_temp_tables
status variable.

Misc fixes


client/mysqltest.c:
  added disconnect command
mysql-test/create-test-result:
  fixed bugs so it actually works
mysql-test/t/include/master-slave.inc:
  establish alternate connections to master and slave
sql/mysql_priv.h:
  Slave_open_temp_tables
sql/mysqlbinlog.cc:
  fixed a bug in reading local binlogs
sql/mysqld.cc:
  added Slave_open_temp_tables status variable
sql/slave.cc:
  fixed freed memory reference in the error message
sql/sql_class.cc:
  slave_proxy_id
sql/sql_class.h:
  slave_proxy_id
sql/sql_parse.cc:
  small optimization - reorder eval in &&
BitKeeper/etc/ignore:
  Added mysql-test/r/3.23/rpl000001.b.result.reject mysql-test/r/3.23/rpl000012.result.reject to the ignore list
sql/sql_table.cc:
  added THD arg to rename_temporary_table
sql/unireg.h:
  the table_cache_key is now 4 bytes longer

9 files changed, 24 insertions, 19 deletions

diff --git a/sql/mysql_priv.h b/sql/mysql_priv.h
index eca9eca56c4..1b2f64e3d76 100644
--- a/sql/mysql_priv.h
+++ b/sql/mysql_priv.h
@@ -397,7 +397,7 @@ void close_temporary_tables(THD *thd);
 TABLE **find_temporary_table(THD *thd, const char *db, const char *table_name);
 bool close_temporary_table(THD *thd, const char *db, const char *table_name);
 void close_temporary(TABLE *table, bool delete_table=1);
-bool rename_temporary_table(TABLE *table, const char *new_db,
+bool rename_temporary_table(THD* thd, TABLE *table, const char *new_db,
 			    const char *table_name);
 void remove_db_from_cache(const my_string db);
 void flush_tables();
@@ -451,7 +451,8 @@ extern ulong refresh_version,flush_version, thread_id,query_id,opened_tables,
 extern ulong filesort_rows, filesort_range_count, filesort_scan_count;
 extern ulong filesort_merge_passes;
 extern ulong select_range_check_count, select_range_count, select_scan_count;
-extern ulong select_full_range_join_count,select_full_join_count;
+extern ulong select_full_range_join_count,select_full_join_count,
+			 slave_open_temp_tables;
 extern uint test_flags,select_errors,mysql_port,ha_open_options;
 extern ulong thd_startup_options, slow_launch_threads, slow_launch_time;
 extern time_t start_time;
diff --git a/sql/mysqlbinlog.cc b/sql/mysqlbinlog.cc
index 21a740ca1f4..0fe9ab21987 100644
--- a/sql/mysqlbinlog.cc
+++ b/sql/mysqlbinlog.cc
@@ -361,8 +361,7 @@ static void dump_local_log_entries(const char* logname)
 	die("Could not read entry at offset %ld : Error in log format or \
 read error",
 	    my_b_tell(file));
-      else
-	die("Could not construct event object");
+      // file->error == 0 means EOF, that's OK, we break in this case
       break;
     }
     if (rec_count >= offset)
diff --git a/sql/mysqld.cc b/sql/mysqld.cc
index ef0d9050097..92d1ee06e44 100644
--- a/sql/mysqld.cc
+++ b/sql/mysqld.cc
@@ -200,7 +200,7 @@ ulong keybuff_size,sortbuff_size,max_item_sort_length,table_cache_size,
       thread_stack_min,net_wait_timeout,what_to_log= ~ (1L << (uint) COM_TIME),
       query_buff_size, lower_case_table_names, mysqld_net_retry_count,
       net_interactive_timeout, slow_launch_time = 2L,
-      net_read_timeout,net_write_timeout;
+      net_read_timeout,net_write_timeout,slave_open_temp_tables=0;
 ulong thread_cache_size=0;
 volatile ulong cached_thread_count=0;
 
@@ -2556,6 +2556,7 @@ struct show_var_st status_vars[]= {
   {"Select_range_check",       (char*) &select_range_check_count, SHOW_LONG},
   {"Select_scan",	       (char*) &select_scan_count,	SHOW_LONG},
   {"Slave_running",            (char*) &slave_running,          SHOW_BOOL},
+  {"Slave_open_temp_tables",   (char*) &slave_open_temp_tables, SHOW_LONG},
   {"Slow_launch_threads",      (char*) &slow_launch_threads,    SHOW_LONG},
   {"Slow_queries",             (char*) &long_query_count,       SHOW_LONG},
   {"Sort_merge_passes",	       (char*) &filesort_merge_passes,  SHOW_LONG},
diff --git a/sql/slave.cc b/sql/slave.cc
index a5a15e8c30e..b54a1a4d6e6 100644
--- a/sql/slave.cc
+++ b/sql/slave.cc
@@ -762,6 +762,7 @@ static int exec_event(THD* thd, NET* net, MASTER_INFO* mi, int event_len)
 	thd->query_error = 0; // clear error
 	thd->net.last_errno = 0;
 	thd->net.last_error[0] = 0;
+	thd->slave_proxy_id = qev->thread_id; // for temp tables
 	mysql_parse(thd, thd->query, q_len);
 	int expected_error,actual_error;
 	if((expected_error = qev->error_code) !=
@@ -782,24 +783,17 @@ static int exec_event(THD* thd, NET* net, MASTER_INFO* mi, int event_len)
       thd->convert_set = 0; // assume no convert for next query
       // unless set explictly
       close_thread_tables(thd);
-      free_root(&thd->mem_root,0);
       
-      if (thd->query_error)
+      if (thd->query_error || thd->fatal_error)
       {
 	sql_print_error("Slave:  error running query '%s' ",
 			qev->query);
+        free_root(&thd->mem_root,0);
 	delete ev;
 	return 1;
       }
-      
+      free_root(&thd->mem_root,0);
       delete ev;
-	    
-      if(thd->fatal_error)
-      {
-	sql_print_error("Slave: Fatal error running query '%s' ",
-			thd->query);
-	return 1;
-      }
 
       mi->inc_pos(event_len);
       flush_master_info(mi);
@@ -875,6 +869,7 @@ static int exec_event(THD* thd, NET* net, MASTER_INFO* mi, int event_len)
 
 	List<Item> fields;
 	lev->set_fields(fields);
+	thd->slave_proxy_id = thd->thread_id;
 	thd->net.vio = net->vio;
 	// mysql_load will use thd->net to read the file
 	thd->net.pkt_nr = net->pkt_nr;
@@ -920,11 +915,13 @@ static int exec_event(THD* thd, NET* net, MASTER_INFO* mi, int event_len)
     }
 
     case START_EVENT:
+      close_temporary_tables(thd);
       mi->inc_pos(event_len);
       flush_master_info(mi);
       break;
                   
     case STOP_EVENT:
+      close_temporary_tables(thd);
       mi->inc_pos(event_len);
       flush_master_info(mi);
       break;
diff --git a/sql/sql_class.cc b/sql/sql_class.cc
index c7d50ee182e..f4a662db805 100644
--- a/sql/sql_class.cc
+++ b/sql/sql_class.cc
@@ -98,6 +98,7 @@ THD::THD():user_time(0),fatal_error(0),last_insert_id_used(0),
   start_time=(time_t) 0;
   current_linfo =  0;
   slave_thread = 0;
+  slave_proxy_id = 0;
   last_nx_table = last_nx_db = 0;
   inactive_timeout=net_wait_timeout;
   open_options=ha_open_options;
diff --git a/sql/sql_class.h b/sql/sql_class.h
index af5dcc65688..55c4c4dfc8b 100644
--- a/sql/sql_class.h
+++ b/sql/sql_class.h
@@ -274,6 +274,10 @@ public:
   // if we do a purge of binary logs, log index info of the threads
   // that are currently reading it needs to be adjusted. To do that
   // each thread that is using LOG_INFO needs to adjust the pointer to it
+
+  ulong slave_proxy_id; // in slave thread we need to know in behalf of which
+  // thread the query is being run to replicate temp tables properly 
+  
   THD();
   ~THD();
   bool store_globals();
diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc
index 8e9584bc9d7..531b1f39840 100644
--- a/sql/sql_parse.cc
+++ b/sql/sql_parse.cc
@@ -860,7 +860,7 @@ mysql_execute_command(void)
   TABLE_LIST *tables=(TABLE_LIST*) lex->table_list.first;
   DBUG_ENTER("mysql_execute_command");
 
-  if(thd->slave_thread && table_rules_on && tables && !tables_ok(thd,tables))
+  if(table_rules_on && thd->slave_thread && tables && !tables_ok(thd,tables))
     DBUG_VOID_RETURN; // skip if we are in the slave thread, some table
   // rules have been given and the table list says the query should not be
   // replicated
diff --git a/sql/sql_table.cc b/sql/sql_table.cc
index d1be84b4143..9ae1b91b08c 100644
--- a/sql/sql_table.cc
+++ b/sql/sql_table.cc
@@ -1437,7 +1437,7 @@ int mysql_alter_table(THD *thd,char *new_db, char *new_name,
     }
     /* Remove link to old table and rename the new one */
     close_temporary_table(thd,table->table_cache_key,table_name);
-    if (rename_temporary_table(new_table, new_db, new_name))
+    if (rename_temporary_table(thd, new_table, new_db, new_name))
     {						// Fatal error
       close_temporary_table(thd,new_db,tmp_name);
       my_free((gptr) new_table,MYF(0));
@@ -1611,6 +1611,8 @@ copy_data_between_tables(TABLE *from,TABLE *to,
       (copy_end++)->set(*ptr,def->field,0);
   }
 
+  found_count=delete_count=0;
+
   if(order) {
     from->io_cache=(IO_CACHE*) my_malloc(sizeof(IO_CACHE),
                                          MYF(MY_FAE | MY_ZEROFILL));
@@ -1628,7 +1630,6 @@ copy_data_between_tables(TABLE *from,TABLE *to,
 
   init_read_record(&info, thd, from, (SQL_SELECT *) 0, 1,1);
 
-  found_count=delete_count=0;
   next_field=to->next_number_field;
   while (!(error=info.read_record(&info)))
   {
diff --git a/sql/unireg.h b/sql/unireg.h
index c293433dd42..9f078ef3766 100644
--- a/sql/unireg.h
+++ b/sql/unireg.h
@@ -41,7 +41,8 @@
 
 #define ERRMAPP 1				/* Errormap f|r my_error */
 #define LIBLEN FN_REFLEN-FN_LEN			/* Max l{ngd p} dev */
-#define MAX_DBKEY_LENGTH (FN_LEN*2+2)
+#define MAX_DBKEY_LENGTH (FN_LEN*2+6)           /* extra 4 bytes for slave tmp
+						 * tables */
 #define MAX_FIELD_NAME 34			/* Max colum name length +2 */
 #define MAX_KEY 32				/* Max used keys */
 #define MAX_REF_PARTS 16			/* Max parts used as ref */