postgrespro
diff --git a/‎contrib/pg_gtm/pg_dtm.c
Lines changed: 4 additions & 5 deletions b/‎contrib/pg_gtm/pg_dtm.c
Lines changed: 4 additions & 5 deletions
diff --git a/‎contrib/pg_xtm/libdtm.h
Lines changed: 10 additions & 13 deletions b/‎contrib/pg_xtm/libdtm.h
Lines changed: 10 additions & 13 deletions
diff --git a/‎contrib/pg_xtm/pg_dtm--1.0.sql
Lines changed: 4 additions & 19 deletions b/‎contrib/pg_xtm/pg_dtm--1.0.sql
Lines changed: 4 additions & 19 deletions
@@ -21,6 +21,7 @@
 #include "storage/procarray.h"
 #include "access/xlogdefs.h"
 #include "access/xact.h"
+#include "access/xtm.h"
 #include "access/transam.h"
 #include "access/xlog.h"
 #include "access/twophase.h"
@@ -80,8 +81,6 @@ static DtmNodeState* local;
 static DtmTransState dtm_tx;
 static DTMConn dtm_conn;
 
-static SnapshotProvider DefaultSnapshotProvider;
-
 void _PG_init(void);
 void _PG_fini(void);
 
@@ -392,7 +391,7 @@ void DtmInitialize()
 		HASH_ELEM | HASH_FUNCTION | HASH_COMPARE | HASH_KEYCOPY);
 
 	RegisterTransactionVisibilityCallback(DtmVisibilityCheck);
-    DefaultSnapshotProvider = SetSnapshotProvider(DtmSnapshotProvider);
+    TM->GetSnapshotData = DtmGetSnapshotData;
 
 	LWLockAcquire(AddinShmemInitLock, LW_EXCLUSIVE);
 	local = (DtmNodeState*)ShmemInitStruct("dtm", sizeof(DtmNodeState), &found);
@@ -413,10 +412,10 @@ void DtmInitialize()
 }
 
 
-Snapshot DtmSnapshotProvider(Snapshot snapshot)
+Snapshot DtmGetSnapshotData(Snapshot snapshot)
 {
     if (dtm_tx.local_snapshot == NULL) {
-        dtm_tx.local_snapshot = DefaultSnapshotProvider(snapshot); 
+        dtm_tx.local_snapshot = GetLocalSnapshotData(snapshot); 
     }
     if (local->last_xid != InvalidTransactionId &&  RecentGlobalDataXmin > local->last_xid) { 
         RecentGlobalDataXmin = local->last_xid;
 
@@ -20,22 +20,19 @@ DTMConn DtmConnect(char *host, int port);
 // bad things will happen.
 void DtmDisconnect(DTMConn dtm);
 
-// Asks DTM for a fresh snapshot. Returns a snapshot on success, or NULL
-// otherwise. Please free the snapshot memory yourself after use.
-Snapshot DtmGlobalGetSnapshot(DTMConn dtm);
 
-// Starts a transaction. Returns the 'gxid' on success, or INVALID_GXID otherwise.
-xid_t DtmGlobalBegin(DTMConn dtm);
+typedef struct {
+    TransasactionId* xids;
+    int nXids;
+} GlobalTransactionId;
 
-// Marks a given transaction as 'committed'. Returns 'true' on success,
-// 'false' otherwise.
-bool DtmGlobalCommit(DTMConn dtm, xid_t gxid);
+/* create entry for new global transaction */
+void DtmGlobalStartTransaction(DTMConn dtm, TransactionId* gitd); 
 
-// Marks a given transaction as 'aborted'.
-void DtmGlobalRollback(DTMConn dtm, xid_t gxid);
+void DtmGlobalGetSnapshot(DTMConn dtm, TransactionId xid, Snapshot snapshot);
 
-// Gets the status of the commit identified by 'gxid'. Returns the status on
-// success, or -1 otherwise.
-int DtmGlobalGetTransStatus(DTMConn dtm, xid_t gxid);
+void DtmGlobalSetTransStatus(DTMConn dtm, TransactionId xid, XidStatus status); /* commit transaction only once all participants are committed, before it do not change CLOG  */
+
+XidStatus DtmGlobalGetTransStatus(DTMConn dtm, TransactionId xid);
 
 #endif
@@ -1,26 +1,11 @@
 -- complain if script is sourced in psql, rather than via CREATE EXTENSION
 \echo Use "CREATE EXTENSION pg_dtm" to load this file. \quit
 
-CREATE FUNCTION dtm_register_node(id integer) RETURNS void
-AS 'MODULE_PATHNAME','dtm_register_node'
+CREATE FUNCTION dtm_global_transaction(xids integer[]) RETURNS void
+AS 'MODULE_PATHNAME','dtm_global_transaction'
 LANGUAGE C;
 
-CREATE FUNCTION dtm_extend(gtid cstring default null) RETURNS bigint
-AS 'MODULE_PATHNAME','dtm_extend'
+CREATE FUNCTION dtm_get_snapshot() RETURNS void
+AS 'MODULE_PATHNAME','dtm_get_snapshot'
 LANGUAGE C;
 
-CREATE FUNCTION dtm_access(snapshot bigint, gtid cstring default null) RETURNS bigint
-AS 'MODULE_PATHNAME','dtm_access'
-LANGUAGE C;
-
-CREATE FUNCTION dtm_begin_prepare(gtid cstring, coordinator integer) RETURNS void
-AS 'MODULE_PATHNAME','dtm_begin_prepare'
-LANGUAGE C;
-
-CREATE FUNCTION dtm_prepare(gtid cstring, csn bigint) RETURNS bigint
-AS 'MODULE_PATHNAME','dtm_prepare'
-LANGUAGE C;
-
-CREATE FUNCTION dtm_end_prepare(gtid cstring, csn bigint) RETURNS void
-AS 'MODULE_PATHNAME','dtm_end_prepare'
-LANGUAGE C;