org.jumpmind.symmetric.service.impl

Class ClusterService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.ClusterService

All Implemented Interfaces:

IClusterService, IService

public class ClusterService
extends AbstractService
implements IClusterService

See Also:

IClusterService

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
ClusterService(IParameterService parameterService, ISymmetricDialect dialect, INodeService nodeService, IExtensionService extensionService)

Method Summary

Modifier and Type	Method and Description
void	aquireInfiniteLock(java.lang.String action)
protected void	checkSymDbOwnership()
void	clearAllLocks()
void	clearInfiniteLock(java.lang.String action)
java.util.Map<java.lang.String,Lock>	findLocks()
protected java.lang.String	generateInstanceId(java.lang.String hostName) The instance id is similar in intent to the serverId, but it is generated by the system on initial startup, and semi-permanently cached as a file on the local file system.
java.lang.String	getInstanceId()
java.lang.String	getServerId() Get a unique identifier that represents the JVM instance this server is currently running in.
void	init()
protected void	initCache()
protected void	initInstanceId()
protected void	initLockTable(java.lang.String action)
protected void	initLockTable(java.lang.String action, java.lang.String lockType)
protected void	insertLock(Lock lock)
boolean	isClusteringEnabled()
boolean	isInfiniteLocked(java.lang.String action)
protected boolean	isLockRefreshNeeded(java.lang.String action)
boolean	lock(java.lang.String action)
boolean	lock(java.lang.String action, java.lang.String lockType)
boolean	lock(java.lang.String action, java.lang.String lockType, long waitMillis)
protected boolean	lockCluster(java.lang.String action, java.util.Date timeToBreakLock, java.util.Date timeLockAcquired, java.lang.String argServerId)
protected boolean	lockExclusive(java.lang.String action)
protected boolean	lockShared(java.lang.String action)
protected boolean	lockWait(java.lang.String action, java.lang.String lockType, long waitMillis)
void	persistToTableForSnapshot()
boolean	refreshLock(java.lang.String action)
void	refreshLockEntries()
void	unlock(java.lang.String action)
void	unlock(java.lang.String action, java.lang.String lockType)
protected boolean	unlockCluster(java.lang.String action, java.lang.String argServerId)
protected boolean	unlockExclusive(java.lang.String action)
protected boolean	unlockShared(java.lang.String action)
protected void	updateCacheLockTime(java.lang.String action, java.util.Date timeLockAcquired)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterService

public ClusterService(IParameterService parameterService,
                      ISymmetricDialect dialect,
                      INodeService nodeService,
                      IExtensionService extensionService)

Method Detail

init

public void init()

Specified by:

init in interface IClusterService

refreshLockEntries

public void refreshLockEntries()

Specified by:

refreshLockEntries in interface IClusterService

initInstanceId

protected void initInstanceId()

checkSymDbOwnership

protected void checkSymDbOwnership()

getInstanceId

public java.lang.String getInstanceId()

Specified by:

getInstanceId in interface IClusterService

persistToTableForSnapshot

public void persistToTableForSnapshot()

Specified by:

persistToTableForSnapshot in interface IClusterService

insertLock

protected void insertLock(Lock lock)

initLockTable

protected void initLockTable(java.lang.String action)

initLockTable

protected void initLockTable(java.lang.String action,
                             java.lang.String lockType)

initCache

protected void initCache()

clearAllLocks

public void clearAllLocks()

Specified by:

clearAllLocks in interface IClusterService

lock

public boolean lock(java.lang.String action,
                    java.lang.String lockType)

Specified by:

lock in interface IClusterService

lock

public boolean lock(java.lang.String action,
                    java.lang.String lockType,
                    long waitMillis)

Specified by:

lock in interface IClusterService

lock

public boolean lock(java.lang.String action)

Specified by:

lock in interface IClusterService

lockCluster

protected boolean lockCluster(java.lang.String action,
                              java.util.Date timeToBreakLock,
                              java.util.Date timeLockAcquired,
                              java.lang.String argServerId)

updateCacheLockTime

protected void updateCacheLockTime(java.lang.String action,
                                   java.util.Date timeLockAcquired)

lockShared

protected boolean lockShared(java.lang.String action)

lockExclusive

protected boolean lockExclusive(java.lang.String action)

lockWait

protected boolean lockWait(java.lang.String action,
                           java.lang.String lockType,
                           long waitMillis)

findLocks

public java.util.Map<java.lang.String,Lock> findLocks()

Specified by:

findLocks in interface IClusterService

generateInstanceId

protected java.lang.String generateInstanceId(java.lang.String hostName)

The instance id is similar in intent to the serverId, but it is generated by the system on initial startup, and semi-permanently cached as a file on the local file system. The intension is to uniquely identity SymmetricDS installations, and protect against situations where things are misconfigured and potentially pointed at the wrong databases, or pointed at the same database without the cluster.lock.enabled parameter turned on.

getServerId

public java.lang.String getServerId()

Get a unique identifier that represents the JVM instance this server is currently running in.

Specified by:

getServerId in interface IClusterService

unlock

public void unlock(java.lang.String action,
                   java.lang.String lockType)

Specified by:

unlock in interface IClusterService

unlock

public void unlock(java.lang.String action)

Specified by:

unlock in interface IClusterService

unlockCluster

protected boolean unlockCluster(java.lang.String action,
                                java.lang.String argServerId)

unlockShared

protected boolean unlockShared(java.lang.String action)

unlockExclusive

protected boolean unlockExclusive(java.lang.String action)

isClusteringEnabled

public boolean isClusteringEnabled()

Specified by:

isClusteringEnabled in interface IClusterService

isInfiniteLocked

public boolean isInfiniteLocked(java.lang.String action)

Specified by:

isInfiniteLocked in interface IClusterService

aquireInfiniteLock

public void aquireInfiniteLock(java.lang.String action)

Specified by:

aquireInfiniteLock in interface IClusterService

clearInfiniteLock

public void clearInfiniteLock(java.lang.String action)

Specified by:

clearInfiniteLock in interface IClusterService

refreshLock

public boolean refreshLock(java.lang.String action)

Specified by:

refreshLock in interface IClusterService

isLockRefreshNeeded

protected boolean isLockRefreshNeeded(java.lang.String action)