Package 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

Modifier and Type	Field	Description
protected static final String[]	actions
protected IExtensionService	extensionService
protected static String	instanceId
protected static boolean	isUpgradedInstanceId
protected Map<String,Lock>	lockCache
protected static final org.slf4j.Logger	log
protected INodeService	nodeService
protected String	serverId
protected static final String[]	sharedActions

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

parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addLock(String action, String lockType)
void	aquireInfiniteLock(String action)
protected void	checkSymDbOwnership()
void	clearAllLocks()
void	clearInfiniteLock(String action)
protected void	disableSharedLock(String action)
Map<String,Lock>	findLocks()
protected static String	generateInstanceId(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.
String	getInstanceId()
String	getServerId()	Get a unique identifier that represents the JVM instance this server is currently running in.
void	init()
protected final void	initCache()
protected void	initInstanceId()
static String	initInstanceId(IClusterInstanceGenerator generator)
protected void	insertLock(Lock lock)
boolean	isClusteringEnabled()
boolean	isInfiniteLocked(String action)
boolean	isLocked(String action)
boolean	lock(String action)
boolean	lock(String action, String lockType)
boolean	lock(String action, String lockType, long waitMillis)
protected boolean	lockCluster(String action, Date timeToBreakLock, Date timeLockAcquired, String argServerId)
protected boolean	lockExclusive(String action)
protected boolean	lockShared(String action)
protected boolean	lockWait(String action, String lockType, long waitMillis)
void	persistToTableForSnapshot()
boolean	refreshLock(String action)
void	refreshLockEntries()
void	removeLock(String action)
void	unlock(String action)
void	unlock(String action, String lockType)
protected boolean	unlockCluster(String action, String argServerId)
protected boolean	unlockExclusive(String action)
protected boolean	unlockShared(String action)
protected void	updateCacheLockTime(String action, Date timeLockAcquired)

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

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, 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

Field Details

actions

protected static final String[] actions

sharedActions

protected static final String[] sharedActions

isUpgradedInstanceId

protected static boolean isUpgradedInstanceId

log

protected static final org.slf4j.Logger log

serverId

protected String serverId

instanceId

protected static String instanceId

nodeService

protected INodeService nodeService

extensionService

protected IExtensionService extensionService

lockCache

protected Map<String,Lock> lockCache

Constructor Details

ClusterService

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

Method Details

init

public void init()

Specified by:

init in interface IClusterService

refreshLockEntries

public void refreshLockEntries()

Specified by:

refreshLockEntries in interface IClusterService

initInstanceId

protected void initInstanceId()

initInstanceId

public static String initInstanceId(IClusterInstanceGenerator generator)

checkSymDbOwnership

protected void checkSymDbOwnership()

getInstanceId

public String getInstanceId()

Specified by:

getInstanceId in interface IClusterService

persistToTableForSnapshot

public void persistToTableForSnapshot()

Specified by:

persistToTableForSnapshot in interface IClusterService

insertLock

protected void insertLock(Lock lock)

initCache

protected final void initCache()

addLock

public void addLock(String action,
 String lockType)

Specified by:

addLock in interface IClusterService

removeLock

public void removeLock(String action)

Specified by:

removeLock in interface IClusterService

clearAllLocks

public void clearAllLocks()

Specified by:

clearAllLocks in interface IClusterService

lock

public boolean lock(String action,
 String lockType)

Specified by:

lock in interface IClusterService

lock

public boolean lock(String action,
 String lockType,
 long waitMillis)

Specified by:

lock in interface IClusterService

lock

public boolean lock(String action)

Specified by:

lock in interface IClusterService

lockCluster

protected boolean lockCluster(String action,
 Date timeToBreakLock,
 Date timeLockAcquired,
 String argServerId)

updateCacheLockTime

protected void updateCacheLockTime(String action,
 Date timeLockAcquired)

lockShared

protected boolean lockShared(String action)

lockExclusive

protected boolean lockExclusive(String action)

lockWait

protected boolean lockWait(String action,
 String lockType,
 long waitMillis)

disableSharedLock

protected void disableSharedLock(String action)

findLocks

public Map<String,Lock> findLocks()

Specified by:

findLocks in interface IClusterService

generateInstanceId

protected static String generateInstanceId(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 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(String action,
 String lockType)

Specified by:

unlock in interface IClusterService

unlock

public void unlock(String action)

Specified by:

unlock in interface IClusterService

unlockCluster

protected boolean unlockCluster(String action,
 String argServerId)

unlockShared

protected boolean unlockShared(String action)

unlockExclusive

protected boolean unlockExclusive(String action)

isLocked

public boolean isLocked(String action)

Specified by:

isLocked in interface IClusterService

isInfiniteLocked

public boolean isInfiniteLocked(String action)

Specified by:

isInfiniteLocked in interface IClusterService

aquireInfiniteLock

public void aquireInfiniteLock(String action)

Specified by:

aquireInfiniteLock in interface IClusterService

clearInfiniteLock

public void clearInfiniteLock(String action)

Specified by:

clearInfiniteLock in interface IClusterService

refreshLock

public boolean refreshLock(String action)

Specified by:

refreshLock in interface IClusterService

isClusteringEnabled

public boolean isClusteringEnabled()

Specified by:

isClusteringEnabled in interface IClusterService