クラス org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler

org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelSchedulerに対する継承グラフ

[凡例]org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelSchedulerのコラボレーション図

[凡例]すべてのメンバ一覧

---

説明

This scheduler provides transaction level scheduling for RAIDb-0 controllers. Each write takes a lock on the whole database. All following writes are blocked until the transaction of the first write completes.

作者:

Emmanuel Cecchet

バージョン:

1.0

RAIDb0PessimisticTransactionLevelScheduler.java の 46 行で定義されています。

Public メソッド
	RAIDb0PessimisticTransactionLevelScheduler ()
final void	scheduleReadRequest (SelectRequest request) throws SQLException
final void	readCompletedNotify (SelectRequest request)
void	scheduleNonSuspendedWriteRequest (AbstractWriteRequest request) throws SQLException
final synchronized void	notifyWriteCompleted (AbstractWriteRequest request)
String	getXmlImpl ()
final void	initializeTransactionId (long transactionId)
final int	getParsingGranularity ()
final void	setParsingGranularity (int parsingGranularity)
final int	getPendingWrites ()
final int	getRAIDbLevel ()
final void	setRAIDbLevel (int raidbLevel)
void	setDatabaseSchema (DatabaseSchema dbs)
void	mergeDatabaseSchema (DatabaseSchema dbs)
final void	readCompleted (SelectRequest request)
final void	scheduleWriteRequest (AbstractWriteRequest request) throws SQLException, RollbackException
final void	writeCompleted (AbstractWriteRequest request)
final long	begin (TransactionMarkerMetaData tm) throws SQLException
final void	beginCompleted (long transactionId)
final void	commit (TransactionMarkerMetaData tm) throws SQLException
final void	commitCompleted (long transactionId)
final void	rollback (TransactionMarkerMetaData tm) throws SQLException
final void	rollbackCompleted (long transactionId)
final void	suspendNewTransactionsForCheckpoint () throws SQLException
final void	resumeNewTransactions ()
void	suspendWrites () throws SQLException
void	resumeWrites ()
String	getXml ()
String[]	getSchedulerData ()
int	getNumberRead ()
int	getNumberWrite ()
int	getPendingTransactions ()
Protected メソッド
final void	commitTransaction (long transactionId)
final void	rollbackTransaction (long transactionId)
boolean	hasSQLMacros (AbstractRequest request)
Protected 変数
int	raidbLevel
int	parsingGranularity
Static Protected 変数
Trace	logger
Private メソッド
void	releaseLock (long transactionId)
Private 変数
long	requestId
TransactionExclusiveLock	lock = new TransactionExclusiveLock()

---

コンストラクタとデストラクタ

org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.RAIDb0PessimisticTransactionLevelScheduler (   )

Creates a new Pessimistic Transaction Level Scheduler RAIDb0PessimisticTransactionLevelScheduler.java の 71 行で定義されています。 { super(RAIDbLevels.RAIDb0, ParsingGranularities.NO_PARSING); }

---

メソッド

final long org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.begin (  TransactionMarkerMetaData  tm  )  throws SQLException [inherited]

