Commit 9a1d651b authored by Sujatha Sivakumar's avatar Sujatha Sivakumar

Merge from mysql-5.1 to mysql-5.5

parents af0e2572 d054027c
/* Copyright (c) 2000, 2011, Oracle and/or its affiliates. All rights reserved. /* Copyright (c) 2000, 2013, Oracle and/or its affiliates. All rights reserved.
This program is free software; you can redistribute it and/or modify This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by it under the terms of the GNU General Public License as published by
...@@ -63,6 +63,8 @@ my_b_copy_to_file(IO_CACHE *cache, FILE *file) ...@@ -63,6 +63,8 @@ my_b_copy_to_file(IO_CACHE *cache, FILE *file)
DBUG_RETURN(1); DBUG_RETURN(1);
cache->read_pos= cache->read_end; cache->read_pos= cache->read_end;
} while ((bytes_in_cache= my_b_fill(cache))); } while ((bytes_in_cache= my_b_fill(cache)));
if(cache->error == -1)
DBUG_RETURN(1);
DBUG_RETURN(0); DBUG_RETURN(0);
} }
...@@ -219,6 +221,8 @@ size_t my_b_fill(IO_CACHE *info) ...@@ -219,6 +221,8 @@ size_t my_b_fill(IO_CACHE *info)
info->error= 0; info->error= 0;
return 0; /* EOF */ return 0; /* EOF */
} }
DBUG_EXECUTE_IF ("simulate_my_b_fill_error",
{DBUG_SET("+d,simulate_file_read_error");});
if ((length= my_read(info->file,info->buffer,max_length, if ((length= my_read(info->file,info->buffer,max_length,
info->myflags)) == (size_t) -1) info->myflags)) == (size_t) -1)
{ {
......
/* Copyright (c) 2000, 2011, Oracle and/or its affiliates. All rights reserved. /* Copyright (c) 2000, 2013, Oracle and/or its affiliates. All rights reserved.
This program is free software; you can redistribute it and/or modify This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by it under the terms of the GNU General Public License as published by
...@@ -49,6 +49,13 @@ size_t my_read(File Filedes, uchar *Buffer, size_t Count, myf MyFlags) ...@@ -49,6 +49,13 @@ size_t my_read(File Filedes, uchar *Buffer, size_t Count, myf MyFlags)
#else #else
readbytes= read(Filedes, Buffer, Count); readbytes= read(Filedes, Buffer, Count);
#endif #endif
DBUG_EXECUTE_IF ("simulate_file_read_error",
{
errno= ENOSPC;
readbytes= (size_t) -1;
DBUG_SET("-d,simulate_file_read_error");
DBUG_SET("-d,simulate_my_b_fill_error");
});
if (readbytes != Count) if (readbytes != Count)
{ {
......
...@@ -9393,6 +9393,8 @@ Write_rows_log_event::do_exec_row(const Relay_log_info *const rli) ...@@ -9393,6 +9393,8 @@ Write_rows_log_event::do_exec_row(const Relay_log_info *const rli)
#ifdef MYSQL_CLIENT #ifdef MYSQL_CLIENT
void Write_rows_log_event::print(FILE *file, PRINT_EVENT_INFO* print_event_info) void Write_rows_log_event::print(FILE *file, PRINT_EVENT_INFO* print_event_info)
{ {
DBUG_EXECUTE_IF("simulate_cache_read_error",
{DBUG_SET("+d,simulate_my_b_fill_error");});
Rows_log_event::print_helper(file, print_event_info, "Write_rows"); Rows_log_event::print_helper(file, print_event_info, "Write_rows");
} }
#endif #endif
......
...@@ -2004,6 +2004,8 @@ bool show_binlogs(THD* thd) ...@@ -2004,6 +2004,8 @@ bool show_binlogs(THD* thd)
if (protocol->write()) if (protocol->write())
goto err; goto err;
} }
if(index_file->error == -1)
goto err;
mysql_bin_log.unlock_index(); mysql_bin_log.unlock_index();
my_eof(thd); my_eof(thd);
DBUG_RETURN(FALSE); DBUG_RETURN(FALSE);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment