MODULE_big = raftable

OBJS = raftable.o worker.o state.o blockmem.o

OBJS = raftable.o worker.o state.o blockmem.o raft/obj/raft.o raft/obj/util.o

EXTENSION = raftable

DATA = raftable--1.0.sql

raft/lib/libraft.a:

make -C raft

all: raftable.so

raft/obj/raft.oraft/obj/util.o:

make -C raft obj/raft.o obj/util.o

EXTRA_INSTALL = contrib/raftable

RAFT_PREFIX = raft

overrideLDFLAGS += -L$(RAFT_PREFIX)/lib -Wl,-whole-archive -lraft -Wl,-no-whole-archive

overrideCFLAGS += -Wfatal-errors

overrideCPPFLAGS += -I$(RAFT_PREFIX)/include

overrideCFLAGS += -Wfatal-errors -Wall

overrideCPPFLAGS += -Iraft/include

PG_CONFIG = pg_config

This extension allows you to have a key-value table replicated between several

Postgres instances over Raft protocol.

Depends on

----------

Raft implementation in C: https://github.com/kvap/raft

Please compile the raft library with -fpic flag.

Internals

---------

blockmem_format(void*origin,size_tsize)

{

block_t*block;

meta_t*meta;

intid;

intblocks= (size-1) /BLOCK_LEN;

if (blocks <=0)return0;

raftable_sql_get(PG_FUNCTION_ARGS)

{

RaftableEntry*e;

RaftableKeykey;

size_tlen;

text_to_cstring_buffer(PG_GETARG_TEXT_P(0),key.data,sizeof(key.data));

PG_RETURN_NULL();

}

staticvoidstart_timer(TimestampTz*timer)

{

*timer-=GetCurrentTimestamp();

}

staticvoidstop_timer(TimestampTz*timer)

{

*timer+=GetCurrentTimestamp();

}

staticlongmsec(TimestampTztimer)

{

longsec;

info.keysize=sizeof(RaftableKey);

info.entrysize=sizeof(RaftableEntry);

boolfound;

inti;

state=ShmemInitStruct(

"raftable_state",

staticbooladd_client(intsock)

{

inti;

Client*c=server.clients;

if (server.clientnum >=MAX_CLIENTS)

{

staticboolremove_client(Client*c)

{

inti=0;

intsock=c->sock;

Assert(sock >=0);

c->sock=-1;

}

}

staticboolnotify(void)

staticvoidnotify(void)

{

inti=0;

for (i=0;i<MAX_CLIENTS;i++)

staticbooltick(inttimeout_ms)

{

inti;

intnumready;

boolraft_ready= false;