summaryrefslogtreecommitdiff
path: root/sql/records.cc
diff options
context:
space:
mode:
authorram@gw.mysql.r18.ru <>2004-10-06 12:49:56 +0500
committerram@gw.mysql.r18.ru <>2004-10-06 12:49:56 +0500
commit0944bed7fcb59fb38230a750bd820a22b3b6b476 (patch)
tree0535bd32f3125c03c099324bb261b9a5c9924a56 /sql/records.cc
parent992b04d3d8073a933b3c0e1ab229edaf52ab5df6 (diff)
parent4ec50dc4d7b216489eda1da5d0053dad30fd738f (diff)
downloadmariadb-git-0944bed7fcb59fb38230a750bd820a22b3b6b476.tar.gz
Merge rkalimullin@bk-internal.mysql.com:/home/bk/mysql-4.0
into gw.mysql.r18.ru:/usr/home/ram/work/4.0.b5733
Diffstat (limited to 'sql/records.cc')
-rw-r--r--sql/records.cc27
1 files changed, 18 insertions, 9 deletions
diff --git a/sql/records.cc b/sql/records.cc
index 7cbb1ab3205..98aede52416 100644
--- a/sql/records.cc
+++ b/sql/records.cc
@@ -131,17 +131,26 @@ void end_read_record(READ_RECORD *info)
static int rr_quick(READ_RECORD *info)
{
- int tmp=info->select->quick->get_next();
- if (tmp)
+ int tmp;
+ while ((tmp= info->select->quick->get_next()))
{
- if (tmp == HA_ERR_END_OF_FILE)
- tmp= -1;
- else
+ if (info->thd->killed)
{
- if (info->print_error)
- info->file->print_error(tmp,MYF(0));
- if (tmp < 0) // Fix negative BDB errno
- tmp=1;
+ my_error(ER_SERVER_SHUTDOWN, MYF(0));
+ return 1;
+ }
+ if (tmp != HA_ERR_RECORD_DELETED)
+ {
+ if (tmp == HA_ERR_END_OF_FILE)
+ tmp= -1;
+ else
+ {
+ if (info->print_error)
+ info->file->print_error(tmp,MYF(0));
+ if (tmp < 0) // Fix negative BDB errno
+ tmp=1;
+ }
+ break;
}
}
return tmp;