ERXRemoteSynchronizer Class Reference

Inherited by ERXSimpleMulticastSynchronizer, and ERJGroupsSynchronizer.

Collaboration diagram for ERXRemoteSynchronizer:

[legend]

List of all members.

Classes
class	RefByteArrayOutputStream
Public Member Functions
	ERXRemoteSynchronizer (IChangeListener listener)
NSDictionary	globalIDsGroupedByEntity (NSArray gids)
abstract void	join () throws Throwable
abstract void	leave () throws Throwable
abstract void	listen () throws Throwable
boolean	shouldSynchronizeEntity (String entityName)
void	writeCacheChanges (int transactionID, NSArray cacheChanges) throws Throwable
Static Public Member Functions
static ERXRemoteSynchronizer	newRemoteSynchronizer (IChangeListener changeListener) throws Throwable
static boolean	remoteSynchronizerEnabled ()
Static Public Attributes
static Logger	log = Logger.getLogger(ERXRemoteSynchronizer.class)
Protected Member Functions
void	_readCacheChange (RemoteChange remoteChange, DataInputStream dis) throws IOException
EOGlobalID	_readGID (EOEntityClassDescription classDescription, String entityName, DataInputStream dis) throws IOException
void	_writeCacheChange (DataOutputStream dos, ERXDatabase.CacheChange cacheChange) throws IOException
abstract void	_writeCacheChanges (int transactionID, NSArray cacheChanges) throws Throwable
void	addChange (RemoteChange remoteChange)
NSArray	filteredCacheChanges (NSArray cacheChanges)
boolean	handleMessageType (int messageType, RemoteChange remoteChange, DataInputStream dis)
EOGlobalID	readGID (DataInputStream dis) throws IOException
NSArray	readGIDs (DataInputStream dis) throws IOException
Object	readKey (DataInputStream dis) throws IOException
void	writeGID (DataOutputStream dos, EOGlobalID gid) throws IOException
void	writeGIDKeys (DataOutputStream dos, EOKeyGlobalID gid) throws IOException
void	writeGIDs (DataOutputStream dos, NSArray gids) throws IOException
void	writeKey (DataOutputStream dos, Object key) throws IOException
void	writeSnapshotCacheChange (DataOutputStream dos, ERXDatabase.CacheChange cacheChange) throws IOException
Private Attributes
NSSet	_excludeEntityNames
NSSet	_includeEntityNames
IChangeListener	_listener
Static Private Attributes
static final int	BYTE_TYPE = 1
static final int	DATA_TYPE = 5
static final int	DELETE = 5
static final int	INSERT = 3
static final int	INT_TYPE = 3
static final int	INVALIDATE = 7
static final int	LONG_TYPE = 4
static final int	SHORT_TYPE = 2
static final int	STRING_TYPE = 6
static final int	TO_MANY_UPDATE = 6
static final int	UPDATE = 4

---

Constructor & Destructor Documentation

ERXRemoteSynchronizer

(

IChangeListener

listener

)

---

Member Function Documentation

void _readCacheChange	(	RemoteChange	remoteChange,
		DataInputStream	dis
	)			throws IOException [protected]

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

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

abstract void _writeCacheChanges	(	int	transactionID,
		NSArray	cacheChanges
	)			throws Throwable [protected, pure virtual]

Implemented in ERXSimpleMulticastSynchronizer, and ERJGroupsSynchronizer.

void addChange

(

RemoteChange

remoteChange

)

[protected]

NSArray filteredCacheChanges

(

NSArray

cacheChanges

)

[protected]

NSDictionary globalIDsGroupedByEntity

(

NSArray

gids

)

boolean handleMessageType	(	int	messageType,
		RemoteChange	remoteChange,
		DataInputStream	dis
	)			[protected]

Reimplemented in ERXSimpleMulticastSynchronizer.

abstract void join

(

)

throws Throwable [pure virtual]

Implemented in ERXSimpleMulticastSynchronizer, and ERJGroupsSynchronizer.

abstract void leave

(

)

throws Throwable [pure virtual]

Implemented in ERXSimpleMulticastSynchronizer, and ERJGroupsSynchronizer.

abstract void listen

(

)

throws Throwable [pure virtual]

Implemented in ERXSimpleMulticastSynchronizer, and ERJGroupsSynchronizer.

static ERXRemoteSynchronizer newRemoteSynchronizer

(

IChangeListener

changeListener

)

throws Throwable [static]

EOGlobalID readGID

(

DataInputStream

dis

)

throws IOException [protected]

NSArray readGIDs

(

DataInputStream

dis

)

throws IOException [protected]

Object readKey

(

DataInputStream

dis

)

throws IOException [protected]

static boolean remoteSynchronizerEnabled

(

)

[static]

boolean shouldSynchronizeEntity

(

String

entityName

)

void writeCacheChanges	(	int	transactionID,
		NSArray	cacheChanges
	)			throws Throwable

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

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

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

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

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

---

Member Data Documentation

NSSet _excludeEntityNames [private]

NSSet _includeEntityNames [private]

IChangeListener _listener [private]

final int BYTE_TYPE = 1 [static, private]

final int DATA_TYPE = 5 [static, private]

final int DELETE = 5 [static, private]

final int INSERT = 3 [static, private]

final int INT_TYPE = 3 [static, private]

final int INVALIDATE = 7 [static, private]

Logger log = Logger.getLogger(ERXRemoteSynchronizer.class) [static]

final int LONG_TYPE = 4 [static, private]

final int SHORT_TYPE = 2 [static, private]

final int STRING_TYPE = 6 [static, private]

final int TO_MANY_UPDATE = 6 [static, private]

final int UPDATE = 4 [static, private]

---

The documentation for this class was generated from the following file:

• /opt/source/Wonder/Frameworks/Core/ERExtensions/Sources/er/extensions/remoteSynchronizer/ERXRemoteSynchronizer.java