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 referee.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 state.o

MODULE_big = multimaster

PG_CPPFLAGS = -I$(libpq_srcdir)

#defineMAX_ROUTES 16

#defineINIT_BUFFER_SIZE 1024

}else {

BIT_CLEAR(Mtm->currentLockNodeMask,resp->node-1);

}

if (

(BIT_CHECK(resp->disabledNodeMask,MtmNodeId-1)||Mtm->status==MTM_IN_MINORITY )

&& !BIT_CHECK(Mtm->disabledNodeMask,resp->node-1)

&&Mtm->nodes[MtmNodeId-1].lastStatusChangeTime+MSEC_TO_USEC(MtmNodeDisableDelay)<MtmGetSystemTime())

{

MTM_ELOG(WARNING,"Node %d thinks that I'm dead, while I'm %s (message %s)",resp->node,MtmNodeStatusMnem[Mtm->status],MtmMessageKindMnem[resp->code]);

BIT_SET(Mtm->disabledNodeMask,MtmNodeId-1);

Mtm->nConfigChanges+=1;

MtmSwitchClusterMode(MTM_RECOVERY);

}elseif (BIT_CHECK(Mtm->disabledNodeMask,resp->node-1)&&sockets[resp->node-1]<0) {

if (BIT_CHECK(resp->disabledNodeMask,MtmNodeId-1))

{

MtmStateProcessEvent(MTM_REMOTE_DISABLE);

}

if (BIT_CHECK(Mtm->disabledNodeMask,resp->node-1)&&

sockets[resp->node-1]<0)

{

MTM_ELOG(WARNING,"Receive heartbeat from disabled node %d",resp->node);

BIT_SET(Mtm->reconnectMask,resp->node-1);

}

}

}

staticvoidMtmScheduleHeartbeat()

}

}

}

if (Mtm->nLiveNodes<Mtm->nAllNodes/2+1) {/* no quorum */

MTM_ELOG(WARNING,"Node is out of quorum: only %d nodes of %d are accessible",Mtm->nLiveNodes,Mtm->nAllNodes);

MtmSwitchClusterMode(MTM_IN_MINORITY);

}elseif (Mtm->status==MTM_INITIALIZATION) {

MtmSwitchClusterMode(MTM_CONNECTED);

}

MtmStateProcessEvent(MTM_ARBITER_RECEIVER_START);

}