提交 ecc217e8 编写于 作者: A Asim R P 提交者: Asim RP

Remove redundant distributed transaction state.

The DTX_STATE_FORCED_COMMITTED was identical to
DTX_STATE_INSERTED_COMMITTED.
上级 01d88778
......@@ -1398,9 +1398,6 @@ RecordTransactionCommit(void)
if (max_wal_senders > 0)
WalSndWakeup();
if (isDtxPrepared)
forcedDistributedCommitted(&recptr);
/*
* Now we may update the CLOG, if we wrote a COMMIT record above
*/
......
......@@ -777,7 +777,7 @@ doNotifyingCommitPrepared(void)
copyDirectDispatchFromTransaction(&direct);
Assert(currentGxact->state == DTX_STATE_FORCED_COMMITTED);
Assert(currentGxact->state == DTX_STATE_INSERTED_COMMITTED);
setCurrentGxactState(DTX_STATE_NOTIFYING_COMMIT_PREPARED);
if (strlen(currentGxact->gid) >= TMGIDSIZE)
......@@ -1212,7 +1212,6 @@ rollbackDtxTransaction(void)
currentGxact->gid);
break;
case DTX_STATE_FORCED_COMMITTED:
case DTX_STATE_NOTIFYING_COMMIT_PREPARED:
case DTX_STATE_INSERTING_COMMITTED:
case DTX_STATE_INSERTED_COMMITTED:
......@@ -2259,21 +2258,6 @@ insertedDistributedCommitted(void)
setCurrentGxactState(DTX_STATE_INSERTED_COMMITTED);
}
/*
* Change state to DTX_STATE_FORCED_COMMITTED.
*/
void
forcedDistributedCommitted(XLogRecPtr *recptr)
{
elog(DTM_DEBUG5,
"forcedDistributedCommitted entering in state = %s for gid = %s (xlog record %X/%X)",
DtxStateToString(currentGxact->state), currentGxact->gid, recptr->xlogid, recptr->xrecoff);
Assert(currentGxact->state == DTX_STATE_INSERTED_COMMITTED);
setCurrentGxactState(DTX_STATE_FORCED_COMMITTED);
}
/* generate global transaction id */
static DistributedTransactionId
generateGID(void)
......
......@@ -306,7 +306,6 @@ extern DistributedTransactionId getMaxDistributedXid(void);
extern bool includeInCheckpointIsNeeded(TMGXACT *gxact);
extern void insertingDistributedCommitted(void);
extern void insertedDistributedCommitted(void);
extern void forcedDistributedCommitted(XLogRecPtr *recptr);
extern void redoDtxCheckPoint(TMGXACT_CHECKPOINT *gxact_checkpoint);
extern void redoDistributedCommitRecord(TMGXACT_LOG *gxact_log);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册