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
|
/****************************************************************
* *
* Copyright (c) 2001-2017 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 "gtm_unistd.h"
#include "gtm_fcntl.h"
#include "gtm_inet.h"
#ifdef UNIX
#include "gtm_ipc.h"
#include <sys/sem.h>
#elif defined(VMS)
#include <ssdef.h>
#include <descrip.h> /* Required for gtmrecv.h */
#endif
#include "gdsroot.h"
#include "gdsblk.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "filestruct.h"
#include "iosp.h"
#include "repl_shutdcode.h"
#include "repl_msg.h"
#include "gtmsource.h"
#include "error.h"
#include "dpgbldir.h"
#ifdef UNIX
#include "ftok_sems.h"
#endif
GBLREF jnlpool_addrs_ptr_t jnlpool;
GBLREF boolean_t is_src_server;
GBLREF gtmsource_options_t gtmsource_options;
error_def(ERR_ASSERT);
error_def(ERR_CTRLC);
error_def(ERR_FORCEDHALT);
error_def(ERR_GTMASSERT);
error_def(ERR_GTMASSERT2);
error_def(ERR_GTMCHECK);
error_def(ERR_OUTOFSPACE);
error_def(ERR_REPLSRCEXITERR);
error_def(ERR_STACKOFLOW);
error_def(ERR_MEMORY);
error_def(ERR_VMSMEMORY);
CONDITION_HANDLER(gtmsource_ch)
{
gd_addr *addr_ptr;
gd_region *reg_local, *reg_top;
sgmnt_addrs *csa;
START_CH(TRUE);
if (!(IS_GTM_ERROR(SIGNAL)) || DUMPABLE || SEVERITY == ERROR)
{
for (addr_ptr = get_next_gdr(NULL); addr_ptr; addr_ptr = get_next_gdr(addr_ptr))
{
for (reg_local = addr_ptr->regions, reg_top = reg_local + addr_ptr->n_regions;
reg_local < reg_top; reg_local++)
{
if (reg_local->open && !reg_local->was_open)
{
csa = (sgmnt_addrs *)&FILE_INFO(reg_local)->s_addrs;
if (csa && (csa->now_crit))
rel_crit(reg_local);
}
}
}
if ((NULL != jnlpool) && (jnlpool->jnlpool_ctl))
{
csa = (sgmnt_addrs *)&FILE_INFO(jnlpool->jnlpool_dummy_reg)->s_addrs;
if (csa && csa->now_crit)
rel_lock(jnlpool->jnlpool_dummy_reg);
}
if (is_src_server)
send_msg_csa(CSA_ARG(NULL) VARLSTCNT(4) ERR_REPLSRCEXITERR, 2, gtmsource_options.secondary_instname,
gtmsource_options.log_file);
NEXTCH;
}
VMS_ONLY (
/* warning, info, or success */
CONTINUE;
)
assertpro(FALSE);
}
|
