ERXObjectStoreCoordinatorSynchronizer.ProcessChangesQueue Class Reference

Inherits er::extensions::eof::ERXObjectStoreCoordinatorSynchronizer::IChangeListener.

Collaboration diagram for ERXObjectStoreCoordinatorSynchronizer.ProcessChangesQueue:

[legend]

List of all members.

Classes
class	CacheChangeProcessor
class	DeleteCacheChangeProcessor
class	DeleteSnapshotProcessor
class	InsertCacheChangeProcessor
class	InsertSnapshotProcessor
class	InvalidateSnapshotProcessor
class	RelationshipSnapshotProcessor
class	SnapshotProcessor
class	ToManyUpdateCacheChangeProcessor
class	UpdateCacheChangeProcessor
class	UpdateSnapshotProcessor
Public Member Functions
void	addChange (Change changes)
void	run ()
void	stop ()
Protected Member Functions
void	_process (EOObjectStoreCoordinator sender, EOObjectStoreCoordinator osc, NSMutableDictionary dbcs, SnapshotProcessor processor, NSDictionary changesByEntity, String userInfoKey)
void	process (EOObjectStoreCoordinator sender, SnapshotProcessor processor, NSDictionary changesByEntity, String userInfoKey)
	ProcessChangesQueue ()
void	processRemoteChange (RemoteChange remoteChange)
void	publishRemoteChanges (int transactionID, LocalChange localChange)
Private Attributes
CacheChangeProcessor	_deleteCacheChangeProcessor = new DeleteCacheChangeProcessor()
SnapshotProcessor	_deleteProcessor = new DeleteSnapshotProcessor()
List	_elements = new LinkedList()
CacheChangeProcessor	_insertCacheChangeProcessor = new InsertCacheChangeProcessor()
SnapshotProcessor	_insertProcessor = new InsertSnapshotProcessor()
SnapshotProcessor	_invalidateProcessor = new InvalidateSnapshotProcessor()
boolean	_running
CacheChangeProcessor	_toManyUpdateCacheChangeProcessor = new ToManyUpdateCacheChangeProcessor()
int	_transactionID
CacheChangeProcessor	_updateCacheChangeProcessor = new UpdateCacheChangeProcessor()
SnapshotProcessor	_updateProcessor = new UpdateSnapshotProcessor()

---

Detailed Description

Thread and locking safe implementation to propagate the changes from one EOF stack to another.

---

Constructor & Destructor Documentation

ProcessChangesQueue

(

)

[protected]

---

Member Function Documentation

void _process	(	EOObjectStoreCoordinator	sender,
		EOObjectStoreCoordinator	osc,
		NSMutableDictionary	dbcs,
		SnapshotProcessor	processor,
		NSDictionary	changesByEntity,
		String	userInfoKey
	)			[protected]

void addChange

(

Change

changes

)

Implements ERXObjectStoreCoordinatorSynchronizer.IChangeListener.

void process	(	EOObjectStoreCoordinator	sender,
		SnapshotProcessor	processor,
		NSDictionary	changesByEntity,
		String	userInfoKey
	)			[protected]

Parameters:

	dictionary
	sender

void processRemoteChange

(

RemoteChange

remoteChange

)

[protected]

void publishRemoteChanges	(	int	transactionID,
		LocalChange	localChange
	)			[protected]

void run

(

)

void stop

(

)

---

Member Data Documentation

CacheChangeProcessor _deleteCacheChangeProcessor = new DeleteCacheChangeProcessor() [private]

SnapshotProcessor _deleteProcessor = new DeleteSnapshotProcessor() [private]

List _elements = new LinkedList() [private]

CacheChangeProcessor _insertCacheChangeProcessor = new InsertCacheChangeProcessor() [private]

SnapshotProcessor _insertProcessor = new InsertSnapshotProcessor() [private]

SnapshotProcessor _invalidateProcessor = new InvalidateSnapshotProcessor() [private]

boolean _running [private]

CacheChangeProcessor _toManyUpdateCacheChangeProcessor = new ToManyUpdateCacheChangeProcessor() [private]

int _transactionID [private]

CacheChangeProcessor _updateCacheChangeProcessor = new UpdateCacheChangeProcessor() [private]

SnapshotProcessor _updateProcessor = new UpdateSnapshotProcessor() [private]

---

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

• /opt/source/Wonder/Frameworks/Core/ERExtensions/Sources/er/extensions/eof/ERXObjectStoreCoordinatorSynchronizer.java