After merge fixes

Return NULL if a time argument is given to date_add(). (Warning will be shown after Dimitri's timezone patch is pushed)


client/mysqltest.c:
  Added MAX_VAR_NAME which was lost in merge
  Added more debugging
  Fixed bug in 'eval'
innobase/data/data0type.c:
  After merge fix
innobase/fil/fil0fil.c:
  After merge fix
innobase/log/log0recv.c:
  After merge fix
myisam/mi_unique.c:
  Better checksum handling
mysql-test/r/func_time.result:
  Return NULL if a time argument is given to date_add()
mysql-test/r/rpl_free_items.result:
  After merge fix
mysql-test/r/rpl_get_lock.result:
  Test was depending on when server was restarted.
mysql-test/r/type_date.result:
  After merge fix
mysql-test/r/type_decimal.result:
  After merge fix
mysql-test/t/func_time.test:
  Removed comment that is not needed anymore
  (After Dimitri's timezone patch is pushed, we should get a warning for the date_add(time...) entry)
mysql-test/t/rpl_get_lock.test:
  Test was depending on when server was restarted.
mysql-test/t/type_date.test:
  Addded missing explanation for bug
netware/mysqld_safe.c:
  Removed end \r
  Run program through indent-ex to get MySQL indentation
sql-common/client.c:
  After merge fix
sql/field.cc:
  Fixed that get_date(time) gives a warning
sql/field.h:
  After merge fix
sql/net_serv.cc:
  More debugging (if DEBUG_DATA_PACKETS is set)
sql/sql_class.cc:
  Removed compiler warning
sql/table.cc:
  Better comment

client/mysqltest.c

@@ -60,6 +60,7 @@
 #include <violite.h>
 
 #define MAX_QUERY     131072
+#define MAX_VAR_NAME	256
 #define MAX_COLUMNS	256
 #define PAD_SIZE	128
 #define MAX_CONS	128
@@ -386,6 +387,7 @@ static void do_eval(DYNAMIC_STRING* query_eval, const char* query)
   register char c;
   register int escaped = 0;
   VAR* v;
+  DBUG_ENTER("do_eval");
 
   for (p= query; (c = *p); ++p)
   {
@@ -417,6 +419,7 @@ static void do_eval(DYNAMIC_STRING* query_eval, const char* query)
       break;
     }
   }
+  DBUG_VOID_RETURN;
 }
 
 
@@ -1739,6 +1742,7 @@ int read_line(char* buf, int size)
   enum {R_NORMAL, R_Q1, R_ESC_Q_Q1, R_ESC_Q_Q2,
 	R_ESC_SLASH_Q1, R_ESC_SLASH_Q2,
 	R_Q2, R_COMMENT, R_LINE_START} state= R_LINE_START;
+  DBUG_ENTER("read_line");
 
   start_lineno= *lineno;
   for (; p < buf_end ;)
@@ -1752,7 +1756,7 @@ int read_line(char* buf, int size)
       cur_file--;
       lineno--;
       if (cur_file == file_stack)
-	return 1;
+	DBUG_RETURN(1);
       continue;
     }
 
@@ -1762,7 +1766,7 @@ int read_line(char* buf, int size)
       if (end_of_query(c))
       {
 	*p= 0;
-	return 0;
+	DBUG_RETURN(0);
       }
       else if (c == '\'')
 	state = R_Q1;
@@ -1779,7 +1783,7 @@ int read_line(char* buf, int size)
       {
 	*p= 0;
 	(*lineno)++;
-	return 0;
+	DBUG_RETURN(0);
       }
       break;
     case R_LINE_START:
@@ -1797,12 +1801,12 @@ int read_line(char* buf, int size)
       {
 	*buf++= '}';
 	*buf= 0;
-	return 0;
+	DBUG_RETURN(0);
       }
       else if (end_of_query(c) || c == '{')
       {
 	*p= 0;
-	return 0;
+	DBUG_RETURN(0);
       }
       else if (c == '\'')
 	state= R_Q1;
