135 lines
5.1 KiB
C
135 lines
5.1 KiB
C
/****************************************************************
|
|
* *
|
|
* Copyright 2003, 2013 Fidelity Information Services, Inc *
|
|
* *
|
|
* This source code contains the intellectual property *
|
|
* of its copyright holder(s), and is made available *
|
|
* under a license. If you do not know the terms of *
|
|
* the license, please stop and do not read further. *
|
|
* *
|
|
****************************************************************/
|
|
|
|
#include "mdef.h"
|
|
#include "gtm_string.h"
|
|
#include "gdsroot.h"
|
|
#include "gdsbt.h"
|
|
#include "gtm_facility.h"
|
|
#include "fileinfo.h"
|
|
#include "gdsfhead.h"
|
|
#include "filestruct.h"
|
|
#include "jnl.h"
|
|
#include "buddy_list.h"
|
|
#include "hashtab_int4.h" /* needed for muprec.h */
|
|
#include "hashtab_int8.h" /* needed for muprec.h */
|
|
#include "hashtab_mname.h" /* needed for muprec.h */
|
|
#include "muprec.h"
|
|
#if defined(VMS)
|
|
#include "iosb_disk.h"
|
|
#endif
|
|
#include "mur_read_file.h"
|
|
#include "iosp.h"
|
|
#include "copy.h"
|
|
#include "gtmmsg.h"
|
|
|
|
GBLREF mur_gbls_t murgbl;
|
|
GBLREF mur_opt_struct mur_options;
|
|
GBLREF jnl_gbls_t jgbl;
|
|
|
|
error_def(ERR_JNLREAD);
|
|
error_def(ERR_JNLBADRECFMT);
|
|
error_def(ERR_NOPINI);
|
|
|
|
#define PROCEED_IF_EXTRACT_SHOW_VERIFY(JCTL, PINI_ADDR, PLST, PPLST) \
|
|
{ /* allow EXTRACT/SHOW/VERIFY to proceed after printing BAD PINI error if error_limit permits. \
|
|
* the way we proceed is by returning as if PINI_ADDR was the first journal record in the file. \
|
|
* this is guaranteed to be a PINI record because of the way GT.M create journal files. \
|
|
*/ \
|
|
GBLREF mur_gbls_t murgbl; \
|
|
GBLREF mur_opt_struct mur_options; \
|
|
ht_ent_int4 *tabent; \
|
|
\
|
|
if (mur_options.update || !(MUR_WITHIN_ERROR_LIMIT(murgbl.err_cnt, mur_options.error_limit))) \
|
|
/* RECOVER/ROLLBACK should not proceed even if error_limit permits */ \
|
|
return ERR_JNLBADRECFMT; \
|
|
PINI_ADDR = JNL_FILE_FIRST_RECORD; \
|
|
if (NULL != (tabent = lookup_hashtab_int4(&JCTL->pini_list, (uint4 *)&PINI_ADDR))) \
|
|
PLST = tabent->value; \
|
|
else \
|
|
PLST = NULL; \
|
|
if (NULL != PLST) \
|
|
{ \
|
|
*PPLST = PLST; \
|
|
return SS_NORMAL; \
|
|
} \
|
|
/* at this point we have a bad PINI record in the beginning of the journal file, we probably should GTMASSERT */\
|
|
return ERR_JNLBADRECFMT; \
|
|
}
|
|
|
|
/* This routine reads a PINI record from a Journal file.
|
|
* If it is not already in the hash table, it saves it in the hash table,
|
|
* For success pplst = (pointer to the pini_list_struct structure) is updated.
|
|
* For success it returns SS_NORMAL. Else error code is returned.
|
|
*/
|
|
uint4 mur_get_pini(jnl_ctl_list *jctl, off_jnl_t pini_addr, pini_list_struct **pplst)
|
|
{
|
|
pini_list_struct *plst;
|
|
struct_jrec_pini *pini_rec;
|
|
uint4 status;
|
|
ht_ent_int4 *tabent;
|
|
struct_jrec_pini *pinirec;
|
|
reg_ctl_list *rctl;
|
|
mur_read_desc_t *mur_desc;
|
|
|
|
if (NULL != (tabent = lookup_hashtab_int4(&jctl->pini_list, (uint4 *)&pini_addr)))
|
|
plst = tabent->value;
|
|
else
|
|
plst = NULL;
|
|
if (NULL != plst)
|
|
{
|
|
*pplst = plst;
|
|
return SS_NORMAL;
|
|
}
|
|
rctl = jctl->reg_ctl;
|
|
mur_desc = rctl->mur_desc;
|
|
mur_desc->random_buff.dskaddr = ROUND_DOWN2(pini_addr, DISK_BLOCK_SIZE);
|
|
mur_desc->random_buff.blen = pini_addr - mur_desc->random_buff.dskaddr + PINI_RECLEN;
|
|
if (mur_desc->random_buff.dskaddr > jctl->eof_addr - mur_desc->random_buff.blen
|
|
|| (SS_NORMAL != (status = mur_read(jctl))))
|
|
{
|
|
if (mur_options.update && jctl->after_end_of_data && !jgbl.forw_phase_recovery)
|
|
return ERR_JNLBADRECFMT;
|
|
gtm_putmsg_csa(CSA_ARG(rctl->csa) VARLSTCNT(5) ERR_JNLBADRECFMT, 3, jctl->jnl_fn_len, jctl->jnl_fn,
|
|
jctl->rec_offset);
|
|
gtm_putmsg_csa(CSA_ARG(rctl->csa) VARLSTCNT(5) ERR_JNLREAD, 3, jctl->jnl_fn_len, jctl->jnl_fn, pini_addr);
|
|
assert(FALSE);
|
|
murgbl.wrn_count++;
|
|
PROCEED_IF_EXTRACT_SHOW_VERIFY(jctl, pini_addr, plst, pplst);
|
|
}
|
|
pinirec = (struct_jrec_pini *)(mur_desc->random_buff.base + (pini_addr - mur_desc->random_buff.dskaddr));
|
|
/* Verify that it's actually a PINI record */
|
|
if (JRT_PINI != pinirec->prefix.jrec_type || PINI_RECLEN != pinirec->prefix.forwptr ||
|
|
!IS_VALID_JNLREC((jnl_record *)pinirec, jctl->jfh))
|
|
{
|
|
if (mur_options.update && jctl->after_end_of_data && !jgbl.forw_phase_recovery)
|
|
return ERR_JNLBADRECFMT;
|
|
gtm_putmsg_csa(CSA_ARG(rctl->csa) VARLSTCNT(5) ERR_JNLBADRECFMT, 3, jctl->jnl_fn_len, jctl->jnl_fn,
|
|
jctl->rec_offset);
|
|
if (JRT_PINI != pinirec->prefix.jrec_type)
|
|
gtm_putmsg_csa(CSA_ARG(rctl->csa) VARLSTCNT(5) ERR_NOPINI, 3, jctl->jnl_fn_len, jctl->jnl_fn, pini_addr);
|
|
assert(FALSE);
|
|
murgbl.wrn_count++;
|
|
PROCEED_IF_EXTRACT_SHOW_VERIFY(jctl, pini_addr, plst, pplst);
|
|
}
|
|
/* Insert it into the list */
|
|
plst = (pini_list_struct *)get_new_element(murgbl.pini_buddy_list, 1);
|
|
plst->pini_addr = pini_addr;
|
|
plst->new_pini_addr = 0;
|
|
plst->state = IGNORE_PROC;
|
|
memcpy(&plst->jpv, &pinirec->process_vector[CURR_JPV], SIZEOF(jnl_process_vector));
|
|
memcpy(&plst->origjpv, &pinirec->process_vector[ORIG_JPV], SIZEOF(jnl_process_vector));
|
|
NON_GTM64_ONLY(assert(SIZEOF(void *) == SIZEOF(pini_addr));)
|
|
add_hashtab_int4(&jctl->pini_list, (uint4 *)&pini_addr, (void *)plst, &tabent);
|
|
*pplst = plst;
|
|
return SS_NORMAL;
|
|
}
|