er.extensions.remoteSynchronizer
Class ERXRemoteSynchronizer

java.lang.Object
  er.extensions.remoteSynchronizer.ERXRemoteSynchronizer

Direct Known Subclasses:

ERJGroupsSynchronizer, ERXSimpleMulticastSynchronizer

public abstract class ERXRemoteSynchronizer
extends Object

The superclass of all remote EOF synchronizers.

Author:

mschrag

Properties

er.extensions.remoteSynchronizer.enabled	if true, remote synchronization is enabled
er.extensions.remoteSynchronizer	the class name of the remote synchronizer to use (default to ERXSimpleMulticastSynchronizer)

Nested Class Summary

static class

ERXRemoteSynchronizer.RefByteArrayOutputStream

Field Summary

static Logger

log

Constructor Summary

ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)

Method Summary

protected void	_readCacheChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange, DataInputStream dis)
protected EOGlobalID	_readGID(EOEntityClassDescription classDescription, String entityName, DataInputStream dis)
protected void	_writeCacheChange(DataOutputStream dos, ERXDatabase.CacheChange cacheChange)
protected abstract void	_writeCacheChanges(int transactionID, NSArray cacheChanges)
protected void	addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)
protected NSArray	filteredCacheChanges(NSArray cacheChanges)
NSDictionary	globalIDsGroupedByEntity(NSArray gids)
protected boolean	handleMessageType(int messageType, ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange, DataInputStream dis)
abstract void	join()
abstract void	leave()
abstract void	listen()
static ERXRemoteSynchronizer	newRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener changeListener)
protected EOGlobalID	readGID(DataInputStream dis)
protected NSArray	readGIDs(DataInputStream dis)
protected Object	readKey(DataInputStream dis)
static boolean	remoteSynchronizerEnabled()
boolean	shouldSynchronizeEntity(String entityName)
void	writeCacheChanges(int transactionID, NSArray cacheChanges)
protected void	writeGID(DataOutputStream dos, EOGlobalID gid)
protected void	writeGIDKeys(DataOutputStream dos, EOKeyGlobalID gid)
protected void	writeGIDs(DataOutputStream dos, NSArray gids)
protected void	writeKey(DataOutputStream dos, Object key)
protected void	writeSnapshotCacheChange(DataOutputStream dos, ERXDatabase.CacheChange cacheChange)

Methods inherited from class java.lang.Object

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

Field Detail

log

public static Logger log

Constructor Detail

ERXRemoteSynchronizer

public ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)

Method Detail

remoteSynchronizerEnabled

public static boolean remoteSynchronizerEnabled()

newRemoteSynchronizer

public static ERXRemoteSynchronizer newRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener changeListener)
                                                   throws Throwable

Throws:

Throwable

_readCacheChange

protected void _readCacheChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
                                DataInputStream dis)
                         throws IOException

Throws:

IOException

handleMessageType

protected boolean handleMessageType(int messageType,
                                    ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
                                    DataInputStream dis)

_writeCacheChange

protected void _writeCacheChange(DataOutputStream dos,
                                 ERXDatabase.CacheChange cacheChange)
                          throws IOException

Throws:

IOException

writeSnapshotCacheChange

protected void writeSnapshotCacheChange(DataOutputStream dos,
                                        ERXDatabase.CacheChange cacheChange)
                                 throws IOException

Throws:

IOException

writeGIDs

protected void writeGIDs(DataOutputStream dos,
                         NSArray gids)
                  throws IOException

Throws:

IOException

writeGID

protected void writeGID(DataOutputStream dos,
                        EOGlobalID gid)
                 throws IOException

Throws:

IOException

writeGIDKeys

protected void writeGIDKeys(DataOutputStream dos,
                            EOKeyGlobalID gid)
                     throws IOException

Throws:

IOException

writeKey

protected void writeKey(DataOutputStream dos,
                        Object key)
                 throws IOException

Throws:

IOException

readGIDs

protected NSArray readGIDs(DataInputStream dis)
                    throws IOException

Throws:

IOException

readGID

protected EOGlobalID readGID(DataInputStream dis)
                      throws IOException

Throws:

IOException

_readGID

protected EOGlobalID _readGID(EOEntityClassDescription classDescription,
                              String entityName,
                              DataInputStream dis)
                       throws IOException

Throws:

IOException

readKey

protected Object readKey(DataInputStream dis)
                  throws IOException

Throws:

IOException

shouldSynchronizeEntity

public boolean shouldSynchronizeEntity(String entityName)

globalIDsGroupedByEntity

public NSDictionary globalIDsGroupedByEntity(NSArray gids)

addChange

protected void addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)

filteredCacheChanges

protected NSArray filteredCacheChanges(NSArray cacheChanges)

join

public abstract void join()
                   throws Throwable

Throws:

Throwable

leave

public abstract void leave()
                    throws Throwable

Throws:

Throwable

listen

public abstract void listen()
                     throws Throwable

Throws:

Throwable

writeCacheChanges

public void writeCacheChanges(int transactionID,
                              NSArray cacheChanges)
                       throws Throwable

Throws:

Throwable

_writeCacheChanges

protected abstract void _writeCacheChanges(int transactionID,
                                           NSArray cacheChanges)
                                    throws Throwable

Throws:

Throwable