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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
/****************************************************************
* *
* Copyright (c) 2006-2023 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 "gtm_unistd.h" /* for close() */
#include "gtm_ipc.h"
#include <sys/shm.h>
#include <sys/sem.h>
#include <errno.h>
#include "gtm_inet.h"
#include "gtm_string.h"
#include "gdsroot.h"
#include "gdsblk.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "filestruct.h"
#include "repl_msg.h"
#include "gtmsource.h"
#include "repl_dbg.h"
#include "gtm_stdio.h"
#include "repl_shutdcode.h"
#include "eintr_wrappers.h"
#include "jnl.h"
#include "jnlbufs.h"
#include "repl_filter.h"
#include "repl_sem.h"
#include "mutex.h"
#include "repl_log.h"
#include "repl_comm.h"
#include "have_crit.h"
#include "anticipatory_freeze.h"
#ifdef GTM_TLS
#include "gtm_repl.h"
#endif
GBLREF jnlpool_addrs_ptr_t jnlpool;
GBLREF uint4 process_id;
GBLREF int gtmsource_sock_fd;
GBLREF int gtmsource_log_fd;
GBLREF FILE *gtmsource_log_fp;
GBLREF int gtmsource_filter;
GBLREF boolean_t gtmsource_logstats;
GBLREF int gtmsource_statslog_fd;
GBLREF FILE *gtmsource_statslog_fp;
GBLREF unsigned char *gtmsource_tcombuff_start;
GBLREF qw_num repl_source_cmp_sent;
GBLREF qw_num repl_source_data_sent;
GBLREF qw_num repl_source_msg_sent;
GBLREF seq_num seq_num_zero;
GBLREF repl_msg_ptr_t gtmsource_msgp;
GBLREF uchar_ptr_t repl_filter_buff;
GBLREF int pool_init;
int gtmsource_end1(boolean_t auto_shutdown)
{
int exit_status, idx, status, save_errno;
seq_num read_jnl_seqno, jnlpool_seqno, diff_seqno, jnlpool_strm_seqno[MAX_SUPPL_STRMS];
int fclose_res;
sgmnt_addrs *repl_csa;
DCL_THREADGBL_ACCESS;
SETUP_THREADGBL_ACCESS;
gtmsource_ctl_close();
DEBUG_ONLY(repl_csa = &FILE_INFO(jnlpool->jnlpool_dummy_reg)->s_addrs;)
assert(!repl_csa->hold_onto_crit); /* so it is ok to invoke and "rel_lock" unconditionally */
rel_lock(jnlpool->jnlpool_dummy_reg);
mutex_cleanup(jnlpool->jnlpool_dummy_reg);
exit_status = NORMAL_SHUTDOWN;
if (!auto_shutdown)
jnlpool->gtmsource_local->shutdown = NORMAL_SHUTDOWN;
read_jnl_seqno = jnlpool->gtmsource_local->read_jnl_seqno;
jnlpool_seqno = jnlpool->jnlpool_ctl->jnl_seqno;
for (idx = 0; idx < MAX_SUPPL_STRMS; idx++)
jnlpool_strm_seqno[idx] = jnlpool->jnlpool_ctl->strm_seqno[idx];
assert(process_id == jnlpool->gtmsource_local->gtmsource_pid);
UNSET_SRC_NEEDS_JPLWRITES(jnlpool, jnlpool->gtmsource_local);
jnlpool->gtmsource_local->gtmsource_pid = 0;
jnlpool->gtmsource_local->gtmsource_state = GTMSOURCE_DUMMY_STATE;
/* Detach from journal pool, except if IFOE is configured, in which case we need the journal pool attached
* so that we can check for instance freeze in database rundown, or if auto_shutdown is set.
* In those cases, the detach will happen automatically when the process terminates.
*/
if (!auto_shutdown && !INST_FREEZE_ON_ERROR_POLICY)
{
JNLPOOL_SHMDT(jnlpool, status, save_errno);
if (0 > status)
repl_log(gtmsource_log_fp, FALSE, TRUE, "Error detaching from journal pool : %s\n", STRERROR(save_errno));
}
gtmsource_free_msgbuff();
gtmsource_free_tcombuff();
gtmsource_free_filter_buff();
gtmsource_stop_heartbeat();
repl_close(>msource_sock_fd);
# ifdef GTM_TLS
/* Free up the SSL/TLS socket structures. */
if (NULL != repl_tls.sock)
gtm_tls_session_close(&repl_tls.sock);
assert(NULL == repl_tls.sock);
/* Free up the SSL/TLS context now that we are shutting down. */
if (NULL != tls_ctx)
gtm_tls_fini(&tls_ctx);
assert(NULL == tls_ctx);
# endif
if (jnlpool_seqno)
{
repl_log(gtmsource_log_fp, TRUE, FALSE, "REPL INFO - Current Jnlpool Seqno : %llu\n", jnlpool_seqno);
for (idx = 0; idx < MAX_SUPPL_STRMS; idx++)
{
if (jnlpool_strm_seqno[idx])
repl_log(gtmsource_log_fp, TRUE, FALSE, "REPL INFO - Stream # %d : Current Jnlpool Stream Seqno "
": %llu\n", idx, jnlpool_strm_seqno[idx]);
}
jnlpool_seqno--;
}
if (read_jnl_seqno)
read_jnl_seqno--;
diff_seqno = jnlpool_seqno - read_jnl_seqno;
repl_log(gtmsource_log_fp, TRUE, FALSE, "REPL INFO - Last Seqno written in jnlpool : %llu", jnlpool_seqno);
repl_log(gtmsource_log_fp, FALSE, FALSE, " Last Seqno sent : %llu", read_jnl_seqno);
repl_log(gtmsource_log_fp, FALSE, TRUE, " Number of unsent Seqno : %llu\n", 0 < diff_seqno ? diff_seqno : 0);
repl_log(gtmsource_log_fp, TRUE, TRUE, "REPL INFO - Jnl Total : %llu Msg Total : %llu CmpMsg Total : %llu\n",
repl_source_data_sent, repl_source_msg_sent, repl_source_cmp_sent);
if (gtmsource_filter & EXTERNAL_FILTER)
repl_stop_filter();
if (auto_shutdown)
return (exit_status);
else
gtmsource_exit(exit_status - NORMAL_SHUTDOWN);
return -1; /* This will never get executed, added to make compiler happy */
}
void gtmsource_end(void)
{
gtmsource_end1(FALSE);
}
|
