NotificationsYou must be signed in to change notification settings
Fork28
Star151

Commit524366f

committed

fix handling of implicit temp tables (pg_temp schema)

1 parent8f73f80 commit524366fCopy full SHA for 524366f

File tree

1 file changed

+15

-13

lines changed

multimaster.c

1 file changed

+15

-13

lines changed

`‎multimaster.c`

Lines changed: 15 additions & 13 deletions

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

Commit524366f

File tree

1 file changed

1 file changed

`‎multimaster.c`

0 commit comments