Commit41a090d

committed

bring xact events back

1 parentb4da6f1 commit41a090dCopy full SHA for 41a090d

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
`@@ -1509,6 +1509,12 @@ FinishPreparedTransaction(const char *gid, bool isCommit)`
`1509`	`1509`	`LWLockAcquire(TwoPhaseStateLock,LW_EXCLUSIVE);`
`1510`	`1510`	`RemoveGXact(gxact);`
`1511`	`1511`	`LWLockRelease(TwoPhaseStateLock);`
	`1512`	`+`
	`1513`	`+if (isCommit)`
	`1514`	`+CallXactCallbacks(XACT_EVENT_COMMIT_PREPARED);`
	`1515`	`+else`
	`1516`	`+CallXactCallbacks(XACT_EVENT_ABORT_PREPARED);`
	`1517`	`+`
`1512`	`1518`	`MyLockedGxact=NULL;`
`1513`	`1519`
`1514`	`1520`	`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
`@@ -305,7 +305,6 @@ static void AtCommit_Memory(void);`
`305`	`305`	`staticvoidAtStart_Cache(void);`
`306`	`306`	`staticvoidAtStart_Memory(void);`
`307`	`307`	`staticvoidAtStart_ResourceOwner(void);`
`308`		`-staticvoidCallXactCallbacks(XactEventevent);`
`309`	`308`	`staticvoidCallSubXactCallbacks(SubXactEventevent,`
`310`	`309`	`SubTransactionIdmySubid,`
`311`	`310`	`SubTransactionIdparentSubid);`
`@@ -1928,6 +1927,7 @@ StartTransaction(void)`
`1928`	`1927`	`*/`
`1929`	`1928`	`s->state=TRANS_INPROGRESS;`
`1930`	`1929`
	`1930`	`+CallXactCallbacks(XACT_EVENT_START);`
`1931`	`1931`	`ShowTransactionState("StartTransaction");`
`1932`	`1932`	`}`
`1933`	`1933`
`@@ -3339,7 +3339,7 @@ UnregisterXactCallback(XactCallback callback, void *arg)`
`3339`	`3339`	`}`
`3340`	`3340`	`}`
`3341`	`3341`
`3342`		`-staticvoid`
	`3342`	`+void`
`3343`	`3343`	`CallXactCallbacks(XactEventevent)`
`3344`	`3344`	`{`
`3345`	`3345`	`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);`
`@@ -403,5 +406,6 @@ extern void ParseAbortRecord(uint8 info, xl_xact_abort *xlrec, xl_xact_parsed_ab`
`403`	`406`	`externvoidEnterParallelMode(void);`
`404`	`407`	`externvoidExitParallelMode(void);`
`405`	`408`	`externboolIsInParallelMode(void);`
	`409`	`+externvoidCallXactCallbacks(XactEventevent);`
`406`	`410`
`407`	`411`	`#endif/* XACT_H */`

Comments

(0)