Commit 36dfa434 authored by unknown's avatar unknown
Browse files

Merge mysql.com:/home/bkroot/mysql-5.1-new-rpl 

into  mysql.com:/home/bk/MERGE/mysql-5.1-merge


BitKeeper/etc/collapsed:
  auto-union
mysql-test/r/view.result:
  Auto merged
mysql-test/t/view.test:
  Auto merged
sql/Makefile.am:
  Auto merged
sql/handler.cc:
  Auto merged
sql/log.cc:
  Auto merged
sql/mysql_priv.h:
  Auto merged
sql/mysqld.cc:
  Auto merged
sql/slave.cc:
  Auto merged
sql/sql_parse.cc:
  Auto merged
sql/sql_select.cc:
  Auto merged
sql/sql_view.cc:
  Auto merged
parents ce963d0c 421f4c09

BitKeeper/etc/collapsed

+2 −0
Original line number Diff line number Diff line
@@ -15,5 +15,7 @@ 
45214442pBGT9KuZEGixBH71jTzbOA

45214a07hVsIGwvwa-WrO-jpeaSwVw

452a92d0-31-8wSzSfZi165fcGcXPA

452c6c6dAjuNghfc1ObZ_UQ5SCl85g

4538a7b0EbDHHkWPbIwxO6ZIDdg6Dg

454a7ef8gdvE_ddMlJyghvOAkKPNOQ

454f8960jsVT_kMKJtZ9OCgXoba0xQ

client/mysqlbinlog.cc

