Package org.jgroups.raft.demos

Class ReplicatedStateMachineDemo

java.lang.Object

org.jgroups.raft.demos.ReplicatedStateMachineDemo

All Implemented Interfaces:

org.jgroups.blocks.cs.Receiver, RAFT.RoleChange

public class ReplicatedStateMachineDemo
extends Object
implements org.jgroups.blocks.cs.Receiver, RAFT.RoleChange

Demos ReplicatedStateMachine

Since:

0.1

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReplicatedStateMachineDemo.Command

Field Summary

Fields

Modifier and Type	Field	Description
protected org.jgroups.JChannel	ch
protected ReplicatedStateMachine<String,Object>	rsm
protected org.jgroups.blocks.cs.BaseServer	server

Constructor Summary

Constructors

Constructor	Description
ReplicatedStateMachineDemo()

Method Summary

Modifier and Type	Method	Description
protected String	dumpLog()
protected long	firstApplied()
protected Object	get(String key)
protected String	getView()
protected long	logSize()
protected void	loop()
static void	main(String[] args)
protected Object	put(String key, String value)
protected static String	read(String name)
void	receive(org.jgroups.Address sender, byte[] buf, int offset, int length)
void	receive(org.jgroups.Address sender, DataInput in)
void	receive(org.jgroups.Address sender, ByteBuffer buf)
protected Object	remove(String key)
void	roleChanged(Role role)
protected void	sendResponse(org.jgroups.Address target, Object rsp)
protected Object	snapshot()
void	start(String props, String name, long timeout, InetAddress bind_addr, int port, boolean listen, boolean nohup)
protected void	start(InetAddress bind_addr, int port)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jgroups.blocks.cs.Receiver

receive

Field Details

ch

protected org.jgroups.JChannel ch

rsm

protected ReplicatedStateMachine<String,Object> rsm

server

protected org.jgroups.blocks.cs.BaseServer server

Constructor Details

ReplicatedStateMachineDemo

public ReplicatedStateMachineDemo()

Method Details

start

public void start(String props,
 String name,
 long timeout,
 InetAddress bind_addr,
 int port,
 boolean listen,
 boolean nohup)
           throws Exception

Throws:

Exception

receive

public void receive(org.jgroups.Address sender,
 byte[] buf,
 int offset,
 int length)

Specified by:

receive in interface org.jgroups.blocks.cs.Receiver

receive

public void receive(org.jgroups.Address sender,
 ByteBuffer buf)

Specified by:

receive in interface org.jgroups.blocks.cs.Receiver

receive

public void receive(org.jgroups.Address sender,
 DataInput in)
             throws Exception

Specified by:

receive in interface org.jgroups.blocks.cs.Receiver

Throws:

Exception

start

protected void start(InetAddress bind_addr,
 int port)
              throws Exception

Throws:

Exception

loop

protected void loop()

put

protected Object put(String key,
 String value)

get

protected Object get(String key)

remove

protected Object remove(String key)

snapshot

protected Object snapshot()

getView

protected String getView()

read

protected static String read(String name)

firstApplied

protected long firstApplied()

logSize

protected long logSize()

dumpLog

protected String dumpLog()

sendResponse

protected void sendResponse(org.jgroups.Address target,
 Object rsp)
                     throws Exception

Throws:

Exception

roleChanged

public void roleChanged(Role role)

Specified by:

roleChanged in interface RAFT.RoleChange

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception