Handle critical errors (not completed)

Author: knizhnik

multimaster.c

@@ -1014,6 +1014,23 @@ void MtmAbortTransaction(MtmTransState* ts)
  * -------------------------------------------
  */
 
+void MtmHandleApplyError(void)
+{
+	ErrorData *edata = CopyErrorData();
+	switch (edata->sqlerrcode) { 
+	  case ERRCODE_DISK_FULL:
+	  case ERRCODE_INSUFFICIENT_RESOURCES:
+	  case ERRCODE_IO_ERROR:
+	  case ERRCODE_DATA_CORRUPTED:
+	  case ERRCODE_INDEX_CORRUPTED:
+	  case ERRCODE_SYSTEM_ERROR:
+	  case ERRCODE_INTERNAL_ERROR:
+	  case ERRCODE_OUT_OF_MEMORY:
+		break;
+	}
+}
+
+
 void MtmRecoveryCompleted(void)
 {
 	MTM_LOG1("Recovery of node %d is completed", MtmNodeId);

multimaster.h

@@ -238,5 +238,6 @@ extern void  MtmCheckQuorum(void);
 extern bool  MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN);
 extern void  MtmRecoveryCompleted(void);
 extern void  MtmMakeTableLocal(char* schema, char* name);
+extern void  MtmHandleApplyError(void);
 
 #endif

pglogical_apply.c

@@ -951,6 +951,7 @@ void MtmExecutor(int id, void* work, size_t size)
     }
     PG_CATCH();
     {
+		MtmHandleApplyError();
 		EmitErrorReport();
         FlushErrorState();
 		MTM_LOG2("%d: REMOTE begin abort transaction %d", MyProcPid, MtmGetCurrentTransactionId());