Commit52d3545

knizhnik

authored and

kelvich

committed

Check for in progress before setting HEAP_XMIN_INVALID hint

1 parent5ced064 commit52d3545Copy full SHA for 52d3545

File tree

2 files changed

+12

-12

lines changed

2 files changed

+12

-12

lines changed

`‎pglogical_proto.c`

Lines changed: 11 additions & 11 deletions

Original file line number	Diff line number	Diff line change
`@@ -77,12 +77,12 @@ pglogical_write_rel(StringInfo out, PGLogicalOutputData *data, Relation rel)`
`77`	`77`	`Oidrelid;`
`78`	`78`
`79`	`79`	`if (MtmTransactionSnapshot(MtmCurrentXid)==INVALID_CSN) {`
`80`		`-MTM_LOG1("%d: pglogical_write_message filtered",MyProcPid);`
	`80`	`+MTM_LOG2("%d: pglogical_write_message filtered",MyProcPid);`
`81`	`81`	`return;`
`82`	`82`	`}`
`83`	`83`
`84`	`84`	`if (DDLInProress) {`
`85`		`-MTM_LOG1("%d: pglogical_write_message filtered DDLInProress",MyProcPid);`
	`85`	`+MTM_LOG2("%d: pglogical_write_message filtered DDLInProress",MyProcPid);`
`86`	`86`	`return;`
`87`	`87`	`}`
`88`	`88`
`@@ -141,7 +141,7 @@ pglogical_write_message(StringInfo out,`
`141`	`141`	`{`
`142`	`142`	`if (MtmTransactionSnapshot(MtmCurrentXid)==INVALID_CSN)`
`143`	`143`	`{`
`144`		`-MTM_LOG1("%d: pglogical_write_message filtered",MyProcPid);`
	`144`	`+MTM_LOG2("%d: pglogical_write_message filtered",MyProcPid);`
`145`	`145`	`return;`
`146`	`146`	`}`
`147`	`147`	`DDLInProress= true;`
`@@ -263,12 +263,12 @@ pglogical_write_insert(StringInfo out, PGLogicalOutputData *data,`
`263`	`263`	`Relationrel,HeapTuplenewtuple)`
`264`	`264`	`{`
`265`	`265`	`if (MtmTransactionSnapshot(MtmCurrentXid)==INVALID_CSN){`
`266`		`-MTM_LOG1("%d: pglogical_write_insert filtered",MyProcPid);`
	`266`	`+MTM_LOG2("%d: pglogical_write_insert filtered",MyProcPid);`
`267`	`267`	`return;`
`268`	`268`	`}`
`269`	`269`
`270`	`270`	`if (DDLInProress) {`
`271`		`-MTM_LOG1("%d: pglogical_write_insert filtered DDLInProress",MyProcPid);`
	`271`	`+MTM_LOG2("%d: pglogical_write_insert filtered DDLInProress",MyProcPid);`
`272`	`272`	`return;`
`273`	`273`	`}`
`274`	`274`
`@@ -286,12 +286,12 @@ pglogical_write_update(StringInfo out, PGLogicalOutputData *data,`
`286`	`286`	`Relationrel,HeapTupleoldtuple,HeapTuplenewtuple)`
`287`	`287`	`{`
`288`	`288`	`if (MtmTransactionSnapshot(MtmCurrentXid)==INVALID_CSN){`
`289`		`-MTM_LOG1("%d: pglogical_write_update filtered",MyProcPid);`
	`289`	`+MTM_LOG2("%d: pglogical_write_update filtered",MyProcPid);`
`290`	`290`	`return;`
`291`	`291`	`}`
`292`	`292`
`293`	`293`	`if (DDLInProress) {`
`294`		`-MTM_LOG1("%d: pglogical_write_update filtered DDLInProress",MyProcPid);`
	`294`	`+MTM_LOG2("%d: pglogical_write_update filtered DDLInProress",MyProcPid);`
`295`	`295`	`return;`
`296`	`296`	`}`
`297`	`297`
`@@ -319,12 +319,12 @@ pglogical_write_delete(StringInfo out, PGLogicalOutputData *data,`
`319`	`319`	`Relationrel,HeapTupleoldtuple)`
`320`	`320`	`{`
`321`	`321`	`if (MtmTransactionSnapshot(MtmCurrentXid)==INVALID_CSN){`
`322`		`-MTM_LOG1("%d: pglogical_write_delete filtered",MyProcPid);`
	`322`	`+MTM_LOG2("%d: pglogical_write_delete filtered",MyProcPid);`
`323`	`323`	`return;`
`324`	`324`	`}`
`325`	`325`
`326`	`326`	`if (DDLInProress) {`
`327`		`-MTM_LOG1("%d: pglogical_write_delete filtered DDLInProress",MyProcPid);`
	`327`	`+MTM_LOG2("%d: pglogical_write_delete filtered DDLInProress",MyProcPid);`
`328`	`328`	`return;`
`329`	`329`	`}`
`330`	`330`
`@@ -356,12 +356,12 @@ pglogical_write_tuple(StringInfo out, PGLogicalOutputData *data,`
`356`	`356`	`uint16nliveatts=0;`
`357`	`357`
`358`	`358`	`if (MtmTransactionSnapshot(MtmCurrentXid)==INVALID_CSN){`
`359`		`-MTM_LOG1("%d: pglogical_write_tuple filtered",MyProcPid);`
	`359`	`+MTM_LOG2("%d: pglogical_write_tuple filtered",MyProcPid);`
`360`	`360`	`return;`
`361`	`361`	`}`
`362`	`362`
`363`	`363`	`if (DDLInProress) {`
`364`		`-MTM_LOG1("%d: pglogical_write_tuple filtered DDLInProress",MyProcPid);`
	`364`	`+MTM_LOG2("%d: pglogical_write_tuple filtered DDLInProress",MyProcPid);`
`365`	`365`	`return;`
`366`	`366`	`}`
`367`	`367`

`‎pglogical_receiver.c`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -524,7 +524,7 @@ pglogical_receiver_main(Datum main_arg)`
`524`	`524`	`MtmSpillToFile(spill_file,buf.data,buf.used);`
`525`	`525`	`ByteBufferReset(&buf);`
`526`	`526`	`}`
`527`		`-if (stmt[0]=='M'&&stmt[1]=='L') {`
	`527`	`+if (stmt[0]=='M'&&stmt[1]=='L') {`
`528`	`528`	`MTM_LOG3("Process deadlock message from %d",nodeId);`
`529`	`529`	`MtmExecutor(stmt,rc-hdr_len);`
`530`	`530`	`}else {`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit52d3545

File tree

2 files changed

2 files changed

`‎pglogical_proto.c`

`‎pglogical_receiver.c`

0 commit comments