Module com.aoapps.appcluster.core

Package com.aoapps.appcluster

Class CronResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

java.lang.Object

com.aoapps.appcluster.ResourceSynchronizer<R,N>

com.aoapps.appcluster.CronResourceSynchronizer<R,N>

public abstract class CronResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>
extends ResourceSynchronizer<R,N>

Synchronizes resource based on cron-like schedules. If the local node is stopped, the synchronizer is stopped. If the locale node or the remote node is disabled, the synchronized is disabled. Otherwise, the synchronizer will operate on a cron-like scheduled basis for testing and synchronizing.

To support masters synchronizing while slaves only test, if a test and a synchronization are scheduled at the same moment, the synchronization is performed if possible, and the test is only performed if the synchronization is not possible. Thus, a synchronization also counts as a test and should perform at least as thorough of a check as a test would perform.

If a synchronization or test is missed, no catch-up is performed. This is true for both when the node is down or when a previous test/synchronization took too long, overlapping the current schedule.

Author:

AO Industries, Inc.

Field Summary

Fields inherited from class com.aoapps.appcluster.ResourceSynchronizer

localResourceNode, remoteResourceNode

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CronResourceSynchronizer(N localResourceNode, N remoteResourceNode, Schedule synchronizeSchedule, Schedule testSchedule)

Method Summary

Modifier and Type	Method	Description
protected abstract boolean	canSynchronize(ResourceSynchronizationMode mode, ResourceNodeDnsResult localDnsResult, ResourceNodeDnsResult remoteDnsResult)	Checks if a resource may be synchronized given the current DNS state of the nodes.
boolean	canSynchronizeNow(ResourceSynchronizationMode mode)	Determines if the synchronizer can run now.
boolean	getCanSynchronizeNow()	Convenience method for JavaBeans property.
boolean	getCanTestNow()	Convenience method for JavaBeans property.
ResourceSynchronizationResult	getLastResult()	Gets the last synchronization result or null if unavailable.
ResourceSynchronizerState	getState()	Gets the current synchronization state.
String	getStateMessage()	Gets a description of the current state or null for no specific message.
Schedule	getSynchronizeSchedule()	Gets the synchronize schedule.
Schedule	getTestSchedule()	Gets the test schedule.
protected void	start()	Starts the synchronizer.
protected void	stop()	Stops the synchronizer.
protected abstract ResourceSynchronizationResult	synchronize(ResourceSynchronizationMode mode, ResourceNodeDnsResult localDnsResult, ResourceNodeDnsResult remoteDnsResult)	Synchronizes (or tests) the resource.
void	synchronizeNow(ResourceSynchronizationMode mode)	Schedules an immediate synchronization if the resource is enabled and sleeping.

Methods inherited from class com.aoapps.appcluster.ResourceSynchronizer

getLocalResourceNode, getRemoteResourceNode, getResultStatus, toString

Methods inherited from class java.lang.Object

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

Constructor Details

CronResourceSynchronizer

protected CronResourceSynchronizer(N localResourceNode,
 N remoteResourceNode,
 Schedule synchronizeSchedule,
 Schedule testSchedule)

Method Details

getSynchronizeSchedule

public Schedule getSynchronizeSchedule()

Gets the synchronize schedule.

canSynchronizeNow

public boolean canSynchronizeNow(ResourceSynchronizationMode mode)

Determines if the synchronizer can run now.

getCanSynchronizeNow

public boolean getCanSynchronizeNow()

Convenience method for JavaBeans property.

See Also:

• canSynchronizeNow(com.aoapps.appcluster.ResourceSynchronizationMode)
• ResourceSynchronizationMode.SYNCHRONIZE

getCanTestNow

public boolean getCanTestNow()

Convenience method for JavaBeans property.

See Also:

• canSynchronizeNow(com.aoapps.appcluster.ResourceSynchronizationMode)
• ResourceSynchronizationMode.TEST_ONLY

synchronizeNow

public void synchronizeNow(ResourceSynchronizationMode mode)

Schedules an immediate synchronization if the resource is enabled and sleeping.

Specified by:

synchronizeNow in class ResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

getTestSchedule

public Schedule getTestSchedule()

Gets the test schedule.

getState

public ResourceSynchronizerState getState()

Description copied from class: ResourceSynchronizer

Gets the current synchronization state.

Specified by:

getState in class ResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

getStateMessage

public String getStateMessage()

Description copied from class: ResourceSynchronizer

Gets a description of the current state or null for no specific message.

Specified by:

getStateMessage in class ResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

getLastResult

public ResourceSynchronizationResult getLastResult()

Description copied from class: ResourceSynchronizer

Gets the last synchronization result or null if unavailable.

Specified by:

getLastResult in class ResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

start

protected void start()

Description copied from class: ResourceSynchronizer

Starts the synchronizer.

Specified by:

start in class ResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

stop

protected void stop()

Description copied from class: ResourceSynchronizer

Stops the synchronizer.

Specified by:

stop in class ResourceSynchronizer<R extends CronResource<R,N>,N extends CronResourceNode<R,N>>

canSynchronize

protected abstract boolean canSynchronize(ResourceSynchronizationMode mode,
 ResourceNodeDnsResult localDnsResult,
 ResourceNodeDnsResult remoteDnsResult)

Checks if a resource may be synchronized given the current DNS state of the nodes.

synchronize

protected abstract ResourceSynchronizationResult synchronize(ResourceSynchronizationMode mode,
 ResourceNodeDnsResult localDnsResult,
 ResourceNodeDnsResult remoteDnsResult)

Synchronizes (or tests) the resource.