Commit8652d7c

committed

Merge branch 'tmp_index_fix'

2 parents56aaa09 +2706559 commit8652d7cCopy full SHA for 8652d7c

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
`@@ -2231,9 +2231,10 @@ static void MtmBroadcastUtilityStmt(char const* sql, bool ignoreError)`
`2231`	`2231`	`}`
`2232`	`2232`	`if (!MtmRunUtilityStmt(conns[i],sql,&utility_errmsg)&& !ignoreError)`
`2233`	`2233`	`{`
`2234`		`-// errorMsg = "Failed to run command at node %d";`
`2235`		`-// XXX: add check for our node`
`2236`		`-errorMsg=utility_errmsg;`
	`2234`	`+if (i+1==MtmNodeId)`
	`2235`	`+errorMsg=utility_errmsg;`
	`2236`	`+else`
	`2237`	`+errorMsg="Failed to run command at node %d";`
`2237`	`2238`
`2238`	`2239`	`failedNode=i;`
`2239`	`2240`	`break;`
`@@ -2438,6 +2439,23 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2438`	`2439`	`skipCommand=stmt->relation->relpersistence==RELPERSISTENCE_TEMP;`
`2439`	`2440`	`}`
`2440`	`2441`	`break;`
	`2442`	`+caseT_IndexStmt:`
	`2443`	`+{`
	`2444`	`+Oidrelid;`
	`2445`	`+Relationrel;`
	`2446`	`+IndexStmtstmt= (IndexStmt)parsetree;`
	`2447`	`+boolisTopLevel= (context==PROCESS_UTILITY_TOPLEVEL);`
	`2448`	`+`
	`2449`	`+if (stmt->concurrent)`
	`2450`	`+PreventTransactionChain(isTopLevel,`
	`2451`	`+"CREATE INDEX CONCURRENTLY");`
	`2452`	`+`
	`2453`	`+relid=RelnameGetRelid(stmt->relation->relname);`
	`2454`	`+rel=heap_open(relid,ShareLock);`
	`2455`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2456`	`+heap_close(rel,NoLock);`
	`2457`	`+}`
	`2458`	`+break;`
`2441`	`2459`	`default:`
`2442`	`2460`	`skipCommand= false;`
`2443`	`2461`	`break;`

Comments

(0)