MODULE_big = multimaster

OBJS = multimaster.oraftable.oarbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o ddd.o bkb.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 ddd.o bkb.o

overrideCPPFLAGS += -I../raftable

typedefstruct {

}

returnhasDeadlock;

}

void*RaftableGet(charconst*key,int*size,RaftableTimestamp*ts,boolnowait)

{

size_ts;

char*value;

Assert(ts==NULL);/* not implemented */

value=raftable_get(key,&s);

*size=s;

returnvalue;

}

voidRaftableSet(charconst*key,voidconst*value,intsize,boolnowait)

{

raftable_set(key,value,size,nowait ?0 :-1);

}

boolRaftableCAS(charconst*key,charconst*value,boolnowait)

{

Assert(false);/* not implemented */

return false;

}

typedefstructRaftableTimestamp {

time_ttime;/* local time at master */

staticchar*state_get_string(StatePstate,RaftableEntry*e,size_t*len)

{

size_tchecklen;

size_tactlen;

char*s;

Assert(state);

Assert(LWLockHeldByMe(state->lock));

*len=blockmem_len(state->blockmem,e->block);

Assert(len>0);

s=palloc(*len);

checklen=blockmem_get(state->blockmem,e->block,s,*len);

Assert(*len==checklen);

actlen=blockmem_len(state->blockmem,e->block);

if (len)*len=actlen;

Assert(actlen>0);

s=palloc(actlen);

actlen-=blockmem_get(state->blockmem,e->block,s,actlen);

Assert(actlen==0);

returns;

}