database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

commit for keep_sync_window

Browse Source
This commit is contained in:
mry
2021-12-01 15:25:31 +08:00
committed by xue_meng_en
parent a25b1e1b62
commit e40c175b52
7 changed files with 59 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/bin/gs_guc/cluster_guc.conf
View File

@ -645,6 +645,7 @@ default_index_kind|int|0,2|NULL|NULL|
undo_zone_count|int|0,1048576|NULL|NULL|
enable_auto_clean_unique_sql|bool|0,0|NULL|NULL|
max_logical_replication_workers|int|0,262143|NULL|Maximum number of logical replication worker processes.|
keep_sync_window|int|0,2147483647|s|NULL|
[cmserver]
log_dir|string|0,0|NULL|NULL|
log_file_size|int|0,2047|MB|NULL|

11
src/bin/gs_guc/pg_guc.cpp
View File

@ -1188,6 +1188,16 @@ static void CheckLastValidReplconninfo(char** opt_lines, int idx)
"the host role will be changed to Normal if the local_role is primary now.\n");
}
}
static void CheckKeepSyncWindow(char** opt_lines, int idx)
{
/* Give a warning if keep_sync_window is set */
if (strcmp(config_param[idx], "keep_sync_window") == 0) {
write_stderr("\nWARNING: If the primary server fails during keep_sync_window, the transactions which "
"were blocked during keep_sync_window will be lost and can't get recovered. This will affect RPO.\n");
}
}
#endif
/*
@ -1285,6 +1295,7 @@ do_gucset(const char *action_type, const char *data_dir)
#ifndef ENABLE_MULTIPLE_NODES
CheckLastValidReplconninfo(opt_lines, i);
CheckKeepSyncWindow(opt_lines, i);
#endif
/* find the line where guc parameter in */

14
src/common/backend/utils/misc/guc/guc_storage.cpp
View File

@ -2876,6 +2876,20 @@ static void InitStorageConfigureNamesInt()
NULL,
NULL,
NULL},
{{"keep_sync_window",
PGC_SIGHUP,
NODE_SINGLENODE,
REPLICATION_MASTER,
gettext_noop("The length of keep sync window."),
NULL,
GUC_UNIT_S},
&u_sess->attr.attr_storage.keep_sync_window,
0,
0,
INT_MAX,
NULL,
NULL,
NULL},
{{"max_concurrent_autonomous_transactions",
PGC_POSTMASTER,
NODE_ALL,

33
src/gausskernel/storage/replication/syncrep.cpp
View File

@ -155,6 +155,9 @@ void SyncRepWaitForLSN(XLogRecPtr XactCommitLSN, bool enableHandleCancel)
char *new_status = NULL;
const char *old_status = NULL;
int mode = u_sess->attr.attr_storage.sync_rep_wait_mode;
TimestampTz now_time;
TimestampTz now_time_dynamical;
bool sync_master_standalone_window = false;
/*
* Fast exit if user has not requested sync replication, or there are no
@ -182,9 +185,21 @@ void SyncRepWaitForLSN(XLogRecPtr XactCommitLSN, bool enableHandleCancel)
* condition but we'll be fetching that cache line anyway so its likely to
* be a low cost check. We don't wait for sync rep if no sync standbys alive
*/
now_time = GetCurrentTimestamp();
long diff_sec;
int diff_microsec;
if (t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone) {
TimestampDifference(t_thrd.walsender_cxt.WalSndCtl->last_sync_master_standalone_time, now_time, &diff_sec,
&diff_microsec);
if(diff_sec >= (long)u_sess->attr.attr_storage.keep_sync_window) {
sync_master_standalone_window = true;
}
}
if (!t_thrd.walsender_cxt.WalSndCtl->sync_standbys_defined ||
XLByteLE(XactCommitLSN, t_thrd.walsender_cxt.WalSndCtl->lsn[mode]) ||
t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone ||
sync_master_standalone_window ||
!SynRepWaitCatchup(XactCommitLSN)) {
LWLockRelease(SyncRepLock);
RESUME_INTERRUPTS();
@ -312,8 +327,17 @@ void SyncRepWaitForLSN(XLogRecPtr XactCommitLSN, bool enableHandleCancel)
/*
* If we modify the syncmode dynamically, we'll stop wait
*/
if (t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone ||
synchronous_commit <= SYNCHRONOUS_COMMIT_LOCAL_FLUSH) {
now_time_dynamical = GetCurrentTimestamp();
long diff_sec_dynamical;
int diff_microsec_dynamical;
if (t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone) {
TimestampDifference(t_thrd.walsender_cxt.WalSndCtl->last_sync_master_standalone_time, now_time_dynamical,
&diff_sec_dynamical, &diff_microsec_dynamical);
}
if (sync_master_standalone_window ||
synchronous_commit <= SYNCHRONOUS_COMMIT_LOCAL_FLUSH ||
(t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone &&
diff_sec_dynamical >= (long)u_sess->attr.attr_storage.keep_sync_window)) {
ereport(WARNING,
(errmsg("canceling wait for synchronous replication due to syncmaster standalone."),
errdetail("The transaction has already committed locally, but might not have been replicated to "
@ -1364,10 +1388,11 @@ void SyncRepCheckSyncStandbyAlive(void)
if (!sync_standby_alive && !t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone &&
t_thrd.walsender_cxt.WalSndCtl->most_available_sync) {
ereport(LOG, (errmsg("synchronous master is now standalone")));
t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone = true;
t_thrd.walsender_cxt.WalSndCtl->last_sync_master_standalone_time = GetCurrentTimestamp();
/*
* If there is any waiting sender, then wake-up them as
* master has switched to standalone mode

1
src/gausskernel/storage/replication/walsender.cpp
View File

@ -4349,6 +4349,7 @@ void WalSndShmemInit(void)
}
t_thrd.walsender_cxt.WalSndCtl->most_available_sync = false;
t_thrd.walsender_cxt.WalSndCtl->sync_master_standalone = false;
t_thrd.walsender_cxt.WalSndCtl->last_sync_master_standalone_time = 0;
t_thrd.walsender_cxt.WalSndCtl->demotion = NoDemote;
SpinLockInit(&t_thrd.walsender_cxt.WalSndCtl->mutex);
}

1
src/include/knl/knl_guc/knl_session_attr_storage.h
View File

@ -91,6 +91,7 @@ typedef struct knl_session_attr_storage {
bool auto_explain_log_verbose;
bool enable_candidate_buf_usage_count;
bool enable_ustore_partial_seqscan;
int keep_sync_window;
int wait_dummy_time;
int DeadlockTimeout;
int LockWaitTimeout;

3
src/include/replication/walsender_private.h
View File

@ -181,7 +181,8 @@ typedef struct WalSndCtlData {
* mode.
*/
bool sync_master_standalone;
TimestampTz last_sync_master_standalone_time;
/*
* The demotion of postmaster Also indicates that all the walsenders
* should reject any demote requests if postmaster is doning domotion.