fis-gtm/sr_port/v15_gdsfhead.h

389 lines
17 KiB
C

/****************************************************************
* *
* Copyright 2005, 2009 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. *
* *
****************************************************************/
#ifndef __V15_GDSFHEAD_H__
#define __V15_GDSFHEAD_H__
/* gdsfhead.h as of journal format 15 (last GT.M V4 format) */
/* this requires gdsroot.h gtm_facility.h fileinfo.h gdsbt.h */
typedef struct v15_gd_segment_struct
{
unsigned short sname_len;
unsigned char sname[MAX_SN_LEN];
unsigned short fname_len;
unsigned char fname[MAX_FN_LEN + 1];
unsigned short blk_size;
unsigned short ext_blk_count;
uint4 allocation;
struct CLB *cm_blk;
unsigned char defext[4];
short defer_time; /* Was passed in cs_addrs */
unsigned char buckets; /* Was passed in FAB */
unsigned char windows; /* Was passed in FAB */
uint4 lock_space;
uint4 global_buffers; /* Was passed in FAB */
uint4 reserved_bytes; /* number of bytes to be left in every database block */
enum db_acc_method acc_meth;
file_control *file_cntl;
struct v15_gd_region_struct *repl_list;
} v15_gd_segment;
typedef union
{
int4 offset; /* relative offset to segment */
v15_gd_segment *addr; /* absolute address of segment */
} v15_gd_seg_addr;
typedef struct v15_gd_region_struct
{
unsigned short rname_len;
unsigned char rname[MAX_RN_LEN];
unsigned short max_key_size;
uint4 max_rec_size;
v15_gd_seg_addr dyn;
v15_gd_seg_addr stat;
bool open;
bool lock_write;
bool null_subs;
unsigned char jnl_state;
/* deleted gbl_lk_root and lcl_lk_root, obsolete fields */
uint4 jnl_alq;
unsigned short jnl_deq;
short jnl_buffer_size;
bool jnl_before_image;
bool opening;
bool read_only;
bool was_open;
unsigned char cmx_regnum;
unsigned char def_coll;
unsigned char filler[1];
unsigned char jnl_file_len;
unsigned char jnl_file_name[JNL_NAME_SIZE];
/* VMS file id struct goes to OS specific struct */
/* VMS lock structure for reference goes to OS specific struct */
int4 node;
int4 sec_size;
} v15_gd_region;
typedef struct
{
CNTR4DCL(evnt_cnt,100);
v15_trans_num evnt_tn;
} v15_bg_trc_rec;
typedef struct
{
int4 curr_count; /* count for this invocation of shared memory */
int4 cumul_count; /* count from the creation of database (not including this invocation) */
} v15_db_csh_acct_rec;
#define TAB_DB_CSH_ACCT_REC(A,B,C) v15_##A,
enum v15_db_csh_acct_rec_type
{
#include "v15_tab_db_csh_acct_rec.h"
v15_n_db_csh_acct_rec_types
};
#undef TAB_DB_CSH_ACCT_REC
#define TAB_BG_TRC_REC(A,B) v15_##B,
enum v15_bg_trc_rec_fixed_type
{
#include "v15_tab_bg_trc_rec_fixed.h"
v15_n_bg_trc_rec_fixed_types
};
enum v15_bg_trc_rec_variable_type
{
#include "v15_tab_bg_trc_rec_variable.h"
v15_n_bg_trc_rec_variable_types
};
#undef TAB_BG_TRC_REC
/* This is the structure describing a segment. It is used as a database file
* header (for MM or BG access methods). The overloaded fields for MM and BG are
* n_bts, bt_buckets, cur_lru_cache_rec_off, cache_lru_cycle.
*/
typedef struct v15_sgmnt_data_struct
{
unsigned char label[GDS_LABEL_SZ];
int4 n_bts; /* number of cache record/blocks */
int filler_bt_header_off[2];
int filler_bt_base_off[2];
int filler_th_base_off[2];
int filler_cache_off[2];
int filler_cur_lru_cache_rec_off[2];
enum db_acc_method acc_meth; /* Access method (BG or MM). This is static data defined
* at file creation.
*/
short start_vbn; /* starting virtual block number. */
bool createinprogress;
bool file_corrupt; /* If this flag is set it shuts the file down. No process
* (except DSE) can successfully map this section after
* the flag is set to TRUE. Processes that already have it
* mapped should produce an error the next time that they use
* the file. The flag can only be reset by the DSE utility.
*/
int4 total_blks_filler; /* Marks old total_blks spot, needed for gvcst_init compatablility code */
file_info created; /* Who created this file */
uint4 lkwkval; /* Incremented for each lock wake up */
int4 yield_lmt; /* maximum number of times a process yields to get optimal jnl writes */
uint4 lock_space_size;/* Number of bytes to be used for locks (in database for bg) */
uint4 owner_node; /* Node on cluster that "owns" the file */
uint4 free_space; /* Space in file header not being used */
uint4 max_bts; /* Maximum number of bt records allowed in file */
uint4 extension_size; /* Number of gds data blocks to extend by */
int4 blk_size; /* Block size for the file. This is static data defined when
* the file is created (via MUPIP). This should correspond to the
* process'es gde description of the file. If it doesn't, the number
* in the file header should be used.
*/
int4 max_rec_size; /* maximum record size allowed for this file */
int4 max_key_size; /* maximum key size allowed for this file */
bool null_subs;
bool lock_write;
bool ccp_jnl_before; /* used for clustered to pass if jnl file has before images */
bool clustered;
bool flush_done;
bool unbacked_cache; /* see mupip_set_file for usage */
short bplmap; /* Blocks per local map (bitmap). This is static data defined when
* the file is created (via MUPIP).
*/
int4 bt_buckets; /* Number of buckets in bt table */
CNTR4DCL(filler_ref_cnt,10); /* reference count. How many people are using the database */
CNTR4DCL(n_wrt_per_flu,11); /* Number of writes per flush call */
/* overloaded for BG and MM */
/************* ACCOUNTING INFOMATION ********************************/
int4 n_retries[CDB_MAX_TRIES];
/* Counts of the number of retries it took to commit a transaction */
int4 n_puts; /* number of puts (non-tp only) */
int4 n_kills; /* number of kills */
int4 n_queries; /* number of $Query's */
int4 n_gets; /* number of MUMPS GETS */
int4 n_order; /* number of orders */
int4 n_zprevs; /* number of $ZPrevious's */
int4 n_data; /* number of datas */
int4 wc_rtries; /* write cache read tries */
int4 wc_rhits; /* write cache read hits */
/* Note that the below field was placed here because these were previously used locations that (likely)
have a value. For this reason, this value should not be counted upon as a true creation date/time
but as a token whose value is somewhat unique amongst multiple generations of the same file. It's
only real purpose is to lend uniqueness to the ftok test in dbinit() where our test system has
created the same file with the same ftok and other matching inode/etc criteria but it is NOT the
same file -- only an extremely similar one whose use of old shared memory created integrity errors. */
union
{
v15_time_t date_time; /* When file was created */
int filler[2]; /* Filler to make sure above is okay even if takes 2 words on some platform */
} creation;
CNTR4DCL(filler_wcs_active_lvl,14); /* (n_wcrs / 2) - entries in wcq_active (trips wcs_wtstart) */
bool filler_wc_blocked; /* former location of wc_blocked as bool */
char root_level; /* current level of the root */
short filler_short; /* filler added to ensure alignment, can be reused */
int4 flush_time[2];
v15_trans_num last_inc_backup;
v15_trans_num last_com_backup;
int4 staleness[2]; /* timer value */
int4 filler_wc_in_free; /* number of write cache records in free queue */
int4 ccp_tick_interval[2]; /* quantum to release write mode if no write occurs and others are queued
* These three values are all set at creation by mupip_create
*/
int4 flu_outstanding;
int4 free_blocks_filler; /* Marks old free_blocks spot, needed for gvcst_init compatablility code */
int4 tp_cdb_sc_blkmod[7]; /* notes down the number of times each place got a cdb_sc_blkmod in tp */
v15_trans_num last_rec_backup;
int4 ccp_quantum_interval[2]; /* delta timer for ccp quantum */
int4 ccp_response_interval[2]; /* delta timer for ccp mailbox response */
uint4 jnl_alq;
unsigned short jnl_deq;
short jnl_buffer_size; /* in pages */
bool jnl_before_image;
unsigned char jnl_state; /* Current journaling state */
bool filler_glob_sec_init[1];/* glob_sec_init field moved to node_local */
unsigned char jnl_file_len; /* journal file name length */
unsigned char jnl_file_name[JNL_NAME_SIZE]; /* journal file name */
v15_th_index trans_hist; /* transaction history - if moved from 2nd fileheader block, change TH_BLOCK */
int4 cache_lru_cycle; /* no longer maintained, but field is preserved in case needed in future */
int4 filler_mm_extender_pid; /* pid of the process executing gdsfilext in MM mode */
int4 filler_db_latch; /* moved - latch for interlocking on tandem */
int4 reserved_bytes; /* Database blocks will always leave this many bytes unused */
CNTR4DCL(filler_in_wtstart,15); /* Count of processes in wcs_wtstart */
short defer_time; /* defer write ; 0 => immediate, -1 => infinite defer,
>0 => defer_time * flush_time[0] is actual defer time
DEFAULT value of defer_time = 1 implying a write-timer every
csd->flush_time[0] seconds */
unsigned char def_coll; /* Default collation type for new globals */
unsigned char def_coll_ver; /* Default collation type version */
boolean_t std_null_coll; /* 0 -> GT.M null collation,i,e, null subs collate between numeric and string
* 1-> standard null collation i.e. null subs collate before numeric and string */
uint4 image_count; /* Is used for Data Base Freezing. */
/* Set to PROCESS_ID on UNIX and */
/* to IMAGE_COUNT on VMS */
uint4 freeze; /* Set to PROCESS_ID on VMS and */
/* to GETUID on UNIX in order */
/* to "freeze" the Write Cache. */
int4 rc_srv_cnt; /* Count of RC servers accessing database */
short dsid; /* DSID value, non-zero when being accessed by RC */
short rc_node;
uint4 autoswitchlimit; /* limit in disk blocks (max 4GB) when jnl should be auto switched */
int4 epoch_interval; /* Time between successive epochs in epoch-seconds */
int4 n_tp_retries[7]; /* indexed by t_tries and incremented by 1 for all regions in restarting TP */
/* The need for having tab_bg_trc_rec_fixed.h and tab_bg_trc_rec_variable.h is because
* of now_running and kill_in_prog coming in between the bg_trc_rec fields.
* In V5.0, this should be rearranged to have a contiguous space for bg_trc_rec fields
*/
/* Include all the bg_trc_rec_fixed accounting fields below */
#define TAB_BG_TRC_REC(A,B) v15_bg_trc_rec fixed_##B;
#include "v15_tab_bg_trc_rec_fixed.h"
#undef TAB_BG_TRC_REC
char now_running[MAX_REL_NAME]; /* for active version stamp */
int4 kill_in_prog; /* counter for multi-crit kills that are not done yet */
/* Note that TAB_BG_TRC_REC and TAB_DB_CSH_ACCT_REC grow in opposite directions */
/* Include all the bg_trc_rec_variable accounting fields below */
#define TAB_BG_TRC_REC(A,B) v15_bg_trc_rec var_##B;
#include "v15_tab_bg_trc_rec_variable.h"
#undef TAB_BG_TRC_REC
/* Note that when there is an overflow in the sum of the sizes of the bg_trc_rec_variable
* types and the db_csh_acct_rec types (due to introduction of new types of accounting
* fields), the character array common_filler below will become a negative sized array
* which will signal a compiler error (rather than an undecipherable runtime error).
*/
char common_filler[584 - SIZEOF(v15_bg_trc_rec) * v15_n_bg_trc_rec_variable_types
- SIZEOF(v15_db_csh_acct_rec) * v15_n_db_csh_acct_rec_types];
/* Include all the db cache accounting fields below */
#define TAB_DB_CSH_ACCT_REC(A,B,C) v15_db_csh_acct_rec acct_##A;
#include "v15_tab_db_csh_acct_rec.h"
#undef TAB_DB_CSH_ACCT_REC
unsigned char reorg_restart_key[256]; /* 1st key of a leaf block where reorg was done last time */
uint4 alignsize; /* alignment size for JRT_ALIGN */
block_id reorg_restart_block;
/******* following three members (filler_{jnl_file,dbfid}, filler_ino_t) together occupy 64 bytes on all platforms *******/
/* this area which was previously used for the field "jnl_file" is now moved to node_local */
union
{
gds_file_id jnl_file_id; /* needed on UNIX to hold space */
unix_file_id u; /* from gdsroot.h even for VMS */
} filler_jnl_file;
union
{
gds_file_id vmsfid; /* not used, just hold space */
unix_file_id u; /* For unix ftok error detection */
} filler_dbfid;
/* jnl_file and dbfid use ino_t, so place them together */
#ifndef INO_T_LONG
char filler_ino_t[8]; /* this filler is not needed for those platforms that have the
size of ino_t 8 bytes -- defined in mdefsp.h (Sun only for now) */
#endif
/*************************************************************************************/
mutex_spin_parms_struct mutex_spin_parms;
int4 mutex_filler1;
int4 mutex_filler2;
int4 mutex_filler3;
int4 mutex_filler4;
/* semid/shmid/sem_ctime/shm_ctime are UNIX only */
int4 semid; /* Since int may not be of fixed size, int4 is used */
int4 shmid; /* Since int may not be of fixed size, int4 is used */
union
{
time_t ctime; /* For current GTM code sem_ctime field corresponds to creation time */
int4 filler[2]; /* Filler to make sure above is okay even if takes 2 words on some platform */
} gt_sem_ctime;
union
{
time_t ctime; /* For current GTM code sem_ctime field corresponds to creation time */
int4 filler[2]; /* Filler to make sure above is okay even if takes 2 words on some platform */
} gt_shm_ctime;
boolean_t recov_interrupted; /* whether a MUPIP JOURNAL -RECOVER/ROLLBACK command on this db got interrupted */
int4 intrpt_recov_jnl_state; /* journaling state at start of interrupted recover/rollback */
int4 intrpt_recov_repl_state; /* replication state at start of interrupted recover/rollback */
jnl_tm_t intrpt_recov_tp_resolve_time; /* since-time for the interrupted recover */
seq_num intrpt_recov_resync_seqno; /* resync/fetchresync jnl_seqno of interrupted rollback */
uint4 n_puts_duplicate; /* number of duplicate sets in non-TP */
uint4 n_tp_updates; /* number of TP transactions that incremented the db curr_tn for this region */
uint4 n_tp_updates_duplicate; /* number of TP transactions that did purely duplicate sets in this region */
char filler3[932];
int4 filler_highest_lbm_blk_changed; /* Records highest local bit map block that
changed so we know how much of master bit
map to write out. Modified only under crit */
char filler_3k_64[60]; /* get to 64 byte aligned */
char filler1_wc_var_lock[16]; /* moved to node_local */
char filler_3k_128[48]; /* 3k + 128 - cache line on HPPA */
char filler2_db_latch[16]; /* moved to node_local */
char filler_3k_192[48]; /* 3k + 192 - cache line on HPPA */
char filler_4096[832]; /* Fill out so map sits on 8K boundary */
char filler_unique_id[32];
char machine_name[MAX_MCNAMELEN];
int4 flush_trigger;
int4 cache_hits;
int4 max_update_array_size; /* maximum size of update array needed for one non-TP set/kill */
int4 max_non_bm_update_array_size; /* maximum size of update array excepting bitmaps */
int4 n_tp_retries_conflicts[7]; /* indexed by t_tries and incremented for conflicting region in TP */
volatile boolean_t wc_blocked; /* write cache blocked until recover done due to process being stopped */
/* in MM mode it is used to call wcs_recover during a file extension */
char filler_rep[176]; /* Leave room for non-replication fields */
/******* REPLICATION RELATED FIELDS ***********/
seq_num reg_seqno; /* the jnl seqno of the last update to this region -- 8-byte aligned */
seq_num resync_seqno; /* Replication related field. The resync-seqno to be sent to the secondary */
v15_trans_num resync_tn; /* tn for this region
* corresponding to
* resync_seqno - used in
* replication lost
* transactions handling */
uint4 repl_resync_tn_filler; /* to accommodate 8 byte
* resync_tn in the future */
seq_num old_resync_seqno; /* maintained to find out if
* transactions were sent
* from primary to secondary
* - used in replication */
int4 repl_state; /* state of replication whether "on" or "off" */
int4 wait_disk_space; /* seconds to wait for diskspace before giving up */
int4 jnl_sync_io; /* drives sync I/O ('direct' if applicable) for journals, if set */
char filler_5104[452];
enum db_ver creation_db_ver; /* Major DB version at time of creation */
enum mdb_ver creation_mdb_ver; /* Minor DB version at time of creation */
enum db_ver certified_for_upgrade_to; /* Version the database is certified for upgrade to */
int filler_5k; /* Fill out to 5K */
/******* SECSHR_DB_CLNUP RELATED FIELDS ***********/
int4 secshr_ops_index;
int4 secshr_ops_array[255]; /* taking up 1K */
char filler_7k[1024]; /* Fill out so map sits on 8K boundary */
char filler_8k[1024]; /* Fill out so map sits on 8K boundary */
unsigned char master_map[MASTER_MAP_SIZE_V4]; /* This map must be aligned on a block size boundary */
/* Master bitmap. Tells whether the local bitmaps have any free blocks or not. */
} v15_sgmnt_data;
/* End of gdsfhead.h */
#ifdef DB64
# ifdef __osf__
# pragma pointer_size(save)
# pragma pointer_size(long)
# else
# error UNSUPPORTED PLATFORM
# endif
#endif
typedef v15_sgmnt_data *v15_sgmnt_data_ptr_t;
#ifdef DB64
# ifdef __osf__
# pragma pointer_size(restore)
# endif
#endif
#endif