Commit3cdb373

committed

disallow concurrent index creation insise tx

1 parent9bacc10 commit3cdb373Copy full SHA for 3cdb373

File tree

-10

lines changed

-10

lines changed

Lines changed: 6 additions & 10 deletions

Original file line number	Diff line number	Diff line change
`@@ -2437,21 +2437,17 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2437`	`2437`	`caseT_IndexStmt:`
`2438`	`2438`	`{`
`2439`	`2439`	`Oidrelid;`
`2440`		`-LOCKMODElockmode;`
`2441`	`2440`	`Relationrel;`
`2442`		`-`
`2443`	`2441`	`IndexStmtstmt= (IndexStmt)parsetree;`
`2444`		`-lockmode=stmt->concurrent ?ShareUpdateExclusiveLock`
`2445`		`-:ShareLock;`
`2446`		`-relid=RangeVarGetRelidExtended(stmt->relation,lockmode,`
`2447`		`- false, false,`
`2448`		`-NULL,// ???`
`2449`		`-NULL);`
	`2442`	`+boolisTopLevel= (context==PROCESS_UTILITY_TOPLEVEL);`
`2450`	`2443`
`2451`		`-rel=heap_open(relid,lockmode);`
	`2444`	`+if (stmt->concurrent)`
	`2445`	`+PreventTransactionChain(isTopLevel,`
	`2446`	`+"CREATE INDEX CONCURRENTLY");`
`2452`	`2447`
	`2448`	`+relid=RelnameGetRelid(stmt->relation->relname);`
	`2449`	`+rel=heap_open(relid,ShareLock);`
`2453`	`2450`	`skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
`2454`		`-`
`2455`	`2451`	`heap_close(rel,NoLock);`
`2456`	`2452`	`}`
`2457`	`2453`	`break;`

Comments

(0)