Commit08762fd

committed

temp index fix

1 parent7a86d88 commit08762fdCopy full SHA for 08762fd

File tree

+25

-3

lines changed

+25

-3

lines changed

Lines changed: 25 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,27 @@ 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`	`+LOCKMODElockmode;`
	`2446`	`+Relationrel;`
	`2447`	`+`
	`2448`	`+IndexStmtstmt= (IndexStmt)parsetree;`
	`2449`	`+lockmode=stmt->concurrent ?ShareUpdateExclusiveLock`
	`2450`	`+:ShareLock;`
	`2451`	`+relid=RangeVarGetRelidExtended(stmt->relation,lockmode,`
	`2452`	`+ false, false,`
	`2453`	`+NULL,// ???`
	`2454`	`+NULL);`
	`2455`	`+`
	`2456`	`+rel=heap_open(relid,lockmode);`
	`2457`	`+`
	`2458`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2459`	`+`
	`2460`	`+heap_close(rel,NoLock);`
	`2461`	`+}`
	`2462`	`+break;`
`2441`	`2463`	`default:`
`2442`	`2464`	`skipCommand= false;`
`2443`	`2465`	`break;`

Comments

(0)