Commit8937e40

committed

fix handling of implicit temp tables (pg_temp schema)

1 parent0e22c9b commit8937e40Copy full SHA for 8937e40

File tree

1 file changed

+15

-13

lines changed

contrib/mmts
- multimaster.c

1 file changed

+15

-13

lines changed

`‎contrib/mmts/multimaster.c`

Lines changed: 15 additions & 13 deletions

Original file line number	Diff line number	Diff line change
`@@ -1140,18 +1140,19 @@ void MtmHandleApplyError(void)`
`1140`	`1140`	`{`
`1141`	`1141`	`ErrorData*edata=CopyErrorData();`
`1142`	`1142`	`switch (edata->sqlerrcode) {`
`1143`		`-caseERRCODE_DISK_FULL:`
`1144`		`-caseERRCODE_INSUFFICIENT_RESOURCES:`
`1145`		`-caseERRCODE_IO_ERROR:`
`1146`		`-caseERRCODE_DATA_CORRUPTED:`
`1147`		`-caseERRCODE_INDEX_CORRUPTED:`
`1148`		`-caseERRCODE_SYSTEM_ERROR:`
`1149`		`-caseERRCODE_INTERNAL_ERROR:`
`1150`		`-caseERRCODE_OUT_OF_MEMORY:`
`1151`		`-elog(WARNING,"Node is excluded from cluster because of non-recoverable error %d",edata->sqlerrcode);`
`1152`		`-MtmSwitchClusterMode(MTM_OUT_OF_SERVICE);`
`1153`		`-kill(PostmasterPid,SIGQUIT);`
`1154`		`-break;`
	`1143`	`+caseERRCODE_DISK_FULL:`
	`1144`	`+caseERRCODE_INSUFFICIENT_RESOURCES:`
	`1145`	`+caseERRCODE_IO_ERROR:`
	`1146`	`+caseERRCODE_DATA_CORRUPTED:`
	`1147`	`+caseERRCODE_INDEX_CORRUPTED:`
	`1148`	`+caseERRCODE_SYSTEM_ERROR:`
	`1149`	`+caseERRCODE_INTERNAL_ERROR:`
	`1150`	`+caseERRCODE_OUT_OF_MEMORY:`
	`1151`	`+elog(WARNING,"Node is excluded from cluster because of non-recoverable error %d, %s, pid=%u",`
	`1152`	`+edata->sqlerrcode,edata->message,getpid());`
	`1153`	`+MtmSwitchClusterMode(MTM_OUT_OF_SERVICE);`
	`1154`	`+kill(PostmasterPid,SIGQUIT);`
	`1155`	`+break;`
`1155`	`1156`	`}`
`1156`	`1157`	`FreeErrorData(edata);`
`1157`	`1158`	`}`
`@@ -3164,7 +3165,8 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`3164`	`3165`	`{`
`3165`	`3166`	`/* Do not replicate temp tables */`
`3166`	`3167`	`CreateStmtstmt= (CreateStmt)parsetree;`
`3167`		`-skipCommand=stmt->relation->relpersistence==RELPERSISTENCE_TEMP;`
	`3168`	`+skipCommand=stmt->relation->relpersistence==RELPERSISTENCE_TEMP\|\|`
	`3169`	`+(stmt->relation->schemaname&&strcmp(stmt->relation->schemaname,"pg_temp")==0);`
`3168`	`3170`	`}`
`3169`	`3171`	`break;`
`3170`	`3172`	`caseT_IndexStmt:`

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!

Commit8937e40

File tree

1 file changed

1 file changed

`‎contrib/mmts/multimaster.c`

0 commit comments