com.orientechnologies.orient.server.distributed.impl

Class ODistributedMessageServiceImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedMessageServiceImpl

All Implemented Interfaces:

ODistributedMessageService

public class ODistributedMessageServiceImpl
extends Object
implements ODistributedMessageService

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)

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentHashMap<String,ODistributedDatabaseImpl>	databases

Constructor Summary

Constructors

Constructor and Description
ODistributedMessageServiceImpl(OHazelcastPlugin manager)

Method Summary

Modifier and Type	Method and Description
void	dispatchResponseToThread(ODistributedResponse response) Not synchronized, it's called when a message arrives
long	getAverageResponseTime()
long	getCurrentLatency(String server)
ODistributedDatabaseImpl	getDatabase(String iDatabaseName)
Set<String>	getDatabases()
ODocument	getLatencies()
ODocument	getMessageStats()
long	getProcessedRequests()
long	getReceivedRequests()
ODistributedResponseManager	getResponseManager(ODistributedRequestId reqId)
void	handleUnreachableNode(String nodeName)
protected void	purgePendingMessages()
ODistributedDatabaseImpl	registerDatabase(String iDatabaseName, ODistributedConfiguration cfg) Creates a distributed database instance if not defined yet.
void	registerRequest(long id, ODistributedResponseManager currentResponseMgr)
void	shutdown()
void	timeoutRequest(long msgId) Removes a response manager because in timeout.
ODistributedDatabaseImpl	unregisterDatabase(String iDatabaseName)
void	updateLatency(String server, long sentOn)
void	updateMessageStats(String message)

Methods inherited from class java.lang.Object

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

Field Detail

databases

protected final ConcurrentHashMap<String,ODistributedDatabaseImpl> databases

Constructor Detail

ODistributedMessageServiceImpl

public ODistributedMessageServiceImpl(OHazelcastPlugin manager)

Method Detail

getDatabase

public ODistributedDatabaseImpl getDatabase(String iDatabaseName)

Specified by:

getDatabase in interface ODistributedMessageService

shutdown

public void shutdown()

getResponseManager

public ODistributedResponseManager getResponseManager(ODistributedRequestId reqId)

Specified by:

getResponseManager in interface ODistributedMessageService

registerRequest

public void registerRequest(long id,
                            ODistributedResponseManager currentResponseMgr)

Specified by:

registerRequest in interface ODistributedMessageService

handleUnreachableNode

public void handleUnreachableNode(String nodeName)

getAverageResponseTime

public long getAverageResponseTime()

registerDatabase

public ODistributedDatabaseImpl registerDatabase(String iDatabaseName,
                                                 ODistributedConfiguration cfg)

Creates a distributed database instance if not defined yet.

Specified by:

registerDatabase in interface ODistributedMessageService

unregisterDatabase

public ODistributedDatabaseImpl unregisterDatabase(String iDatabaseName)

Specified by:

unregisterDatabase in interface ODistributedMessageService

getDatabases

public Set<String> getDatabases()

Specified by:

getDatabases in interface ODistributedMessageService

dispatchResponseToThread

public void dispatchResponseToThread(ODistributedResponse response)

Not synchronized, it's called when a message arrives

Specified by:

dispatchResponseToThread in interface ODistributedMessageService

timeoutRequest

public void timeoutRequest(long msgId)

Removes a response manager because in timeout.

getLatencies

public ODocument getLatencies()

Specified by:

getLatencies in interface ODistributedMessageService

getCurrentLatency

public long getCurrentLatency(String server)

Specified by:

getCurrentLatency in interface ODistributedMessageService

updateLatency

public void updateLatency(String server,
                          long sentOn)

Specified by:

updateLatency in interface ODistributedMessageService

purgePendingMessages

protected void purgePendingMessages()

getMessageStats

public ODocument getMessageStats()

Specified by:

getMessageStats in interface ODistributedMessageService

updateMessageStats

public void updateMessageStats(String message)

Specified by:

updateMessageStats in interface ODistributedMessageService

getReceivedRequests

public long getReceivedRequests()

Specified by:

getReceivedRequests in interface ODistributedMessageService

getProcessedRequests

public long getProcessedRequests()

Specified by:

getProcessedRequests in interface ODistributedMessageService