com.sleepycat.je.rep.elections

Class Acceptor

java.lang.Object

java.lang.Thread

com.sleepycat.je.utilint.StoppableThread

com.sleepycat.je.rep.elections.ElectionAgentThread

com.sleepycat.je.rep.elections.Acceptor

All Implemented Interfaces:

ExceptionListenerUser, java.lang.Runnable

public class Acceptor
extends ElectionAgentThread

Plays the role of Acceptor in the consensus algorithm. It runs in its own thread listening for and responding to messages sent by Proposers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Acceptor.SuggestionGenerator

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SERVICE_NAME

Fields inherited from class com.sleepycat.je.rep.elections.ElectionAgentThread

channelQueue, formatter, logger, protocol

Fields inherited from class com.sleepycat.je.utilint.StoppableThread

envImpl

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Acceptor(Protocol protocol, RepNode repNode, Acceptor.SuggestionGenerator suggestionGenerator) Creates an Acceptor

Method Summary

Methods

Modifier and Type	Method and Description
(package private) TextProtocol.ResponseMessage	process(Protocol.Accept accept) Responds to Accept request
(package private) TextProtocol.ResponseMessage	process(Protocol.Propose propose) Responds to a Propose request.
void	run() The Acceptor thread body.

Methods inherited from class com.sleepycat.je.rep.elections.ElectionAgentThread

getLogger, initiateSoftShutdown, shutdown

Methods inherited from class com.sleepycat.je.utilint.StoppableThread

cleanup, getSavedShutdownException, getTotalCpuTime, getTotalUserTime, isShutdown, saveShutdownException, setExceptionListener, shutdownDone, shutdownThread

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final java.lang.String SERVICE_NAME

See Also:

Constant Field Values

Constructor Detail

Acceptor

public Acceptor(Protocol protocol,
        RepNode repNode,
        Acceptor.SuggestionGenerator suggestionGenerator)

Creates an Acceptor

Method Detail

run

public void run()

The Acceptor thread body.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

process

TextProtocol.ResponseMessage process(Protocol.Propose propose)

Responds to a Propose request.

Parameters:

propose - the request proposal

Returns:

the response: a Promise if the request was accepted, a Reject otherwise.

process

TextProtocol.ResponseMessage process(Protocol.Accept accept)

Responds to Accept request

Parameters:

accept - the request

Returns:

an Accepted or Reject response as appropriate.