org.objectweb.cjdbc.controller.scheduler.raidb1
Class RAIDb1QueryLevelScheduler

java.lang.Object
  org.objectweb.cjdbc.controller.scheduler.AbstractScheduler
      org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1QueryLevelScheduler

All Implemented Interfaces:

XmlComponent

public class RAIDb1QueryLevelScheduler

extends AbstractScheduler

This scheduler provides query level scheduling for RAIDb-1 controllers. Reads can execute in parallel until a write comes in. Then the write waits for the completion of the reads. Any new read is stacked after the write and they are released together when the write has completed its execution.

Version:

1.0

Author:

Emmanuel Cecchet , Jean-Bernard van Zuylen

Field Summary

private int	pendingReads
private java.lang.Object	readSync
private long	requestId
private java.lang.Object	writeSync

Fields inherited from class org.objectweb.cjdbc.controller.scheduler.AbstractScheduler

logger, parsingGranularity, raidbLevel

Fields inherited from interface org.objectweb.cjdbc.common.xml.XmlComponent

DOCTYPE_CONTROLLER, DOCTYPE_DB, XML_VERSION

Constructor Summary

RAIDb1QueryLevelScheduler()
Creates a new Query Level Scheduler

Method Summary

protected void	commitTransaction(long transactionId) Commit a transaction given its id.
java.lang.String	getXmlImpl()
void	notifyStoredProcedureCompleted(StoredProcedure proc) Notify the completion of a stored procedure.
void	notifyWriteCompleted(AbstractWriteRequest request) Notify the completion of a write statement.
void	readCompletedNotify(SelectRequest request) Notify the completion of a read statement.
protected void	releaseSavepointTransaction(long transactionId, java.lang.String name) Release a savepoint given its name from a transaction given its id.
protected void	rollbackTransaction(long transactionId) Rollback a transaction given its id.
protected void	rollbackTransaction(long transactionId, java.lang.String savepointName) Rollback a transaction given its id to a savepoint given its name.
void	scheduleNonSuspendedStoredProcedure(StoredProcedure proc) Schedule a write request (implementation specific).
void	scheduleNonSuspendedWriteRequest(AbstractWriteRequest request) Schedule a write request (implementation specific).
void	scheduleReadRequest(SelectRequest request) Schedule a read request (implementation specific).
protected void	setSavepointTransaction(long transactionId, java.lang.String name) Set a savepoint given its name to a transaction given its id.
private void	waitForReadCompletion(AbstractRequest request) Wait for the reads completion.

Methods inherited from class org.objectweb.cjdbc.controller.scheduler.AbstractScheduler

begin, beginCompleted, commit, commitCompleted, getNumberRead, getNumberWrite, getParsingGranularity, getPendingTransactions, getPendingWrites, getRAIDbLevel, getSchedulerData, getXml, incrementSavepointId, initializeTransactionId, isSuspendedTransactions, isSuspendedWrites, mergeDatabaseSchema, readCompleted, releaseSavepoint, resumeNewTransactions, resumeWrites, rollback, rollback, rollbackCompleted, savepointCompleted, scheduleStoredProcedure, scheduleWriteRequest, setDatabaseSchema, setParsingGranularity, setRAIDbLevel, setSavepoint, setSavepoint, storedProcedureCompleted, suspendNewTransactionsForCheckpoint, suspendWrites, writeCompleted

Methods inherited from class java.lang.Object

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

Field Detail

requestId

private long requestId

pendingReads

private int pendingReads

readSync

private java.lang.Object readSync

writeSync

private java.lang.Object writeSync

Constructor Detail

RAIDb1QueryLevelScheduler

public RAIDb1QueryLevelScheduler()

Creates a new Query Level Scheduler

Method Detail

scheduleReadRequest

public void scheduleReadRequest(SelectRequest request)
                         throws java.sql.SQLException

Description copied from class: AbstractScheduler

Schedule a read request (implementation specific). This method blocks until the read can be executed.

Specified by:

scheduleReadRequest in class AbstractScheduler

Parameters:

request - Select request to schedule (SQL macros are already handled if needed)

Throws:

java.sql.SQLException - if a timeout occurs

See Also:

AbstractScheduler.scheduleReadRequest(SelectRequest)

readCompletedNotify

public final void readCompletedNotify(SelectRequest request)

Description copied from class: AbstractScheduler

Notify the completion of a read statement.

Specified by:

readCompletedNotify in class AbstractScheduler

Parameters:

request - the completed request

See Also:

