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)

MTM_ELOG(WARNING,"Arbiter trying to connect to %s:%d: %s",host,port,strerror(errcode));

gotoError;

}

}else {

MTM_ELOG(WARNING,"Arbiter waiting socket to %s:%d: %s",host,port,strerror(errno));

}elseif (rc==0) {

MTM_ELOG(WARNING,"Arbiter failed to connect to socket to %s:%d within specified timeout",host,port);

gotoError;

}else {

MTM_ELOG(WARNING,"Arbiter failed to wait socket to %s:%d: %s",host,port,strerror(errno));

gotoError;

}

}

elseif (rc!=0) {

#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_make_table_local'

LANGUAGE C;

CREATEFUNCTIONmtm.broadcast_table(srcTable regclass, dstNodesMaskbigint) RETURNS void

AS'MODULE_PATHNAME','mtm_broadcast_table'

LANGUAGE C;

CREATEFUNCTIONmtm.copy_table(srcTable regclass, dstNodeinteger) RETURNS void

AS'MODULE_PATHNAME','mtm_copy_table'

LANGUAGE C;

CREATEFUNCTIONmtm.dump_lock_graph() RETURNStext

AS'MODULE_PATHNAME','mtm_dump_lock_graph'

LANGUAGE C;

AS'MODULE_PATHNAME','mtm_check_deadlock'

LANGUAGE C;

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));

CREATE OR REPLACEFUNCTIONmtm.alter_sequences() RETURNSbooleanAS