lib.easyjava.net.replication.multipaxos

Class PaxosNode<E extends PaxosCommand>

java.lang.Object

lib.easyjava.net.replication.multipaxos.PaxosNode<E>

Type Parameters:

E - the type of command which will be synchronized using Paxos.

public abstract class PaxosNode<E extends PaxosCommand>
extends java.lang.Object

A node in a multi-Paxos cluster. Each node will fully replicate the current state of the cluster. This node will act as a proposer, acceptor, and learner in the multi-Paxos algorithm.

Author:

Rob Rua (robrua@alumni.cmu.edu), Jordan Harry (jordak6200@gmail.com)

Field Summary

Fields

Modifier and Type	Field and Description
int	nodeID

Constructor Summary

Constructors

Constructor and Description
PaxosNode(int nodeID, int port, java.util.Map<java.lang.Integer,java.lang.String> nodeHostPorts)
PaxosNode(int nodeID, int port, java.util.Map<java.lang.Integer,java.lang.String> nodeHostPorts, Logger logger)

Method Summary

Modifier and Type	Method and Description
boolean	propose(E command) Proposes a new command to the paxos cluster
void	stop() Stop running the node and clean up associated resources.

Methods inherited from class java.lang.Object

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

Field Detail

nodeID

public final int nodeID

Constructor Detail

PaxosNode

public PaxosNode(int nodeID,
                 int port,
                 java.util.Map<java.lang.Integer,java.lang.String> nodeHostPorts)
          throws java.lang.NumberFormatException,
                 java.net.UnknownHostException,
                 java.net.SocketException

Parameters:

nodeID - the id of this paxos node in the cluster

port - the port to run the node off of

nodeHostPorts - the hostnames and ports (colon delimited) for all nodes in the cluster (including this one) in sorted ID order

Throws:

java.lang.NumberFormatException - if a port number was badly formatted

java.net.UnknownHostException - if the host can't be found

java.net.SocketException - if a connection could not be established

PaxosNode

public PaxosNode(int nodeID,
                 int port,
                 java.util.Map<java.lang.Integer,java.lang.String> nodeHostPorts,
                 Logger logger)
          throws java.lang.NumberFormatException,
                 java.net.UnknownHostException,
                 java.net.SocketException

Parameters:

nodeID - the id of this paxos node in the cluster

port - the port to run the node off of

nodeHostPorts - the hostnames and ports (colon delimited) for all nodes in the cluster (including this one) in sorted ID order

logger - the logger to use for this paxos node

Throws:

java.lang.NumberFormatException - if a port number was badly formatted

java.net.UnknownHostException - if the host can't be found

java.net.SocketException - if a connection could not be established

Method Detail

propose

public boolean propose(E command)

Proposes a new command to the paxos cluster

Parameters:

command - the command to propose

Returns:

whether the command was accepted by the cluster

stop

public void stop()

Stop running the node and clean up associated resources.