AbstractScheduler.readCompletedNotify(SelectRequest)

scheduleNonSuspendedWriteRequest

public void scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
                                      throws java.sql.SQLException

Description copied from class: AbstractScheduler

Schedule a write request (implementation specific). This method blocks until the request can be executed.

Specified by:

scheduleNonSuspendedWriteRequest in class AbstractScheduler

Parameters:

request - Write request to schedule (SQL macros are already handled if needed)

Throws:

java.sql.SQLException - if a timeout occurs

See Also:

AbstractScheduler.scheduleWriteRequest(AbstractWriteRequest)

notifyWriteCompleted

public final void notifyWriteCompleted(AbstractWriteRequest request)

Description copied from class: AbstractScheduler

Notify the completion of a write statement. This method does not need to be synchronized, it is enforced by the caller.

Specified by:

notifyWriteCompleted in class AbstractScheduler

Parameters:

request - the completed request

See Also:

AbstractScheduler.notifyWriteCompleted(AbstractWriteRequest)

scheduleNonSuspendedStoredProcedure

public final void scheduleNonSuspendedStoredProcedure(StoredProcedure proc)
                                               throws java.sql.SQLException,
                                                      RollbackException

Description copied from class: AbstractScheduler

Schedule a write request (implementation specific). This method blocks until the request can be executed.

Specified by:

scheduleNonSuspendedStoredProcedure in class AbstractScheduler

Parameters:

proc - Stored procedure to schedule

Throws:

java.sql.SQLException - if a timeout occurs

RollbackException - if the transaction must be rollbacked

See Also:

AbstractScheduler.scheduleNonSuspendedStoredProcedure(org.objectweb.cjdbc.common.sql.StoredProcedure)

notifyStoredProcedureCompleted

public final void notifyStoredProcedureCompleted(StoredProcedure proc)

Description copied from class: AbstractScheduler

Notify the completion of a stored procedure. This method does not need to be synchronized, it is enforced by the caller.

Specified by:

notifyStoredProcedureCompleted in class AbstractScheduler

Parameters:

proc - the completed stored procedure

See Also:

AbstractScheduler.notifyStoredProcedureCompleted(org.objectweb.cjdbc.common.sql.StoredProcedure)

waitForReadCompletion

private void waitForReadCompletion(AbstractRequest request)
                            throws java.sql.SQLException

Wait for the reads completion. Synchronizes on this.readSync.

Parameters:

request - the request that is being scheduled

Throws:

java.sql.SQLException - if an error occurs

commitTransaction

protected final void commitTransaction(long transactionId)

Description copied from class: AbstractScheduler

Commit a transaction given its id.

Specified by:

commitTransaction in class AbstractScheduler

Parameters:

transactionId - the transaction id

See Also:

AbstractScheduler.commitTransaction(long)

rollbackTransaction

protected final void rollbackTransaction(long transactionId)

Description copied from class: AbstractScheduler

Rollback a transaction given its id.

Specified by:

rollbackTransaction in class AbstractScheduler

Parameters:

transactionId - the transaction id

See Also:

AbstractScheduler.rollbackTransaction(long)

rollbackTransaction

protected final void rollbackTransaction(long transactionId,
                                         java.lang.String savepointName)

Description copied from class: AbstractScheduler

Rollback a transaction given its id to a savepoint given its name.

Specified by:

rollbackTransaction in class AbstractScheduler

Parameters:

transactionId - the transaction id

savepointName - the name of the savepoint

See Also:

AbstractScheduler.rollbackTransaction(long, String)

setSavepointTransaction

protected final void setSavepointTransaction(long transactionId,
                                             java.lang.String name)

Description copied from class: AbstractScheduler

Set a savepoint given its name to a transaction given its id.

Specified by:

setSavepointTransaction in class AbstractScheduler

Parameters:

transactionId - the transaction id

name - the name of the savepoint

See Also:

AbstractScheduler.setSavepointTransaction(long, String)

releaseSavepointTransaction

protected final void releaseSavepointTransaction(long transactionId,
                                                 java.lang.String name)

Description copied from class: AbstractScheduler

Release a savepoint given its name from a transaction given its id.

Specified by:

releaseSavepointTransaction in class AbstractScheduler

Parameters:

transactionId - the transaction id

name - the name of the savepoint

See Also:

AbstractScheduler.releaseSavepointTransaction(long, String)

getXmlImpl

public java.lang.String getXmlImpl()

Specified by:

getXmlImpl in class AbstractScheduler

See Also:

AbstractScheduler.getXmlImpl()