Commit 4280cdc4 authored by unknown's avatar unknown

Merge rburnett@bk-internal.mysql.com:/home/bk/mysql-5.1-kt

into  big_geek.:D:/work/mysql/mysql-5.1-vc71

parents 2380913d c38308de
...@@ -25,6 +25,7 @@ functions */ ...@@ -25,6 +25,7 @@ functions */
#if defined(_MSC_VER) && _MSC_VER >= 1400 #if defined(_MSC_VER) && _MSC_VER >= 1400
/* Avoid endless warnings about sprintf() etc. being unsafe. */ /* Avoid endless warnings about sprintf() etc. being unsafe. */
#define _CRT_SECURE_NO_DEPRECATE 1 #define _CRT_SECURE_NO_DEPRECATE 1
#define _USE_32BIT_TIME_T 1 /* force time_t to be 32 bit */
#endif #endif
#include <sys/locking.h> #include <sys/locking.h>
......
...@@ -108,7 +108,14 @@ sub mtr_exe_exists (@) { ...@@ -108,7 +108,14 @@ sub mtr_exe_exists (@) {
map {$_.= ".exe"} @path if $::glob_win32; map {$_.= ".exe"} @path if $::glob_win32;
foreach my $path ( @path ) foreach my $path ( @path )
{ {
return $path if -x $path; if($::glob_win32)
{
return $path if -f $path;
}
else
{
return $path if -x $path;
}
} }
if ( @path == 1 ) if ( @path == 1 )
{ {
......
...@@ -37,9 +37,6 @@ ...@@ -37,9 +37,6 @@
HFTODO this must be hidden if we don't want client capabilities in HFTODO this must be hidden if we don't want client capabilities in
embedded library embedded library
*/ */
#ifdef __WIN__
#include <winsock.h>
#endif
#include <my_global.h> #include <my_global.h>
#include <mysql.h> #include <mysql.h>
#include <mysql_embed.h> #include <mysql_embed.h>
...@@ -51,7 +48,9 @@ ...@@ -51,7 +48,9 @@
#include <violite.h> #include <violite.h>
#include <signal.h> #include <signal.h>
#include <errno.h> #include <errno.h>
#ifdef __WIN__
#include <winsock.h>
#endif
#ifdef __NETWARE__ #ifdef __NETWARE__
#include <sys/select.h> #include <sys/select.h>
#endif #endif
......
...@@ -472,13 +472,20 @@ int tina_end(ha_panic_function type) ...@@ -472,13 +472,20 @@ int tina_end(ha_panic_function type)
/* /*
Finds the end of a line. Finds the end of a line.
Currently only supports files written on a UNIX OS. Supports DOS, Unix, or Mac OS line endings.
*/ */
byte * find_eoln(byte *data, off_t begin, off_t end) byte * find_eoln(byte *data, off_t begin, off_t end, int *eoln_len)
{ {
off_t dataend= begin;
*eoln_len= 0;
for (off_t x= begin; x < end; x++) for (off_t x= begin; x < end; x++)
if (data[x] == '\n') if (data[x] == '\r' || data[x] == '\n')
return data + x; (*eoln_len)++;
else if (!(*eoln_len))
dataend++;
else
return data+dataend;
return 0; return 0;
} }
...@@ -627,6 +634,7 @@ int ha_tina::find_current_row(byte *buf) ...@@ -627,6 +634,7 @@ int ha_tina::find_current_row(byte *buf)
{ {
byte *mapped_ptr; byte *mapped_ptr;
byte *end_ptr; byte *end_ptr;
int eoln_len;
DBUG_ENTER("ha_tina::find_current_row"); DBUG_ENTER("ha_tina::find_current_row");
mapped_ptr= (byte *)share->mapped_file + current_position; mapped_ptr= (byte *)share->mapped_file + current_position;
...@@ -636,7 +644,7 @@ int ha_tina::find_current_row(byte *buf) ...@@ -636,7 +644,7 @@ int ha_tina::find_current_row(byte *buf)
not to conflict with undergoing concurrent insert. not to conflict with undergoing concurrent insert.
*/ */
if ((end_ptr= find_eoln(share->mapped_file, current_position, if ((end_ptr= find_eoln(share->mapped_file, current_position,
local_saved_data_file_length)) == 0) local_saved_data_file_length, &eoln_len)) == 0)
DBUG_RETURN(HA_ERR_END_OF_FILE); DBUG_RETURN(HA_ERR_END_OF_FILE);
for (Field **field=table->field ; *field ; field++) for (Field **field=table->field ; *field ; field++)
...@@ -684,7 +692,7 @@ int ha_tina::find_current_row(byte *buf) ...@@ -684,7 +692,7 @@ int ha_tina::find_current_row(byte *buf)
} }
(*field)->store(buffer.ptr(), buffer.length(), system_charset_info); (*field)->store(buffer.ptr(), buffer.length(), system_charset_info);
} }
next_position= (end_ptr - share->mapped_file)+1; next_position= (end_ptr - share->mapped_file)+eoln_len;
/* Maybe use \N for null? */ /* Maybe use \N for null? */
memset(buf, 0, table->s->null_bytes); /* We do not implement nulls! */ memset(buf, 0, table->s->null_bytes); /* We do not implement nulls! */
......
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