postgrespro
diff --git a/‎contrib/pg_xtm/libdtm.c
Lines changed: 9 additions & 2 deletions b/‎contrib/pg_xtm/libdtm.c
Lines changed: 9 additions & 2 deletions
diff --git a/‎contrib/pg_xtm/libdtm.h
Lines changed: 6 additions & 4 deletions b/‎contrib/pg_xtm/libdtm.h
Lines changed: 6 additions & 4 deletions
diff --git a/‎contrib/pg_xtm/pg_dtm--1.0.sql
Lines changed: 1 addition & 1 deletion b/‎contrib/pg_xtm/pg_dtm--1.0.sql
Lines changed: 1 addition & 1 deletion
@@ -121,7 +121,7 @@ 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, TransactionId xid, Snapshot s) {
+Snapshot DtmGlobalGetSnapshot(DTMConn dtm, NodeId nodeid, TransactionId xid, Snapshot s) {
 	bool ok;
 	int i;
 	xid_t number;
@@ -173,6 +173,7 @@ Snapshot DtmGlobalGetSnapshot(DTMConn dtm, TransactionId xid, Snapshot s) {
 	return NULL;
 }
 
+#if 0
 // Starts a transaction. Returns the 'gxid' on success, or INVALID_GXID otherwise.
 xid_t DtmGlobalBegin(DTMConn dtm) {
 	bool ok;
@@ -195,7 +196,12 @@ xid_t DtmGlobalBegin(DTMConn dtm) {
 
 	return gxid;
 }
+#endif
 
+void DtmGlobalSetTransStatus(DTMConn dtm, NodeId nodeid, TransactionId xid, XidStatus status)
+{
+}
+#if 0
 // Marks a given transaction as 'committed'. Returns 'true' on success,
 // 'false' otherwise.
 bool DtmGlobalCommit(DTMConn dtm, xid_t gxid) {
@@ -232,10 +238,11 @@ void DtmGlobalRollback(DTMConn dtm, xid_t gxid) {
 		return;
 	}
 }
+#endif
 
 // Gets the status of the transaction identified by 'gxid'. Returns the status
 // on success, or -1 otherwise.
-XidStatus DtmGlobalGetTransStatus(DTMConn dtm, TransactionId gxid) {
+XidStatus DtmGlobalGetTransStatus(DTMConn dtm, NodeId nodeid, TransactionId gxid) {
 	bool result;
 	char statuschar;
 
 
@@ -10,6 +10,7 @@
 #define COMMIT_YES     1
 #define COMMIT_NO      2
 
+typedef int NodeId;
 typedef unsigned long long xid_t;
 
 typedef struct DTMConnData *DTMConn;
@@ -24,16 +25,17 @@ void DtmDisconnect(DTMConn dtm);
 
 typedef struct {
     TransactionId* xids;
-    int nXids;
+    NodeId* nodes;
+    int nNodes;
 } GlobalTransactionId;
 
 /* create entry for new global transaction */
 void DtmGlobalStartTransaction(DTMConn dtm, GlobalTransactionId* gitd); 
 
-Snapshot DtmGlobalGetSnapshot(DTMConn dtm, TransactionId xid, Snapshot snapshot);
+Snapshot DtmGlobalGetSnapshot(DTMConn dtm, NodeId nodeid, TransactionId xid, Snapshot snapshot);
 
-void DtmGlobalSetTransStatus(DTMConn dtm, TransactionId xid, XidStatus status); /* commit transaction only once all participants are committed, before it do not change CLOG  */
+void DtmGlobalSetTransStatus(DTMConn dtm, NodeId nodeid, TransactionId xid, XidStatus status); /* commit transaction only once all participants are committed, before it do not change CLOG  */
 
-XidStatus DtmGlobalGetTransStatus(DTMConn dtm, TransactionId xid);
+XidStatus DtmGlobalGetTransStatus(DTMConn dtm, NodeId nodeid, TransactionId xid);
 
 #endif
@@ -1,7 +1,7 @@
 -- 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_global_transaction(xids integer[]) RETURNS void
+CREATE FUNCTION dtm_global_transaction(nodes integer[], xids integer[]) RETURNS void
 AS 'MODULE_PATHNAME','dtm_global_transaction'
 LANGUAGE C;