Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 2200c60

Browse files
committed
disable temporary sequences before we port SeqNextvalHook to new pg
1 parent 9fa9dd2 commit 2200c60

File tree

2 files changed

+16
-16
lines changed

2 files changed

+16
-16
lines changed

multimaster.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -283,7 +283,7 @@ static ExecutorStart_hook_type PreviousExecutorStartHook;
283283
static ExecutorFinish_hook_type PreviousExecutorFinishHook;
284284
static ProcessUtility_hook_type PreviousProcessUtilityHook;
285285
static shmem_startup_hook_type PreviousShmemStartupHook;
286-
static seq_nextval_hook_t PreviousSeqNextvalHook;
286+
// static seq_nextval_hook_t PreviousSeqNextvalHook;
287287

288288
static void MtmExecutorStart(QueryDesc *queryDesc, int eflags);
289289
static void MtmExecutorFinish(QueryDesc *queryDesc);
@@ -3360,8 +3360,8 @@ _PG_init(void)
33603360
PreviousProcessUtilityHook = ProcessUtility_hook;
33613361
ProcessUtility_hook = MtmProcessUtility;
33623362

3363-
PreviousSeqNextvalHook = SeqNextvalHook;
3364-
SeqNextvalHook = MtmSeqNextvalHook;
3363+
// PreviousSeqNextvalHook = SeqNextvalHook;
3364+
// SeqNextvalHook = MtmSeqNextvalHook;
33653365
}
33663366

33673367
/*
@@ -3373,7 +3373,7 @@ _PG_fini(void)
33733373
shmem_startup_hook = PreviousShmemStartupHook;
33743374
ExecutorFinish_hook = PreviousExecutorFinishHook;
33753375
ProcessUtility_hook = PreviousProcessUtilityHook;
3376-
SeqNextvalHook = PreviousSeqNextvalHook;
3376+
// SeqNextvalHook = PreviousSeqNextvalHook;
33773377
}
33783378

33793379

pglogical_apply.c

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1172,18 +1172,18 @@ void MtmExecutor(void* work, size_t size)
11721172
s.len = save_len;
11731173
break;
11741174
}
1175-
case 'N':
1176-
{
1177-
int64 next;
1178-
Oid relid;
1179-
Assert(rel != NULL);
1180-
relid = RelationGetRelid(rel);
1181-
close_rel(rel);
1182-
rel = NULL;
1183-
next = pq_getmsgint64(&s);
1184-
AdjustSequence(relid, next);
1185-
break;
1186-
}
1175+
// case 'N':
1176+
// {
1177+
// int64 next;
1178+
// Oid relid;
1179+
// Assert(rel != NULL);
1180+
// relid = RelationGetRelid(rel);
1181+
// close_rel(rel);
1182+
// rel = NULL;
1183+
// next = pq_getmsgint64(&s);
1184+
// AdjustSequence(relid, next);
1185+
// break;
1186+
// }
11871187
case '0':
11881188
Assert(rel != NULL);
11891189
heap_truncate_one_rel(rel);

0 commit comments

Comments
 (0)