Begin a new transaction and return the corresponding transaction identifier. This method is called from the driver when setAutoCommit(false) is called. 引数: tm  The transaction marker metadata 戻り値: the transaction identifier 例外: SQLException  if an error occurs AbstractScheduler.java の 371 行で定義されています。 参照元 org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager.begin(). { // Check if writes are suspended synchronized (writesSync) { if (suspendedWrites) { try { // Wait on writesSync long timeout = tm.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); writesSync.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining > 0) tm.setTimeout(remaining); else { String msg = Translate.get("scheduler.begin.timeout.writeSync"); logger.warn(msg); throw new SQLException(msg); } } else writesSync.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.begin.timeout.writeSync") + " (" + e + ")"; logger.error(msg); throw new SQLException(msg); } } pendingWrites++; } // Check if transactions are suspended synchronized (transactionSync) { if (suspendedTransactions) try { // Wait on transactionSync long timeout = tm.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); transactionSync.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining > 0) tm.setTimeout(remaining); else { String msg = Translate .get("scheduler.begin.timeout.transactionSync"); logger.warn(msg); throw new SQLException(msg); } } else transactionSync.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.begin.timeout.transactionSync") + " (" + e + ")"; logger.error(msg); throw new SQLException(msg); } tid++; pendingTransactions++; return tid; } }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.beginCompleted (  long  transactionId  )  [inherited]

Notify the completion of a begin command. 引数: transactionId  of the completed begin AbstractScheduler.java の 456 行で定義されています。 参照元 org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager.begin(). { // Take care of suspended write synchronized (writesSync) { pendingWrites--; // It this is the last write to complete and writes are // suspended we have to notify suspendedWrites() if (suspendedWrites && (pendingWrites == 0)) { synchronized (endOfCurrentWrites) { endOfCurrentWrites.notifyAll(); } } } }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.commit (  TransactionMarkerMetaData  tm  )  throws SQLException [inherited]

Commit a transaction. Calls the implementation specific commitTransaction() 引数: tm  The transaction marker metadata 例外: SQLException  if an error occurs 参照: commitTransaction(long) AbstractScheduler.java の 484 行で定義されています。 { // Check if writes are suspended synchronized (writesSync) { if (suspendedWrites) { try { // Wait on writesSync long timeout = tm.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); writesSync.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining > 0) tm.setTimeout(remaining); else { String msg = Translate.get("scheduler.commit.timeout.writeSync"); logger.warn(msg); throw new SQLException(msg); } } else writesSync.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.commit.timeout.writeSync") + " (" + e + ")"; logger.error(msg); throw new SQLException(msg); } } pendingWrites++; } commitTransaction(tm.getTransactionId()); }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.commitCompleted (  long  transactionId  )  [inherited]

Notify the completion of a commit command. 引数: transactionId  of the completed commit AbstractScheduler.java の 539 行で定義されています。 { // Take care of suspended transactions synchronized (transactionSync) { pendingTransactions--; // If it is the last pending transaction to complete and we // are waiting for pending transactions to complete, then wake // up suspendNewTransactionsForCheckpoint() if (suspendedTransactions && (pendingTransactions == 0)) { synchronized (endOfCurrentTransactions) { endOfCurrentTransactions.notifyAll(); } } } // Take care of suspended write synchronized (writesSync) { pendingWrites--; // It this is the last write to complete and writes are // suspended we have to notify suspendedWrites() if (suspendedWrites && (pendingWrites == 0)) { synchronized (endOfCurrentWrites) { endOfCurrentWrites.notifyAll(); } } } }

final void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.commitTransaction (  long  transactionId  )  [protected, virtual]

参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.commitTransaction(long) org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 161 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.releaseLock(). { releaseLock(transactionId); }

int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getNumberRead (   )  [inherited]

戻り値: Returns the numberRead. AbstractScheduler.java の 834 行で定義されています。 参照元 org.objectweb.cjdbc.common.monitor.scheduler.NumberRequestsCollector.getValue(). { return numberRead; }

int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getNumberWrite (   )  [inherited]

戻り値: Returns the numberWrite. AbstractScheduler.java の 842 行で定義されています。 参照元 org.objectweb.cjdbc.common.monitor.scheduler.NumberRequestsCollector.getValue(). { return numberWrite; }

final int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getParsingGranularity (   )  [inherited]

Get the needed query parsing granularity. 戻り値: needed query parsing granularity AbstractScheduler.java の 128 行で定義されています。 参照元 org.objectweb.cjdbc.controller.requestmanager.RequestManager.setScheduler(). { return parsingGranularity; }

int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getPendingTransactions (   )  [inherited]

戻り値: Returns the pendingTransactions. AbstractScheduler.java の 850 行で定義されています。 { return pendingTransactions; }

final int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getPendingWrites (   )  [inherited]

Returns the number of pending writes. 戻り値: int AbstractScheduler.java の 148 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.pendingWrites. 参照元 org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelScheduler.acquireLockAndSetRequestId(), org.objectweb.cjdbc.controller.scheduler.raidb2.RAIDb2QueryLevelScheduler.notifyWriteCompleted(), org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1QueryLevelScheduler.notifyWriteCompleted(), org.objectweb.cjdbc.controller.scheduler.singledb.SingleDBPessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(), org.objectweb.cjdbc.controller.scheduler.raidb2.RAIDb2QueryLevelScheduler.scheduleNonSuspendedWriteRequest(), org.objectweb.cjdbc.controller.scheduler.raidb2.RAIDb2PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(), org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1QueryLevelScheduler.scheduleNonSuspendedWriteRequest(), org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(), org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(), org.objectweb.cjdbc.controller.scheduler.raidb2.RAIDb2QueryLevelScheduler.scheduleReadRequest(), と org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1QueryLevelScheduler.scheduleReadRequest(). { return pendingWrites; }

final int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getRAIDbLevel (   )  [inherited]

Returns the RAIDbLevel. 戻り値: int AbstractScheduler.java の 158 行で定義されています。 参照元 org.objectweb.cjdbc.controller.requestmanager.RequestManager.assignAndCheckSchedulerLoadBalancerValidity(). { return raidbLevel; }

String [] org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getSchedulerData (   )  [inherited]

Returns live information on the scheduler 戻り値: array of data AbstractScheduler.java の 818 行で定義されています。 参照元 org.objectweb.cjdbc.controller.monitoring.datacollector.DataCollector.retrieveSchedulerData(). { String[] data = new String[7]; data[0] = "" + numberRead; data[1] = "" + numberWrite; data[2] = "" + pendingTransactions; data[3] = "" + pendingWrites; data[4] = "" + numberRead + numberWrite; data[5] = (suspendedTransactions) ? "1" : "0"; data[6] = (suspendedWrites) ? "1" : "0"; return data; }

String org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getXml (   )  [inherited]

Get information about the Request Scheduler in xml format 戻り値: String containing information in xml AbstractScheduler.java の 804 行で定義されています。 { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_RequestScheduler + ">"); info.append(this.getXmlImpl()); info.append("</" + DatabasesXmlTags.ELT_RequestScheduler + ">"); return info.toString(); }

String org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.getXmlImpl (   )  [virtual]

参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getXmlImpl() org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 208 行で定義されています。 { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_RAIDb0Scheduler + " " + DatabasesXmlTags.ATT_level + "=\"" + DatabasesXmlTags.VAL_pessimisticTransaction + "\"/>"); return info.toString(); }

boolean org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.hasSQLMacros (  AbstractRequest  request  )  [protected, inherited]

Returns true if the query contains SQL macros. Currently supported macros are NOW() and RAND(). 引数: request  the request to check 戻り値: true if the query contains SQL macros. AbstractScheduler.java の 348 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.AbstractRequest.getSQL(). { String lower = request.getSQL().toLowerCase(); if (lower.indexOf("now()") > 0) return true; if (lower.indexOf("rand()") > 0) return true; return false; }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.initializeTransactionId (  long  transactionId  )  [inherited]

Initialize the transaction id with the given value (usually retrieved from the recovery log). 引数: transactionId  new current transaction identifier AbstractScheduler.java の 118 行で定義されています。 { this.tid = transactionId; }

void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.mergeDatabaseSchema (  DatabaseSchema  dbs  )  [inherited]

Merge the given DatabaseSchema with the current one. 引数: dbs  a DatabaseSchema value 参照: org.objectweb.cjdbc.controller.scheduler.schema.SchedulerDatabaseSchema org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelSchedulerで再定義されています。 AbstractScheduler.java の 193 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.info(). { logger.info(Translate.get("scheduler.doesnt.support.schemas")); }

final synchronized void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.notifyWriteCompleted (  AbstractWriteRequest  request  )  [virtual]

参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.notifyWriteCompleted(AbstractWriteRequest) org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 145 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.AbstractRequest.getTransactionId(), org.objectweb.cjdbc.common.sql.AbstractRequest.isAutoCommit, org.objectweb.cjdbc.common.sql.AbstractWriteRequest.isCreate(), と org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.releaseLock(). { // Requests outside transaction delimiters must release the lock // as soon as they have executed if (request.isAutoCommit() && (!request.isCreate())) releaseLock(request.getTransactionId()); }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.readCompleted (  SelectRequest  request  )  [inherited]

Notify the completion of a read statement. 引数: request  the completed request AbstractScheduler.java の 225 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.numberRead. { numberRead++; this.readCompletedNotify(request); }

final void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.readCompletedNotify (  SelectRequest  request  )  [virtual]

参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.readCompletedNotify(SelectRequest) org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 98 行で定義されています。 { }

void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.releaseLock (  long  transactionId  )  [private]

Release the locks we may own on the schema. 引数: transactionId  id of the transaction that releases the lock RAIDb0PessimisticTransactionLevelScheduler.java の 179 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.debug(), org.objectweb.cjdbc.controller.scheduler.schema.TransactionExclusiveLock.getLocker(), org.objectweb.cjdbc.common.log.Trace.isDebugEnabled(), org.objectweb.cjdbc.controller.scheduler.schema.TransactionExclusiveLock.isLocked, org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.lock, org.objectweb.cjdbc.controller.scheduler.schema.TransactionExclusiveLock.release(), と org.objectweb.cjdbc.common.log.Trace.warn(). 参照元 org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.commitTransaction(), org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.notifyWriteCompleted(), と org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.rollbackTransaction(). { // Are we the lock owner ? if (lock.isLocked()) { if (lock.getLocker() == transactionId) lock.release(); // Note that the following warnings could be safely ignored if the // transaction // commiting/rolllbacking (releasing the lock) has not done any // conflicting write else if (logger.isDebugEnabled()) logger.debug("Transaction " + transactionId + " wants to release the lock held by transaction " + lock.getLocker()); } else if (logger.isDebugEnabled()) logger.warn("Transaction " + transactionId + " tries to release a lock that has not been acquired."); }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.resumeNewTransactions (   )  [inherited]

Resume new transactions that were suspended by suspendNewTransactionsForCheckpoint(). 参照: suspendNewTransactionsForCheckpoint() AbstractScheduler.java の 726 行で定義されています。 { synchronized (transactionSync) { suspendedTransactions = false; // Wake up all pending begin statements transactionSync.notifyAll(); } }

void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.resumeWrites (   )  [inherited]

Resume the execution of write queries that were suspended by suspendWrites(). 参照: suspendWrites() AbstractScheduler.java の 783 行で定義されています。 { synchronized (writesSync) { suspendedWrites = false; // Wake up all waiting writes writesSync.notifyAll(); } }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.rollback (  TransactionMarkerMetaData  tm  )  throws SQLException [inherited]

Rollback a transaction. Calls the implementation specific rollbackTransaction() 引数: tm  The transaction marker metadata 例外: SQLException  if an error occurs 参照: rollbackTransaction(long) AbstractScheduler.java の 583 行で定義されています。 { // Check if writes are suspended synchronized (writesSync) { if (suspendedWrites) { try { // Wait on writesSync long timeout = tm.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); writesSync.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining > 0) tm.setTimeout(remaining); else { String msg = Translate .get("scheduler.rollback.timeout.writeSync"); logger.warn(msg); throw new SQLException(msg); } } else writesSync.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.rollback.timeout.writeSync") + " (" + e + ")"; logger.error(msg); throw new SQLException(msg); } } pendingWrites++; } rollbackTransaction(tm.getTransactionId()); }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.rollbackCompleted (  long  transactionId  )  [inherited]

Notify the completion of a rollback command. 引数: transactionId  of the rollback commit AbstractScheduler.java の 639 行で定義されています。 { // Take care of suspended transactions synchronized (transactionSync) { pendingTransactions--; // If it is the last pending transaction to complete and we // are waiting for pending transactions to complete, then wake // up suspendNewTransactionsForCheckpoint() if (suspendedTransactions && (pendingTransactions == 0)) { synchronized (endOfCurrentTransactions) { endOfCurrentTransactions.notifyAll(); } } } // Take care of suspended write synchronized (writesSync) { pendingWrites--; // It this is the last write to complete and writes are // suspended we have to notify suspendedWrites() if (suspendedWrites && (pendingWrites == 0)) { synchronized (endOfCurrentWrites) { endOfCurrentWrites.notifyAll(); } } } }

final void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.rollbackTransaction (  long  transactionId  )  [protected, virtual]

参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.rollbackTransaction(long) org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 169 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.releaseLock(). { releaseLock(transactionId); }

void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest (  AbstractWriteRequest  request  )  throws SQLException [virtual]

Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. Note that CREATE statements are not synchronized. 参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.scheduleWriteRequest(AbstractWriteRequest) org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 109 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.schema.TransactionExclusiveLock.acquire(), org.objectweb.cjdbc.common.log.Trace.debug(), org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.getPendingWrites(), org.objectweb.cjdbc.common.log.Trace.isDebugEnabled(), org.objectweb.cjdbc.common.log.Trace.isWarnEnabled(), org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.lock, org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.requestId, と org.objectweb.cjdbc.common.log.Trace.warn(). { if (request.isCreate()) { synchronized (this) { request.setId(requestId++); } return; } if (lock.acquire(request)) { synchronized (this) { request.setId(requestId++); } if (logger.isDebugEnabled()) logger.debug("Request " + request.getId() + " scheduled for write (" + getPendingWrites() + " pending writes)"); } else { if (logger.isWarnEnabled()) logger.warn("Request " + request.getId() + " timed out (" + request.getTimeout() + " s)"); throw new SQLException("Timeout (" + request.getTimeout() + ") for request: " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } }

final void org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.scheduleReadRequest (  SelectRequest  request  )  throws SQLException [virtual]

Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. 参照: org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.scheduleReadRequest(SelectRequest) org.objectweb.cjdbc.controller.scheduler.AbstractSchedulerに実装されています. RAIDb0PessimisticTransactionLevelScheduler.java の 86 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.requestId. { synchronized (this) { request.setId(requestId++); } }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.scheduleWriteRequest (  AbstractWriteRequest  request  )  throws SQLException, RollbackException [inherited]

Schedule a write request. This method blocks if the writes are suspended. Then the number of pending writes is updated and the implementation specific scheduleNonSuspendedWriteRequest function is called. SQL macros are replaced in the request if the scheduler has needSQLMacroHandling set to true. 引数: request  Write request to schedule 例外: SQLException  if a timeout occurs RollbackException  if an error occurs 参照: scheduleNonSuspendedWriteRequest(AbstractWriteRequest) AbstractScheduler.java の 243 行で定義されています。 参照先 org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.pendingWrites, org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.suspendedWrites, org.objectweb.cjdbc.common.log.Trace.warn(), と org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.writesSync. { synchronized (writesSync) { if (suspendedWrites) { try { // Wait on writesSync int timeout = request.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); long lTimeout = timeout * 1000; writesSync.wait(lTimeout); long end = System.currentTimeMillis(); int remaining = (int) (lTimeout - (end - start)); if (remaining > 0) request.setTimeout(remaining); else { String msg = Translate.get("scheduler.request.timeout", new String[]{String.valueOf(request.getId()), String.valueOf(request.getTimeout())}); logger.warn(msg); throw new SQLException(msg); } } else this.writesSync.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.request.timeout.failed", e); logger.warn(msg); throw new SQLException(msg); } } pendingWrites++; } scheduleNonSuspendedWriteRequest(request); }

void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.setDatabaseSchema (  DatabaseSchema  dbs  )  [inherited]

Sets the DatabaseSchema of the current virtual database. This is only needed by some schedulers that will have to define their own scheduler schema 引数: dbs  a DatabaseSchema value 参照: org.objectweb.cjdbc.controller.scheduler.schema.SchedulerDatabaseSchema org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelSchedulerで再定義されています。 AbstractScheduler.java の 181 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.info(), と org.objectweb.cjdbc.common.log.Trace.isInfoEnabled(). { if (logger.isInfoEnabled()) logger.info(Translate.get("scheduler.doesnt.support.schemas")); }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.setParsingGranularity (  int  parsingGranularity  )  [inherited]

Set the needed query parsing granularity. 引数: parsingGranularity  Parsing granularity needed by the scheduler AbstractScheduler.java の 138 行で定義されています。 { this.parsingGranularity = parsingGranularity; }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.setRAIDbLevel (  int  raidbLevel  )  [inherited]

Sets the RAIDb level. 引数: raidbLevel  The RAIDbLevel to set AbstractScheduler.java の 168 行で定義されています。 { this.raidbLevel = raidbLevel; }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.suspendNewTransactionsForCheckpoint (   )  throws SQLException [inherited]

Suspend all calls to begin() until all current transactions are finished in order to store a checkpoint. This method returns when all pending transactions have finished. New transactions remain suspended until resumeNewTransactions() is called. 参照: resumeNewTransactions() AbstractScheduler.java の 687 行で定義されています。 { synchronized (transactionSync) { suspendedTransactions = true; if (pendingTransactions == 0) return; } synchronized (endOfCurrentTransactions) { // Here we have a potential synchronization problem since the last // transaction completion could have happened before we entered this // synchronized block. Therefore we recheck if there is effectively // still pending transactions. If this is not the case, we don't have // to sleep and we can immediately return. if (pendingTransactions == 0) return; // Wait for pending transactions to end try { endOfCurrentTransactions.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.suspend.transaction.failed", e); logger.error(msg); throw new SQLException(msg); } } }

void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.suspendWrites (   )  throws SQLException [inherited]

Suspend all write queries. This method blocks until all pending writes are completed. Writes execution is resumed by calling resumeWrites() 参照: resumeWrites() AbstractScheduler.java の 744 行で定義されています。 { synchronized (writesSync) { suspendedWrites = true; if (pendingWrites == 0) return; } synchronized (endOfCurrentWrites) { // Here we have a potential synchronization problem since the last // write completion could have happened before we entered this // synchronized block. Therefore we recheck if there is effectively // still pending writes. If this is not the case, we don't have // to sleep and we can immediately return. if (pendingWrites == 0) return; // Wait for pending transactions to end try { endOfCurrentWrites.wait(); } catch (InterruptedException e) { String msg = Translate.get("scheduler.suspend.writes.failed", e); logger.error(msg); throw new SQLException(msg); } } }

final void org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.writeCompleted (  AbstractWriteRequest  request  )  [inherited]

Notify the completion of a write statement. This method updates the number of pending writes and calls the implementation specific notifyWriteCompleted function. Finally, the suspendWrites() function is notified if needed. 引数: request  the completed request 参照: notifyWriteCompleted(AbstractWriteRequest) suspendWrites() AbstractScheduler.java の 311 行で定義されています。 { synchronized (writesSync) { pendingWrites--; notifyWriteCompleted(request); // It this is the last write to complete and writes are // suspended we have to notify suspendedWrites() if (suspendedWrites && (pendingWrites == 0)) { synchronized (endOfCurrentWrites) { endOfCurrentWrites.notifyAll(); } } } numberWrite++; }

---

変数

TransactionExclusiveLock org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.lock = new TransactionExclusiveLock() [private]

RAIDb0PessimisticTransactionLevelScheduler.java の 62 行で定義されています。 参照元 org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.releaseLock(), と org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest().

Trace org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.logger [static, protected, inherited]

初期値: Trace .getLogger("org.objectweb.cjdbc.controller.scheduler") AbstractScheduler.java の 81 行で定義されています。

int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.parsingGranularity [protected, inherited]

AbstractScheduler.java の 66 行で定義されています。

int org.objectweb.cjdbc.controller.scheduler.AbstractScheduler.raidbLevel [protected, inherited]

AbstractScheduler.java の 65 行で定義されています。

long org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.requestId [private]

RAIDb0PessimisticTransactionLevelScheduler.java の 61 行で定義されています。 参照元 org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(), と org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.scheduleReadRequest().

---

このクラスの説明は次のファイルから生成されました:

• RAIDb0PessimisticTransactionLevelScheduler.java

---