提交 a97d50df 编写于 作者: A Adam Berlin 提交者: Adam Berlin

Removes duplicate setting of portal->status.

上级 624298a9
...@@ -2134,7 +2134,6 @@ _SPI_pquery(QueryDesc *queryDesc, bool fire_triggers, long tcount) ...@@ -2134,7 +2134,6 @@ _SPI_pquery(QueryDesc *queryDesc, bool fire_triggers, long tcount)
if (!IsResQueueLockedForPortal(ActivePortal)) if (!IsResQueueLockedForPortal(ActivePortal))
{ {
/** TODO: siva - can we ever reach this point? */ /** TODO: siva - can we ever reach this point? */
ActivePortal->status = PORTAL_QUEUE;
ResLockPortal(ActivePortal, queryDesc); ResLockPortal(ActivePortal, queryDesc);
ActivePortal->status = PORTAL_ACTIVE; ActivePortal->status = PORTAL_ACTIVE;
} }
......
...@@ -267,8 +267,6 @@ ProcessQuery(Portal portal, ...@@ -267,8 +267,6 @@ ProcessQuery(Portal portal,
if((!ResourceSelectOnly || portal->sourceTag == T_SelectStmt) && if((!ResourceSelectOnly || portal->sourceTag == T_SelectStmt) &&
stmt->canSetTag) stmt->canSetTag)
{ {
portal->status = PORTAL_QUEUE;
ResLockPortal(portal, queryDesc); ResLockPortal(portal, queryDesc);
} }
else else
...@@ -694,7 +692,6 @@ PortalStart(Portal portal, ParamListInfo params, Snapshot snapshot, ...@@ -694,7 +692,6 @@ PortalStart(Portal portal, ParamListInfo params, Snapshot snapshot,
*/ */
if (IsResQueueEnabled() && !superuser()) if (IsResQueueEnabled() && !superuser())
{ {
portal->status = PORTAL_QUEUE;
/* /*
* MPP-16369 - If we are in SPI context, only acquire * MPP-16369 - If we are in SPI context, only acquire
* resource queue lock if the outer portal hasn't * resource queue lock if the outer portal hasn't
......
...@@ -551,6 +551,8 @@ ResLockPortal(Portal portal, QueryDesc *qDesc) ...@@ -551,6 +551,8 @@ ResLockPortal(Portal portal, QueryDesc *qDesc)
plan = qDesc->plannedstmt->planTree; plan = qDesc->plannedstmt->planTree;
portal->status = PORTAL_QUEUE;
queueid = portal->queueId; queueid = portal->queueId;
/* /*
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册