dmq integration: remove pre-dmq transaction handling

Author: kelvich

multimaster--1.0.sql

@@ -16,14 +16,6 @@ AS 'MODULE_PATHNAME','dmq_receiver_loop'
 LANGUAGE C;
 
 
-CREATE FUNCTION mtm.start_replication() RETURNS void
-AS 'MODULE_PATHNAME','mtm_start_replication'
-LANGUAGE C;
-
-CREATE FUNCTION mtm.stop_replication() RETURNS void
-AS 'MODULE_PATHNAME','mtm_stop_replication'
-LANGUAGE C;
-
 -- Stop replication to the node. Node is didsabled, If drop_slot is true, then replication slot is dropped and node can be recovered using basebackup and recover_node function.
 -- If drop_slot is false and limit for maximal slot gap was not reached, then node can be restarted using resume_node function.
 CREATE FUNCTION mtm.stop_node(node integer, drop_slot bool default false) RETURNS void
@@ -47,18 +39,6 @@ AS 'MODULE_PATHNAME','mtm_resume_node'
 LANGUAGE C;
 
 
-CREATE FUNCTION mtm.get_snapshot() RETURNS bigint
-AS 'MODULE_PATHNAME','mtm_get_snapshot'
-LANGUAGE C;
-
-CREATE FUNCTION mtm.get_csn(xid bigint) RETURNS bigint
-AS 'MODULE_PATHNAME','mtm_get_csn'
-LANGUAGE C;
-
-CREATE FUNCTION mtm.get_last_csn() RETURNS bigint
-AS 'MODULE_PATHNAME','mtm_get_last_csn'
-LANGUAGE C;
-
 CREATE TYPE mtm.node_state AS (
     "id" integer,
     "enabled" bool,
@@ -124,13 +104,6 @@ CREATE TYPE mtm.trans_state AS (
     "config_changes" integer
 );
 
-CREATE FUNCTION mtm.get_trans_by_gid(git text) RETURNS mtm.trans_state
-AS 'MODULE_PATHNAME','mtm_get_trans_by_gid'
-LANGUAGE C;
-
-CREATE FUNCTION mtm.get_trans_by_xid(xid bigint) RETURNS mtm.trans_state
-AS 'MODULE_PATHNAME','mtm_get_trans_by_xid'
-LANGUAGE C;
 
 CREATE FUNCTION mtm.get_cluster_state() RETURNS mtm.cluster_state
 AS 'MODULE_PATHNAME','mtm_get_cluster_state'
@@ -160,10 +133,6 @@ CREATE FUNCTION mtm.poll_node(node_id integer, no_wait boolean default FALSE) RE
 AS 'MODULE_PATHNAME','mtm_poll_node'
 LANGUAGE C;
 
-CREATE FUNCTION mtm.inject_2pc_error(stage integer) RETURNS void
-AS 'MODULE_PATHNAME','mtm_inject_2pc_error'
-LANGUAGE C;
-
 CREATE FUNCTION mtm.check_deadlock(xid bigint) RETURNS boolean
 AS 'MODULE_PATHNAME','mtm_check_deadlock'
 LANGUAGE C;

src/bgwpool.c

@@ -253,9 +253,9 @@ void BgwPoolExecute(BgwPool* pool, void* work, size_t size)
 
 void BgwPoolStop(BgwPool* pool)
 {
-    SpinLockAcquire(&pool->lock);
+    // SpinLockAcquire(&pool->lock);
 	pool->shutdown = true;
-    SpinLockRelease(&pool->lock);            
+    // SpinLockRelease(&pool->lock);            
 	PGSemaphoreUnlock(pool->available);
 	PGSemaphoreUnlock(pool->overflow);
 }

src/include/multimaster.h

@@ -507,7 +507,6 @@ extern void MtmRollbackPreparedTransaction(int nodeId, char const* gid);
 extern bool MtmFilterTransaction(char* record, int size);
 extern void MtmPrecommitTransaction(char const* gid);
 extern char* MtmGucSerialize(void);
-extern bool MtmTransIsActive(void);
 extern MtmTransState* MtmGetActiveTransaction(MtmL2List* list);
 extern void MtmReleaseLocks(void);
 extern void MtmInitMessage(MtmArbiterMessage* msg, MtmMessageCode code);
@@ -519,4 +518,6 @@ extern int MtmGetNumberOfVotingNodes(void);
 extern void MtmToggleDML(void);
 extern void MtmUpdateControlFile(void);
 
+extern void MtmCheckSlots(void);
+
 #endif