| hu.netmind.persistence.node.ServiceProvider
All known Subclasses: hu.netmind.persistence.node.NodeServer, hu.netmind.persistence.node.NodeManager, hu.netmind.persistence.node.NodeClient,
| ServiceProvider | | public interface ServiceProvider (Code) | | This is the interface which provides synchronization services
to nodes.
author:
Brautigam Robert
version:
Revision: $Revision$ |
| Method Summary | |
| void | endCommit(int index, Long serial)
Mark the end of a commit phase. | | Long | getNextSerial()
Get a new serial number. | | SessionInfo | lock(int index, long threadId, long txSerial, List metas, SessionInfo info, int wait, boolean ensureCurrent)
Lock an object.
Parameters:
index - The index of the node.
Parameters:
threadId - The id of the thread in which the lock operation was initiated.
Parameters:
metas - The metas to lock.
Parameters:
info - The session info to attach to lock.
Parameters:
wait - Number of milliseconds to wait, before lock considered used.
Parameters:
ensureCurrent - Ensure that the objects described in the metadata list are current. | | void | notifyChange(List metas, Long endSerial, Long txSerial)
Notify object changes. | | Long | startCommit(int index)
Wait for starting a commit. | | void | unlock(int index, long threadId, long txSerial, List metas)
Unlock objects. | | void | updateEntries(String tableName, Long serial)
Send cache update request. | | void | waitForQuery(Long serial)
Wait for a query to execute with the given serial. |
| endCommit | | void endCommit(int index, Long serial)(Code) | | Mark the end of a commit phase.
|
| getNextSerial | | Long getNextSerial()(Code) | | Get a new serial number.
|
| lock | | SessionInfo lock(int index, long threadId, long txSerial, List metas, SessionInfo info, int wait, boolean ensureCurrent)(Code) | | Lock an object.
Parameters:
index - The index of the node.
Parameters:
threadId - The id of the thread in which the lock operation was initiated.
Parameters:
metas - The metas to lock.
Parameters:
info - The session info to attach to lock.
Parameters:
wait - Number of milliseconds to wait, before lock considered used.
Parameters:
ensureCurrent - Ensure that the objects described in the metadata list are current. A session info if at least one of the objects if already locked. |
| notifyChange | | void notifyChange(List metas, Long endSerial, Long txSerial)(Code) | | Notify object changes.
|
| startCommit | | Long startCommit(int index)(Code) | | Wait for starting a commit. The commit can start if
there are no queries executed with greater serial.
The serial the commit can run with. |
| unlock | | void unlock(int index, long threadId, long txSerial, List metas)(Code) | | Unlock objects.
|
| updateEntries | | void updateEntries(String tableName, Long serial)(Code) | | Send cache update request.
|
| waitForQuery | | void waitForQuery(Long serial)(Code) | | Wait for a query to execute with the given serial.
This method returns, if all commits before the given serial
are finished.
|
|
|