Commitd83d922

committed

bring xact events back

1 parent0e5b8ef commitd83d922Copy full SHA for d83d922

File tree

+26

-3

lines changed

+26

-3

lines changed

Lines changed: 16 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1510,6 +1510,12 @@ FinishPreparedTransaction(const char *gid, bool isCommit)`
`1510`	`1510`	`LWLockAcquire(TwoPhaseStateLock,LW_EXCLUSIVE);`
`1511`	`1511`	`RemoveGXact(gxact);`
`1512`	`1512`	`LWLockRelease(TwoPhaseStateLock);`
	`1513`	`+`
	`1514`	`+if (isCommit)`
	`1515`	`+CallXactCallbacks(XACT_EVENT_COMMIT_PREPARED);`
	`1516`	`+else`
	`1517`	`+CallXactCallbacks(XACT_EVENT_ABORT_PREPARED);`
	`1518`	`+`
`1513`	`1519`	`MyLockedGxact=NULL;`
`1514`	`1520`
`1515`	`1521`	`pfree(buf);`
`@@ -2408,3 +2414,13 @@ PrepareRedoRemove(TransactionId xid, bool giveWarning)`
`2408`	`2414`
`2409`	`2415`	`return;`
`2410`	`2416`	`}`
	`2417`	`+`
	`2418`	`+`
	`2419`	`+/*`
	`2420`	`+ * Return identified of current global transaction`
	`2421`	`+ */`
	`2422`	`+constchar*`
	`2423`	`+GetLockedGlobalTransactionId(void)`
	`2424`	`+{`
	`2425`	`+returnMyLockedGxact ?MyLockedGxact->gid :NULL;`
	`2426`	`+}`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -306,7 +306,6 @@ static void AtCommit_Memory(void);`
`306`	`306`	`staticvoidAtStart_Cache(void);`
`307`	`307`	`staticvoidAtStart_Memory(void);`
`308`	`308`	`staticvoidAtStart_ResourceOwner(void);`
`309`		`-staticvoidCallXactCallbacks(XactEventevent);`
`310`	`309`	`staticvoidCallSubXactCallbacks(SubXactEventevent,`
`311`	`310`	`SubTransactionIdmySubid,`
`312`	`311`	`SubTransactionIdparentSubid);`
`@@ -1922,6 +1921,7 @@ StartTransaction(void)`
`1922`	`1921`	`*/`
`1923`	`1922`	`s->state=TRANS_INPROGRESS;`
`1924`	`1923`
	`1924`	`+CallXactCallbacks(XACT_EVENT_START);`
`1925`	`1925`	`ShowTransactionState("StartTransaction");`
`1926`	`1926`	`}`
`1927`	`1927`
`@@ -3335,7 +3335,7 @@ UnregisterXactCallback(XactCallback callback, void *arg)`
`3335`	`3335`	`}`
`3336`	`3336`	`}`
`3337`	`3337`
`3338`		`-staticvoid`
	`3338`	`+void`
`3339`	`3339`	`CallXactCallbacks(XactEventevent)`
`3340`	`3340`	`{`
`3341`	`3341`	`XactCallbackItem*item;`

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -57,4 +57,7 @@ extern void PrepareRedoAdd(char *buf, XLogRecPtr start_lsn,`
`57`	`57`	`XLogRecPtrend_lsn);`
`58`	`58`	`externvoidPrepareRedoRemove(TransactionIdxid,boolgiveWarning);`
`59`	`59`	`externvoidrestoreTwoPhaseData(void);`
	`60`	`+`
	`61`	`+externconstchar*GetLockedGlobalTransactionId(void);`
	`62`	`+`
`60`	`63`	`#endif/* TWOPHASE_H */`

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -97,14 +97,17 @@ extern intMyXactFlags;`
`97`	`97`	`*/`
`98`	`98`	`typedefenum`
`99`	`99`	`{`
	`100`	`+XACT_EVENT_START,`
`100`	`101`	`XACT_EVENT_COMMIT,`
`101`	`102`	`XACT_EVENT_PARALLEL_COMMIT,`
`102`	`103`	`XACT_EVENT_ABORT,`
`103`	`104`	`XACT_EVENT_PARALLEL_ABORT,`
`104`	`105`	`XACT_EVENT_PREPARE,`
`105`	`106`	`XACT_EVENT_PRE_COMMIT,`
`106`	`107`	`XACT_EVENT_PARALLEL_PRE_COMMIT,`
`107`		`-XACT_EVENT_PRE_PREPARE`
	`108`	`+XACT_EVENT_PRE_PREPARE,`
	`109`	`+XACT_EVENT_COMMIT_PREPARED,`
	`110`	`+XACT_EVENT_ABORT_PREPARED`
`108`	`111`	`}XactEvent;`
`109`	`112`
`110`	`113`	`typedefvoid (XactCallback) (XactEventevent,voidarg);`
`@@ -405,5 +408,6 @@ extern void ParseAbortRecord(uint8 info, xl_xact_abort *xlrec, xl_xact_parsed_ab`
`405`	`408`	`externvoidEnterParallelMode(void);`
`406`	`409`	`externvoidExitParallelMode(void);`
`407`	`410`	`externboolIsInParallelMode(void);`
	`411`	`+externvoidCallXactCallbacks(XactEventevent);`
`408`	`412`
`409`	`413`	`#endif/* XACT_H */`

Comments

(0)