1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
/****************************************************************
* *
* Copyright (c) 2012-2024 Fidelity National Information *
* Services, Inc. and/or its subsidiaries. All rights reserved. *
* *
* 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 <errno.h>
#include <sys/sem.h>
#include "gtm_string.h"
#include "gdsroot.h"
#include "gdsblk.h"
#include "gdsbml.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "gdsblkops.h"
#include "gdscc.h"
#include "filestruct.h"
#include "jnl.h"
#include "min_max.h"
#include "t_qread.h"
#include "dse.h"
#include "gtmmsg.h"
#include "t_begin.h"
#include "t_write_map.h"
#include "t_abort.h"
#include "t_retry.h"
#include "t_end.h"
#include "wbox_test_init.h"
#include "error.h"
#include "t_recycled2free.h"
#include "cdb_sc.h"
#include "eintr_wrappers.h"
#include "gtmimagename.h"
#include "clear_cache_array.h"
#include "gtmio.h"
#include "sleep_cnt.h"
#include "wcs_sleep.h"
#include "interlock.h"
#include "gdsbgtr.h"
#include "copy.h"
#include "shmpool.h"
#include "do_semop.h"
#include "gtm_semutils.h"
#include "inline_atomic_pid.h"
GBLREF uint4 process_id;
void clear_cache_array(sgmnt_addrs *csa, sgmnt_data_ptr_t csd, gd_region* reg, block_id new_total, block_id old_total)
{
char *err_msg;
boolean_t got_lock;
cache_rec_ptr_t cr;
cache_rec_ptr_t cr_lo, cr_top, hash_hdr;
bt_rec_ptr_t bt;
node_local_ptr_t cnl;
unix_db_info *udi;
int semval;
DCL_THREADGBL_ACCESS;
SETUP_THREADGBL_ACCESS;
/* If called from db_init, assure we've grabbed the access semaphor and are the only process attached to the database.
* Otherwise, we should have crit when called from wcs_recover or mu_truncate.
*/
udi = FILE_INFO(reg);
assert((udi->grabbed_access_sem && (DB_COUNTER_SEM_INCR == (semval = semctl(udi->semid, DB_COUNTER_SEM, GETVAL))))
|| csa->now_crit);
hash_hdr = (cache_rec_ptr_t)csa->acc_meth.bg.cache_state->cache_array;
cr_lo = hash_hdr + csd->bt_buckets;
cr_top = cr_lo + csd->n_bts;
cnl = csa->nl;
/* Last thing we did was wcs_flu, so no buffers should have been dirtied in the meantime. */
assert(0 == cnl->wcs_active_lvl);
for (cr = cr_lo; cr < cr_top; cr++)
{
assert(0 == cr->dirty);
if ((CR_BLKEMPTY != cr->blk) && (new_total <= cr->blk))
{ /* Invalidate this cache record. */
cr->cycle++;
if (CR_BLKEMPTY != cr->blk)
{
bt = bt_get(cr->blk);
if (NULL != bt)
{
bt->cache_index = CR_NOTVALID;
bt->blk = BT_NOTVALID;
bt->tn = 0;
}
}
cr->blk = CR_BLKEMPTY;
BML_RSRV_RESET(cr);
/* when cr->blk is empty, ensure no bt points to this cache-record */
cr->bt_index = 0; /* offset to bt_rec */
cr->data_invalid = 0; /* process_id */
cr->flushed_dirty_tn = 0; /* value of dirty at the time of flush */
cr->in_tend = 0;
/* release of a shmpool reformat block if the current cache record is pointing to it */
SHMPOOL_FREE_CR_RFMT_BLOCK(reg, csa, cr);
WRITE_LATCH_VAL(cr) = LATCH_CLEAR;
cr->jnl_addr = 0;
cr->refer = FALSE;
assert(!cr->stopped);
}
}
}
|
