Commitbfd72af

authored and

committed

Handle critical errors (not completed)

1 parent97a3e42 commitbfd72afCopy full SHA for bfd72af

File tree

+19

-0

lines changed

+19

-0

lines changed

Lines changed: 17 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1014,6 +1014,23 @@ void MtmAbortTransaction(MtmTransState* ts)`
`1014`	`1014`	`* -------------------------------------------`
`1015`	`1015`	`*/`
`1016`	`1016`
	`1017`	`+voidMtmHandleApplyError(void)`
	`1018`	`+{`
	`1019`	`+ErrorData*edata=CopyErrorData();`
	`1020`	`+switch (edata->sqlerrcode) {`
	`1021`	`+caseERRCODE_DISK_FULL:`
	`1022`	`+caseERRCODE_INSUFFICIENT_RESOURCES:`
	`1023`	`+caseERRCODE_IO_ERROR:`
	`1024`	`+caseERRCODE_DATA_CORRUPTED:`
	`1025`	`+caseERRCODE_INDEX_CORRUPTED:`
	`1026`	`+caseERRCODE_SYSTEM_ERROR:`
	`1027`	`+caseERRCODE_INTERNAL_ERROR:`
	`1028`	`+caseERRCODE_OUT_OF_MEMORY:`
	`1029`	`+break;`
	`1030`	`+}`
	`1031`	`+}`
	`1032`	`+`
	`1033`	`+`
`1017`	`1034`	`voidMtmRecoveryCompleted(void)`
`1018`	`1035`	`{`
`1019`	`1036`	`MTM_LOG1("Recovery of node %d is completed",MtmNodeId);`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -238,5 +238,6 @@ extern void MtmCheckQuorum(void);`
`238`	`238`	`externboolMtmRecoveryCaughtUp(intnodeId,XLogRecPtrslotLSN);`
`239`	`239`	`externvoidMtmRecoveryCompleted(void);`
`240`	`240`	`externvoidMtmMakeTableLocal(charschema,charname);`
	`241`	`+externvoidMtmHandleApplyError(void);`
`241`	`242`
`242`	`243`	`#endif`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -951,6 +951,7 @@ void MtmExecutor(int id, void* work, size_t size)`
`951`	`951`	`}`
`952`	`952`	`PG_CATCH();`
`953`	`953`	`{`
	`954`	`+MtmHandleApplyError();`
`954`	`955`	`EmitErrorReport();`
`955`	`956`	`FlushErrorState();`
`956`	`957`	`MTM_LOG2("%d: REMOTE begin abort transaction %d",MyProcPid,MtmGetCurrentTransactionId());`

Comments

(0)