fixed bug #1073

(Replication LOAD DATA INFILE mysqlbinlog doesn't cleanup tmp files) 

1 files changed, 18 insertions, 2 deletions

diff --git a/client/mysqlbinlog.cc b/client/mysqlbinlog.cc
index ac1c9db30e6..0590490e1c4 100644
--- a/client/mysqlbinlog.cc
+++ b/client/mysqlbinlog.cc
@@ -21,6 +21,7 @@
 #include <assert.h>
 #include "log_event.h"
 #include "include/my_sys.h"
+#include "unistd.h"
 
 #define BIN_LOG_HEADER_SIZE	4
 #define PROBE_HEADER_LEN	(EVENT_LEN_OFFSET+4)
@@ -81,9 +82,9 @@ class Load_log_processor
 	bname--;
 
       uint blen= ce->fname_len - (bname-ce->fname);
-      uint full_len= target_dir_name_len + blen;
+      uint full_len= target_dir_name_len + blen + 9 + 9 + 1;
       char *tmp;
-      if (!(tmp= my_malloc(full_len + 9 + 1,MYF(MY_WME))) ||
+      if (!(tmp= my_malloc(full_len,MYF(MY_WME))) ||
 	  set_dynamic(&file_names,(gptr)&ce,ce->file_id))
       {
 	die("Could not construct local filename %s%s",target_dir_name,bname);
@@ -96,6 +97,21 @@ class Load_log_processor
       memcpy(ptr,bname,blen);
       ptr+= blen;
       sprintf(ptr,"-%08x",ce->file_id);
+      ptr+= 9;
+
+      uint version= 0;
+      for (;;)
+      {
+	sprintf(ptr,"-%08x",version);
+	if (access(tmp,F_OK))
+	  break;
+	version++;
+	if (version>UINT_MAX)
+	{
+	  die("Could not construct local filename %s%s",target_dir_name,bname);
+	  return 0;
+	}
+      }
 
       ce->set_fname_outside_temp_buf(tmp,full_len);