Adding upstream version 1:10.5.12.upstream/1%10.5.12upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 119 insertions, 0 deletions

diff --git a/storage/myisam/mi_panic.c b/storage/myisam/mi_panic.c
new file mode 100644
index 00000000..541cf399
--- /dev/null
+++ b/storage/myisam/mi_panic.c
@@ -0,0 +1,119 @@
+/* Copyright (c) 2000, 2003, 2005, 2006 MySQL AB, 2009 Sun Microsystems, Inc.
+   Use is subject to license terms.
+
+   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
+   the Free Software Foundation; version 2 of the License.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1335  USA */
+
+#include "fulltext.h"
+
+	/* if flag == HA_PANIC_CLOSE then all misam files are closed */
+	/* if flag == HA_PANIC_WRITE then all misam files are unlocked and
+	   all changed data in single user misam is written to file */
+	/* if flag == HA_PANIC_READ then all misam files that was locked when
+	   mi_panic(HA_PANIC_WRITE) was done is locked. A mi_readinfo() is
+	   done for all single user files to get changes in database */
+
+
+int mi_panic(enum ha_panic_function flag)
+{
+  int error=0;
+  LIST *list_element,*next_open;
+  MI_INFO *info;
+  DBUG_ENTER("mi_panic");
+
+  mysql_mutex_lock(&THR_LOCK_myisam);
+  for (list_element=myisam_open_list ; list_element ; list_element=next_open)
+  {
+    next_open=list_element->next;		/* Save if close */
+    info=(MI_INFO*) list_element->data;
+    switch (flag) {
+    case HA_PANIC_CLOSE:
+      mysql_mutex_unlock(&THR_LOCK_myisam);     /* Not exactly right... */
+      if (mi_close(info))
+	error=my_errno;
+      mysql_mutex_lock(&THR_LOCK_myisam);
+      break;
+    case HA_PANIC_WRITE:		/* Do this to free databases */
+#ifdef CANT_OPEN_FILES_TWICE
+      if (info->s->options & HA_OPTION_READ_ONLY_DATA)
+	break;
+#endif
+      if (flush_key_blocks(info->s->key_cache, info->s->kfile,
+                           &info->s->dirty_part_map, FLUSH_RELEASE))
+	error=my_errno;
+      if (info->opt_flag & WRITE_CACHE_USED)
+	if (flush_io_cache(&info->rec_cache))
+	  error=my_errno;
+      if (info->opt_flag & READ_CACHE_USED)
+      {
+	if (flush_io_cache(&info->rec_cache))
+	  error=my_errno;
+	reinit_io_cache(&info->rec_cache,READ_CACHE,0,
+		       (pbool) (info->lock_type != F_UNLCK),1);
+      }
+      if (info->lock_type != F_UNLCK && ! info->was_locked)
+      {
+	info->was_locked=info->lock_type;
+	if (mi_lock_database(info,F_UNLCK))
+	  error=my_errno;
+      }
+#ifdef CANT_OPEN_FILES_TWICE
+      if (info->s->kfile >= 0 && mysql_file_close(info->s->kfile, MYF(0)))
+	error = my_errno;
+      if (info->dfile >= 0 && mysql_file_close(info->dfile, MYF(0)))
+	error = my_errno;
+      info->s->kfile=info->dfile= -1;	/* Files aren't open anymore */
+#endif
+      break;
+    case HA_PANIC_READ:			/* Restore to before WRITE */
+#ifdef CANT_OPEN_FILES_TWICE
+      {					/* Open closed files */
+	char name_buff[FN_REFLEN];
+	if (info->s->kfile < 0)
+          if ((info->s->kfile= mysql_file_open(mi_key_file_kfile,
+                                               fn_format(name_buff,
+                                                         info->filename, "",
+                                                         N_NAME_IEXT, 4),
+                                               info->mode, MYF(MY_WME))) < 0)
+	    error = my_errno;
+	if (info->dfile < 0)
+	{
+          if ((info->dfile= mysql_file_open(mi_key_file_dfile,
+                                            fn_format(name_buff,
+                                                      info->filename, "",
+                                                      N_NAME_DEXT, 4),
+                                            info->mode, MYF(MY_WME))) < 0)
+	    error = my_errno;
+	  info->rec_cache.file=info->dfile;
+	}
+      }
+#endif
+      if (info->was_locked)
+      {
+	if (mi_lock_database(info, info->was_locked))
+	  error=my_errno;
+	info->was_locked=0;
+      }
+      break;
+    }
+  }
+  if (flag == HA_PANIC_CLOSE)
+  {
+    (void) mi_log(0);				/* Close log if neaded */
+    ft_free_stopwords();
+  }
+  mysql_mutex_unlock(&THR_LOCK_myisam);
+  if (!error)
+    DBUG_RETURN(0);
+  DBUG_RETURN(my_errno=error);
+} /* mi_panic */