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

Name	Description
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)
er.extensions.remoteSynchronizer.includeEntities	er.extensions.remoteSynchronizer.includeEntities
er.extensions.remoteSynchronizer.excludeEntities	er.extensions.remoteSynchronizer.excludeEntities

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ERXRemoteSynchronizer.RefByteArrayOutputStream

Constructor Summary

Constructors

Constructor and Description
ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)

Method Summary

Modifier and Type	Method and Description
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<ERXDatabase.CacheChange> cacheChanges)
protected void	addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)
protected NSArray<ERXDatabase.CacheChange>	filteredCacheChanges(NSArray<ERXDatabase.CacheChange> cacheChanges)
NSDictionary<String,NSSet<EOGlobalID>>	globalIDsGroupedByEntity(NSArray<EOGlobalID> 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<EOGlobalID>	readGIDs(DataInputStream dis)
protected Object	readKey(DataInputStream dis)
static boolean	remoteSynchronizerEnabled()
boolean	shouldSynchronizeEntity(String entityName)
void	writeCacheChanges(int transactionID, NSArray<ERXDatabase.CacheChange> cacheChanges)
protected void	writeGID(DataOutputStream dos, EOGlobalID gid)
protected void	writeGIDKeys(DataOutputStream dos, EOKeyGlobalID gid)
protected void	writeGIDs(DataOutputStream dos, NSArray<EOGlobalID> 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

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<EOGlobalID> 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<EOGlobalID> 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<String,NSSet<EOGlobalID>> globalIDsGroupedByEntity(NSArray<EOGlobalID> gids)

addChange

protected void addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)

filteredCacheChanges

protected NSArray<ERXDatabase.CacheChange> filteredCacheChanges(NSArray<ERXDatabase.CacheChange> 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<ERXDatabase.CacheChange> cacheChanges)
                       throws Throwable

Throws:

Throwable

_writeCacheChanges

protected abstract void _writeCacheChanges(int transactionID,
                                           NSArray<ERXDatabase.CacheChange> cacheChanges)
                                    throws Throwable

Throws:

Throwable