summaryrefslogtreecommitdiff
path: root/sql/net_serv.cc
diff options
context:
space:
mode:
authorunknown <monty@mashka.mysql.fi>2003-01-02 16:26:26 +0200
committerunknown <monty@mashka.mysql.fi>2003-01-02 16:26:26 +0200
commit62b38d20ddcf4fb0f519e8b647916d7b367e894c (patch)
treed5f028634bcbaae2571568955a56ea1b2b5c266b /sql/net_serv.cc
parentba8ed9315a7dc7f1c8850f9104d5bc5fc052231f (diff)
parent8ec8636c41b3e9823fa7222e1dfe4d68fbb9ac76 (diff)
downloadmariadb-git-62b38d20ddcf4fb0f519e8b647916d7b367e894c.tar.gz
Merge work:/my/mysql-4.0 into mashka.mysql.fi:/home/my/mysql-4.0
sql/net_serv.cc: Auto merged sql/sql_parse.cc: Auto merged
Diffstat (limited to 'sql/net_serv.cc')
-rw-r--r--sql/net_serv.cc21
1 files changed, 18 insertions, 3 deletions
diff --git a/sql/net_serv.cc b/sql/net_serv.cc
index 0d4cf9b9444..49454c9df2c 100644
--- a/sql/net_serv.cc
+++ b/sql/net_serv.cc
@@ -479,6 +479,7 @@ static void my_net_skip_rest(NET *net, uint32 remain, thr_alarm_t *alarmed)
ALARM alarm_buff;
uint retry_count=0;
my_bool old_mode;
+ uint32 old=remain;
if (!thr_alarm_in_use(&alarmed))
{
@@ -500,6 +501,12 @@ static void my_net_skip_rest(NET *net, uint32 remain, thr_alarm_t *alarmed)
return;
}
remain -= (uint32) length;
+ if (!remain && old==MAX_THREE_BYTES &&
+ (length=vio_read(net->vio,(char*) net->buff,NET_HEADER_SIZE)))
+ {
+ old=remain= uint3korr(net->buff);
+ net->pkt_nr++;
+ }
statistic_add(bytes_received,length,&LOCK_bytes_received);
}
}
@@ -660,11 +667,19 @@ my_real_read(NET *net, ulong *complen)
{
if (net_realloc(net,helping))
{
+#ifdef MYSQL_SERVER
#ifndef NO_ALARM
- if (i == 1)
- my_net_skip_rest(net, (uint32) len, &alarmed);
+ if (net->compress)
+ {
+ len= packet_error;
+ goto end;
+ }
+ my_net_skip_rest(net, (uint32) len, &alarmed);
+ len=0;
+#endif
+#else
+ len= packet_error; /* Return error */
#endif
- len= packet_error; /* Return error */
goto end;
}
}