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
|
/****************************************************************
* *
* Copyright (c) 2006-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 "mdef.h"
#include "gdsroot.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_instance.h"
GBLREF jnlpool_addrs_ptr_t jnlpool;
GBLREF time_t gtmsource_last_flush_time;
GBLREF volatile time_t gtmsource_now;
GBLREF gtmsource_state_t gtmsource_state;
/* Flush the source server's current resync_seqno into the corresponding slot in the replication instance file header */
void gtmsource_flush_fh(seq_num resync_seqno)
{
sgmnt_addrs *repl_csa;
assert((NULL != jnlpool) && (NULL != jnlpool->jnlpool_dummy_reg) && jnlpool->jnlpool_dummy_reg->open);
# ifdef DEBUG
repl_csa = &FILE_INFO(jnlpool->jnlpool_dummy_reg)->s_addrs;
assert(!repl_csa->hold_onto_crit);
ASSERT_VALID_JNLPOOL(repl_csa);
# endif
jnlpool->gtmsource_local->read_jnl_seqno = resync_seqno;
gtmsource_last_flush_time = gtmsource_now;
if (jnlpool->gtmsource_local->last_flush_resync_seqno == resync_seqno)
return;
/* need to flush resync_seqno to instance file. Grab the journal pool lock before flushing */
grab_lock(jnlpool->jnlpool_dummy_reg, TRUE, HANDLE_CONCUR_ONLINE_ROLLBACK); /* sets gtmsource_state */
if (GTMSOURCE_HANDLE_ONLN_RLBK == gtmsource_state)
return;
repl_inst_flush_gtmsrc_lcl(); /* this requires the ftok semaphore to be held */
rel_lock(jnlpool->jnlpool_dummy_reg);
return;
}
|
