diff options
author | Sinisa@sinisa.nasamreza.org <> | 2002-07-17 14:46:09 +0300 |
---|---|---|
committer | Sinisa@sinisa.nasamreza.org <> | 2002-07-17 14:46:09 +0300 |
commit | 393bd5cff1f8ff34db6209dddbe8b4a042dce50b (patch) | |
tree | 2471cb78c008d6f0fdd06d1d52c298d8a5bb4bd3 | |
parent | 460477344a71444ad1958149917f94b020d50b1f (diff) | |
download | mariadb-git-393bd5cff1f8ff34db6209dddbe8b4a042dce50b.tar.gz |
Another try to fix slave timeouts
-rw-r--r-- | sql/mini_client.cc | 5 | ||||
-rw-r--r-- | sql/slave.cc | 7 |
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"; |