summaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorunknown <vva@eagle.mysql.r18.ru>2004-04-03 02:46:12 +0500
committerunknown <vva@eagle.mysql.r18.ru>2004-04-03 02:46:12 +0500
commitbf4849e8bc1d3fc68861c3f996e4f63a04088433 (patch)
tree881dc8d1d5600ec2d6caf9254de023023fc9b6a9 /sql
parent69942b1367f3199efa3286cc6cb794e3dce448f1 (diff)
parentcee153b87a19f2c60916ca62e48c11a42dd8bf9c (diff)
downloadmariadb-git-bf4849e8bc1d3fc68861c3f996e4f63a04088433.tar.gz
Merge eagle.mysql.r18.ru:/home/vva/work/mysql.orig/clear/mysql-4.1
into eagle.mysql.r18.ru:/home/vva/work/BUG_2385/mysql-4.1 sql/mysql_priv.h: Auto merged sql/mysqld.cc: Auto merged sql/sql_table.cc: Auto merged
Diffstat (limited to 'sql')
-rw-r--r--sql/mysql_priv.h2
-rw-r--r--sql/mysqld.cc4
-rw-r--r--sql/sql_table.cc42
3 files changed, 36 insertions, 12 deletions
diff --git a/sql/mysql_priv.h b/sql/mysql_priv.h
index 7a5ae167442..a97bd05fed6 100644
--- a/sql/mysql_priv.h
+++ b/sql/mysql_priv.h
@@ -171,6 +171,8 @@ extern CHARSET_INFO *national_charset_info, *table_alias_charset;
#define TEST_CORE_ON_SIGNAL 256 /* Give core if signal */
#define TEST_NO_STACKTRACE 512
#define TEST_SIGINT 1024 /* Allow sigint on threads */
+#define TEST_SYNCHRONIZATION 2048 /* get server to do sleep in some
+ places */
/* options for select set by the yacc parser (stored in lex->options) */
#define SELECT_DISTINCT (1L << 0)
diff --git a/sql/mysqld.cc b/sql/mysqld.cc
index 4f4e441045a..0f75c7d14ef 100644
--- a/sql/mysqld.cc
+++ b/sql/mysqld.cc
@@ -2108,8 +2108,10 @@ static int init_common_variables(const char *conf_file_name, int argc,
if (*(MYSQL_SERVER_SUFFIX))
strxmov(strend(server_version),MYSQL_SERVER_SUFFIX,"-debug",NullS);
else
-#endif
+ strmov(strend(server_version),"--debug");
+#else
strmov(strend(server_version),MYSQL_SERVER_SUFFIX);
+#endif
load_defaults(conf_file_name, groups, &argc, &argv);
defaults_argv=argv;
diff --git a/sql/sql_table.cc b/sql/sql_table.cc
index 81286cea227..5e358f76d3f 100644
--- a/sql/sql_table.cc
+++ b/sql/sql_table.cc
@@ -1902,7 +1902,8 @@ int mysql_create_like_table(THD* thd, TABLE_LIST* table,
char *table_name= table->real_name;
char *src_db= thd->db;
char *src_table= table_ident->table.str;
- int err;
+ int err, res= -1;
+ TABLE_LIST src_tables_list;
DBUG_ENTER("mysql_create_like_table");
/*
@@ -1916,6 +1917,13 @@ int mysql_create_like_table(THD* thd, TABLE_LIST* table,
my_error(ER_WRONG_TABLE_NAME, MYF(0), src_table);
DBUG_RETURN(-1);
}
+
+ src_tables_list.db= table_ident->db.str ? table_ident->db.str : thd->db;
+ src_tables_list.real_name= table_ident->table.str;
+ src_tables_list.next= 0;
+
+ if (lock_and_wait_for_table_name(thd, &src_tables_list))
+ goto err;
if ((tmp_table= find_temporary_table(thd, src_db, src_table)))
strxmov(src_path, (*tmp_table)->path, reg_ext, NullS);
@@ -1926,7 +1934,7 @@ int mysql_create_like_table(THD* thd, TABLE_LIST* table,
if (access(src_path, F_OK))
{
my_error(ER_BAD_TABLE_ERROR, MYF(0), src_table);
- DBUG_RETURN(-1);
+ goto err;
}
}
@@ -1954,9 +1962,14 @@ int mysql_create_like_table(THD* thd, TABLE_LIST* table,
/*
Create a new table by copying from source table
- */
- if (my_copy(src_path, dst_path, MYF(MY_WME)))
- DBUG_RETURN(-1);
+ */
+#ifndef DBUG_OFF
+ // The code stated below is for test synchronization.test Bug #2385
+ if (test_flags & TEST_SYNCHRONIZATION)
+ sleep(3);
+#endif
+ if (my_copy(src_path, dst_path, MYF(MY_WME|MY_DONT_OVERWRITE_FILE)))
+ goto err;
/*
As mysql_truncate don't work on a new table at this stage of
@@ -1972,14 +1985,14 @@ int mysql_create_like_table(THD* thd, TABLE_LIST* table,
{
(void) rm_temporary_table(create_info->db_type,
dst_path); /* purecov: inspected */
- DBUG_RETURN(-1); /* purecov: inspected */
+ goto err; /* purecov: inspected */
}
}
else if (err)
{
(void) quick_rm_table(create_info->db_type, db,
table_name); /* purecov: inspected */
- DBUG_RETURN(-1); /* purecov: inspected */
+ goto err; /* purecov: inspected */
}
// Must be written before unlock
@@ -1992,7 +2005,8 @@ int mysql_create_like_table(THD* thd, TABLE_LIST* table,
HA_LEX_CREATE_TMP_TABLE));
mysql_bin_log.write(&qinfo);
}
- DBUG_RETURN(0);
+ res= 0;
+ goto err;
table_exists:
if (create_info->options & HA_LEX_CREATE_IF_NOT_EXISTS)
@@ -2001,10 +2015,16 @@ table_exists:
sprintf(warn_buff,ER(ER_TABLE_EXISTS_ERROR),table_name);
push_warning(thd, MYSQL_ERROR::WARN_LEVEL_WARN,
ER_TABLE_EXISTS_ERROR,warn_buff);
- DBUG_RETURN(0);
+ res= 0;
}
- my_error(ER_TABLE_EXISTS_ERROR, MYF(0), table_name);
- DBUG_RETURN(-1);
+ else
+ my_error(ER_TABLE_EXISTS_ERROR, MYF(0), table_name);
+
+err:
+ pthread_mutex_lock(&LOCK_open);
+ unlock_table_name(thd, &src_tables_list);
+ pthread_mutex_unlock(&LOCK_open);
+ DBUG_RETURN(res);
}