Commit 57aeec9a authored by unknown's avatar unknown

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

into  perch.ndb.mysql.com:/home/jonas/src/51-clean

parents ba02b2e4 3eacd484
...@@ -1235,6 +1235,7 @@ sub kill_running_server () { ...@@ -1235,6 +1235,7 @@ sub kill_running_server () {
$using_ndbcluster_master= $opt_with_ndbcluster; $using_ndbcluster_master= $opt_with_ndbcluster;
ndbcluster_stop(); ndbcluster_stop();
$master->[0]->{'ndbcluster'}= 1; $master->[0]->{'ndbcluster'}= 1;
$using_ndbcluster_slave= $opt_with_ndbcluster;
ndbcluster_stop_slave(); ndbcluster_stop_slave();
$slave->[0]->{'ndbcluster'}= 1; $slave->[0]->{'ndbcluster'}= 1;
} }
......
...@@ -210,7 +210,7 @@ master-bin.000001 282 Write_rows 1 # ...@@ -210,7 +210,7 @@ master-bin.000001 282 Write_rows 1 #
master-bin.000001 316 Xid 1 # COMMIT /* xid= */ master-bin.000001 316 Xid 1 # COMMIT /* xid= */
delete from t1; delete from t1;
delete from t2; delete from t2;
alter table t2 type=MyISAM; alter table t2 engine=MyISAM;
insert into t1 values (1); insert into t1 values (1);
begin; begin;
select * from t1 for update; select * from t1 for update;
...@@ -266,18 +266,18 @@ master-bin.000001 343 Query 1 # use `test`; delete from t1 ...@@ -266,18 +266,18 @@ master-bin.000001 343 Query 1 # use `test`; delete from t1
master-bin.000001 420 Xid 1 # COMMIT /* xid= */ master-bin.000001 420 Xid 1 # COMMIT /* xid= */
master-bin.000001 447 Query 1 # use `test`; delete from t2 master-bin.000001 447 Query 1 # use `test`; delete from t2
master-bin.000001 524 Xid 1 # COMMIT /* xid= */ master-bin.000001 524 Xid 1 # COMMIT /* xid= */
master-bin.000001 551 Query 1 # use `test`; alter table t2 type=MyISAM master-bin.000001 551 Query 1 # use `test`; alter table t2 engine=MyISAM
master-bin.000001 640 Table_map 1 # test.t1 master-bin.000001 642 Table_map 1 # test.t1
master-bin.000001 679 Write_rows 1 # master-bin.000001 681 Write_rows 1 #
master-bin.000001 713 Xid 1 # COMMIT /* xid= */ master-bin.000001 715 Xid 1 # COMMIT /* xid= */
master-bin.000001 740 Table_map 1 # test.t2 master-bin.000001 742 Table_map 1 # test.t2
master-bin.000001 779 Write_rows 1 # master-bin.000001 781 Write_rows 1 #
master-bin.000001 813 Query 1 # use `test`; drop table t1,t2 master-bin.000001 815 Query 1 # use `test`; drop table t1,t2
master-bin.000001 892 Query 1 # use `test`; create table t0 (n int) master-bin.000001 894 Query 1 # use `test`; create table t0 (n int)
master-bin.000001 978 Table_map 1 # test.t0 master-bin.000001 980 Table_map 1 # test.t0
master-bin.000001 1017 Write_rows 1 # master-bin.000001 1019 Write_rows 1 #
master-bin.000001 1051 Table_map 1 # test.t0 master-bin.000001 1053 Table_map 1 # test.t0
master-bin.000001 1090 Write_rows 1 # master-bin.000001 1092 Write_rows 1 #
master-bin.000001 1124 Query 1 # use `test`; create table t2 (n int) engine=innodb master-bin.000001 1126 Query 1 # use `test`; create table t2 (n int) engine=innodb
do release_lock("lock1"); do release_lock("lock1");
drop table t0,t2; drop table t0,t2;
...@@ -32,8 +32,8 @@ rpl_until : Unstable test case, bug#15886 ...@@ -32,8 +32,8 @@ rpl_until : Unstable test case, bug#15886
sp-goto : GOTO is currently is disabled - will be fixed in the future sp-goto : GOTO is currently is disabled - will be fixed in the future
subselect : Bug#15706 (ps mode) [PATCH PENDING] subselect : Bug#15706 (ps mode) [PATCH PENDING]
rpl_ndb_log : result not deterministic rpl_ndb_log : result not deterministic
binlog_row_mix_innodb_myisam : Bug #17386
binlog_row_insert_select : Bug #17385 binlog_row_insert_select : Bug #17385
rpl_row_basic_2myisam : Bug #17385 rpl_row_basic_2myisam : Bug #17385
rpl_row_basic_3innodb : Bug #17385 rpl_row_basic_3innodb : Bug #17385
rpl_row_create_table : Bug #17385 rpl_row_create_table : Bug #17385
ndb_load : Bug#17233
...@@ -121,6 +121,7 @@ int safe_mutex_lock(safe_mutex_t *mp,const char *file, uint line) ...@@ -121,6 +121,7 @@ int safe_mutex_lock(safe_mutex_t *mp,const char *file, uint line)
fflush(stderr); fflush(stderr);
abort(); abort();
} }
mp->thread= pthread_self();
if (mp->count++) if (mp->count++)
{ {
fprintf(stderr,"safe_mutex: Error in thread libray: Got mutex at %s, \ fprintf(stderr,"safe_mutex: Error in thread libray: Got mutex at %s, \
...@@ -128,7 +129,6 @@ line %d more than 1 time\n", file,line); ...@@ -128,7 +129,6 @@ line %d more than 1 time\n", file,line);
fflush(stderr); fflush(stderr);
abort(); abort();
} }
mp->thread=pthread_self();
mp->file= file; mp->file= file;
mp->line=line; mp->line=line;
pthread_mutex_unlock(&mp->global); pthread_mutex_unlock(&mp->global);
...@@ -154,6 +154,7 @@ int safe_mutex_unlock(safe_mutex_t *mp,const char *file, uint line) ...@@ -154,6 +154,7 @@ int safe_mutex_unlock(safe_mutex_t *mp,const char *file, uint line)
fflush(stderr); fflush(stderr);
abort(); abort();
} }
mp->thread= 0;
mp->count--; mp->count--;
#ifdef __WIN__ #ifdef __WIN__
pthread_mutex_unlock(&mp->mutex); pthread_mutex_unlock(&mp->mutex);
...@@ -207,6 +208,7 @@ int safe_cond_wait(pthread_cond_t *cond, safe_mutex_t *mp, const char *file, ...@@ -207,6 +208,7 @@ int safe_cond_wait(pthread_cond_t *cond, safe_mutex_t *mp, const char *file,
fflush(stderr); fflush(stderr);
abort(); abort();
} }
mp->thread=pthread_self();
if (mp->count++) if (mp->count++)
{ {
fprintf(stderr, fprintf(stderr,
...@@ -215,7 +217,6 @@ int safe_cond_wait(pthread_cond_t *cond, safe_mutex_t *mp, const char *file, ...@@ -215,7 +217,6 @@ int safe_cond_wait(pthread_cond_t *cond, safe_mutex_t *mp, const char *file,
fflush(stderr); fflush(stderr);
abort(); abort();
} }
mp->thread=pthread_self();
mp->file= file; mp->file= file;
mp->line=line; mp->line=line;
pthread_mutex_unlock(&mp->global); pthread_mutex_unlock(&mp->global);
...@@ -245,6 +246,7 @@ int safe_cond_timedwait(pthread_cond_t *cond, safe_mutex_t *mp, ...@@ -245,6 +246,7 @@ int safe_cond_timedwait(pthread_cond_t *cond, safe_mutex_t *mp,
} }
#endif #endif
pthread_mutex_lock(&mp->global); pthread_mutex_lock(&mp->global);
mp->thread=pthread_self();
if (mp->count++) if (mp->count++)
{ {
fprintf(stderr, fprintf(stderr,
...@@ -253,7 +255,6 @@ int safe_cond_timedwait(pthread_cond_t *cond, safe_mutex_t *mp, ...@@ -253,7 +255,6 @@ int safe_cond_timedwait(pthread_cond_t *cond, safe_mutex_t *mp,
fflush(stderr); fflush(stderr);
abort(); abort();
} }
mp->thread=pthread_self();
mp->file= file; mp->file= file;
mp->line=line; mp->line=line;
pthread_mutex_unlock(&mp->global); pthread_mutex_unlock(&mp->global);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment