Merge work:/home/bk/mysql-4.0

into mysql.sashanet.com:/home/sasha/src/bk/mysql-4.0

Merge work:/home/bk/mysql-4.0
into mysql.sashanet.com:/home/sasha/src/bk/mysql-4.0
415df59f · sasha@mysql.sashanet.com · 56a36c71 · a74811e7 · 415df59f · 415df59f
Commit 415df59f authored Oct 13, 2001 by sasha@mysql.sashanet.com
15 changed files
--- a/client/mysqlmanagerc.c
+++ b/client/mysqlmanagerc.c
@@ -14,7 +14,7 @@
   along with this program; if not, write to the Free Software
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-#define MANAGER_CLIENT_VERSION "1.0"
+#define MANAGER_CLIENT_VERSION "1.1"
 #include <my_global.h>
 #include <mysql.h>
@@ -28,7 +28,7 @@
 #include <unistd.h>
 #ifndef MYSQL_MANAGER_PORT
-#define MYSQL_MANAGER_PORT 23546
+#define MYSQL_MANAGER_PORT 9305
 #endif
 static void die(const char* fmt, ...);

--- a/client/mysqltest.c
+++ b/client/mysqltest.c
@@ -2158,12 +2158,15 @@ static void var_from_env(const char* name, const char* def_val)
 static void init_var_hash()
 {
+  VAR* v;
  if (hash_init(&var_hash, 1024, 0, 0, get_var_key, var_free, MYF(0)))
    die("Variable hash initialization failed");
  var_from_env("MASTER_MYPORT", "9306");
  var_from_env("SLAVE_MYPORT", "9307");
  var_from_env("MYSQL_TEST_DIR", "/tmp");
  var_from_env("BIG_TEST", opt_big_test ? "1" : "0");
+  v=var_init(0,"MAX_TABLES", 0, (sizeof(ulong) == 4) ? "31" : "63",0);
+  hash_insert(&var_hash, (byte*)v);
 }

