com.j_spaces.core.server.processor

Class Processor

java.lang.Object

com.j_spaces.core.server.processor.Processor

All Implemented Interfaces:

IConsumerObject<BusPacket<Processor>>

public class Processor
extends Object
implements IConsumerObject<BusPacket<Processor>>

Main logic handler inside engine.

Constructor Summary

Constructors

Constructor and Description
Processor(SpaceEngine engine)

Method Summary

Modifier and Type	Method and Description
void	cleanUp() clean up resources
void	dispatch(BusPacket<Processor> packet) Main event loop.
void	entryArrivedSA(EntryArrivedPacket packet) Handles EntryArrived packets.
void	entryUnmatchedSA(EntryUnmatchedPacket packet) Handles overridden packets.
void	entryUpdatedSA(EntryUpdatedPacket packet)
void	handleCheckXtnStatusInTm(CheckXtnStatusInTmBusPackect packet) Handles check xtn state in TM .
void	handleCommitSA(CommitBusPacket packet) Handles commit SA.
void	handleCommittedTakenEntries(Context context, XtnEntry xtnEntry) handle taken entries under commit .
void	handleDirectChangeSA(Context context, ITemplateHolder template, boolean fromReplication, boolean origin)
void	handleDirectMultipleChangeSA(Context context, ITemplateHolder template)
void	handleDirectMultipleReadIEOrTakeIESA(Context context, ITemplateHolder template)
void	handleDirectMultipleReadTakeSA(Context context, ITemplateHolder template)
void	handleDirectReadIEOrTakeIESA(Context context, ITemplateHolder template, boolean fromReplication, boolean origin)
void	handleDirectReadOrTakeSA(Context context, ITemplateHolder template, boolean fromReplication, boolean origin)
void	handleDirectUpdateSA(Context context, ITemplateHolder template) perform update given a template which is the updated entry.
WriteEntryResult	handleDirectWriteSA(Context context, IEntryHolder entry, IServerTypeDesc typeDesc, boolean fromReplication, boolean origin, boolean reInsertedEntry, boolean supplied_uid, boolean lockXtnsIfNeeded, int modifiers) Handles Direct write SA.
void	handleEntryExpiredCoreSA(IEntryHolder entry, ServerTransaction txn, boolean fromReplication) Handles EntryExpired packets.
void	handleEntryExpiredSA(EntryExpiredBusPacket packet) Handles EntryExpired packets.
void	handleEntryTakenSA(EntryTakenPacket packet) Handles EntryTaked packets.
void	handleLockedFifoEntriesBeforeXtnEnd(Context context, XtnEntry xtnEntry, boolean fromRollback) before xtn terminated update the last readLock/Writelock fifo xtn number for this entryin order to have a coherent picture its is called during prepare/commit/rb from the engine main routines before status change
void	handleLockedFifoEntriesOnXtnEnd(Context context, XtnEntry xtnEntry, boolean fromRollback) when xtn terminated send the fifo entries to look for for fifo templates its is called during commit/rb from the engine main routines
void	handleNewRolledbackEntries(Context context, XtnEntry xtnEntry) handle new entries under rollback .
boolean	handleNotifyFifoInCommit(Context context, XtnEntry xtnEntry, boolean fifoNotifyForNonFifoEvents) this routine is called if the m_CrossXtnsFifoNotifications proprty is set if inserts the entries to the recentFifo queue of notify this routine is called directly after commit and not by backgroud thread return true if any entry considered
void	handleNotifyRegistration(NotifyTemplateHolder template, boolean fromReplication, AnswerHolder answer, OperationID operationID)
void	handleRemoveWaitingForInfoSA(RemoveWaitingForInfoSABusPacket packet) Handles the remove of waiting for info of a entry .
void	handleRollbackSA(RollbackBusPacket packet) Handles rollback SA.
void	handleUpdateOrWrite(IResponseContext respContext, UpdateOrWriteContext ctx, ReplyPacket<?> respPacket)

Methods inherited from class java.lang.Object

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

Constructor Detail

Processor

public Processor(SpaceEngine engine)

Method Detail

cleanUp

public void cleanUp()

Description copied from interface: IConsumerObject

clean up resources

Specified by:

cleanUp in interface IConsumerObject<BusPacket<Processor>>

dispatch

public void dispatch(BusPacket<Processor> packet)

Main event loop. Handles Bus Packets.

Specified by:

dispatch in interface IConsumerObject<BusPacket<Processor>>

handleDirectWriteSA

public WriteEntryResult handleDirectWriteSA(Context context,
                                            IEntryHolder entry,
                                            IServerTypeDesc typeDesc,
                                            boolean fromReplication,
                                            boolean origin,
                                            boolean reInsertedEntry,
                                            boolean supplied_uid,
                                            boolean lockXtnsIfNeeded,
                                            int modifiers)
                                     throws TransactionException,
                                            UnusableEntryException,
                                            RemoteException,
                                            SAException

Handles Direct write SA. if entryHolder.m_NoWriteLease == true, the return value will be String otherwise LeaseProxy

Throws:

TransactionException

UnusableEntryException

RemoteException

SAException

handleUpdateOrWrite

