Receive snapshots implicitly

knizhnik · knizhnik · commit 34c5245802e8 · 2015-09-21T17:13:33.000+03:00
diff --git a/contrib/pg_xtm/pg_dtm.c b/contrib/pg_xtm/pg_dtm.c
@@ -452,6 +452,13 @@ PG_FUNCTION_INFO_V1(dtm_get_current_snapshot_xmin);
 Datum
 dtm_get_current_snapshot_xmin(PG_FUNCTION_ARGS)
 {
+    // if (IsolationUsesXactSnapshot()){ /* RR & S */
+    //     DtmEnsureConnection();
+    //     DtmGlobalGetSnapshot(DtmConn, DtmNodeId, gtid.xids[DtmNodeId], &DtmSnapshot);
+    //     Assert(CurrentTransactionSnapshot != NULL);
+    //     DtmMergeSnapshots(CurrentTransactionSnapshot, &DtmSnapshot);
+    //     DtmUpdateRecentXmin();
+    // }
     PG_RETURN_INT32(CurrentTransactionSnapshot->xmin);
 }
 

Original file line number	Diff line number	Diff line change
`@@ -452,6 +452,13 @@ PG_FUNCTION_INFO_V1(dtm_get_current_snapshot_xmin);`
`452`	`452`	`Datum`
`453`	`453`	`dtm_get_current_snapshot_xmin(PG_FUNCTION_ARGS)`
`454`	`454`	`{`
	`455`	`+ // if (IsolationUsesXactSnapshot()){ /* RR & S */`
	`456`	`+ // DtmEnsureConnection();`
	`457`	`+ // DtmGlobalGetSnapshot(DtmConn, DtmNodeId, gtid.xids[DtmNodeId], &DtmSnapshot);`
	`458`	`+ // Assert(CurrentTransactionSnapshot != NULL);`
	`459`	`+ // DtmMergeSnapshots(CurrentTransactionSnapshot, &DtmSnapshot);`
	`460`	`+ // DtmUpdateRecentXmin();`
	`461`	`+ // }`
`455`	`462`	`PG_RETURN_INT32(CurrentTransactionSnapshot->xmin);`
`456`	`463`	`}`
`457`	`464`