summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSinisa@sinisa.nasamreza.org <>2002-07-17 14:46:09 +0300
committerSinisa@sinisa.nasamreza.org <>2002-07-17 14:46:09 +0300
commit393bd5cff1f8ff34db6209dddbe8b4a042dce50b (patch)
tree2471cb78c008d6f0fdd06d1d52c298d8a5bb4bd3
parent460477344a71444ad1958149917f94b020d50b1f (diff)
downloadmariadb-git-393bd5cff1f8ff34db6209dddbe8b4a042dce50b.tar.gz
Another try to fix slave timeouts
-rw-r--r--sql/mini_client.cc5
-rw-r--r--sql/slave.cc7
2 files changed, 8 insertions, 4 deletions
diff --git a/sql/mini_client.cc b/sql/mini_client.cc
index 8f703b80e3a..453f27822d9 100644
--- a/sql/mini_client.cc
+++ b/sql/mini_client.cc
@@ -112,6 +112,8 @@ static my_bool is_NT(void)
}
#endif
+extern ulong slave_net_timeout;
+
/*
** Create a named pipe connection
*/
@@ -203,6 +205,7 @@ mc_mysql_init(MYSQL *mysql)
#ifdef __WIN__
mysql->options.connect_timeout=20;
#endif
+ mysql->net.timeout = slave_net_timeout;
return mysql;
}
@@ -655,7 +658,7 @@ mc_mysql_connect(MYSQL *mysql,const char *host, const char *user,
goto error;
}
vio_keepalive(net->vio,TRUE);
-
+ net->timeout=slave_net_timeout;
/* Get version info */
mysql->protocol_version= PROTOCOL_VERSION; /* Assume this */
if ((pkt_length=mc_net_safe_read(mysql)) == packet_error)
diff --git a/sql/slave.cc b/sql/slave.cc
index dd815037d5e..b11fcc0d847 100644
--- a/sql/slave.cc
+++ b/sql/slave.cc
@@ -456,7 +456,7 @@ int fetch_nx_table(THD* thd, MASTER_INFO* mi)
nx_errno = ER_BAD_HOST_ERROR;
goto err;
}
- mysql->net.timeout=slave_net_timeout;
+
safe_connect(thd, mysql, mi);
if (slave_killed(thd))
goto err;
@@ -1312,7 +1312,7 @@ pthread_handler_decl(handle_slave,arg __attribute__((unused)))
goto err;
}
- mysql->net.timeout=slave_net_timeout;
+
thd->proc_info = "connecting to master";
#ifndef DBUG_OFF
sql_print_error("Slave thread initialized");
@@ -1331,7 +1331,8 @@ pthread_handler_decl(handle_slave,arg __attribute__((unused)))
}
connected:
-
+
+ mysql->net.timeout=slave_net_timeout;
while (!slave_killed(thd))
{
thd->proc_info = "Requesting binlog dump";