+15 −0
Original line number Diff line number Diff line
@@ -1360,6 +1360,21 @@ static int dump_local_log_entries(const char* logname) 
  }

  else // reading from stdin;

  {

    /*

      Windows opens stdin in text mode by default. Certain characters

      such as CTRL-Z are interpeted as events and the read() method

      will stop. CTRL-Z is the EOF marker in Windows. to get past this

      you have to open stdin in binary mode. Setmode() is used to set

      stdin in binary mode. Errors on setting this mode result in 

      halting the function and printing an error message to stderr.

    */

#if defined (__WIN__) || (_WIN64)

    if (_setmode(fileno(stdin), O_BINARY) == -1)

    {

       fprintf(stderr, "Could not set binary mode on stdin.\n");

       return 1;

    }

#endif 

    if (init_io_cache(file, fileno(stdin), 0, READ_CACHE, (my_off_t) 0,

		      0, MYF(MY_WME | MY_NABP | MY_DONT_CHECK_FILESIZE)))

      return 1;

include/m_ctype.h

+6 −6
Original line number Diff line number Diff line
@@ -190,8 +190,8 @@ typedef struct my_charset_handler_st 
               const unsigned char *s, const unsigned char *e);

  

  /* Functions for case and sort conversion */

  void    (*caseup_str)(struct charset_info_st *, char *);

  void    (*casedn_str)(struct charset_info_st *, char *);

  uint    (*caseup_str)(struct charset_info_st *, char *);

  uint    (*casedn_str)(struct charset_info_st *, char *);

  uint    (*caseup)(struct charset_info_st *, char *src, uint srclen,

                                              char *dst, uint dstlen);

  uint    (*casedn)(struct charset_info_st *, char *src, uint srclen,
@@ -324,8 +324,8 @@ extern uint my_instr_simple(struct charset_info_st *, 




/* Functions for 8bit */

extern void my_caseup_str_8bit(CHARSET_INFO *, char *);

extern void my_casedn_str_8bit(CHARSET_INFO *, char *);

extern uint my_caseup_str_8bit(CHARSET_INFO *, char *);

extern uint my_casedn_str_8bit(CHARSET_INFO *, char *);

extern uint my_caseup_8bit(CHARSET_INFO *, char *src, uint srclen,

                                           char *dst, uint dstlen);

extern uint my_casedn_8bit(CHARSET_INFO *, char *src, uint srclen,
@@ -415,8 +415,8 @@ int my_mbcharlen_8bit(CHARSET_INFO *, uint c); 




/* Functions for multibyte charsets */

extern void my_caseup_str_mb(CHARSET_INFO *, char *);

extern void my_casedn_str_mb(CHARSET_INFO *, char *);

extern uint my_caseup_str_mb(CHARSET_INFO *, char *);

extern uint my_casedn_str_mb(CHARSET_INFO *, char *);

extern uint my_caseup_mb(CHARSET_INFO *, char *src, uint srclen,

                                         char *dst, uint dstlen);

extern uint my_casedn_mb(CHARSET_INFO *, char *src, uint srclen,

mysql-test/extra/binlog_tests/binlog.test

+13 −0
Original line number Diff line number Diff line
@@ -59,4 +59,17 @@ insert into t1 values(null); 
select * from t1;

drop table t1;



# bug#22027 

create table t1 (a int);

create table if not exists t2 select * from t1;



# bug#22762

create temporary table tt1 (a int);

create table if not exists t3 like tt1;



--replace_column 2 # 5 #

--replace_regex /table_id: [0-9]+/table_id: #/ /\/\* xid=.* \*\//\/* xid= *\//

show binlog events from 102;

drop table t1,t2,t3,tt1;



-- source extra/binlog_tests/binlog_insert_delayed.test

mysql-test/extra/rpl_tests/rpl_deadlock.test

+27 −15
Original line number Diff line number Diff line
@@ -15,7 +15,8 @@ 
connection master;

eval CREATE TABLE t1 (a INT NOT NULL, KEY(a)) ENGINE=$engine_type;

eval CREATE TABLE t2 (a INT NOT NULL, KEY(a)) ENGINE=$engine_type;

eval CREATE TABLE t3 (a INT) ENGINE=$engine_type;

# requiring 'unique' for the timeout part of the test

eval CREATE TABLE t3 (a INT  UNIQUE) ENGINE=$engine_type;

eval CREATE TABLE t4 (a INT) ENGINE=$engine_type;

show variables like 'slave_transaction_retries';

sync_slave_with_master;
@@ -30,7 +31,9 @@ stop slave; 
connection master;

begin;

# Let's keep BEGIN and the locked statement in two different relay logs.

let $1=200;

insert into t2 values (0); # t2,t1 actors of deadlock in repl-ed ta

#insert into t3 select * from t2 for update;

let $1=10;

disable_query_log;

while ($1)

{
@@ -38,16 +41,14 @@ while ($1) 
 dec $1;

}

enable_query_log;

insert into t3 select * from t2 for update;

insert into t1 values(1);

commit;

save_master_pos;



connection slave;

begin;

# Let's make our transaction large so that it's slave who is chosen as

# victim

let $1=1000;

# Let's make our transaction large so that it's repl-ed msta that's victim

let $1=100;

disable_query_log;

while ($1)

{
@@ -55,14 +56,21 @@ while ($1) 
 dec $1;

}

enable_query_log;

select * from t1 for update;

select * from t1 for update; # t1,t2 on local slave's

start slave;



# bad option, todo: replicate a non-transactional t_sync with the transaction

# and use wait_until_rows_count macro below

--real_sleep 3 # hope that slave is blocked now

insert into t2 values(22); # provoke deadlock, slave should be victim

#let $count=11;

#let $table=t_sync;

#--include wait_until_rows_count.inc



select * from t2 for update /* dl */; # provoke deadlock, repl-ed should be victim

commit;

sync_with_master;

select * from t1; # check that slave succeeded finally

select * from t2;

select * from t1; # check that repl-ed succeeded finally

select * from t2 /* must be 1 */;

# check that no error is reported

--replace_column 1 # 7 # 8 # 9 # 16 # 22 # 23 # 33 #

--replace_result $MASTER_MYPORT MASTER_MYPORT
@@ -73,14 +81,16 @@ show slave status; 
# 2) Test lock wait timeout



stop slave;

change master to master_log_pos=536; # the BEGIN log event

delete from t3;

change master to master_log_pos=544; # the BEGIN log event

begin;

select * from t2 for update; # hold lock

start slave;

--real_sleep 10 # slave should have blocked, and be retrying

--real_sleep 10 # repl-ed should have blocked, and be retrying

select count(*) from t3  /* must be zero */; # replaying begins after rollback

commit;

sync_with_master;

select * from t1; # check that slave succeeded finally

select * from t1; # check that repl-ed succeeded finally

select * from t2;

# check that no error is reported

--replace_column 1 # 7 # 8 # 9 # 11 # 16 # 22 # 23 # 33 #
@@ -96,11 +106,13 @@ set global max_relay_log_size=0; 


# This is really copy-paste of 2) of above

stop slave;

change master to master_log_pos=536;

delete from t3;

change master to master_log_pos=544;

begin;

select * from t2 for update;

start slave;

--real_sleep 10

select count(*) from t3  /* must be zero */; # replaying begins after rollback

commit;

sync_with_master;

select * from t1;
@@ -115,4 +127,4 @@ connection master; 
drop table t1,t2,t3,t4;

sync_slave_with_master;



# End of 4.1 tests
 
--echo End of 5.1 tests