com.goldencode.p2j.net

Class LocalStateSync

java.lang.Object

com.goldencode.p2j.net.LocalStateSync

public class LocalStateSync
extends java.lang.Object

Used by a proxy to implement state synchronization where both "sides" are in the same JVM. Use sync() to drive the process. This class is needed by proxy implementations which are run without a network environment. This maintains the semantics of state synchronization which is necessary since any local redirector environments have no Session object which would otherwise service that requirement.

Field Summary

Fields

Modifier and Type	Field and Description
private StateSynchronizer	sink Sink for state changes.
private StateSynchronizer	source Source of state changes.

Constructor Summary

Constructors

Constructor and Description
LocalStateSync(StateSynchronizer source, StateSynchronizer sink) Constructor.

Method Summary

Modifier and Type	Method and Description
void	sync() Drive the state synchronization process by reading any pending changes and applying them if any changes are available.

Methods inherited from class java.lang.Object

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

Field Detail

source

private StateSynchronizer source

Source of state changes.

sink

private StateSynchronizer sink

Sink for state changes.

Constructor Detail

LocalStateSync

public LocalStateSync(StateSynchronizer source,
                      StateSynchronizer sink)

Constructor.

Parameters:

source - The state synchronizer from which to obtain changes. Must not be null.

sink - The state synchronizer in which to apply changes. Must not be null.

Method Detail

sync

public void sync()

Drive the state synchronization process by reading any pending changes and applying them if any changes are available. This method is normally called before any method invocation can occur in a proxy object.

Changes are obtained via StateSynchronizer.getChanges() and they are applied via StateSynchronizer.applyChanges(java.io.Externalizable). This method is synchronized to make all processing thread-safe.