com.orientechnologies.orient.server.distributed.impl

Class ODistributedWorker

java.lang.Object

java.lang.Thread

com.orientechnologies.orient.server.distributed.impl.ODistributedWorker

All Implemented Interfaces:

Runnable

public class ODistributedWorker
extends Thread

Hazelcast implementation of distributed peer. There is one instance per database. Each node creates own instance to talk with each others.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected ODatabaseDocumentInternal	database
protected String	databaseName
protected ODistributedDatabaseImpl	distributed
protected int	id
protected OUser	lastUser
protected String	localNodeName
protected ArrayBlockingQueue<ODistributedRequest>	localQueue
protected ODistributedServerManager	manager
protected ODistributedMessageServiceImpl	msgService
protected boolean	running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ODistributedWorker(ODistributedDatabaseImpl iDistributed, String iDatabaseName, int i, boolean acceptsWhileNotOnline)

Method Summary

Modifier and Type	Method and Description
protected boolean	dbNotAvailable(int retry)
ODatabaseDocumentInternal	getDatabase()
protected String	getLocalNodeName()
long	getProcessedRequests()
ODistributedRequest	getProcessing()
protected void	handleError(ODistributedRequest iRequest, Object responsePayload)
void	initDatabaseInstance() Opens the database.
boolean	isWaitingForNextRequest()
protected ODistributedRequest	nextMessage()
protected void	onMessage(ODistributedRequest iRequest) Executes the remote call on the local node and send back the result
boolean	processRequest(ODistributedRequest request)
protected ODistributedRequest	readRequest()
void	reset()
void	run()
static boolean	sendResponseBack(Object current, ODistributedServerManager manager, ODistributedRequest iRequest, Object responsePayload)
void	sendShutdown()
void	shutdown()

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

distributed

protected final ODistributedDatabaseImpl distributed

manager

protected final ODistributedServerManager manager

msgService

protected final ODistributedMessageServiceImpl msgService

localNodeName

protected final String localNodeName

databaseName

protected final String databaseName

localQueue

protected final ArrayBlockingQueue<ODistributedRequest> localQueue

id

protected final int id

database

protected volatile ODatabaseDocumentInternal database

lastUser

protected volatile OUser lastUser

running

protected volatile boolean running

Constructor Detail

ODistributedWorker

public ODistributedWorker(ODistributedDatabaseImpl iDistributed,
                          String iDatabaseName,
                          int i,
                          boolean acceptsWhileNotOnline)

Method Detail

processRequest

public boolean processRequest(ODistributedRequest request)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

initDatabaseInstance

public void initDatabaseInstance()

Opens the database.

dbNotAvailable

protected boolean dbNotAvailable(int retry)

shutdown

public void shutdown()

getDatabase

public ODatabaseDocumentInternal getDatabase()

readRequest

protected ODistributedRequest readRequest()
                                   throws InterruptedException

Throws:

InterruptedException

isWaitingForNextRequest

public boolean isWaitingForNextRequest()

nextMessage

protected ODistributedRequest nextMessage()
                                   throws InterruptedException

Throws:

InterruptedException

onMessage

protected void onMessage(ODistributedRequest iRequest)

Executes the remote call on the local node and send back the result

handleError

protected void handleError(ODistributedRequest iRequest,
                           Object responsePayload)

getLocalNodeName

protected String getLocalNodeName()

sendResponseBack

public static boolean sendResponseBack(Object current,
                                       ODistributedServerManager manager,
                                       ODistributedRequest iRequest,
                                       Object responsePayload)

getProcessedRequests

public long getProcessedRequests()

reset

public void reset()

sendShutdown

public void sendShutdown()

getProcessing

public ODistributedRequest getProcessing()