--- a/include/mysql.h
+++ b/include/mysql.h
@@ -238,7 +238,7 @@ typedef struct st_mysql_res {
 typedef struct st_mysql_manager
 {
-  Vio* vio;
+  NET net;
  char *host,*user,*passwd;
  unsigned int port;
  my_bool free_me;

--- a/libmysql/libmysql.c
+++ b/libmysql/libmysql.c
@@ -905,7 +905,8 @@ unpack_fields(MYSQL_DATA *data,MEM_ROOT *alloc,uint fields,
 static MYSQL_DATA *read_rows(MYSQL *mysql,MYSQL_FIELD *mysql_fields,
 			     uint fields)
 {
-  uint	field,pkt_len;
+  uint	field;
+  ulong pkt_len;
  ulong len;
  uchar *cp;
  char	*to;
@@ -991,7 +992,7 @@ read_one_row(MYSQL *mysql,uint fields,MYSQL_ROW row, ulong *lengths)
  ulong pkt_len,len;
  uchar *pos,*prev_pos;
-  if ((pkt_len=(uint) net_safe_read(mysql)) == packet_error)
+  if ((pkt_len=net_safe_read(mysql)) == packet_error)
    return -1;
  if (pkt_len == 1 && mysql->net.read_pos[0] == 254)
    return 1;				/* End of data */
@@ -1453,7 +1454,7 @@ mysql_real_connect(MYSQL *mysql,const char *host, const char *user,
  my_socket	sock;
  uint32	ip_addr;
  struct	sockaddr_in sock_addr;
-  uint		pkt_length;
+  ulong		pkt_length;
  NET		*net= &mysql->net;
 #ifdef __WIN__
  HANDLE	hPipe=INVALID_HANDLE_VALUE;
@@ -2135,7 +2136,7 @@ int STDCALL mysql_read_query_result(MYSQL *mysql)
  uchar *pos;
  ulong field_count;
  MYSQL_DATA *fields;
-  uint length;
+  ulong length;
  DBUG_ENTER("mysql_read_query_result");
  /* read from the connection which we actually used, which

--- a/libmysql/manager.c
+++ b/libmysql/manager.c
@@ -91,6 +91,7 @@ MYSQL_MANAGER*  STDCALL mysql_manager_connect(MYSQL_MANAGER* con,
  uint32 ip_addr;
  char msg_buf[MAX_MYSQL_MANAGER_MSG];
  int msg_len;
+  Vio* vio;
  if (!host)
    host="localhost";
@@ -105,13 +106,14 @@ MYSQL_MANAGER*  STDCALL mysql_manager_connect(MYSQL_MANAGER* con,
    strmov(con->last_error,"Cannot create socket");
    goto err;
  }
-  if (!(con->vio=vio_new(sock,VIO_TYPE_TCPIP,FALSE)))
+  if (!(vio=vio_new(sock,VIO_TYPE_TCPIP,FALSE)))
  {
    con->last_errno=ENOMEM;
    strmov(con->last_error,"Cannot create network I/O object");
    goto err;
  }
-  vio_blocking(con->vio,TRUE);
+  vio_blocking(vio,TRUE);
+  my_net_init(&con->net,vio);
  bzero((char*) &sock_addr,sizeof(sock_addr));
  sock_addr.sin_family = AF_INET;
  if ((int) (ip_addr = inet_addr(host)) != (int) INADDR_NONE)
@@ -155,7 +157,7 @@ MYSQL_MANAGER*  STDCALL mysql_manager_connect(MYSQL_MANAGER* con,
    goto err;
  }
  /* read the greating */
-  if (vio_read(con->vio,msg_buf,MAX_MYSQL_MANAGER_MSG)<=0)
+  if (my_net_read(&con->net) == packet_error)
  {
    con->last_errno=errno;
    strmov(con->last_error,"Read error on socket");
@@ -163,19 +165,19 @@ MYSQL_MANAGER*  STDCALL mysql_manager_connect(MYSQL_MANAGER* con,
  }
  sprintf(msg_buf,"%-.16s %-.16s\n",user,passwd);
  msg_len=strlen(msg_buf);
-  if (vio_write(con->vio,msg_buf,msg_len)!=msg_len)
+  if (my_net_write(&con->net,msg_buf,msg_len) || net_flush(&con->net))
  {
-    con->last_errno=errno;
+    con->last_errno=con->net.last_errno;
    strmov(con->last_error,"Write error on socket");
    goto err;
  }
-  if (vio_read(con->vio,msg_buf,MAX_MYSQL_MANAGER_MSG)<=0)
+  if (my_net_read(&con->net) == packet_error)
  {
    con->last_errno=errno;
    strmov(con->last_error,"Read error on socket");
    goto err;
  }
-  if ((con->cmd_status=atoi(msg_buf)) != MANAGER_OK)
+  if ((con->cmd_status=atoi(con->net.read_pos)) != MANAGER_OK)
  {
    strmov(con->last_error,"Access denied");
    goto err;
@@ -210,11 +212,7 @@ void            STDCALL mysql_manager_close(MYSQL_MANAGER* con)
     allocated in my_multimalloc() along with con->host, freeing
     con->hosts frees the whole block
  */
-  if (con->vio)
+  net_end(&con->net);
-  {
-    vio_delete(con->vio);
-    con->vio=0;
-  }
  if (con->free_me)
    my_free((gptr)con,MYF(0));
 }
@@ -224,7 +222,7 @@ int STDCALL mysql_manager_command(MYSQL_MANAGER* con,const char* cmd,
 {
  if (!cmd_len)
    cmd_len=strlen(cmd);
-  if (vio_write(con->vio,(char*)cmd,cmd_len) != cmd_len)
+  if (my_net_write(&con->net,(char*)cmd,cmd_len) || net_flush(&con->net))
  {
    con->last_errno=errno;
    strmov(con->last_error,"Write error on socket");
@@ -238,9 +236,9 @@ int  STDCALL mysql_manager_fetch_line(MYSQL_MANAGER* con, char* res_buf,
 						 int res_buf_size)
 {
  char* res_buf_end=res_buf+res_buf_size;
-  char* net_buf_pos=con->net_buf_pos, *net_buf_end=con->net_data_end;
+  char* net_buf=con->net.read_pos, *net_buf_end;
  int res_buf_shift=RES_BUF_SHIFT;
-  int done=0;
+  uint num_bytes;
  if (res_buf_size<RES_BUF_SHIFT)
  {
@@ -249,50 +247,26 @@ int  STDCALL mysql_manager_fetch_line(MYSQL_MANAGER* con, char* res_buf,
    return 1;
  }
-  for (;;)
+  if ((num_bytes=my_net_read(&con->net)) == packet_error)
  {
-    for (;net_buf_pos<net_buf_end && res_buf<res_buf_end;
+    con->last_errno=errno;
-	 net_buf_pos++,res_buf++)
+    strmov(con->last_error,"socket read failed");
-    {
+    return 1;
-      char c=*net_buf_pos;
-      if (c == '\r')
-	c=*++net_buf_pos;
-      if (c == '\n')
-      {
-	*res_buf=0;
-	net_buf_pos++;
-	done=1;
-	break;
-      }
-      else
-	*res_buf=*net_buf_pos;
-    }
-    if (done || res_buf==res_buf_end)
-      break;
-    if (net_buf_pos == net_buf_end && res_buf<res_buf_end)
-    {
-      int num_bytes;
-      if ((num_bytes=vio_read(con->vio,con->net_buf,con->net_buf_size))<=0)
-      {
-	con->last_errno=errno;
-	strmov(con->last_error,"socket read failed");
-	return 1;
-      }
-      net_buf_pos=con->net_buf;
-      net_buf_end=net_buf_pos+num_bytes;
-    }
  }
-  con->net_buf_pos=net_buf_pos;
-  con->net_data_end=net_buf_end;
+  net_buf_end=net_buf+num_bytes;
-  res_buf=res_buf_end-res_buf_size;
-  if ((con->eof=(res_buf[3]==' ')))
+  if ((con->eof=(net_buf[3]==' ')))
    res_buf_shift--;
-  res_buf_end-=res_buf_shift;
+  net_buf+=res_buf_shift;
-  for (;res_buf<res_buf_end;res_buf++)
+  res_buf_end[-1]=0;
+  for (;net_buf<net_buf_end && res_buf < res_buf_end;res_buf++,net_buf++)
  {
-    if(!(*res_buf=res_buf[res_buf_shift]))
+    if((*res_buf=*net_buf) == '\r')
+    {
+      *res_buf=0;
      break;
+    }
  }
  return 0;
 }

--- a/mysql-test/mysql-test-run.sh
+++ b/mysql-test/mysql-test-run.sh
@@ -233,6 +233,9 @@ while test $# -gt 0; do
      EXTRA_MASTER_MYSQLD_OPT="$EXTRA_MASTER_MYSQLD_OPT $1"
      EXTRA_SLAVE_MYSQLD_OPT="$EXTRA_SLAVE_MYSQLD_OPT $1"
      ;;
+    --strace-client )
+      STRACE_CLIENT=1
+      ;;        
    --debug)
      EXTRA_MASTER_MYSQLD_OPT="$EXTRA_MASTER_MYSQLD_OPT \
       --debug=d:t:i:O,$MYSQL_TEST_DIR/var/log/master.trace"
@@ -298,6 +301,10 @@ if [ x$SOURCE_DIST = x1 ] ; then
 else
   MYSQL_TEST="$BASEDIR/client/mysqltest"
 fi
+ if [ -n "$STRACE_CLIENT" ]; then
+  MYSQL_TEST="strace -o $MYSQL_TEST_DIR/var/log/mysqltest.strace $MYSQL_TEST"
+ fi
 MYSQLADMIN="$BASEDIR/client/mysqladmin"
 MYSQL_MANAGER_CLIENT="$BASEDIR/client/mysqlmanagerc"
 MYSQL_MANAGER="$BASEDIR/tools/mysqlmanager"
@@ -667,8 +674,8 @@ start_master()
    elif [ x$DO_GDB = x1 ]
    then
      $ECHO "set args $master_args" > $GDB_MASTER_INIT
-      manager_launch master $XTERM -display :0 -title "Master" -e gdb -x \
+      manager_launch master $XTERM -display $DISPLAY \
-       $GDB_MASTER_INIT $MYSQLD 
+      -title "Master" -e gdb -x $GDB_MASTER_INIT $MYSQLD 
    else	    
      manager_launch master $MYSQLD $master_args  
    fi  

--- a/mysql-test/r/join.result
+++ b/mysql-test/r/join.result
@@ -89,7 +89,7 @@ a
 1
 2
 select t1.a from t1 as t1 left join t1 as t2 using (a) left join t1 as t3 using (a) left join t1 as t4 using (a) left join t1 as t5 using (a) left join t1 as t6 using (a) left join t1 as t7 using (a) left join t1 as t8 using (a) left join t1 as t9 using (a) left join t1 as t10 using (a) left join t1 as t11 using (a) left join t1 as t12 using (a) left join t1 as t13 using (a) left join t1 as t14 using (a) left join t1 as t15 using (a) left join t1 as t16 using (a) left join t1 as t17 using (a) left join t1 as t18 using (a) left join t1 as t19 using (a) left join t1 as t20 using (a) left join t1 as t21 using (a) left join t1 as t22 using (a) left join t1 as t23 using (a) left join t1 as t24 using (a) left join t1 as t25 using (a) left join t1 as t26 using (a) left join t1 as t27 using (a) left join t1 as t28 using (a) left join t1 as t29 using (a) left join t1 as t30 using (a) left join t1 as t31 using (a) left join t1 as t32 using (a) left join t1 as t33 using (a) left join t1 as t34 using (a) left join t1 as t35 using (a) left join t1 as t36 using (a) left join t1 as t37 using (a) left join t1 as t38 using (a) left join t1 as t39 using (a) left join t1 as t40 using (a) left join t1 as t41 using (a) left join t1 as t42 using (a) left join t1 as t43 using (a) left join t1 as t44 using (a) left join t1 as t45 using (a) left join t1 as t46 using (a) left join t1 as t47 using (a) left join t1 as t48 using (a) left join t1 as t49 using (a) left join t1 as t50 using (a) left join t1 as t51 using (a) left join t1 as t52 using (a) left join t1 as t53 using (a) left join t1 as t54 using (a) left join t1 as t55 using (a) left join t1 as t56 using (a) left join t1 as t57 using (a) left join t1 as t58 using (a) left join t1 as t59 using (a) left join t1 as t60 using (a) left join t1 as t61 using (a) left join t1 as t62 using (a) left join t1 as t63 using (a) left join t1 as t64 using (a) left join t1 as t65 using (a);
-Too many tables. MySQL can only use 31 tables in a join
+Too many tables. MySQL can only use $MAX_TABLES tables in a join
 drop table t1;
 CREATE TABLE t1 (
 a int(11) NOT NULL,

--- a/mysql-test/t/join.test
+++ b/mysql-test/t/join.test
 #
 # This failed for lia Perminov
 #
+eval_result; # because MAX_TABLES is different on 64-bit system
 drop table if exists t1,t2;
 create table t1 (id int primary key);
 create table t2 (id int);

--- a/sql/mini_client.cc
+++ b/sql/mini_client.cc
@@ -351,11 +351,11 @@ static int mc_sock_connect(my_socket s, const struct sockaddr *name,
 ** or packet is an error message
 *****************************************************************************/
-uint STDCALL
+ulong STDCALL
 mc_net_safe_read(MYSQL *mysql)
 {
  NET *net= &mysql->net;
-  uint len=0;
+  ulong len=0;
  if (net->vio != 0)
    len=my_net_read(net);
@@ -514,7 +514,7 @@ mc_mysql_connect(MYSQL *mysql,const char *host, const char *user,
  my_socket	sock;
  ulong		ip_addr;
  struct	sockaddr_in sock_addr;
-  uint		pkt_length;
+  ulong		pkt_length;
  NET		*net= &mysql->net;
  thr_alarm_t   alarmed;
  ALARM alarm_buff;
@@ -921,8 +921,8 @@ void STDCALL mc_mysql_free_result(MYSQL_RES *result)
      DBUG_PRINT("warning",("Not all rows in set were read; Ignoring rows"));
      for (;;)
      {
-	uint pkt_len;
+	ulong pkt_len;
-	if ((pkt_len=(uint) mc_net_safe_read(result->handle)) == packet_error)
+	if ((pkt_len=mc_net_safe_read(result->handle)) == packet_error)
 	  break;
 	if (pkt_len == 1 && result->handle->net.read_pos[0] == 254)
 	  break;				/* End of data */
@@ -999,7 +999,7 @@ int STDCALL mc_mysql_read_query_result(MYSQL *mysql)
  uchar *pos;
  ulong field_count;
  MYSQL_DATA *fields;
-  uint length;
+  ulong length;
  DBUG_ENTER("mc_mysql_read_query_result");
  if ((length = mc_net_safe_read(mysql)) == packet_error)
@@ -1174,7 +1174,8 @@ static my_ulonglong mc_net_field_length_ll(uchar **packet)
 static MYSQL_DATA *mc_read_rows(MYSQL *mysql,MYSQL_FIELD *mysql_fields,
 			     uint fields)
 {
-  uint	field,pkt_len;
+  uint	field;
+  ulong pkt_len;
  ulong len;
  uchar *cp;
  char	*to;
@@ -1183,7 +1184,7 @@ static MYSQL_DATA *mc_read_rows(MYSQL *mysql,MYSQL_FIELD *mysql_fields,
  NET *net = &mysql->net;
  DBUG_ENTER("mc_read_rows");
-  if ((pkt_len=(uint) mc_net_safe_read(mysql)) == packet_error)
+  if ((pkt_len=mc_net_safe_read(mysql)) == packet_error)
    DBUG_RETURN(0);
  if (!(result=(MYSQL_DATA*) my_malloc(sizeof(MYSQL_DATA),
 				       MYF(MY_WME | MY_ZEROFILL))))
@@ -1260,7 +1261,7 @@ static int mc_read_one_row(MYSQL *mysql,uint fields,MYSQL_ROW row,
  ulong pkt_len,len;
  uchar *pos,*prev_pos;
-  if ((pkt_len=(uint) mc_net_safe_read(mysql)) == packet_error)
+  if ((pkt_len=mc_net_safe_read(mysql)) == packet_error)
    return -1;
  if (pkt_len == 1 && mysql->net.read_pos[0] == 254)
    return 1;				/* End of data */

--- a/sql/mini_client.h
+++ b/sql/mini_client.h
@@ -35,7 +35,7 @@ mc_mysql_init(MYSQL *mysql);
 void STDCALL
 mc_mysql_debug(const char *debug);
-uint STDCALL
+ulong STDCALL
 mc_net_safe_read(MYSQL *mysql);
 char * STDCALL mc_mysql_error(MYSQL *mysql);

--- a/sql/slave.cc
+++ b/sql/slave.cc
@@ -335,7 +335,7 @@ static int init_intvar_from_file(int* var, IO_CACHE* f, int default_val)
 static int create_table_from_dump(THD* thd, NET* net, const char* db,
 				  const char* table_name)
 {
-  uint packet_len = my_net_read(net); // read create table statement
+  ulong packet_len = my_net_read(net); // read create table statement
  Vio* save_vio;
  HA_CHECK_OPT check_opt;
  TABLE_LIST tables;
@@ -870,7 +870,7 @@ command");
 static uint read_event(MYSQL* mysql, MASTER_INFO *mi)
 {
-  uint len = packet_error;
+  ulong len = packet_error;
  // for convinience lets think we start by
  // being in the interrupted state :-)
  int read_errno = EINTR;
@@ -890,7 +890,7 @@ static uint read_event(MYSQL* mysql, MASTER_INFO *mi)
  }
  if (abort_loop || abort_slave)
    return packet_error;
-  if (len == packet_error || (int) len < 1)
+  if (len == packet_error || (long) len < 1)
  {
    sql_print_error("Error reading packet from server: %s (read_errno %d,\
 server_errno=%d)",

--- a/sql/sql_parse.cc
+++ b/sql/sql_parse.cc
@@ -938,10 +938,12 @@ bool dispatch_command(enum enum_server_command command, THD *thd,
      pos = uint4korr(packet);
      flags = uint2korr(packet + 4);
      pthread_mutex_lock(&LOCK_server_id);
+      thd->server_id=0; /* avoid suicide */
      kill_zombie_dump_threads(slave_server_id = uint4korr(packet+6));
      thd->server_id = slave_server_id;
      pthread_mutex_unlock(&LOCK_server_id);
      mysql_binlog_send(thd, thd->strdup(packet + 10), pos, flags);
+      unregister_slave(thd,1,1);
      // fake COM_QUIT -- if we get here, the thread needs to terminate
      error = TRUE;
      net->error = 0;

--- a/sql/sql_repl.cc
+++ b/sql/sql_repl.cc
@@ -106,10 +106,25 @@ static int fake_rotate_event(NET* net, String* packet, char* log_file_name,
  p+= len; \
 }\
+void unregister_slave(THD* thd, bool only_mine, bool need_mutex)
+{
+  if (need_mutex)
+    pthread_mutex_lock(&LOCK_slave_list);
+  if (thd->server_id)
+  {
+    SLAVE_INFO* old_si;
+    if ((old_si = (SLAVE_INFO*)hash_search(&slave_list,
+					   (byte*)&thd->server_id, 4)) &&
+	(!only_mine || old_si->thd == thd))
+    hash_delete(&slave_list, (byte*)old_si);
+  }
+  if (need_mutex)
+    pthread_mutex_unlock(&LOCK_slave_list);
+}
 int register_slave(THD* thd, uchar* packet, uint packet_length)
 {
-  SLAVE_INFO *si, *old_si;
+  SLAVE_INFO *si;
  int res = 1;
  uchar* p = packet, *p_end = packet + packet_length;
@@ -119,18 +134,16 @@ int register_slave(THD* thd, uchar* packet, uint packet_length)
  if (!(si = (SLAVE_INFO*)my_malloc(sizeof(SLAVE_INFO), MYF(MY_WME))))
    goto err;
-  si->server_id = uint4korr(p);
+  thd->server_id = si->server_id = uint4korr(p);
  p += 4;
  get_object(p,si->host);
  get_object(p,si->user);
  get_object(p,si->password);
  si->port = uint2korr(p);
+  si->thd = thd;
  pthread_mutex_lock(&LOCK_slave_list);
-  if ((old_si = (SLAVE_INFO*)hash_search(&slave_list,
+  unregister_slave(thd,0,0);
-					(byte*)&si->server_id, 4)))
-     hash_delete(&slave_list, (byte*)old_si);
  res = hash_insert(&slave_list, (byte*) si);
  pthread_mutex_unlock(&LOCK_slave_list);
  return res;

--- a/sql/sql_repl.h
+++ b/sql/sql_repl.h
@@ -10,6 +10,7 @@ typedef struct st_slave_info
  char user[USERNAME_LENGTH+1];
  char password[HASH_PASSWORD_LENGTH+1];
  uint16 port;
+  THD* thd;
 } SLAVE_INFO;
 extern bool opt_show_slave_auth_info, opt_old_rpl_compat;
@@ -44,6 +45,7 @@ void reset_master();
 void init_slave_list();
 void end_slave_list();
 int register_slave(THD* thd, uchar* packet, uint packet_length);
+void unregister_slave(THD* thd, bool only_mine, bool need_mutex);
 int purge_master_logs(THD* thd, const char* to_log);
 bool log_in_use(const char* log_name);
 void adjust_linfo_offsets(my_off_t purge_offset);

--- a/tools/mysqlmanager.c
+++ b/tools/mysqlmanager.c
@@ -133,7 +133,7 @@ typedef enum {PARAM_STDOUT,PARAM_STDERR} PARAM_TYPE;
 struct manager_thd
 {
-  Vio* vio;
+  NET net;
  char user[MAX_USER_NAME+1];
  int priv_flags;
  char* cmd_buf;
@@ -154,7 +154,7 @@ struct manager_exec* cur_launch_exec=0;
 static struct manager_thd* manager_thd_new(Vio* vio);
 static struct manager_exec* manager_exec_new(char* arg_start,char* arg_end);
-static void manager_exec_print(Vio* vio,struct manager_exec* e);
+static void manager_exec_print(NET* net,struct manager_exec* e);
 static void manager_thd_free(struct manager_thd* thd);
 static void manager_exec_free(void* e);
 static void manager_exec_connect(struct manager_exec* e);
@@ -291,9 +291,9 @@ static void die(const char* fmt,...);
 static void print_time(FILE* fp);
 static void clean_up();
 static struct manager_cmd* lookup_cmd(char* s,int len);
-static void client_msg(Vio* vio,int err_code,const char* fmt,...);
+static int client_msg(NET* net,int err_code,const char* fmt,...);
-static void client_msg_pre(Vio* vio,int err_code,const char* fmt,...);
+static int client_msg_pre(NET* net,int err_code,const char* fmt,...);
-static void client_msg_raw(Vio* vio,int err_code,int pre,const char* fmt,
+static int client_msg_raw(NET* net,int err_code,int pre,const char* fmt,
 			    va_list args);
 static int authenticate(struct manager_thd* thd);
 static char* read_line(struct manager_thd* thd); /* returns pointer to end of
@@ -307,6 +307,27 @@ static int exec_line(struct manager_thd* thd,char* buf,char* buf_end);
 void print_stacktrace();
 #endif
+static void log_msg(const char* fmt, int msg_type, va_list args);
+/* No 'inline' here becasue functions with ... can't do that portable */
+#define LOG_MSG_FUNC(type,TYPE) static void type  \
+ (const char* fmt,...) { \
+  va_list args; \
+  va_start(args,fmt); \
+  log_msg(fmt,TYPE,args);\
+ }
+LOG_MSG_FUNC(log_err,LOG_ERR)
+LOG_MSG_FUNC(log_warn,LOG_WARN)
+LOG_MSG_FUNC(log_info,LOG_INFO)
+#ifndef DBUG_OFF
+LOG_MSG_FUNC(log_debug,LOG_DEBUG)
+#else
+void log_debug(const char* __attribute__((unused)) fmt,...) {}
+#endif
 static void handle_segfault(int sig)
 {
  if (in_segfault)
@@ -369,11 +390,13 @@ static int exec_line(struct manager_thd* thd,char* buf,char* buf_end)
  struct manager_cmd* cmd;
  for (;p<buf_end && !isspace(*p);p++)
    *p=tolower(*p);
+  log_info("Command '%s'", buf);
  if (!(cmd=lookup_cmd(buf,(int)(p-buf))))
  {
-    client_msg(thd->vio,MANAGER_CLIENT_ERR,
+    if(client_msg(&thd->net,MANAGER_CLIENT_ERR,
-	       "Unrecognized command, type help to see list of supported\
+	       "Unrecognized command '%s', type help to see list of supported\
- commands");
+ commands", buf))
+      thd->fatal=1;
    return 1;
  }
  for (;p<buf_end && isspace(*p);p++);
@@ -393,13 +416,13 @@ static struct manager_cmd* lookup_cmd(char* s,int len)
 HANDLE_NOARG_DECL(handle_ping)
 {
-  client_msg(thd->vio,MANAGER_OK,"Server management daemon is alive");
+  client_msg(&thd->net,MANAGER_OK,"Server management daemon is alive");
  return 0;
 }
 HANDLE_NOARG_DECL(handle_quit)
 {
-  client_msg(thd->vio,MANAGER_OK,"Goodbye");
+  client_msg(&thd->net,MANAGER_OK,"Goodbye");
  thd->finished=1;
  return 0;
 }
@@ -407,19 +430,19 @@ HANDLE_NOARG_DECL(handle_quit)
 HANDLE_NOARG_DECL(handle_help)
 {
  struct manager_cmd* cmd = commands;
-  Vio* vio = thd->vio;
+  NET* net = &thd->net;
-  client_msg_pre(vio,MANAGER_INFO,"Available commands:");
+  client_msg_pre(net,MANAGER_INFO,"Available commands:");
  for (;cmd->name;cmd++)
  {
-    client_msg_pre(vio,MANAGER_INFO,"%s - %s", cmd->name, cmd->help);
+    client_msg_pre(net,MANAGER_INFO,"%s - %s", cmd->name, cmd->help);
  }
-  client_msg_pre(vio,MANAGER_INFO,"End of help");
+  client_msg_pre(net,MANAGER_INFO,"End of help");
  return 0;
 }
 HANDLE_NOARG_DECL(handle_shutdown)
 {
-  client_msg(thd->vio,MANAGER_OK,"Shutdown started, goodbye");
+  client_msg(&thd->net,MANAGER_OK,"Shutdown started, goodbye");
  thd->finished=1;
  shutdown_requested = 1;
  if (!one_thread)
@@ -470,10 +493,10 @@ HANDLE_DECL(handle_set_exec_con)
    }
  }
  pthread_mutex_unlock(&lock_exec_hash);
-  client_msg(thd->vio,MANAGER_OK,"Entry updated");
+  client_msg(&thd->net,MANAGER_OK,"Entry updated");
  return 0;
 err:
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,error);
+  client_msg(&thd->net,MANAGER_CLIENT_ERR,error);
  return 1;
 }
@@ -531,10 +554,10 @@ static int set_exec_param(struct manager_thd* thd, char* args_start,
  }
  strnmov(param,arg_p,FN_REFLEN);
  pthread_mutex_unlock(&lock_exec_hash);
-  client_msg(thd->vio,MANAGER_OK,"Entry updated");
+  client_msg(&thd->net,MANAGER_OK,"Entry updated");
  return 0;
 err:
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,error);
+  client_msg(&thd->net,MANAGER_CLIENT_ERR,error);
  return 1;
 }
@@ -581,10 +604,10 @@ HANDLE_DECL(handle_start_exec)
  pthread_mutex_unlock(&e->lock);
  if (error)
    goto err;
-  client_msg(thd->vio,MANAGER_OK,"'%s' started",e->ident);
+  client_msg(&thd->net,MANAGER_OK,"'%s' started",e->ident);
  return 0;
 err:
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,error);
+  client_msg(&thd->net,MANAGER_CLIENT_ERR,error);
  return 1;
 }
@@ -636,11 +659,11 @@ HANDLE_DECL(handle_stop_exec)
  pthread_mutex_unlock(&e->lock);
  if (!error)
  {
-    client_msg(thd->vio,MANAGER_OK,"'%s' terminated",e->ident);
+    client_msg(&thd->net,MANAGER_OK,"'%s' terminated",e->ident);
    return 0;
  }
 err:
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,error);
+  client_msg(&thd->net,MANAGER_CLIENT_ERR,error);
  return 1;
 }
@@ -705,7 +728,7 @@ HANDLE_DECL(handle_query)
      *p++='\t';
    }
    *p=0;
-    client_msg_pre(thd->vio,MANAGER_OK,buf);
+    client_msg_pre(&thd->net,MANAGER_OK,buf);
    while ((row=mysql_fetch_row(res)))
    {
@@ -716,14 +739,14 @@ HANDLE_DECL(handle_query)
 	*p++='\t';
      }
      *p=0;
-      client_msg_pre(thd->vio,MANAGER_OK,buf);
+      client_msg_pre(&thd->net,MANAGER_OK,buf);
    }
  }
  pthread_mutex_unlock(&e->lock);
-  client_msg(thd->vio,MANAGER_OK,"End");
+  client_msg(&thd->net,MANAGER_OK,"End");
  return 0;
 err:
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,error);
+  client_msg(&thd->net,MANAGER_CLIENT_ERR,error);
  return 1;
 }
@@ -756,10 +779,10 @@ HANDLE_DECL(handle_def_exec)
  }
  hash_insert(&exec_hash,(byte*)e);
  pthread_mutex_unlock(&lock_exec_hash);
-  client_msg(thd->vio,MANAGER_OK,"Exec definition created");
+  client_msg(&thd->net,MANAGER_OK,"Exec definition created");
  return 0;
 err:
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,error);
+  client_msg(&thd->net,MANAGER_CLIENT_ERR,error);
  if (e)
    manager_exec_free(e);
  return 1;
@@ -768,16 +791,16 @@ err:
 HANDLE_NOARG_DECL(handle_show_exec)
 {
  uint i;
-  client_msg_pre(thd->vio,MANAGER_INFO,"Exec_def\tPid\tExit_status\tCon_info\
+  client_msg_pre(&thd->net,MANAGER_INFO,"Exec_def\tPid\tExit_status\tCon_info\
 \tStdout\tStderr\tArguments");
  pthread_mutex_lock(&lock_exec_hash);
  for (i=0;i<exec_hash.records;i++)
  {
    struct manager_exec* e=(struct manager_exec*)hash_element(&exec_hash,i);
-    manager_exec_print(thd->vio,e);
+    manager_exec_print(&thd->net,e);
  }
  pthread_mutex_unlock(&lock_exec_hash);
-  client_msg(thd->vio,MANAGER_INFO,"End");
+  client_msg(&thd->net,MANAGER_INFO,"End");
  return 0;
 }
@@ -873,7 +896,7 @@ static char* arg_strmov(char* dest, const char* src, int n)
  return dest;
 }
-static void manager_exec_print(Vio* vio,struct manager_exec* e)
+static void manager_exec_print(NET* net,struct manager_exec* e)
 {
  char buf[MAX_MYSQL_MANAGER_MSG];
  char* p=buf,*buf_end=buf+sizeof(buf)-1;
@@ -921,7 +944,7 @@ static void manager_exec_print(Vio* vio,struct manager_exec* e)
  }
 end:  
  *p=0;
-  client_msg_pre(vio,MANAGER_INFO,buf);
+  client_msg_pre(net,MANAGER_INFO,buf);
  return;
 }
@@ -933,7 +956,7 @@ static int authenticate(struct manager_thd* thd)
  struct manager_user* u;
  char c;
-  client_msg(thd->vio,MANAGER_INFO, manager_greeting);
+  client_msg(&thd->net,MANAGER_INFO, manager_greeting);
  if (!(buf_end=read_line(thd)))
    return -1;
  for (buf=thd->cmd_buf,p=thd->user,p_end=p+MAX_USER_NAME;
@@ -959,7 +982,7 @@ static int authenticate(struct manager_thd* thd)
  my_MD5Final(digest,&context);
  if (memcmp(u->md5_pass,digest,MD5_LEN))
    return 1;
-  client_msg(thd->vio,MANAGER_OK,"OK");
+  client_msg(&thd->net,MANAGER_OK,"OK");
  return 0;
 }
@@ -1025,24 +1048,6 @@ static void log_msg(const char* fmt, int msg_type, va_list args)
  pthread_mutex_unlock(&lock_log);
 }
-/* No 'inline' here becasue functions with ... can't do that portable */
-#define LOG_MSG_FUNC(type,TYPE) static void type  \
- (const char* fmt,...) { \
-  va_list args; \
-  va_start(args,fmt); \
-  log_msg(fmt,TYPE,args);\
- }
-LOG_MSG_FUNC(log_err,LOG_ERR)
-LOG_MSG_FUNC(log_warn,LOG_WARN)
-LOG_MSG_FUNC(log_info,LOG_INFO)
-#ifndef DBUG_OFF
-LOG_MSG_FUNC(log_debug,LOG_DEBUG)
-#else
-void log_debug(const char* __attribute__((unused)) fmt,...) {}
-#endif
 static pthread_handler_decl(process_launcher_messages,
 			    __attribute__((unused)) arg)
 {
@@ -1121,7 +1126,7 @@ static pthread_handler_decl(process_connection,arg)
  return 0;					/* Don't get cc warning */
 }
-static void client_msg_raw(Vio* vio, int err_code, int pre, const char* fmt,
+static int client_msg_raw(NET* net, int err_code, int pre, const char* fmt,
 			   va_list args)
 {
  char buf[MAX_CLIENT_MSG_LEN],*p,*buf_end;
@@ -1136,73 +1141,51 @@ static void client_msg_raw(Vio* vio, int err_code, int pre, const char* fmt,
    p=buf_end - 2;
  *p++='\r';
  *p++='\n';
-  if (vio_write(vio,buf,(uint)(p-buf))<=0)
-    log_err("Failed writing to client: errno=%d",errno);
+  if (my_net_write(net,buf,(uint)(p-buf)) || net_flush(net))
+  {
+    p[-2]=0;
+    log_err("Failed writing '%s' to client: errno=%d",buf,errno);
+    net_end(net);
+    return 1;
+  }
+  return 0;
 }
-static void client_msg(Vio* vio, int err_code, const char* fmt, ...)
+static int client_msg(NET* net, int err_code, const char* fmt, ...)
 {
  va_list args;
  va_start(args,fmt);
-  client_msg_raw(vio,err_code,0,fmt,args);
+  return client_msg_raw(net,err_code,0,fmt,args);
 }
-static void client_msg_pre(Vio* vio, int err_code, const char* fmt, ...)
+static int client_msg_pre(NET* net, int err_code, const char* fmt, ...)
 {
  va_list args;
  va_start(args,fmt);
-  client_msg_raw(vio,err_code,1,fmt,args);
+  return client_msg_raw(net,err_code,1,fmt,args);
 }
 static char* read_line(struct manager_thd* thd)
 {
-  char* p=thd->cmd_buf;
+  int len;
-  char* buf_end = thd->cmd_buf + manager_max_cmd_len;
+  char* p, *buf_end;
-  int escaped = 0;
+  if ((len=my_net_read(&thd->net)) == (int)packet_error || !len)
-  for (;p<buf_end;)
-  {
-    int len,read_len;
-    char *block_end,*p_back;
-    uint retry_count=0;
-    read_len = min(NET_BLOCK,(uint)(buf_end-p));
-    while ((len=vio_read(thd->vio,p,read_len))<=0)
    {
-      if (vio_should_retry(thd->vio) && retry_count++ < MAX_RETRY_COUNT)
-	continue;
      log_err("Error reading command from client (Error: %d)",
-	      vio_errno(thd->vio));
+	      errno);
      thd->fatal=1;
      return 0;
    }
-    block_end=p+len;
+  buf_end=thd->cmd_buf+len;
-    /* a trick to unescape in place */
+  for (p=thd->cmd_buf;p<buf_end;p++)
-    for (p_back=p;p<block_end;p++)
+    if (*p == '\r' || *p == '\n')
    {
-      char c=*p;
+      *p=0;
-      if (c==ESCAPE_CHAR)
+      break;
-      {
-	if (!escaped)
-	{
-	  escaped=1;
-	  continue;
-	}
-	else
-	  escaped=0;
-      }
-      if (c==EOL_CHAR && !escaped)
-	break;
-      *p_back++=c;
-      escaped=0;
-    }
-    if (p!=block_end)
-    {
-      *p_back=0;
-      return p_back;
    }
-  }
-  client_msg(thd->vio,MANAGER_CLIENT_ERR,"Command line too long");
+  return p;
-  return 0;
 }
 static void handle_child(int __attribute__((unused)) sig)
@@ -1225,25 +1208,29 @@ static void handle_child(int __attribute__((unused)) sig)
 struct manager_thd* manager_thd_new(Vio* vio)
 {
  struct manager_thd* tmp;
-  if (!(tmp=(struct manager_thd*)my_malloc(sizeof(*tmp)+manager_max_cmd_len,
+  if (!(tmp=(struct manager_thd*)my_malloc(sizeof(*tmp),
 					MYF(0))))
  {
    log_err("Out of memory in manager_thd_new");
    return 0;
  }
-  tmp->vio=vio;
+  my_net_init(&tmp->net,vio);
  tmp->user[0]=0;
  tmp->priv_flags=0;
  tmp->fatal=tmp->finished=0;
-  tmp->cmd_buf=(char*)tmp+sizeof(*tmp);
+  tmp->cmd_buf=tmp->net.read_pos;
  return tmp;
 }
 static void manager_thd_free(struct manager_thd* thd)
 {
-  if (thd->vio)
+  NET* net=&thd->net;
-    vio_close(thd->vio);
+  if (net->vio)
-  my_free((byte*)thd->vio,MYF(0));
+  {
+    vio_delete(net->vio);
+    net->vio=0;
+  }
+  net_end(&thd->net);
 }
 static void clean_up()
@@ -1410,15 +1397,18 @@ static int run_server_loop()
      vio_close(vio);
      continue;
    }
    if (authenticate(thd))
    {
-      client_msg(vio,MANAGER_ACCESS, "Access denied");
+      client_msg(&thd->net,MANAGER_ACCESS, "Access denied");
      manager_thd_free(thd);
+      log_info("Client failed to authenticate");
      continue;
    }
    if (shutdown_requested)
+    {
+      manager_thd_free(thd);
      break;
+    }
    if (one_thread)
    {
      process_connection((void*)thd);
@@ -1427,7 +1417,8 @@ static int run_server_loop()
    }
    else if (pthread_create(&th,&thr_attr,process_connection,(void*)thd))
    {
-      client_msg(vio,MANAGER_INTERNAL_ERR,"Could not create thread, errno=%d",
+      client_msg(&thd->net,MANAGER_INTERNAL_ERR,
+		 "Could not create thread, errno=%d",
 		 errno);
      manager_thd_free(thd);
      continue;