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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/****************************************************************
* *
* Copyright 2005 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"
#ifdef UNIX
#include "gtm_ipc.h"
#include <sys/sem.h>
#include <sys/shm.h>
#include <sys/un.h>
#ifndef __MVS__
#include <sys/param.h>
#endif
#elif defined(VMS)
#include <psldef.h>
#include <descrip.h> /* Required for gtmrecv.h */
#include <ssdef.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 "gtmrecv.h"
#include "read_db_files_from_gld.h"
#include "updproc.h"
#include "mupip_exit.h"
#include "gtm_event_log.h"
#include "repl_log.h"
#ifdef VMS
#include "repl_shm.h"
#include "repl_sem.h"
#endif
GBLREF void (*call_on_signal)();
GBLREF recvpool_addrs recvpool;
GBLREF upd_helper_entry_ptr_t helper_entry;
GBLREF int4 forced_exit_err;
GBLREF int4 exi_condition;
static void updhelper_common_cleanup(boolean_t exit)
{ /* common cleanup actions for reader and writer */
upd_helper_ctl_ptr_t upd_helper_ctl;
uint4 status;
error_def(ERR_FORCEDHALT);
upd_helper_ctl = recvpool.upd_helper_ctl;
if (NULL != helper_entry)
{
if (exit || ERR_FORCEDHALT == UNIX_ONLY(forced_exit_err) VMS_ONLY(exi_condition))
{ /* Let the receiver know this was a clean shutdown and the slot is available for re-use. Checkhealth will not
* report NOT alive for this type of shutdown */
helper_entry->helper_shutdown = NORMAL_SHUTDOWN;
} else
{ /* Abnormal termination. Slot is available for re-use. However, checkhealth will report NOT alive status
* until a new helper takes up this slot or forcefully cleared by a subsequent start -helpers command */
helper_entry->helper_shutdown = ABNORMAL_SHUTDOWN;
}
helper_entry->helper_pid = 0; /* vacate my slot */
if (!exit) /* terminating due to a signal */
{
assert(NULL != upd_helper_ctl);
upd_helper_ctl->reap_helpers = HELPER_REAP_NOWAIT; /* let the receiver know it should reap my slot */
}
}
#ifdef UNIX
SHMDT(recvpool.recvpool_ctl);
#elif defined(VMS)
if(SS_NORMAL != (status = detach_shm(recvpool.shm_range)))
repl_log(stderr, TRUE, TRUE, "Update helper could not detach from recvpool : %s\n", REPL_STR_ERROR);
if (SS_NORMAL != (status = signoff_from_gsec(recvpool.shm_lockid)))
repl_log(stderr, TRUE, TRUE, "Error dequeueing lock on recvpool global section : %s\n", REPL_STR_ERROR);
#else
#error Unsupported Platform
#endif
recvpool.recvpool_ctl = NULL;
helper_entry = NULL;
gtm_event_log_close();
return;
}
static void updhelper_reader_stop(boolean_t exit)
{
call_on_signal = NULL; /* do not re-enter on error */
updhelper_common_cleanup(exit);
if (exit)
mupip_exit(SS_NORMAL);
return;
}
static void updhelper_writer_stop(boolean_t exit)
{
call_on_signal = NULL; /* do not re-enter on error */
updhelper_common_cleanup(exit);
if (exit)
mupip_exit(SS_NORMAL);
return;
}
void updhelper_reader_sigstop(void)
{ /* reader termination due to a signal */
updhelper_reader_stop(FALSE);
return;
}
void updhelper_reader_end(void)
{ /* reader shutdown */
updhelper_reader_stop(TRUE);
return;
}
void updhelper_writer_sigstop(void)
{ /* writer termination due to a signal */
updhelper_writer_stop(FALSE);
return;
}
void updhelper_writer_end(void)
{ /* writer shutdown */
updhelper_writer_stop(TRUE);
return;
}
|