@@ -1822,7 +1826,7 @@ int read_line(char* buf, int size)
       if (end_of_query(c))
       {
 	*p= 0;
-	return 0;
+	DBUG_RETURN(0);
       }
       if (c != '\'')
 	state= R_NORMAL;
@@ -1843,7 +1847,7 @@ int read_line(char* buf, int size)
       if (end_of_query(c))
       {
 	*p= 0;
-	return 0;
+	DBUG_RETURN(0);
       }
       if (c != '"')
 	state= R_NORMAL;
@@ -1859,7 +1863,7 @@ int read_line(char* buf, int size)
       *p++= c;
   }
   *p= 0;					/* Always end with \0 */
-  return feof(*cur_file);
+  DBUG_RETURN(feof(*cur_file));
 }
 
 
@@ -1894,8 +1898,11 @@ int read_query(struct st_query** q_ptr)
   q->type = Q_UNKNOWN;
   q->query_buf= q->query= 0;
   if (read_line(read_query_buf, sizeof(read_query_buf)))
+  {
+    DBUG_PRINT("warning",("too long query"));
     DBUG_RETURN(1);
-
+  }
+   DBUG_PRINT("info", ("query: %s", read_query_buf));
   if (*p == '#')
   {
     q->type = Q_COMMENT;
@@ -2261,6 +2268,7 @@ int run_query(MYSQL* mysql, struct st_query* q, int flags)
   char* query;
   int query_len, got_error_on_send= 0;
   DBUG_ENTER("run_query");
+  DBUG_PRINT("enter",("flags: %d", flags));
   
   if (q->type != Q_EVAL)
   {
@@ -2728,7 +2736,10 @@ int main(int argc, char **argv)
       case Q_EVAL_RESULT: eval_result = 1; break;
       case Q_EVAL:
 	if (q->query == q->query_buf)
+        {
 	  q->query= q->first_argument;
+          q->first_word_len= 0;
+        }
 	/* fall through */
       case Q_QUERY_VERTICAL:
       case Q_QUERY_HORIZONTAL:
@@ -2738,13 +2749,16 @@ int main(int argc, char **argv)
 	{
 	  /* This happens when we use 'query_..' on it's own line */
 	  q_send_flag=1;
+          DBUG_PRINT("info",
+                     ("query: '%s' first_word_len: %d  send_flag=1",
+                      q->query, q->first_word_len));
 	  break;
 	}
 	/* fix up query pointer if this is * first iteration for this line */
 	if (q->query == q->query_buf)
 	  q->query += q->first_word_len + 1;
 	display_result_vertically= (q->type==Q_QUERY_VERTICAL);
-	error |= run_query(&cur_con->mysql, q, QUERY_REAP|QUERY_SEND);
+	error|= run_query(&cur_con->mysql, q, QUERY_REAP|QUERY_SEND);
 	display_result_vertically= old_display_result_vertically;
 	break;
       }

innobase/data/data0type.c

@@ -104,7 +104,6 @@ dtype_form_prtype(
 	return(old_prtype + (charset_coll << 16));
 }
 
-#ifdef UNIV_DEBUG
 /*************************************************************************
 Validates a data type structure. */
 

innobase/fil/fil0fil.c

@@ -2825,8 +2825,7 @@ fil_load_single_table_tablespaces(void)
 			if (!dbpath) {
 				dbpath = mem_alloc(dbpath_len);
 			} else {
-				dbpath = mem_realloc(dbpath, dbpath_len,
-							__FILE__, __LINE__);
+				dbpath = ut_realloc(dbpath, dbpath_len);
 			}
 		}
 		sprintf(dbpath, "%s/%s", fil_path_to_mysql_datadir,

innobase/log/log0recv.c

@@ -1513,7 +1513,6 @@ recv_apply_log_recs_for_backup(void)
 
 	recv_sys_empty_hash();
 }
