EXTENSION = multimaster

DATA = multimaster--1.0.sql

OBJS = multimaster.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o pglogical_relid_map.o ddd.o bkb.o spill.o

OBJS = multimaster.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o pglogical_relid_map.o ddd.o bkb.o spill.o referee.o

MODULE_big = multimaster

PG_CPPFLAGS = -I$(libpq_srcdir)

#defineBIT_CHECK(mask,bit) (((mask) & ((nodemask_t)1 << (bit))) != 0)

#defineBIT_CLEAR(mask,bit) (mask &= ~((nodemask_t)1 << (bit)))

#defineBIT_SET(mask,bit) (mask |= ((nodemask_t)1 << (bit)))

#defineALL_BITS ((nodemask_t)~0)

externnodemask_tMtmFindMaxClique(nodemask_t*matrix,intn_modes,int*clique_size);

LANGUAGE C;

CREATETYPEmtm.cluster_stateAS ("id"integer,"status"text,"disabledNodeMask"bigint,"disconnectedNodeMask"bigint,"catchUpNodeMask"bigint,"liveNodes"integer,"allNodes"integer,"nActiveQueries"integer,"nPendingQueries"integer,"queueSize"bigint,"transCount"bigint,"timeShift"bigint,"recoverySlot"integer,

"xidHashSize"bigint,"gidHashSize"bigint,"oldestXid"bigint,"configChanges"integer,"stalledNodeMask"bigint,"stoppedNodeMask"bigint,"lastStatusChange"timestamp);

"xidHashSize"bigint,"gidHashSize"bigint,"oldestXid"bigint,"configChanges"integer,"stalledNodeMask"bigint,"stoppedNodeMask"bigint,"deadNodeMask"bigint,"lastStatusChange"timestamp);

CREATETYPEmtm.trans_stateAS ("status"text,"gid"text,"xid"bigint,"coordinator"integer,"gxid"bigint,"csn"timestamp,"snapshot"timestamp,"local"boolean,"prepared"boolean,"active"boolean,"twophase"boolean,"votingCompleted"boolean,"participants"bigint,"voted"bigint,"configChanges"integer);

AS'MODULE_PATHNAME','mtm_check_deadlock'

LANGUAGE C;

CREATEFUNCTIONmtm.arbitraror_poll_status(xidbigint) RETURNSbigint

AS'MODULE_PATHNAME','mtm_arbitrator_poll'

CREATEFUNCTIONmtm.referee_poll(xidbigint) RETURNSbigint

AS'MODULE_PATHNAME','mtm_referee_poll'

LANGUAGE C;

CREATETABLEIF NOT EXISTSmtm.local_tables(rel_schematext, rel_nametext,primary key(rel_schema, rel_name));