Commit4696afa

committed

2 parents463c1bc +8652d7c commit4696afaCopy full SHA for 4696afa

File tree

+21

-3

lines changed

+21

-3

lines changed

Lines changed: 21 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -2247,9 +2247,10 @@ static void MtmBroadcastUtilityStmt(char const* sql, bool ignoreError)`
`2247`	`2247`	`}`
`2248`	`2248`	`if (!MtmRunUtilityStmt(conns[i],sql,&utility_errmsg)&& !ignoreError)`
`2249`	`2249`	`{`
`2250`		`-// errorMsg = "Failed to run command at node %d";`
`2251`		`-// XXX: add check for our node`
`2252`		`-errorMsg=utility_errmsg;`
	`2250`	`+if (i+1==MtmNodeId)`
	`2251`	`+errorMsg=utility_errmsg;`
	`2252`	`+else`
	`2253`	`+errorMsg="Failed to run command at node %d";`
`2253`	`2254`
`2254`	`2255`	`failedNode=i;`
`2255`	`2256`	`break;`
`@@ -2454,6 +2455,23 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2454`	`2455`	`skipCommand=stmt->relation->relpersistence==RELPERSISTENCE_TEMP;`
`2455`	`2456`	`}`
`2456`	`2457`	`break;`
	`2458`	`+caseT_IndexStmt:`
	`2459`	`+{`
	`2460`	`+Oidrelid;`
	`2461`	`+Relationrel;`
	`2462`	`+IndexStmtstmt= (IndexStmt)parsetree;`
	`2463`	`+boolisTopLevel= (context==PROCESS_UTILITY_TOPLEVEL);`
	`2464`	`+`
	`2465`	`+if (stmt->concurrent)`
	`2466`	`+PreventTransactionChain(isTopLevel,`
	`2467`	`+"CREATE INDEX CONCURRENTLY");`
	`2468`	`+`
	`2469`	`+relid=RelnameGetRelid(stmt->relation->relname);`
	`2470`	`+rel=heap_open(relid,ShareLock);`
	`2471`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2472`	`+heap_close(rel,NoLock);`
	`2473`	`+}`
	`2474`	`+break;`
`2457`	`2475`	`default:`
`2458`	`2476`	`skipCommand= false;`
`2459`	`2477`	`break;`

Comments

(0)