-#endif /* UNIV_HOTBACKUP */
 
 #ifdef notdefined
 /***********************************************************************

myisam/mi_unique.c

@@ -70,7 +70,7 @@ ha_checksum mi_unique_hash(MI_UNIQUEDEF *def, const byte *record)
 {
   const byte *pos, *end;
   ha_checksum crc= 0;
-  ulong seed= 4;
+  ulong seed1=0, seed2= 4;
   HA_KEYSEG *keyseg;
 
   for (keyseg=def->seg ; keyseg < def->end ; keyseg++)
@@ -109,11 +109,10 @@ ha_checksum mi_unique_hash(MI_UNIQUEDEF *def, const byte *record)
     end= pos+length;
     if (type == HA_KEYTYPE_TEXT || type == HA_KEYTYPE_VARTEXT)
     {
-      ulong tmp= 0;
       keyseg->charset->coll->hash_sort(keyseg->charset,
-                                       (const uchar*) pos, length, &tmp,
-                                       &seed);
-      crc^= tmp;
+                                       (const uchar*) pos, length, &seed1,
+                                       &seed2);
+      crc^= seed1;
     }
     else
       while (pos != end)

mysql-test/r/func_time.result

@@ -528,7 +528,7 @@ date_add(date,INTERVAL "1 1:1:1" DAY_SECOND)
 2003-01-03 01:01:01
 select date_add(time,INTERVAL 1 SECOND) from t1;
 date_add(time,INTERVAL 1 SECOND)
-2006-07-08 00:00:01
+NULL
 drop table t1;
 select last_day('2000-02-05') as f1, last_day('2002-12-31') as f2,
 last_day('2003-03-32') as f3, last_day('2003-04-01') as f4,

mysql-test/r/rpl_free_items.result

-slave stop;
+stop slave;
 drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
 reset master;
 reset slave;
 drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
-slave start;
+start slave;
 create table t1 (a int);
 create table t2 (a int);
 drop table t1;

mysql-test/r/rpl_get_lock.result

@@ -18,9 +18,9 @@ get_lock("lock",3)
 select * from t1;
 n
 1
-select is_free_lock("lock"), is_used_lock("lock");
-is_free_lock("lock")	is_used_lock("lock")
-0	6
+select is_free_lock("lock"), is_used_lock("lock") = connection_id();
+is_free_lock("lock")	is_used_lock("lock") = connection_id()
+0	1
 explain extended select is_free_lock("lock"), is_used_lock("lock");
 id	select_type	table	type	possible_keys	key	key_len	ref	rows	Extra
 1	SIMPLE	NULL	NULL	NULL	NULL	NULL	NULL	NULL	No tables used

mysql-test/r/type_date.result

@@ -73,7 +73,7 @@ SELECT DATE_FORMAT("2002-03-06 10:11:12", CONCAT('%a, %d %M %Y %H:%i:%s ' ,  t2.
 DATE_FORMAT("2002-03-06 10:11:12", CONCAT('%a, %d %M %Y %H:%i:%s ' ,  t2.GMT))	DATE_FORMAT("2002-03-06 10:11:12",  CONCAT('%a, %d %M %Y %H:%i:%s ' ,  t2.GMT))
 Wed, 06 March 2002 10:11:12 GMT-0800	Wed, 06 March 2002 10:11:12 GMT-0800
 drop table t1,t2;
-CREATE TABLE t1 (f1 time default NULL, f2 time default NULL) TYPE=MyISAM;
+CREATE TABLE t1 (f1 time default NULL, f2 time default NULL);
 INSERT INTO t1 (f1, f2) VALUES ('09:00', '12:00');
 SELECT DATE_FORMAT(f1, "%l.%i %p") , DATE_FORMAT(f2, "%l.%i %p") FROM t1;
 DATE_FORMAT(f1, "%l.%i %p")	DATE_FORMAT(f2, "%l.%i %p")

mysql-test/r/type_decimal.result

@@ -449,7 +449,7 @@ SHOW CREATE TABLE t1;
 Table	Create Table
 t1	CREATE TABLE `t1` (
   `a_dec` decimal(12,11) default NULL
-) TYPE=MyISAM
+) ENGINE=MyISAM DEFAULT CHARSET=latin1
 DROP TABLE t1;
 create table t1(a decimal(7,3));
 insert into t1 values ('1'),('+1'),('-1'),('0000000001'),('+0000000001'),('-0000000001'),('10'),('+10'),('-10'),('0000000010'),('+0000000010'),('-0000000010'),('100'),('+100'),('-100'),('0000000100'),('+0000000100'),('-0000000100'),('1000'),('+1000'),('-1000'),('0000001000'),('+0000001000'),('-0000001000'),('10000'),('+10000'),('-10000'),('0000010000'),('+0000010000'),('-0000010000'),('100000'),('+100000'),('-100000'),('0000100000'),('+0000100000'),('-0000100000'),('1000000'),('+1000000'),('-1000000'),('0001000000'),('+0001000000'),('-0001000000'),('10000000'),('+10000000'),('-10000000'),('0010000000'),('+0010000000'),('-0010000000'),('100000000'),('+100000000'),('-100000000'),('0100000000'),('+0100000000'),('-0100000000'),('1000000000'),('+1000000000'),('-1000000000'),('1000000000'),('+1000000000'),('-1000000000');

mysql-test/t/func_time.test

@@ -255,8 +255,6 @@ select date_add(date,INTERVAL "1 1" YEAR_MONTH) from t1;
 select date_add(date,INTERVAL "1:1:1" HOUR_SECOND) from t1;
 select date_add(date,INTERVAL "1 1:1" DAY_MINUTE) from t1;
 select date_add(date,INTERVAL "1 1:1:1" DAY_SECOND) from t1;
-
-# The following is not as one would expect...
 select date_add(time,INTERVAL 1 SECOND) from t1;
 drop table t1;
 

mysql-test/t/rpl_get_lock.test

@@ -22,7 +22,7 @@ connection slave;
 sync_with_master;
 select get_lock("lock",3);
 select * from t1;
-select is_free_lock("lock"), is_used_lock("lock");
+select is_free_lock("lock"), is_used_lock("lock") = connection_id();
 explain extended select is_free_lock("lock"), is_used_lock("lock");
 # Check lock functions
 select is_free_lock("lock2");

mysql-test/t/type_date.test

@@ -81,9 +81,10 @@ SELECT DATE_FORMAT("2002-03-06 10:11:12", CONCAT('%a, %d %M %Y %H:%i:%s ' ,  t2.
 drop table t1,t2;
 
 #
-# Bug 4036
+# Multiple SELECT DATE_FORMAT gave incorrect results (Bug #4036)
 #
-CREATE TABLE t1 (f1 time default NULL, f2 time default NULL) TYPE=MyISAM;
+
+CREATE TABLE t1 (f1 time default NULL, f2 time default NULL);
 INSERT INTO t1 (f1, f2) VALUES ('09:00', '12:00');
 SELECT DATE_FORMAT(f1, "%l.%i %p") , DATE_FORMAT(f2, "%l.%i %p") FROM t1;
 DROP TABLE t1;

netware/mysqld_safe.c

@@ -47,7 +47,7 @@ char mysqld[PATH_MAX];
 char hostname[PATH_MAX];
 char default_option[PATH_MAX];
 
-FILE *log_fd  = NULL;
+FILE *log_fd= NULL;
 
 /******************************************************************************
 
@@ -58,15 +58,15 @@ FILE *log_fd  = NULL;
 void usage(void);
 void vlog(char *, va_list);
 void log(char *, ...);
-void start_defaults(int, char*[]);
+void start_defaults(int, char *[]);
 void finish_defaults();
 void read_defaults(arg_list_t *);
-void parse_args(int, char*[]);
-void get_options(int, char*[]);
+void parse_args(int, char *[]);
+void get_options(int, char *[]);
 void check_data_vol();
 void check_setup();
 void check_tables();
-void mysql_start(int, char*[]);
+void mysql_start(int, char *[]);
 void parse_setvar(char *arg);
 
 /******************************************************************************
@@ -161,7 +161,7 @@ void start_defaults(int argc, char *argv[])
   int i;
 
   // default options
-  static char *default_options[] =
+  static char *default_options[]=
   {
     "--no-defaults",
     "--defaults-file=",
@@ -170,19 +170,19 @@ void start_defaults(int argc, char *argv[])
   };
 
   // autoclose
-  autoclose = FALSE;
+  autoclose= FALSE;
 
   // basedir
   get_basedir(argv[0], basedir);
 
   // check-tables
-  checktables = FALSE;
+  checktables= FALSE;
 
   // hostname
-  if (gethostname(hostname,PATH_MAX) < 0)
+  if (gethostname(hostname, PATH_MAX) < 0)
   {
     // default
-    strcpy(hostname,"mysql");
+    strcpy(hostname, "mysql");
   }
 
   // address
@@ -192,10 +192,10 @@ void start_defaults(int argc, char *argv[])
   snprintf(port, PATH_MAX, "3306");
 
   // default option
-	default_option[0] = NULL;
-  for (i=0; (argc > 1) && default_options[i]; i++)
+  default_option[0]= NULL;
+  for (i= 0; (argc > 1) && default_options[i]; i++)
   {
-		if(!strnicmp(argv[1], default_options[i], strlen(default_options[i])))
+    if (!strnicmp(argv[1], default_options[i], strlen(default_options[i])))
     {
       strncpy(default_option, argv[1], PATH_MAX);
       break;
@@ -203,11 +203,11 @@ void start_defaults(int argc, char *argv[])
   }
 
   // set after basedir is established
-  datadir[0] = NULL;
-  pid_file[0] = NULL;
-  err_log[0] = NULL;
-  safe_log[0] = NULL;
-  mysqld[0] = NULL;
+  datadir[0]= NULL;
+  pid_file[0]= NULL;
+  err_log[0]= NULL;
+  safe_log[0]= NULL;
+  mysqld[0]= NULL;
 }
 
 /******************************************************************************
@@ -223,19 +223,24 @@ void finish_defaults()
   int i;
 
   // datadir
-  if (!datadir[0]) snprintf(datadir, PATH_MAX, "%s/data", basedir);
+  if (!datadir[0])
+    snprintf(datadir, PATH_MAX, "%s/data", basedir);
 
   // pid-file
-  if (!pid_file[0]) snprintf(pid_file, PATH_MAX, "%s/%s.pid", datadir, hostname);
+  if (!pid_file[0])
+    snprintf(pid_file, PATH_MAX, "%s/%s.pid", datadir, hostname);
 
   // err-log
-  if (!err_log[0]) snprintf(err_log, PATH_MAX, "%s/%s.err", datadir, hostname);
+  if (!err_log[0])
+    snprintf(err_log, PATH_MAX, "%s/%s.err", datadir, hostname);
 
   // safe-log
-  if (!safe_log[0]) snprintf(safe_log, PATH_MAX, "%s/%s.safe", datadir, hostname);
+  if (!safe_log[0])
+    snprintf(safe_log, PATH_MAX, "%s/%s.safe", datadir, hostname);
 
   // mysqld
-  if (!mysqld[0]) snprintf(mysqld, PATH_MAX, "%s/bin/mysqld-max", basedir);
+  if (!mysqld[0])
+    snprintf(mysqld, PATH_MAX, "%s/bin/mysqld-max", basedir);
 
   if (stat(mysqld, &buf))
   {
@@ -268,7 +273,8 @@ void read_defaults(arg_list_t *pal)
   // args
   init_args(&al);
   add_arg(&al, mydefaults);
-  if (default_option[0]) add_arg(&al, default_option);
+  if (default_option[0])
+    add_arg(&al, default_option);
   add_arg(&al, "mysqld");
   add_arg(&al, "server");
   add_arg(&al, "mysqld_safe");
@@ -279,14 +285,15 @@ void read_defaults(arg_list_t *pal)
   free_args(&al);
 
   // gather defaults
-	if((fp = fopen(defaults_file, "r")) != NULL)
+  if ((fp= fopen(defaults_file, "r")) != NULL)
   {
-	  while(fgets(line, PATH_MAX, fp))
+    while (fgets(line, PATH_MAX, fp))
     {
       char *p;
 
       // remove end-of-line character
-      if ((p = strrchr(line, '\n')) != NULL) *p = '\0';
+      if ((p= strrchr(line, '\n')) != NULL)
+	*p= '\0';
 
       // add the option as an argument
       add_arg(pal, line);
@@ -308,13 +315,13 @@ void read_defaults(arg_list_t *pal)
 ******************************************************************************/
 void parse_args(int argc, char *argv[])
 {
-  int index = 0;
+  int index= 0;
   int c;
 
   // parse options
   enum opts
   {
-    OPT_BASEDIR = 0xFF,
+    OPT_BASEDIR= 0xFF,
     OPT_DATADIR,
     OPT_PID_FILE,
     OPT_BIND_ADDRESS,
@@ -326,7 +333,7 @@ void parse_args(int argc, char *argv[])
     OPT_SETVAR
   };
 
-  static struct option options[] =
+  static struct option options[]=
   {
     {"autoclose", no_argument, &autoclose, TRUE},
     {"basedir", required_argument, 0, OPT_BASEDIR},
@@ -344,15 +351,14 @@ void parse_args(int argc, char *argv[])
   };
 
   // we have to reset getopt_long because we use it multiple times
-  optind = 1;
+  optind= 1;
 
   // turn off error reporting
-  opterr = 0;
+  opterr= 0;
 
-  while ((c = getopt_long(argc, argv, "b:h:P:", options, &index)) >= 0)
-  {
-    switch (c)
+  while ((c= getopt_long(argc, argv, "b:h:P:", options, &index)) >= 0)
   {
+    switch (c) {
     case OPT_BASEDIR:
     case 'b':
       strcpy(basedir, optarg);
@@ -413,11 +419,12 @@ void parse_setvar(char *arg)
 
   if ((pos= strindex(arg, "port")))
   {
-    for (; *pos && *pos != '='; pos++) ;
+    for (; *pos && *pos != '='; pos++);
     if (*pos)
       strcpy(port, pos + 1);
   }
 }
+
 /******************************************************************************
 
 
@@ -469,10 +476,10 @@ void check_data_vol()
 
   // find volume name
   strcpy(buff, datadir);
-  if (p = strchr(buff, ':'))
+  if (p= strchr(buff, ':'))
   {
     // terminate after volume name
-    *p = 0;
+    *p= 0;
   }
   else
   {
@@ -540,12 +547,12 @@ void check_tables()
   log("checking tables...\n");
 
   // list databases
-	if ((datadir_entry = opendir(datadir)) == NULL)
+  if ((datadir_entry= opendir(datadir)) == NULL)
   {
     return;
   }
 
-	while((db_entry = readdir(datadir_entry)) != NULL)
+  while ((db_entry= readdir(datadir_entry)) != NULL)
   {
     if (db_entry->d_name[0] == '.')
     {
@@ -557,12 +564,12 @@ void check_tables()
       snprintf(db, PATH_MAX, "%s/%s", datadir, db_entry->d_name);
 
       // list tables
-      if ((db_entry = opendir(db)) == NULL)
+      if ((db_entry= opendir(db)) == NULL)
       {
 	continue;
       }
 
-      while((table_entry = readdir(db_entry)) != NULL)
+      while ((table_entry= readdir(db_entry)) != NULL)
       {
 	// create long table name
 	snprintf(table, PATH_MAX, "%s/%s", db, strlwr(table_entry->d_name));
@@ -634,7 +641,7 @@ void mysql_start(int argc, char *argv[])
   char skip;
 
   // private options
-  static char *private_options[] =
+  static char *private_options[]=
   {
     "--autoclose",
     "--check-tables",
@@ -649,17 +656,17 @@ void mysql_start(int argc, char *argv[])
   add_arg(&al, "%s", mysqld);
 
   // parent args
-  for(i = 1; i < argc; i++)
+  for (i= 1; i < argc; i++)
   {
-    skip = FALSE;
+    skip= FALSE;
 
     // skip private arguments
-    for (j=0; private_options[j]; j++)
+    for (j= 0; private_options[j]; j++)
     {
-      if(!strnicmp(argv[i], private_options[j], strlen(private_options[j])))
+      if (!strnicmp(argv[i], private_options[j], strlen(private_options[j])))
       {
-        skip = TRUE;
-	consoleprintf("The argument skipped is %s\n",argv[i]);
+	skip= TRUE;
+	consoleprintf("The argument skipped is %s\n", argv[i]);
 	break;
       }
     }
@@ -667,14 +674,15 @@ void mysql_start(int argc, char *argv[])
     if (!skip)
     {
       add_arg(&al, "%s", argv[i]);
-      consoleprintf("The final argument is %s\n",argv[i]);
+      consoleprintf("The final argument is %s\n", argv[i]);
     }
   }
   // spawn
   do
   {
     // check the database tables
-    if (checktables) check_tables();
+    if (checktables)
+      check_tables();
 
     // status
     time(&cal);
@@ -710,10 +718,11 @@ int main(int argc, char **argv)
   get_options(argc, argv);
 
   // keep the screen up
-  if (!autoclose) setscreenmode(SCR_NO_MODE);
+  if (!autoclose)
+    setscreenmode(SCR_NO_MODE);
 
   // create log file
-  log_fd = fopen(safe_log, "w+");
+  log_fd= fopen(safe_log, "w+");
 
   // header
   log("MySQL Server %s, for %s (%s)\n\n", VERSION, SYSTEM_TYPE, MACHINE_TYPE);
@@ -736,7 +745,8 @@ int main(int argc, char **argv)
   mysql_start(argc, argv);
 
   // close log file
-  if (log_fd) fclose(log_fd);
+  if (log_fd)
+    fclose(log_fd);
 
   return 0;
 }

sql-common/client.c

@@ -1732,7 +1732,8 @@ CLI_MYSQL_REAL_CONNECT(MYSQL *mysql,const char *host, const char *user,
 	sprintf(net->last_error, ER(CR_UNKNOWN_HOST), host, tmp_errno);
 	goto error;
       }
-      memcpy(&sock_addr.sin_addr,hp->h_addr, (size_t) hp->h_length);
+      memcpy(&sock_addr.sin_addr, hp->h_addr,
+             min(sizeof(sock_addr.sin_addr), (size_t) hp->h_length));
       my_gethostbyname_r_free();
     }
     sock_addr.sin_port = (ushort) htons((ushort) port);

sql/field.cc

@@ -3395,10 +3395,21 @@ String *Field_time::val_str(String *val_buffer,
 }
 
 
-bool Field_time::get_date(TIME *ltime,
-			  bool fuzzydate  __attribute__((unused)))
+/*
+  Normally we would not consider 'time' as a vaild date, but we allow
+  get_date() here to be able to do things like
+  DATE_FORMAT(time, "%l.%i %p")
+*/
+ 
+bool Field_time::get_date(TIME *ltime, uint fuzzydate)
 {
-  long tmp=(long) sint3korr(ptr);
+  long tmp;
+  if (!fuzzydate)
+  {
+    set_warning(MYSQL_ERROR::WARN_LEVEL_WARN, ER_WARN_DATA_OUT_OF_RANGE);
+    return 1;
+  }
+  tmp=(long) sint3korr(ptr);
   ltime->neg=0;
   if (tmp < 0)
   {

sql/field.h

@@ -800,7 +800,7 @@ class Field_time :public Field_str {
   double val_real(void);
   longlong val_int(void);
   String *val_str(String*,String *);
-  bool get_date(TIME *ltime,bool fuzzydate);
+  bool get_date(TIME *ltime, uint fuzzydate);
   bool send_binary(Protocol *protocol);
   bool get_time(TIME *ltime);
   int cmp(const char *,const char*);

sql/net_serv.cc

@@ -284,7 +284,9 @@ my_net_write(NET *net,const char *packet,ulong len)
   buff[3]= (uchar) net->pkt_nr++;
   if (net_write_buff(net,(char*) buff,NET_HEADER_SIZE))
     return 1;
+#ifndef DEBUG_DATA_PACKETS
   DBUG_DUMP("packet_header",(char*) buff,NET_HEADER_SIZE);
+#endif
   return test(net_write_buff(net,packet,len));
 }
 
@@ -394,6 +396,9 @@ net_write_buff(NET *net,const char *packet,ulong len)
   else
     left_length= (ulong) (net->buff_end - net->write_pos);
 
+#ifdef DEBUG_DATA_PACKETS
+  DBUG_DUMP("data", packet, len);
+#endif
   if (len > left_length)
   {
     if (net->write_pos != net->buff)
@@ -776,6 +781,8 @@ my_real_read(NET *net, ulong *complen)
       if (i == 0)
       {					/* First parts is packet length */
 	ulong helping;
+        DBUG_DUMP("packet_header",(char*) net->buff+net->where_b,
+                  NET_HEADER_SIZE);
 	if (net->buff[net->where_b + 3] != (uchar) net->pkt_nr)
 	{
 	  if (net->buff[net->where_b] != (uchar) 255)
@@ -784,7 +791,6 @@ my_real_read(NET *net, ulong *complen)
 		       ("Packets out of order (Found: %d, expected %u)",
 			(int) net->buff[net->where_b + 3],
 			net->pkt_nr));
-	    DBUG_DUMP("packet_header",(char*) net->buff+net->where_b, 4);
 #ifdef EXTRA_DEBUG
 	    fprintf(stderr,"Packets out of order (Found: %d, expected %d)\n",
 		    (int) net->buff[net->where_b + 3],
@@ -841,6 +847,10 @@ my_real_read(NET *net, ulong *complen)
     vio_blocking(net->vio, net_blocking, &old_mode);
   }
   net->reading_or_writing=0;
+#ifdef DEBUG_DATA_PACKETS
+  if (len != packet_error)
+    DBUG_DUMP("data",(char*) net->buff+net->where_b, len);
+#endif
   return(len);
 }
 

sql/sql_class.cc

@@ -162,7 +162,8 @@ THD::THD():user_time(0), current_statement(0), is_fatal_error(0),
 {
   host= user= priv_user= db= ip=0;
   host_or_ip= "connecting host";
-  locked=killed=some_tables_deleted=no_errors=password= 0;
+  locked=some_tables_deleted=no_errors=password= 0;
+  killed=0;
   query_start_used= 0;
   count_cuted_fields= CHECK_FIELD_IGNORE;
   db_length= col_access= 0;

sql/table.cc

@@ -1134,7 +1134,7 @@ File create_frm(register my_string name, uint reclength, uchar *fileinfo,
   char fill[IO_SIZE];
 
 #if SIZEOF_OFF_T > 4
-  /* Fix this in MySQL 4.0;  The current limit is 4G rows (QQ) */
+  /* Fix this when we have new .frm files;  Current limit is 4G rows (QQ) */
   if (create_info->max_rows > ~(ulong) 0)
     create_info->max_rows= ~(ulong) 0;
   if (create_info->min_rows > ~(ulong) 0)