/* * Copyright (C) 2008 Search Solution Corporation. All rights reserved by Search Solution. * * 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * */ /* * recovery.c - */ #ident "$Id$" #include "config.h" #include #include "recovery.h" #include "log_manager.h" #include "replication.h" #include "btree.h" #include "btree_load.h" #include "system_catalog.h" #include "disk_manager.h" #include "extendible_hash.h" #include "file_manager.h" #include "large_object_directory.h" #include "large_object.h" #include "overflow_file.h" /* * * THE ARRAY OF SERVER RECOVERY FUNCTIONS * * Note: When adding new entries, be sure to add the an entry to print it as * a string in rv_rcvindex_string(). */ struct rvfun RV_fun[] = { {RVDK_NEWVOL, "RVDK_NEWVOL", NULL, disk_rv_redo_dboutside_newvol, NULL, disk_rv_dump_hdr}, {RVDK_FORMAT, "RVDK_FORMAT", disk_rv_undo_format, log_rv_copy_char, log_rv_dump_char, disk_rv_dump_hdr}, {RVDK_INITMAP, "RVDK_INITMAP", NULL, disk_rv_redo_init_map, NULL, disk_rv_dump_init_map}, {RVDK_VHDR_SCALLOC, "RVDK_VHDR_SCALLOC", disk_vhdr_rv_undoredo_free_sectors, disk_vhdr_rv_undoredo_free_sectors, disk_vhdr_rv_dump_free_sectors, disk_vhdr_rv_dump_free_sectors}, {RVDK_VHDR_PGALLOC, "RVDK_VHDR_PGALLOC", disk_vhdr_rv_undoredo_free_pages, disk_vhdr_rv_undoredo_free_pages, disk_vhdr_rv_dump_free_pages, disk_vhdr_rv_dump_free_pages}, {RVDK_IDALLOC, "RVDK_IDALLOC", disk_rv_clear_alloctable, disk_rv_set_alloctable, disk_rv_dump_alloctable, disk_rv_dump_alloctable}, {RVDK_IDDEALLOC_WITH_VOLHEADER, "RVDK_IDDEALLOC_WITH_VOLHEADER", disk_rv_set_alloctable_with_vhdr, disk_rv_clear_alloctable_with_vhdr, disk_rv_dump_alloctable_with_vhdr, disk_rv_dump_alloctable_with_vhdr}, {RVDK_MAGIC, "RVDK_MAGIC", disk_rv_redo_magic, disk_rv_redo_magic, disk_rv_dump_magic, disk_rv_dump_magic}, {RVDK_CHANGE_CREATION, "RVDK_CHANGE_CREATION", disk_rv_undoredo_set_creation_time, disk_rv_undoredo_set_creation_time, disk_rv_dump_set_creation_time, disk_rv_dump_set_creation_time}, {RVDK_RESET_BOOT_HFID, "RVDK_RESET_BOOT_HFID", disk_rv_undoredo_set_boot_hfid, disk_rv_undoredo_set_boot_hfid, disk_rv_dump_set_boot_hfid, disk_rv_dump_set_boot_hfid}, {RVDK_LINK_PERM_VOLEXT, "RVDK_LINK_PERM_VOLEXT", disk_rv_undoredo_link, disk_rv_undoredo_link, disk_rv_dump_link, disk_rv_dump_link}, {RVFL_CREATE_TMPFILE, "RVFL_CREATE_TMPFILE", file_rv_undo_create_tmp, NULL, file_rv_dump_create_tmp, NULL}, {RVFL_FTAB_CHAIN, "RVFL_FTBCHAIN", log_rv_copy_char, log_rv_copy_char, file_rv_dump_ftab_chain, file_rv_dump_ftab_chain}, {RVFL_IDSTABLE, "RVFL_IDSTABLE", log_rv_copy_char, log_rv_copy_char, file_rv_dump_idtab, file_rv_dump_idtab}, {RVFL_MARKED_DELETED, "RVFL_MARKED_DELETED", file_rv_undoredo_mark_as_deleted, file_rv_undoredo_mark_as_deleted, file_rv_dump_marked_as_deleted, file_rv_dump_marked_as_deleted}, {RVFL_ALLOCSET_SECT, "RVFL_ALLOCSET_SECT", file_rv_allocset_undoredo_sector, file_rv_allocset_undoredo_sector, file_rv_allocset_dump_sector, file_rv_allocset_dump_sector}, {RVFL_ALLOCSET_PAGETB_ADDRESS, "RVFL_ALLOCSET_PAGETB_ADDRESS", file_rv_allocset_undoredo_page, file_rv_allocset_undoredo_page, file_rv_allocset_dump_page, file_rv_allocset_dump_page}, {RVFL_ALLOCSET_NEW, "RVFL_ALLOCSET_NEW", log_rv_copy_char, log_rv_copy_char, file_rv_dump_allocset, file_rv_dump_allocset}, {RVFL_ALLOCSET_LINK, "RVFL_ALLOCSET_LINK", file_rv_allocset_undoredo_link, file_rv_allocset_undoredo_link, file_rv_allocset_dump_link, file_rv_allocset_dump_link}, {RVFL_ALLOCSET_ADD_PAGES, "RVFL_ALLOCSET_ADD_PAGES", file_rv_allocset_undoredo_add_pages, file_rv_allocset_undoredo_add_pages, file_rv_allocset_dump_add_pages, file_rv_allocset_dump_add_pages}, {RVFL_ALLOCSET_DELETE_PAGES, "RVFL_ALLOCSET_DELETE_PAGES", file_rv_allocset_undoredo_delete_pages, file_rv_allocset_undoredo_delete_pages, file_rv_allocset_dump_delete_pages, file_rv_allocset_dump_delete_pages}, {RVFL_ALLOCSET_SECT_SHIFT, "RVFL_ALLOCSET_SECT_SHIFT", file_rv_allocset_undoredo_sectortab, file_rv_allocset_undoredo_sectortab, file_rv_allocset_dump_sectortab, file_rv_allocset_dump_sectortab}, {RVFL_ALLOCSET_COPY, "RVFL_ALLOCSET_COPY", log_rv_copy_char, log_rv_copy_char, file_rv_dump_allocset, file_rv_dump_allocset}, {RVFL_FHDR, "RVFL_FHDR", log_rv_copy_char, log_rv_copy_char, file_rv_dump_fhdr, file_rv_dump_fhdr}, {RVFL_FHDR_ADD_LAST_ALLOCSET, "RVFL_FHDR_ADD_LAST_ALLOCSET", file_rv_fhdr_remove_last_allocset, file_rv_fhdr_add_last_allocset, file_rv_fhdr_dump_last_allocset, file_rv_fhdr_dump_last_allocset}, {RVFL_FHDR_REMOVE_LAST_ALLOCSET, "RVFL_FHDR_REMOVE_LAST_ALLOCSET", file_rv_fhdr_add_last_allocset, file_rv_fhdr_remove_last_allocset, file_rv_fhdr_dump_last_allocset, file_rv_fhdr_dump_last_allocset}, {RVFL_FHDR_CHANGE_LAST_ALLOCSET, "RVFL_FHDR_CHANGE_LAST_ALLOCSET", file_rv_fhdr_change_last_allocset, file_rv_fhdr_change_last_allocset, file_rv_fhdr_dump_last_allocset, file_rv_fhdr_dump_last_allocset}, {RVFL_FHDR_ADD_PAGES, "RVFL_FHDR_ADD_PAGES", file_rv_fhdr_undoredo_add_pages, file_rv_fhdr_undoredo_add_pages, file_rv_fhdr_dump_add_pages, file_rv_fhdr_dump_add_pages}, {RVFL_FHDR_MARK_DELETED_PAGES, "RVFL_FHDR_MARK_DELETED_PAGES", file_rv_fhdr_undoredo_mark_deleted_pages, file_rv_fhdr_undoredo_mark_deleted_pages, file_rv_fhdr_dump_mark_deleted_pages, file_rv_fhdr_dump_mark_deleted_pages}, {RVFL_FHDR_DELETE_PAGES, "RVFL_FHDR_DELETE_PAGES", NULL, file_rv_fhdr_delete_pages, NULL, file_rv_fhdr_delete_pages_dump}, {RVFL_FHDR_FTB_EXPANSION, "RVFL_FHDR_FTB_EXPANSION", file_rv_fhdr_undoredo_expansion, file_rv_fhdr_undoredo_expansion, file_rv_fhdr_dump_expansion, file_rv_fhdr_dump_expansion}, {RVFL_FILEDESC, "RVFL_FILEDESC", log_rv_copy_char, log_rv_copy_char, log_rv_dump_char, log_rv_dump_char}, {RVFL_DES_FIRSTREST_NEXTVPID, "RVFL_DES_FIRSTREST_NEXTVPID", file_rv_descriptor_undoredo_firstrest_nextvpid, file_rv_descriptor_undoredo_firstrest_nextvpid, file_rv_descriptor_dump_firstrest_nextvpid, file_rv_descriptor_dump_firstrest_nextvpid}, {RVFL_DES_NREST_NEXTVPID, "RVFL_DES_NREST_NEXTVPID", file_rv_descriptor_undoredo_nrest_nextvpid, file_rv_descriptor_undoredo_nrest_nextvpid, file_rv_descriptor_dump_nrest_nextvpid, file_rv_descriptor_dump_nrest_nextvpid}, {RVFL_TRACKER_REGISTER, "RVFL_TRACKER_REGISTER", file_rv_tracker_undo_register, NULL, file_rv_tracker_dump_undo_register, NULL}, {RVFL_LOGICAL_NOOP, "RVFL_LOGICAL_NOOP", NULL, file_rv_logical_redo_nop, NULL, NULL}, {RVHF_CREATE, "RVHF_CREATE", NULL, heap_rv_redo_newpage, NULL, heap_rv_dump_statistics}, {RVHF_NEWPAGE, "RVHF_NEWPAGE", NULL, heap_rv_redo_newpage, NULL, heap_rv_dump_chain}, {RVHF_STATS, "RVHF_STATS", heap_rv_undoredo_pagehdr, heap_rv_undoredo_pagehdr, heap_rv_dump_statistics, heap_rv_dump_statistics}, {RVHF_CHAIN, "RVHF_CHAIN", heap_rv_undoredo_pagehdr, heap_rv_undoredo_pagehdr, heap_rv_dump_chain, heap_rv_dump_chain}, {RVHF_INSERT, "RVHF_INSERT", heap_rv_undo_insert, heap_rv_redo_insert, log_rv_dump_char, log_rv_dump_char}, {RVHF_DELETE, "RVHF_DELETE", heap_rv_undo_delete, heap_rv_redo_delete, log_rv_dump_char, log_rv_dump_char}, {RVHF_DELETE_NEWHOME, "RVHF_DELETE_NEWHOME", heap_rv_undo_delete, heap_rv_redo_delete_newhome, log_rv_dump_char, log_rv_dump_char}, {RVHF_UPDATE, "RVHF_UPDATE", heap_rv_undoredo_update, heap_rv_undoredo_update, log_rv_dump_char, log_rv_dump_char}, {RVHF_UPDATE_TYPE, "RVHF_UPDATE_TYPE", heap_rv_undoredo_update_type, heap_rv_undoredo_update_type, log_rv_dump_char, log_rv_dump_char}, {RVHF_REUSE_PAGE, "RVHF_REUSE_PAGE", NULL, heap_rv_redo_reuse, NULL, heap_rv_dump_reuse}, {RVOVF_NEWPAGE_LOGICAL_UNDO, "RVOVF_NEWPAGE_LOGICAL_UNDO", overflow_rv_newpage_logical_undo, NULL, overflow_rv_newpage_logical_dump_undo, NULL}, {RVOVF_NEWPAGE_INSERT, "RVOVF_NEWPAGE_INSERT", NULL, log_rv_copy_char, NULL, log_rv_dump_char}, {RVOVF_NEWPAGE_LINK, "RVOVF_NEWPAGE_LINK", overflow_rv_newpage_link_undo, overflow_rv_link, overflow_rv_link_dump, overflow_rv_link_dump}, {RVOVF_PAGE_UPDATE, "RVOVF_PAGE_UPDATE", log_rv_copy_char, log_rv_copy_char, log_rv_dump_char, log_rv_dump_char}, {RVOVF_CHANGE_LINK, "RVOVF_CHANGE_LINK", overflow_rv_link, overflow_rv_link, overflow_rv_link_dump, overflow_rv_link_dump}, {RVEH_REPLACE, "RVEH_REPLACE", log_rv_copy_char, log_rv_copy_char, NULL, NULL}, {RVEH_INSERT, "RVEH_INSERT", ehash_rv_insert_undo, ehash_rv_insert_redo, NULL, NULL}, {RVEH_DELETE, "RVEH_DELETE", ehash_rv_delete_undo, ehash_rv_delete_redo, NULL, NULL}, {RVEH_INIT_BUCKET, "RVEH_INIT_BUCKET", NULL, ehash_rv_init_bucket_redo, NULL, NULL}, {RVEH_CONNECT_BUCKET, "RVEH_CONNECT_BUCKET", log_rv_copy_char, ehash_rv_connect_bucket_redo, NULL, NULL}, {RVEH_INC_COUNTER, "RVEH_INC_COUNTER", ehash_rv_increment, ehash_rv_increment, NULL, NULL}, {RVBT_NDHEADER_UPD, "RVBT_NDHEADER_UPD", btree_rv_nodehdr_undoredo_update, btree_rv_nodehdr_undoredo_update, btree_rv_nodehdr_dump, btree_rv_nodehdr_dump}, {RVBT_NDHEADER_INS, "RVBT_NDHEADER_INS", btree_rv_nodehdr_undo_insert, btree_rv_nodehdr_redo_insert, btree_rv_nodehdr_dump, btree_rv_nodehdr_dump}, {RVBT_NDRECORD_UPD, "RVBT_NDRECORD_UPD", btree_rv_noderec_undoredo_update, btree_rv_noderec_undoredo_update, btree_rv_noderec_dump, btree_rv_noderec_dump}, {RVBT_NDRECORD_INS, "RVBT_NDRECORD_INS", btree_rv_noderec_undo_insert, btree_rv_noderec_redo_insert, btree_rv_noderec_dump_slot_id, btree_rv_noderec_dump}, {RVBT_NDRECORD_DEL, "RVBT_NDRECORD_DEL", btree_rv_noderec_redo_insert, btree_rv_noderec_undo_insert, btree_rv_noderec_dump, btree_rv_noderec_dump_slot_id}, {RVBT_PUT_PGRECORDS, "RVBT_PUT_PGRECORDS", btree_rv_pagerec_delete, btree_rv_pagerec_insert, NULL, NULL}, {RVBT_DEL_PGRECORDS, "RVBT_DEL_PGRECORDS", btree_rv_pagerec_insert, btree_rv_pagerec_delete, NULL, NULL}, {RVBT_GET_NEWPAGE, "RVBT_GET_NEWPAGE", NULL, btree_rv_newpage_redo_init, NULL, NULL}, {RVBT_NEW_PGALLOC, "RVBT_NEW_PGALLOC", btree_rv_newpage_undo_alloc, NULL, btree_rv_newpage_dump_undo_alloc, NULL}, {RVBT_KEYVAL_INS, "RVBT_KEYVAL_INS", btree_rv_keyval_undo_insert, NULL, btree_rv_keyval_dump, NULL}, {RVBT_KEYVAL_DEL, "RVBT_KEYVAL_DEL", btree_rv_keyval_undo_delete, NULL, btree_rv_keyval_dump, NULL}, {RVBT_COPYPAGE, "RVBT_COPYPAGE", btree_rv_undoredo_copy_page, btree_rv_undoredo_copy_page, NULL, NULL}, {RVBT_LFRECORD_DEL, "RVBT_LFRECORD_DEL", NULL, btree_rv_leafrec_redo_delete, NULL, NULL}, {RVBT_LFRECORD_KEYINS, "RVBT_LFRECORD_KEYINS", btree_rv_leafrec_undo_insert_key, btree_rv_leafrec_redo_insert_key, NULL, NULL}, {RVBT_LFRECORD_OIDINS, "RVBT_LFRECORD_OIDINS", NULL, btree_rv_leafrec_redo_insert_oid, NULL, btree_rv_leafrec_dump_insert_oid}, {RVBT_NOOP, "RVBT_NOOP", NULL, btree_rv_nop, NULL, NULL}, {RVBT_ROOTHEADER_UPD, "RVBT_ROOTHEADER_UPD", btree_rv_roothdr_undo_update, btree_rv_nodehdr_undoredo_update, btree_rv_roothdr_dump, btree_rv_nodehdr_dump}, {RVBT_UPDATE_OVFID, "RVBT_UPDATE_OVFID", btree_rv_ovfid_undoredo_update, btree_rv_ovfid_undoredo_update, btree_rv_ovfid_dump, btree_rv_ovfid_dump}, {RVBT_INS_PGRECORDS, "RVBT_INS_PGRECORDS", btree_rv_pagerec_delete, btree_rv_pagerec_insert, NULL, NULL}, {RVBT_OID_TRUNCATE, "RVBT_OID_TRUNCATE", NULL, btree_rv_redo_truncate_oid, NULL, NULL}, {RVBT_CREATE_INDEX, "RVBT_CREATE_INDEX", btree_rv_undo_create_index, NULL, btree_rv_dump_create_index, NULL}, {RVCT_NEWPAGE, "RVCT_NEWPAGE", NULL, catalog_rv_new_page_redo, NULL, NULL}, {RVCT_INSERT, "RVCT_INSERT", catalog_rv_insert_undo, catalog_rv_insert_redo, NULL, NULL}, {RVCT_DELETE, "RVCT_DELETE", catalog_rv_delete_undo, catalog_rv_delete_redo, NULL, NULL}, {RVCT_UPDATE, "RVCT_UPDATE", catalog_rv_update, catalog_rv_update, NULL, NULL}, {RVCT_NEW_OVFPAGE_LOGICAL_UNDO, "RVCT_NEW_OVFPAGE_LOGICAL_UNDO", catalog_rv_ovf_page_logical_insert_undo, NULL, NULL, NULL}, {RVLOM_INSERT, "RVLOM_INSERT", largeobjmgr_rv_delete, largeobjmgr_rv_insert, log_rv_dump_char, log_rv_dump_char}, {RVLOM_DELETE, "RVLOM_DELETE", largeobjmgr_rv_insert, largeobjmgr_rv_delete, log_rv_dump_char, log_rv_dump_char}, {RVLOM_OVERWRITE, "RVLOM_OVERWRITE", largeobjmgr_rv_overwrite, largeobjmgr_rv_overwrite, largeobjmgr_rv_overwrite_dump, largeobjmgr_rv_overwrite_dump}, {RVLOM_TAKEOUT, "RVLOM_TAKEOUT", largeobjmgr_rv_putin, largeobjmgr_rv_takeout, largeobjmgr_rv_putin_dump, largeobjmgr_rv_takeout_dump}, {RVLOM_PUTIN, "RVLOM_PUTIN", largeobjmgr_rv_takeout, largeobjmgr_rv_putin, largeobjmgr_rv_takeout_dump, largeobjmgr_rv_putin_dump}, {RVLOM_APPEND, "RVLOM_APPEND", largeobjmgr_rv_append_undo, largeobjmgr_rv_append_redo, largeobjmgr_rv_append_dump_undo, log_rv_dump_char}, {RVLOM_SPLIT, "RVLOM_SPLIT", largeobjmgr_rv_split_undo, largeobjmgr_rv_split_redo, largeobjmgr_rv_split_dump, largeobjmgr_rv_split_dump}, {RVLOM_GET_NEWPAGE, "RVLOM_GET_NEWPAGE", largeobjmgr_rv_get_newpage_undo, largeobjmgr_rv_get_newpage_redo, NULL, NULL}, {RVLOM_DIR_RCV_STATE, "RVLOM_DIR_RCV_STATE", largeobjmgr_rv_dir_rcv_state_undoredo, largeobjmgr_rv_dir_rcv_state_undoredo, largeobjmgr_rv_dir_rcv_state_dump, largeobjmgr_rv_dir_rcv_state_dump}, {RVLOM_DIR_PG_REGION, "RVLOM_DIR_PG_REGION", largeobjmgr_rv_dir_page_region_undoredo, largeobjmgr_rv_dir_page_region_undoredo, NULL, NULL}, {RVLOM_DIR_NEW_PG, "RVLOM_DIR_NEW_PG", largeobjmgr_rv_dir_new_page_undo, largeobjmgr_rv_dir_new_page_redo, NULL, NULL}, {RVLOG_OUTSIDE_LOGICAL_REDO_NOOP, "RVLOG_OUTSIDE_LOGICAL_REDO_NOOP", NULL, log_rv_outside_noop_redo, NULL, NULL}, {RVREPL_DATA_INSERT, "RVREPL_DATA_INSERT", NULL, NULL, NULL, #if defined(WINDOWS) NULL}, #else /* WINDOWS */ repl_data_insert_log_dump}, #endif /* WINDOWS */ {RVREPL_DATA_UPDATE, "RVREPL_DATA_UPDATE", NULL, NULL, NULL, #if defined(WINDOWS) NULL}, #else /* WINDOWS */ repl_data_insert_log_dump}, #endif /* WINDOWS */ {RVREPL_DATA_DELETE, "RVREPL_DATA_DELETE", NULL, NULL, NULL, #if defined(WINDOWS) NULL}, #else /* WINDOWS */ repl_data_insert_log_dump}, #endif /* WINDOWS */ {RVREPL_SCHEMA, "RVREPL_SCHEMA", NULL, NULL, NULL, #if defined(WINDOWS) NULL} #else /* WINDOWS */ repl_schema_log_dump} #endif /* WINDOWS */ }; /* * rv_rcvindex_string - RETURN STRING ASSOCIATED WITH GIVEN LOG_RCVINDEX * * return: * * rcvindex(in): Numeric recovery index * * NOTE: Return a string corresponding to the associated recovery * index identifier. */ const char * rv_rcvindex_string (LOG_RCVINDEX rcvindex) { return RV_fun[rcvindex].recv_string; } /* * rv_check_rvfuns - CHECK ORDERING OF RECOVERY FUNCTIONS * * return: * * NOTE:Check the ordering of recovery functions. * This is a debugging function. */ void rv_check_rvfuns (void) { unsigned int i, num_indices; num_indices = DIM (RV_fun); for (i = 0; i < num_indices; i++) if (RV_fun[i].recv_index != i) { er_log_debug (ARG_FILE_LINE, "log_check_rvfuns: *** SYSTEM ERROR ***" " Bad compilation... Recovery function %d is out of" " sequence in index %d of recovery function array\n", RV_fun[i].recv_index, i); er_set (ER_FATAL_ERROR_SEVERITY, ARG_FILE_LINE, ER_GENERIC_ERROR, 0); break; } }