Commit 437c3af3 authored by serg@serg.mylan's avatar serg@serg.mylan

Merge bk-internal:/home/bk/mysql-4.0/

into serg.mylan:/usr/home/serg/Abk/mysql-4.0
parents b5b4f44a 6bbe7b80
...@@ -1160,7 +1160,7 @@ bool dispatch_command(enum enum_server_command command, THD *thd, ...@@ -1160,7 +1160,7 @@ bool dispatch_command(enum enum_server_command command, THD *thd,
pos = uint4korr(packet); pos = uint4korr(packet);
flags = uint2korr(packet + 4); flags = uint2korr(packet + 4);
thd->server_id=0; /* avoid suicide */ thd->server_id=0; /* avoid suicide */
if ((slave_server_id= uint4korr(packet+6))) if ((slave_server_id= uint4korr(packet+6))) // mysqlbinlog.server_id==0
kill_zombie_dump_threads(slave_server_id); kill_zombie_dump_threads(slave_server_id);
thd->server_id = slave_server_id; thd->server_id = slave_server_id;
mysql_binlog_send(thd, thd->strdup(packet + 10), (my_off_t) pos, flags); mysql_binlog_send(thd, thd->strdup(packet + 10), (my_off_t) pos, flags);
......
...@@ -522,7 +522,7 @@ Increase max_allowed_packet on master"; ...@@ -522,7 +522,7 @@ Increase max_allowed_packet on master";
case LOG_READ_EOF: case LOG_READ_EOF:
DBUG_PRINT("wait",("waiting for data in binary log")); DBUG_PRINT("wait",("waiting for data in binary log"));
if (thd->server_id==0) if (thd->server_id==0) // for mysqlbinlog (mysqlbinlog.server_id==0)
{ {
pthread_mutex_unlock(log_lock); pthread_mutex_unlock(log_lock);
goto end; goto end;
......
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