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
|
/****************************************************************
* *
* Copyright (c) 2018 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 <sys/shm.h>
#include "mdef.h"
#include "mlkdef.h"
#include "gdsroot.h"
#include "gdsblk.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "filestruct.h"
#include "cmidef.h" /* for cmmdef.h */
#include "hashtab_mname.h" /* needed for cmmdef.h */
#include "cmmdef.h" /* for gtcmtr_protos.h */
#include "util.h"
#include "lke.h"
#include "lke_getcli.h"
#include "mlk_shrhash_resize.h"
#include "interlock.h"
#include "sleep.h"
#include "min_max.h"
#include "gtmmsg.h"
#include "do_shmat.h"
#include "mlk_ops.h"
GBLREF gd_addr *gd_header;
error_def(ERR_NOREGION);
void lke_growhash(void)
{
/* Arguments for lke_getcli */
bool locks, all = TRUE, wait = TRUE, interactive = FALSE, match = FALSE, memory = TRUE, nocrit = TRUE;
boolean_t exact = TRUE, resize_status;
int4 pid;
mstr regname, node, one_lock;
char regbuf[MAX_RN_LEN], nodebuf[32], one_lockbuf[MAX_KEY_SZ];
gd_region *reg;
int regidx;
boolean_t was_crit;
mlk_pvtctl pctl;
DCL_THREADGBL_ACCESS;
SETUP_THREADGBL_ACCESS;
regname.addr = regbuf;
regname.len = SIZEOF(regbuf);
node.addr = nodebuf;
node.len = SIZEOF(nodebuf);
one_lock.addr = one_lockbuf;
one_lock.len = SIZEOF(one_lockbuf);
if (lke_getcli(&all, &wait, &interactive, &pid, ®name, &node, &one_lock, &memory, &nocrit, &exact,
NULL, NULL) == 0)
return;
for (reg = gd_header->regions, regidx = 0; regidx != gd_header->n_regions; ++reg, ++regidx)
{
/* If region matches and is open */
if (((0 == regname.len)
|| ((reg->rname_len == regname.len) && !memcmp(reg->rname, regname.addr, regname.len)))
&& reg->open)
{
assert(IS_REG_BG_OR_MM(reg));
if (IS_STATSDB_REGNAME(reg))
continue;
match = TRUE;
/* Construct a dummy pctl to pass in */
MLK_PVTCTL_INIT(pctl, reg);
GRAB_LOCK_CRIT_AND_SYNC(pctl, was_crit);
resize_status = mlk_shrhash_resize(&pctl);
REL_LOCK_CRIT(pctl, was_crit);
util_out_print("Resize of lock hash memory !AZ for region !AD", TRUE,
(resize_status ? "succeeded" : "FAILED"), REG_LEN_STR(reg));
}
}
if (!match && (0 != regname.len))
rts_error_csa(NULL, VARLSTCNT(4) ERR_NOREGION, 2, regname.len, regname.addr);
}
|
