src/org/objectweb/cjdbc/controller/scheduler/singledb/SingleDBPessimisticTransactionLevelScheduler.java

説明を見る。

package org.objectweb.cjdbc.controller.scheduler.singledb;

import java.sql.SQLException;

import org.objectweb.cjdbc.common.sql.AbstractWriteRequest;
import org.objectweb.cjdbc.common.sql.ParsingGranularities;
import org.objectweb.cjdbc.common.sql.SelectRequest;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;
import org.objectweb.cjdbc.controller.requestmanager.RAIDbLevels;
import org.objectweb.cjdbc.controller.scheduler.AbstractScheduler;
import org.objectweb.cjdbc.controller.scheduler.schema.TransactionExclusiveLock;

public class SingleDBPessimisticTransactionLevelScheduler
    extends
      AbstractScheduler
{

  //
  // How the code is organized ?
  //
  // 1. Member variables
  // 2. Constructor
  // 3. Request handling
  // 4. Transaction management
  // 5. Debug/Monitoring
  //

  private long             requestId;
  TransactionExclusiveLock lock = new TransactionExclusiveLock();

  //
  // Constructor
  //

  public SingleDBPessimisticTransactionLevelScheduler()
  {
    super(RAIDbLevels.SingleDB, ParsingGranularities.NO_PARSING);
  }

  //
  // Request Handling
  //

  public final synchronized void scheduleReadRequest(SelectRequest request)
      throws SQLException
  {
    request.setId(requestId++);
  }

  public final void readCompletedNotify(SelectRequest request)
  {
  }

  public void scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
      throws SQLException
  {
    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.getId());
    }
  }

  public final synchronized void notifyWriteCompleted(
      AbstractWriteRequest request)
  {
    // Requests outside transaction delimiters must release the lock
    // as soon as they have executed
    if (request.isAutoCommit())
      releaseLock(request.getTransactionId());
  }

  //
  // Transaction Management
  //

  protected final void commitTransaction(long transactionId)
  {
    releaseLock(transactionId);
  }

  protected final void rollbackTransaction(long transactionId)
  {
    releaseLock(transactionId);
  }

  private void releaseLock(long transactionId)
  {
    // 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.");
  }

  //
  // Debug/Monitoring
  //

  public String getXmlImpl()
  {
    return "<" + DatabasesXmlTags.ELT_SingleDBScheduler + " "
        + DatabasesXmlTags.ATT_level + "=\""
        + DatabasesXmlTags.VAL_pessimisticTransaction + "\"/>";
  }

}

---