MODULE_big = multimaster

OBJS = multimaster.oreceiver_raw.o decoder_raw.olibdtm.o bytebuf.o bgwpool.o sockhub/sockhub.o

OBJS = multimaster.o libdtm.o bytebuf.o bgwpool.o sockhub/sockhub.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o

EXTENSION = multimaster

DATA = multimaster--1.0.sql

PG_CPPFLAGS = -I$(libpq_srcdir)

PG_CPPFLAGS = -I$(libpq_srcdir) -DUSE_PGLOGICAL_OUTPUT

SHLIB_LINK =$(libpq)

MODULE_big = multimaster

OBJS = multimaster.o pglogical_receiver.o decoder_raw.o libdtm.o bytebuf.o bgwpool.o sockhub/sockhub.o

EXTENSION = multimaster

DATA = multimaster--1.0.sql

PG_CPPFLAGS = -I$(libpq_srcdir)

SHLIB_LINK = $(libpq)

ifdef USE_PGXS

PG_CONFIG = pg_config

PGXS := $(shell $(PG_CONFIG) --pgxs)

include $(PGXS)

else

subdir = contrib/multimaster

top_builddir = ../..

include $(top_builddir)/src/Makefile.global

include $(top_srcdir)/contrib/contrib-global.mk

endif

staticvoidDtmBackgroundWorker(Datumarg);

staticvoidMMMarkTransAsLocal(TransactionIdxid);

staticvoidMMExecutor(intid,void*work,size_tsize);

staticBgwPool*MMPoolConstructor(void);

staticshmem_startup_hook_typeprev_shmem_startup_hook;

{

standard_ExecutorFinish(queryDesc);

}

}

staticvoidMMExecutor(intid,void*work,size_tsize)

{

TransactionIdxid=*(TransactionId*)work;

char*stmts= (char*)work+4;

boolfinished= false;

MMJoinTransaction(xid);

SetCurrentStatementStartTimestamp();

StartTransactionCommand();

SPI_connect();

PushActiveSnapshot(GetTransactionSnapshot());

PG_TRY();

{

intrc=SPI_execute(stmts, false,0);

SPI_finish();

PopActiveSnapshot();

finished= true;

if (rc!=SPI_OK_INSERT&&rc!=SPI_OK_UPDATE&&rc!=SPI_OK_DELETE) {

ereport(LOG, (errmsg("Executor %d: failed to apply transaction %u",

id,xid)));

AbortCurrentTransaction();

}else {

CommitTransactionCommand();

}

}

PG_CATCH();

{

FlushErrorState();

if (!finished) {

SPI_finish();

if (ActiveSnapshotSet()) {

PopActiveSnapshot();

}

}

AbortCurrentTransaction();

}

PG_END_TRY();

}

}

externvoidMMExecute(void*work,intsize)

{

externboolMMIsLocalTransaction(TransactionIdxid);

externvoidMMReceiverStarted(void);

externvoidMMExecute(void*work,intsize);

externvoidMMExecutor(intid,void*work,size_tsize);

externchar*MMDatabaseName;