Commita1aeea6

committed

Fix bug in monotonic sequences support

1 parent700bab9 commita1aeea6Copy full SHA for a1aeea6

File tree

-5

lines changed

-5

lines changed

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1161,11 +1161,13 @@ void MtmExecutor(void* work, size_t size)`
`1161`	`1161`	`case'N':`
`1162`	`1162`	`{`
`1163`	`1163`	`int64next;`
	`1164`	`+Oidrelid;`
`1164`	`1165`	`Assert(rel!=NULL);`
`1165`		`-next=pq_getmsgint64(&s);`
`1166`		`-AdjustSequence(RelationGetRelid(rel),next);`
	`1166`	`+relid=RelationGetRelid(rel);`
`1167`	`1167`	`close_rel(rel);`
`1168`	`1168`	`rel=NULL;`
	`1169`	`+next=pq_getmsgint64(&s);`
	`1170`	`+AdjustSequence(relid,next);`
`1169`	`1171`	`break;`
`1170`	`1172`	`}`
`1171`	`1173`	`case'0':`

Lines changed: 0 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -861,9 +861,6 @@ void AdjustSequence(Oid relid, int64 next)`
`861`	`861`	`/* open and AccessShareLock sequence */`
`862`	`862`	`init_sequence(relid,&elm,&seqrel);`
`863`	`863`
`864`		`-/* lock page' buffer and read tuple */`
`865`		`-seq=read_seq_tuple(elm,seqrel,&buf,&seqtuple);`
`866`		`-`
`867`	`864`	`if (elm->last!=elm->cached&&elm->last+elm->increment>next)/* cached number is greater than received */`
`868`	`865`	`{`
`869`	`866`	`relation_close(seqrel,NoLock);`

Comments

(0)