replicate grant stmt

kelvich · kelvich · commit 6681d70c8f69 · 2016-04-08T11:30:34.000+03:00
diff --git a/contrib/mmts/multimaster.c b/contrib/mmts/multimaster.c
@@ -2245,6 +2245,7 @@ static void MtmBroadcastUtilityStmt(char const* sql, bool ignoreError)
 			if (MtmGUCBufferAllocated && !MtmRunUtilityStmt(conns[i], MtmGUCBuffer->data, &utility_errmsg) && !ignoreError)
 			{
 				errorMsg = "Failed to set GUC variables at node %d";
+				elog(ERROR, utility_errmsg);
 				failedNode = i;
 				break;
 			}
@@ -2431,7 +2432,7 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 		case T_PrepareStmt:
 		case T_ExecuteStmt:
 		case T_DeallocateStmt:
-		case T_GrantStmt: /* XXX: we could replicate some of these these */;
+		//case T_GrantStmt: /* XXX: we could replicate some of these these */;
 		//case T_GrantRoleStmt:
 		//case T_AlterDatabaseStmt:
 		//case T_AlterDatabaseSetStmt:
@@ -2442,7 +2443,7 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 		case T_ClusterStmt: /* XXX: we could replicate these */;
 		case T_VacuumStmt:
 		case T_ExplainStmt:
-		case T_AlterSystemStmt:
+		//case T_AlterSystemStmt:
 		case T_VariableShowStmt:
 		case T_DiscardStmt:
 		//case T_CreateEventTrigStmt:
@@ -2460,7 +2461,13 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 			break;
 		case T_VariableSetStmt:
 			{
-				//VariableSetStmt *stmt = (VariableSetStmt *) parsetree;
+				VariableSetStmt *stmt = (VariableSetStmt *) parsetree;
+
+				skipCommand = true;
+
+				/* Prevent SET TRANSACTION from replication */
+				if (MtmTx.isTransactionBlock || stmt->kind == VAR_SET_MULTI)
+					break;
 
 				if (!MtmGUCBufferAllocated)
 				{
@@ -2479,8 +2486,6 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 				//appendStringInfoString(MtmGUCBuffer, "; ");
 
 				appendStringInfoString(MtmGUCBuffer, queryString);
-
-				skipCommand = true;
 			}
 			break;
 		case T_CreateStmt:
@@ -2507,7 +2512,7 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 				{
 					rel = heap_open(relid, ShareLock);
 					skipCommand = rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP;
-					heap_close(rel, NoLock);
+					heap_close(rel, ShareLock);
 				}
 			}
 			break;
