multidb refactor: change ddd to be a separate file with it own private data structures

Author: kelvich

multimaster--1.0.sql

@@ -168,10 +168,6 @@ CREATE FUNCTION mtm.check_deadlock(xid bigint) RETURNS boolean
 AS 'MODULE_PATHNAME','mtm_check_deadlock'
 LANGUAGE C;
 
-CREATE FUNCTION mtm.referee_poll(xid bigint) RETURNS bigint
-AS 'MODULE_PATHNAME','mtm_referee_poll'
-LANGUAGE C;
-
 CREATE TABLE IF NOT EXISTS mtm.local_tables(rel_schema name, rel_name name, primary key(rel_schema, rel_name));
 
 CREATE TABLE mtm.referee_decision(key text primary key not null, node_id int);

src/bgwpool.c

@@ -11,10 +11,11 @@
 #include "datatype/timestamp.h"
 #include "utils/portal.h"
 #include "tcop/pquery.h"
+#include "utils/guc.h"
 
 #include "bgwpool.h"
-#include "multimaster.h"
-#include "utils/guc.h"
+#include "mm.h"
+#include "logger.h"
 
 bool MtmIsLogicalReceiver;
 int  MtmMaxWorkers;
@@ -26,7 +27,6 @@ void BgwPoolDynamicWorkerMainLoop(Datum arg);
 
 static void BgwShutdownWorker(int sig)
 {
-	MTM_LOG1("Background worker %d received shutdown request", MyProcPid);
 	if (MtmPool) { 
 		BgwPoolStop(MtmPool);
 	}
@@ -38,12 +38,13 @@ static void BgwPoolMainLoop(BgwPool* pool)
     void* work;
 	static PortalData fakePortal;
 
-	MTM_ELOG(LOG, "Start background worker %d, shutdown=%d", MyProcPid, pool->shutdown);
+	mtm_log(BgwPoolEvent, "Start background worker %d, shutdown=%d", MyProcPid, pool->shutdown);
 
 	MtmBackgroundWorker = true;
 	MtmIsLogicalReceiver = true;
 	MtmPool = pool;
 
+	// XXX: fix that
 	pqsignal(SIGINT, BgwShutdownWorker);
 	pqsignal(SIGQUIT, BgwShutdownWorker);
 	pqsignal(SIGTERM, BgwShutdownWorker);
@@ -100,7 +101,7 @@ static void BgwPoolMainLoop(BgwPool* pool)
         SpinLockRelease(&pool->lock);
     }
 	SpinLockRelease(&pool->lock);
-	MTM_ELOG(LOG, "Shutdown background worker %d", MyProcPid);
+	mtm_log(BgwPoolEvent, "Shutdown background worker %d", MyProcPid);
 }
 
 void BgwPoolInit(BgwPool* pool, BgwPoolExecutor executor, char const* dbname,  char const* dbuser, size_t queueSize, size_t nWorkers)

src/bkb.c

@@ -119,3 +119,23 @@ nodemask_t MtmFindMaxClique(nodemask_t* graph, int n_nodes, int* clique_size)
 	*clique_size = result.size;
 	return mask;
 }
+
+#ifdef TEST
+#include <stdio.h>
+#include <stdint.h>
+#include "bkb.h"
+
+int main()
+{
+	nodemask_t matrix[64] = {0};
+	nodemask_t clique;
+	int clique_size;
+	matrix[0] = 6;
+	matrix[1] = 4;
+	matrix[2] = 1;
+	matrix[4] = 3;
+	clique = MtmFindMaxClique(matrix, 64, &clique_size);
+	printf("Clique=%llx\n", clique);
+	return 0;
+}
+#endif