fis-gtm/sr_port/mu_int_maps.c

269 lines
7.8 KiB
C
Raw Permalink Normal View History

/****************************************************************
* *
* Copyright 2001, 2010 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 "gdsroot.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "gdsdbver.h"
#include "gdsblk.h"
#include "gdsbml.h"
#include "copy.h"
#include "mu_int_maps.h"
#include "util.h"
#include "mupint.h"
/* Include prototypes */
#include "bit_set.h"
GBLREF uint4 mu_int_offset[];
GBLREF uint4 mu_int_errknt;
GBLREF unsigned char *mu_int_locals;
GBLREF unsigned char *mu_int_master;
GBLREF sgmnt_data mu_int_data;
GBLREF block_id mu_int_path[];
GBLREF boolean_t tn_reset_this_reg;
GBLREF int mu_int_plen;
GBLREF int4 mu_int_blks_to_upgrd;
GBLREF int disp_map_errors;
GBLREF int mu_map_errs;
GBLREF int disp_trans_errors;
GBLREF int trans_errors;
void mu_int_maps(void)
{
unsigned char *local;
uchar_ptr_t disk;
boolean_t agree, disk_full, local_full, master_full;
int maps, mapsize, mcnt, lcnt, bcnt;
unsigned int level;
uint_ptr_t dskmap_p;
uint4 dskmap, lfree, *lmap, map_blk_size;
block_id blkno, last_bmp;
enum db_ver ondsk_blkver;
error_def(ERR_DBREADBM);
error_def(ERR_DBLVLINC);
error_def(ERR_DBMBSIZMN);
error_def(ERR_DBMBSIZMX);
error_def(ERR_DBMBTNSIZMX);
error_def(ERR_DBLOCMBINC);
error_def(ERR_DBBFSTAT);
error_def(ERR_DBMBPFLINT);
error_def(ERR_DBMBPFLDLBM);
error_def(ERR_DBMBPFRDLBM);
error_def(ERR_DBMBPFRINT);
error_def(ERR_DBMBPFLDIS);
error_def(ERR_DBMBPINCFL);
error_def(ERR_DBMRKFREE);
error_def(ERR_DBMRKBUSY);
error_def(ERR_DBMBMINCFRE);
mu_int_offset[0] = 0;
maps = (mu_int_data.trans_hist.total_blks + mu_int_data.bplmap - 1) / mu_int_data.bplmap;
local = mu_int_locals;
map_blk_size = BM_SIZE(mu_int_data.bplmap);
last_bmp = ((mu_int_data.trans_hist.total_blks / mu_int_data.bplmap) * mu_int_data.bplmap);
mapsize = mu_int_data.bplmap;
for (mcnt = 0; mcnt < maps; mcnt++, local += BM_MINUS_BLKHDR_SIZE(mapsize))
{
assert(mapsize == mu_int_data.bplmap);
blkno = mcnt * mu_int_data.bplmap;
bml_busy(blkno, mu_int_locals);
disk = mu_int_read(blkno, &ondsk_blkver); /* ondsk_blkver set to GDSV4 or GDSV5 (GDSVCURR) */
if (!disk)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err(ERR_DBREADBM, 0, 0, 0, 0, 0, 0, LCL_MAP_LEVL);
continue;
}
if (LCL_MAP_LEVL != (level = (unsigned int)((blk_hdr_ptr_t)disk)->levl))
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err(ERR_DBLVLINC, 0, 0, 0, 0, 0, 0, level);
}
if (((blk_hdr_ptr_t)disk)->bsiz < map_blk_size)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err(ERR_DBMBSIZMN, 0, 0, 0, 0, 0, 0, level);
continue;
}
if (((blk_hdr_ptr_t)disk)->bsiz > map_blk_size)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err(ERR_DBMBSIZMX, 0, 0, 0, 0, 0, 0, level);
continue;
}
if (tn_reset_this_reg)
{
((blk_hdr_ptr_t)disk)->tn = 0;
mu_int_write(blkno, disk);
if (GDSVCURR != mu_int_data.desired_db_format)
mu_int_blks_to_upgrd++;
} else if (GDSVCURR != ondsk_blkver)
mu_int_blks_to_upgrd++;
if (((blk_hdr_ptr_t)disk)->tn >= mu_int_data.trans_hist.curr_tn)
{
if (trans_errors < disp_trans_errors)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err(ERR_DBMBTNSIZMX, 0, 0, 0, 0, 0, 0, level);
trans_errors++;
} else
{
mu_int_errknt++;
trans_errors++;
}
}
master_full = !bit_set(mcnt, mu_int_master);
if (last_bmp == blkno)
mapsize = (mu_int_data.trans_hist.total_blks - blkno);
disk_full = (NO_FREE_SPACE == bml_find_free(0, disk + SIZEOF(blk_hdr), mapsize));
agree = TRUE;
for (lcnt = 0, dskmap_p = (uint_ptr_t)(disk + SIZEOF(blk_hdr)), lmap = (uint4 *)local;
lcnt < mapsize;
lcnt += SIZEOF(int4) * BITS_PER_UCHAR / BML_BITS_PER_BLK,
dskmap_p++, lmap++) /* # of bits/ bits per blk */
{
GET_LONG(dskmap, dskmap_p);
/* do a quick check to see if there is anything wrong with the
bitmaps entries that fit into an int4.
We need to check that the free bit matches the in-memory
copy and that there are no illegal combinations.
There are four combinations per block
(00 = busy, 01 = free, 10 = unused (invalid bitmap value),
11 = free block which was previously used).
We use the following calculation to determine if there are
any illegal combinations within the current int4.
00011011 take original value from bitmap on disk.
and 01010101 mask off "reused" bit.
----------
00010001 = free blocks.
xor 01010101 toggle free bit
----------
01000100 = busy blocks
<< 1
----------
10001000 = mask checking the "reused" bit for the busy blocks
and 00011011 original value from bitmap on disk.
----------
00001000 non-zero indicates an illegal combination somewhere
in the int4.
*/
if ((dskmap & SIXTEEN_BLKS_FREE) != *lmap
|| ((((dskmap & SIXTEEN_BLKS_FREE) ^ SIXTEEN_BLKS_FREE) << 1) & dskmap))
{
if (agree)
{
agree = FALSE;
mu_int_path[0] = blkno;
mu_int_plen = 1;
if (mu_map_errs < disp_map_errors)
mu_int_err(ERR_DBLOCMBINC, 0, 0, 0, 0, 0, 0, level);
else
mu_int_errknt++;
}
for (bcnt = 0; bcnt < SIZEOF(int4) * BITS_PER_UCHAR / BML_BITS_PER_BLK; bcnt++)
{
if (!(mu_int_isvalid_mask[bcnt] ^ (dskmap & mu_int_mask[bcnt])))
{
mu_int_path[0] = blkno + lcnt + bcnt;
mu_int_plen = 1;
mu_int_err(ERR_DBBFSTAT,
0, 0, 0, 0, 0, 0, level);
}
else if ((lfree = mu_int_isfree_mask[bcnt] & *(lmap)) ^ mu_int_isfree_mask[bcnt] & dskmap)
{
mu_int_path[0] = blkno + lcnt + bcnt;
mu_int_plen = 1;
/* for the following two mu_int_err(), we should actually be calculating the
* actual level of the mu_int_path[0]. But this would need a read() of the block,
* which might slow down the process. We should consider this however at a
* later time. */
if (!lfree)
mu_int_err(ERR_DBMRKFREE, 0, 0, 0, 0, 0, 0, LCL_MAP_LEVL);
else if (mu_map_errs < disp_map_errors)
{
mu_int_err(ERR_DBMRKBUSY, 0, 0, 0, 0, 0, 0, LCL_MAP_LEVL);
mu_map_errs++;
} else
{
mu_int_errknt++;
mu_map_errs++;
}
}
}
}
}
if (!agree)
{
local_full = (NO_FREE_SPACE == bml_find_free(0, local, mapsize));
if (local_full || disk_full)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
if (mu_map_errs < disp_map_errors)
{
mu_int_err(master_full ?
(local_full ? ERR_DBMBPFLINT
: ERR_DBMBPFLDLBM)
: (local_full ?
ERR_DBMBPFRDLBM
: ERR_DBMBPFRINT),
0, 0, 0, 0, 0, 0, level);
} else
mu_int_errknt++;
} else if (master_full)
{
if (mu_map_errs < disp_map_errors)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err( ERR_DBMBPFLDIS,
0, 0, 0, 0, 0, 0, level);
} else
mu_int_errknt++;
}
} else if (disk_full ^ master_full)
{
if (mu_map_errs < disp_map_errors)
{
mu_int_path[0] = blkno;
mu_int_plen = 1;
mu_int_err(master_full ? ERR_DBMBPINCFL
: ERR_DBMBMINCFRE,
0, 0, 0, 0, 0, 0, level);
} else
mu_int_errknt++;
}
free(disk);
}
if (mu_map_errs >= disp_map_errors)
{
util_out_print("Maximum number of incorrectly busy errors to display: !UL, has been exceeded", TRUE,
disp_map_errors);
util_out_print("!UL incorrectly busy errors encountered", TRUE, mu_map_errs);
}
return;
}