public void handleUpdateOrWrite(IResponseContext respContext,
                                UpdateOrWriteContext ctx,
                                ReplyPacket<?> respPacket)

handleDirectUpdateSA

public void handleDirectUpdateSA(Context context,
                                 ITemplateHolder template)

perform update given a template which is the updated entry.

entryUpdatedSA

public void entryUpdatedSA(EntryUpdatedPacket packet)
                    throws EntryDeletedException,
                           SAException

Parameters:

packet -

Throws:

SAException

EntryDeletedException

entryUnmatchedSA

public void entryUnmatchedSA(EntryUnmatchedPacket packet)
                      throws SAException,
                             EntryDeletedException

Handles overridden packets.

Throws:

SAException

EntryDeletedException

entryArrivedSA

public void entryArrivedSA(EntryArrivedPacket packet)
                    throws SAException,
                           EntryDeletedException

Handles EntryArrived packets.

Throws:

SAException

EntryDeletedException

handleEntryTakenSA

public void handleEntryTakenSA(EntryTakenPacket packet)
                        throws Exception

Handles EntryTaked packets.

Throws:

Exception

handleEntryExpiredSA

public void handleEntryExpiredSA(EntryExpiredBusPacket packet)
                          throws Exception

Handles EntryExpired packets.

Throws:

Exception

handleEntryExpiredCoreSA

public void handleEntryExpiredCoreSA(IEntryHolder entry,
                                     ServerTransaction txn,
                                     boolean fromReplication)
                              throws Exception

Handles EntryExpired packets.

Throws:

Exception

handleDirectReadOrTakeSA

public void handleDirectReadOrTakeSA(Context context,
                                     ITemplateHolder template,
                                     boolean fromReplication,
                                     boolean origin)

handleDirectChangeSA

public void handleDirectChangeSA(Context context,
                                 ITemplateHolder template,
                                 boolean fromReplication,
                                 boolean origin)

handleDirectReadIEOrTakeIESA

public void handleDirectReadIEOrTakeIESA(Context context,
                                         ITemplateHolder template,
                                         boolean fromReplication,
                                         boolean origin)

handleNotifyRegistration

public void handleNotifyRegistration(NotifyTemplateHolder template,
                                     boolean fromReplication,
                                     AnswerHolder answer,
                                     OperationID operationID)

handleCommitSA

public void handleCommitSA(CommitBusPacket packet)
                    throws SAException

Handles commit SA.

Throws:

SAException

handleNotifyFifoInCommit

public boolean handleNotifyFifoInCommit(Context context,
                                        XtnEntry xtnEntry,
                                        boolean fifoNotifyForNonFifoEvents)
                                 throws SAException

this routine is called if the m_CrossXtnsFifoNotifications proprty is set if inserts the entries to the recentFifo queue of notify this routine is called directly after commit and not by backgroud thread return true if any entry considered

Throws:

SAException

handleLockedFifoEntriesOnXtnEnd

public void handleLockedFifoEntriesOnXtnEnd(Context context,
                                            XtnEntry xtnEntry,
                                            boolean fromRollback)
                                     throws SAException

when xtn terminated send the fifo entries to look for for fifo templates its is called during commit/rb from the engine main routines

Throws:

SAException

handleLockedFifoEntriesBeforeXtnEnd

public void handleLockedFifoEntriesBeforeXtnEnd(Context context,
                                                XtnEntry xtnEntry,
                                                boolean fromRollback)
                                         throws SAException

before xtn terminated update the last readLock/Writelock fifo xtn number for this entryin order to have a coherent picture its is called during prepare/commit/rb from the engine main routines before status change

Throws:

SAException

handleCommittedTakenEntries

public void handleCommittedTakenEntries(Context context,
                                        XtnEntry xtnEntry)
                                 throws SAException

handle taken entries under commit . NOTE: this method is called in prepare-commit stage in order to evict taken entries. taken entries are not handled in post-commit stage (habdleCommitSA) in order to enabled rewritting entries with same UIDS transaction table is locked when this method is called

Throws:

SAException

handleRollbackSA

public void handleRollbackSA(RollbackBusPacket packet)
                      throws SAException

Handles rollback SA.

Throws:

SAException

handleNewRolledbackEntries

public void handleNewRolledbackEntries(Context context,
                                       XtnEntry xtnEntry)
                                throws SAException

handle new entries under rollback . clean those entries. it is called directly in order to clean user-defined UIDS

Throws:

SAException

handleRemoveWaitingForInfoSA

public void handleRemoveWaitingForInfoSA(RemoveWaitingForInfoSABusPacket packet)
                                  throws SAException

Handles the remove of waiting for info of a entry .

Throws:

SAException

handleDirectMultipleReadTakeSA

public void handleDirectMultipleReadTakeSA(Context context,
                                           ITemplateHolder template)

handleDirectMultipleReadIEOrTakeIESA

public void handleDirectMultipleReadIEOrTakeIESA(Context context,
                                                 ITemplateHolder template)

handleDirectMultipleChangeSA

public void handleDirectMultipleChangeSA(Context context,
                                         ITemplateHolder template)

handleCheckXtnStatusInTm

public void handleCheckXtnStatusInTm(CheckXtnStatusInTmBusPackect packet)

Handles check xtn state in TM .