クラス org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2

org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2に対する継承グラフ

[凡例]org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2のコラボレーション図

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

---

説明

RAIDb-2 load balancer.

This class is an abstract call because the read requests coming from the Request Manager are NOT treated here but in the subclasses. Transaction management and write requests are broadcasted to all backends owning the written table.

作者:

Emmanuel Cecchet

バージョン:

1.0

RAIDb2.java の 76 行で定義されています。

Public メソッド
	RAIDb2 (VirtualDatabase vdb, WaitForCompletionPolicy waitForCompletionPolicy, CreateTablePolicy createTablePolicy, long timestampResolution) throws SQLException
int	execWriteRequest (AbstractWriteRequest request) throws AllBackendsFailedException, SQLException
ResultSet	execWriteRequestWithKeys (AbstractWriteRequest request) throws AllBackendsFailedException, SQLException
abstract java.sql.ResultSet	execReadRequest (SelectRequest request) throws SQLException
ResultSet	execReadStoredProcedure (StoredProcedure proc) throws SQLException
int	execWriteStoredProcedure (StoredProcedure proc) throws SQLException
final void	begin (TransactionMarkerMetaData tm) throws SQLException
void	commit (TransactionMarkerMetaData tm) throws SQLException
void	rollback (TransactionMarkerMetaData tm) throws SQLException
void	enableBackend (DatabaseBackend db, boolean writeEnabled) throws SQLException
synchronized void	disableBackend (DatabaseBackend db) throws SQLException
String	getXmlImpl ()
abstract String	getRaidb2Xml ()
int	getRAIDbLevel ()
void	setRAIDbLevel (int raidbLevel)
int	getParsingGranularity ()
void	setParsingGranularity (int parsingGranularity)
abstract ResultSet	execReadOnlyReadStoredProcedure (StoredProcedure proc) throws SQLException
void	setWeight (String name, int w) throws SQLException
abstract String	getInformation ()
String	getXml ()
Protected メソッド
java.sql.ResultSet	executeRequestOnBackend (SelectRequest request, DatabaseBackend backend) throws SQLException, UnreachableBackendException
java.sql.ResultSet	executeStoredProcedureOnBackend (StoredProcedure proc, DatabaseBackend backend) throws SQLException, UnreachableBackendException
void	waitForAllWritesToComplete (long transactionId) throws SQLException
void	waitForAllWritesToComplete (DatabaseBackend backend, long transactionId) throws SQLException
void	waitForAllWritesToComplete (DatabaseBackend backend) throws SQLException
ResultSet	executeStatementOnBackend (SelectRequest request, DatabaseBackend backend, Connection c) throws SQLException, BadConnectionException
Protected 変数
ArrayList	backendBlockingThreads
ArrayList	backendNonBlockingThreads
ReadPrioritaryFIFOWriteLock	backendBlockingThreadsRWLock = new ReadPrioritaryFIFOWriteLock()
ReadPrioritaryFIFOWriteLock	backendNonBlockingThreadsRWLock = new ReadPrioritaryFIFOWriteLock()
WaitForCompletionPolicy	waitForCompletionPolicy
CreateTablePolicy	createTablePolicy
VirtualDatabase	vdb
int	raidbLevel
int	parsingGranularity
Static Protected 変数
Trace	logger
Private メソッド
int	getNbToWait (int nbOfThreads)
void	execWriteRequest (AbstractWriteRequest request, boolean useKeys) throws AllBackendsFailedException, SQLException
AbstractTask	callStoredProcedure (StoredProcedure proc, boolean isRead) throws SQLException
Private 変数
long	timestampResolution
int	execWriteRequestResult = 0
ResultSet	execWriteRequestWithKeysResult = null

---

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

org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.RAIDb2 (  VirtualDatabase  vdb, WaitForCompletionPolicy  waitForCompletionPolicy, CreateTablePolicy  createTablePolicy, long  timestampResolution )  throws SQLException

Creates a new RAIDb-1 Round Robin request load balancer. A new backend worker thread is created for each backend. 引数: vdb  the virtual database this load balancer belongs to. waitForCompletionPolicy  how many backends must complete before returning the result ? createTablePolicy  the policy defining how 'create table' statements should be handled timestampResolution  timestamp resolution for NOW macros 例外: SQLException  if an error occurs RAIDb2.java の 115 行で定義されています。 { super(vdb, RAIDbLevels.RAIDb2, ParsingGranularities.TABLE); this.waitForCompletionPolicy = waitForCompletionPolicy; backendBlockingThreads = new ArrayList(); backendNonBlockingThreads = new ArrayList(); this.createTablePolicy = createTablePolicy; this.timestampResolution = timestampResolution; }

---

メソッド

final void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.begin (  TransactionMarkerMetaData  tm  )  throws SQLException [virtual]

Begins a new transaction. 引数: tm  the transaction marker metadata 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 1005 行で定義されています。 { }

AbstractTask org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.callStoredProcedure (  StoredProcedure  proc, boolean  isRead )  throws SQLException [private]

Post the stored procedure call in the threads task list. 引数: proc  the stored procedure to call isRead  true if the call returns a ResultSet 戻り値: the task that has been executed (caller can get the result by calling getResult()) 例外: SQLException  if an error occurs RAIDb2.java の 843 行で定義されています。 参照先 org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.acquireRead(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addTask(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getFailed(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getSuccess(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.hasStoredProcedure(), org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.releaseRead(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.removeTask(), と org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.setTotalNb(). { ArrayList backendThreads = backendBlockingThreads; ReadPrioritaryFIFOWriteLock lock = backendBlockingThreadsRWLock; try { lock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendThreads.size(); // Create the task AbstractTask task; if (isRead) task = new ReadStoredProcedureTask(getNbToWait(nbOfThreads), nbOfThreads, proc); else task = new WriteStoredProcedureTask(getNbToWait(nbOfThreads), nbOfThreads, proc); synchronized (task) { int nbOfBackends = 0; // Post the task in each backendThread tasklist and wakeup the threads for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); if (thread.getBackend().hasStoredProcedure(proc.getProcedureName())) { nbOfBackends++; synchronized (thread) { if ((waitForCompletionPolicy.getPolicy() == WaitForCompletionPolicy.ALL)) thread.addTask(task); else thread.addTask(task, proc.getTransactionId()); thread.notify(); } } if (nbOfBackends == 0) throw new SQLException(Translate.get( "loadbalancer.backend.no.required.storedprocedure", proc .getProcedureName())); else task.setTotalNb(nbOfBackends); } lock.releaseRead(); // Wait for completion (notified by the task) try { // Wait on task long timeout = proc.getTimeout() * 1000; if (timeout > 0) { long start = System.currentTimeMillis(); task.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining <= 0) { String msg = Translate.get("loadbalancer.storedprocedure.timeout", new String[]{String.valueOf(proc.getId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())}); // Try to remove the request from the task list lock.acquireRead(); nbOfThreads = backendThreads.size(); for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.removeTask(task); } } lock.releaseRead(); logger.warn(msg); throw new SQLException(msg); } // No need to update request timeout since the execution is finished } else task.wait(); } catch (InterruptedException e) { // Try to remove the request from the task list try { lock.acquireRead(); nbOfThreads = backendThreads.size(); } catch (InterruptedException ignore) { nbOfThreads = 0; // Give up } for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.removeTask(task); } } lock.releaseRead(); throw new SQLException(Translate.get( "loadbalancer.storedprocedure.timeout", new String[]{ String.valueOf(proc.getId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())})); } if (task.getSuccess() > 0) return task; else { // All tasks failed ArrayList exceptions = task.getExceptions(); if (exceptions == null) throw new SQLException(Translate.get( "loadbalancer.storedprocedure.all.failed", proc.getId())); else { String errorMsg = Translate.get( "loadbalancer.storedprocedure.failed.stack", proc.getId()) + "\n"; for (int i = 0; i < exceptions.size(); i++) errorMsg += ((SQLException) exceptions.get(i)).getMessage() + "\n"; logger.error(errorMsg); throw new SQLException(errorMsg); } } } }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.commit (  TransactionMarkerMetaData  tm  )  throws SQLException [virtual]

Commits a transaction. 引数: tm  the transaction marker metadata 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 1015 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addTask(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getFailed(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getSuccess(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.isStartedTransaction(). { if (waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) waitForAllWritesToComplete(tm.getTransactionId()); try { backendNonBlockingThreadsRWLock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendNonBlockingThreads.size(); ArrayList commitList = new ArrayList(); Long iTid = new Long(tm.getTransactionId()); // Build the list of backend that need to commit this transaction for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendNonBlockingThreads .get(i); if (thread.getBackend().isStartedTransaction(iTid)) commitList.add(thread); } nbOfThreads = commitList.size(); if (nbOfThreads == 0) { backendNonBlockingThreadsRWLock.releaseRead(); return; } // Create the task CommitTask task = new CommitTask(getNbToWait(nbOfThreads), nbOfThreads, tm .getTimeout(), tm.getLogin(), tm.getTransactionId()); synchronized (task) { // Post the task in each backendThread tasklist and wakeup the threads for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) commitList.get(i); synchronized (thread) { thread.addTask(task); thread.notify(); } } backendNonBlockingThreadsRWLock.releaseRead(); // Wait for completion (notified by the task) try { // Wait on task long timeout = tm.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); task.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining <= 0) { String msg = Translate.get("loadbalancer.commit.timeout", new String[]{String.valueOf(tm.getTransactionId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())}); logger.warn(msg); throw new SQLException(msg); } } else task.wait(); } catch (InterruptedException e) { throw new SQLException(Translate.get("loadbalancer.commit.timeout", new String[]{String.valueOf(tm.getTransactionId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())})); } if (task.getSuccess() > 0) return; else { // All tasks failed ArrayList exceptions = task.getExceptions(); if (exceptions == null) throw new SQLException(Translate.get( "loadbalancer.commit.all.failed", tm.getTransactionId())); else { String errorMsg = Translate.get("loadbalancer.commit.failed.stack", tm.getTransactionId()) + "\n"; for (int i = 0; i < exceptions.size(); i++) errorMsg += ((SQLException) exceptions.get(i)).getMessage() + "\n"; logger.error(errorMsg); throw new SQLException(errorMsg); } } } }

synchronized void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.disableBackend (  DatabaseBackend  db  )  throws SQLException [virtual]

Disables a backend that was previously enabled. Ask the corresponding connection manager to finalize the connections if needed. No sanity checks are performed by this function. 引数: db  the database backend to disable 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ecで再定義されています。 RAIDb2.java の 1421 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addPriorityTask(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.equals(), と org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(). { if (db.isWriteEnabled()) { // Start with the backendBlockingThread list try { backendBlockingThreadsRWLock.acquireWrite(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.writelock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendBlockingThreads.size(); // Find the right blocking thread for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendBlockingThreads .get(i); if (thread.getBackend().equals(db)) { logger.info(Translate .get("loadbalancer.backend.workerthread.blocking.remove", db .getName())); backendBlockingThreads.remove(thread); synchronized (thread) { // Kill the thread thread.addPriorityTask(new KillThreadTask(1, 1)); thread.notify(); } break; } } backendBlockingThreadsRWLock.releaseWrite(); // Continue with the backendNonBlockingThread list try { backendNonBlockingThreadsRWLock.acquireWrite(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.writelock.failed", e); logger.error(msg); throw new SQLException(msg); } // Find the right non-blocking thread nbOfThreads = backendNonBlockingThreads.size(); for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendNonBlockingThreads .get(i); if (thread.getBackend().equals(db)) { logger.info(Translate.get( "loadbalancer.backend.workerthread.non.blocking.remove", db .getName())); backendNonBlockingThreads.remove(thread); synchronized (thread) { // Kill the thread thread.addPriorityTask(new KillThreadTask(1, 1)); thread.notify(); } break; } } backendNonBlockingThreadsRWLock.releaseWrite(); } db.disable(); if (db.isInitialized()) db.finalizeConnections(); }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.enableBackend (  DatabaseBackend  db, boolean  writeEnabled )  throws SQLException [virtual]

Enables a Backend that was previously disabled. Ask the corresponding connection manager to initialize the connections if needed. No sanity checks are performed by this function. 引数: db  The database backend to enable writeEnabled  True if the backend must be enabled for writes 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ecで再定義されています。 RAIDb2.java の 1356 行で定義されています。 参照先 org.objectweb.cjdbc.controller.backend.DatabaseBackend.enableWrite(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.getName(). { if (writeEnabled) { // Create 2 worker threads BackendWorkerThread blockingThread = new BackendWorkerThread( (DatabaseBackend) db, this); BackendWorkerThread nonBlockingThread = new BackendWorkerThread( (DatabaseBackend) db, this); // Add first to the blocking thread list try { backendBlockingThreadsRWLock.acquireWrite(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.writelock.failed", e); logger.error(msg); throw new SQLException(msg); } backendBlockingThreads.add(blockingThread); backendBlockingThreadsRWLock.releaseWrite(); blockingThread.start(); logger.info(Translate.get( "loadbalancer.backend.workerthread.blocking.add", db.getName())); // Then add to the non-blocking thread list try { backendNonBlockingThreadsRWLock.acquireWrite(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.writelock.failed", e); logger.error(msg); throw new SQLException(msg); } backendNonBlockingThreads.add(nonBlockingThread); backendNonBlockingThreadsRWLock.releaseWrite(); nonBlockingThread.start(); logger.info(Translate.get( "loadbalancer.backend.workerthread.non.blocking.add", db.getName())); db.enableWrite(); } if (!db.isInitialized()) db.initializeConnections(); db.enableRead(); }

abstract ResultSet org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.execReadOnlyReadStoredProcedure (  StoredProcedure  proc  )  throws SQLException [pure virtual, inherited]

Call a read-only stored procedure that returns a ResultSet. The stored procedure will be executed by one node only. 引数: proc  the stored procedure call 戻り値: a java.sql.ResultSet value 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB, org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_LPRF, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_WRR, と org.objectweb.cjdbc.controller.loadbalancer.singledb.SingleDBを実装しています.

abstract java.sql.ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execReadRequest (  SelectRequest  request  )  throws SQLException [pure virtual]

Implementation specific load balanced read execution. 引数: request  an SelectRequest 戻り値: the corresponding java.sql.ResultSet 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_RR, と org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_WRRを実装しています.

ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execReadStoredProcedure (  StoredProcedure  proc  )  throws SQLException [virtual]

参照: org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.execReadStoredProcedure(org.objectweb.cjdbc.common.sql.StoredProcedure) org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 816 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.tasks.ReadStoredProcedureTask.getResult(). { ReadStoredProcedureTask task = (ReadStoredProcedureTask) callStoredProcedure( proc, true); return task.getResult(); }

java.sql.ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.executeRequestOnBackend (  SelectRequest  request, DatabaseBackend  backend )  throws SQLException, UnreachableBackendException [protected]

Execute a read request on the selected backend. 引数: request  the request to execute backend  the backend that will execute the request 戻り値: the ResultSet 例外: SQLException  if an error occurs RAIDb2.java の 492 行で定義されています。 { // Handle macros request.setSQL(RequestManager.handleSQLMacros(request.getSQL(), timestampResolution, false)); // Ok, we have a backend, let's execute the request AbstractConnectionManager cm = backend.getConnectionManager(request .getLogin()); // Sanity check if (cm == null) { String msg = Translate.get("loadbalancer.connectionmanager.not.found", new String[]{request.getLogin(), backend.getName()}); logger.error(msg); throw new SQLException(msg); } // Execute the query if (request.isAutoCommit()) { if (waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) // We could do something finer grain here by waiting // only for writes that depend on the tables we need // but is that really worth the overhead ? waitForAllWritesToComplete(backend); ResultSet rs = null; boolean badConnection; do { badConnection = false; // Use a connection just for this request Connection c = null; try { c = cm.getConnection(); } catch (UnreachableBackendException e1) { logger.error(Translate.get( "loadbalancer.backend.disabling.unreachable", backend.getName())); backend.disable(); throw new UnreachableBackendException(Translate.get( "loadbalancer.backend.unreacheable", backend.getName())); } // Sanity check if (c == null) throw new UnreachableBackendException( "No more connections on backend " + backend.getName()); // Execute Query try { rs = executeStatementOnBackend(request, backend, c); cm.releaseConnection(c); } catch (SQLException e) { cm.releaseConnection(c); throw new SQLException(Translate.get( "loadbalancer.request.failed.on.backend", new String[]{ request.getSQLShortForm(vdb.getSQLShortFormLength()), backend.getName(), e.getMessage()})); } catch (BadConnectionException e) { // Get rid of the bad connection cm.deleteConnection(c); badConnection = true; } } while (badConnection); if (logger.isDebugEnabled()) logger.debug(Translate.get("loadbalancer.execute.on", new String[]{ String.valueOf(request.getId()), backend.getName()})); return rs; } else { // Inside a transaction Connection c; long tid = request.getTransactionId(); Long lTid = new Long(tid); // Wait for previous writes to complete if (waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) waitForAllWritesToComplete(backend, request.getTransactionId()); if (!backend.isStartedTransaction(lTid)) { // transaction has not been started yet on this backend try { c = cm.getConnection(tid); } catch (UnreachableBackendException e1) { logger.error(Translate.get( "loadbalancer.backend.disabling.unreachable", backend.getName())); backend.disable(); throw new UnreachableBackendException(Translate.get( "loadbalancer.backend.unreacheable", backend.getName())); } // Sanity check if (c == null) throw new SQLException(Translate.get( "loadbalancer.unable.get.connection", new String[]{ String.valueOf(tid), backend.getName()})); // begin transaction backend.startTransaction(lTid); c.setAutoCommit(false); } else { // Re-use the connection used by this transaction c = cm.retrieveConnection(tid); // Sanity check if (c == null) throw new SQLException(Translate.get( "loadbalancer.unable.retrieve.connection", new String[]{ String.valueOf(tid), backend.getName()})); } // Execute Query ResultSet rs = null; try { rs = executeStatementOnBackend(request, backend, c); } catch (SQLException e) { throw new SQLException(Translate.get( "loadbalancer.request.failed.on.backend", new String[]{ request.getSQLShortForm(vdb.getSQLShortFormLength()), backend.getName(), e.getMessage()})); } catch (BadConnectionException e) { // Connection failed, so did the transaction // Disable the backend. cm.deleteConnection(tid); String msg = Translate.get( "loadbalancer.backend.disabling.connection.failure", backend .getName()); logger.error(msg); backend.disable(); throw new SQLException(msg); } if (logger.isDebugEnabled()) logger.debug(Translate.get("loadbalancer.execute.transaction.on", new String[]{String.valueOf(tid), String.valueOf(request.getId()), backend.getName()})); return rs; } }

ResultSet org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.executeStatementOnBackend (  SelectRequest  request, DatabaseBackend  backend, Connection  c )  throws SQLException, BadConnectionException [protected, inherited]

Execute a statement on a backend. If the execution fails, the connection is checked for validity. If the connection was not valid, the query is automatically retried on a new connection. 引数: request  the request to execute backend  the backend on which the request is executed c  connection used to create the statement 戻り値: the ResultSet 例外: SQLException  if an error occurs AbstractLoadBalancer.java の 251 行で定義されています。 参照先 java.sql.Statement.executeQuery(), java.sql.Statement.setCursorName(), java.sql.Statement.setFetchSize(), java.sql.Statement.setMaxRows(), java.sql.Statement.setQueryTimeout(), org.objectweb.cjdbc.controller.backend.DriverCompliance.supportSetCursorName, org.objectweb.cjdbc.controller.backend.DriverCompliance.supportSetFetchSize, org.objectweb.cjdbc.controller.backend.DriverCompliance.supportSetMaxRows, と org.objectweb.cjdbc.controller.backend.DriverCompliance.supportSetQueryTimeout. 参照元 org.objectweb.cjdbc.controller.loadbalancer.singledb.SingleDB.execReadRequest(). { ResultSet rs = null; try { backend.addPendingReadRequest(request); String sql = request.getSQL(); // Rewrite the query if needed sql = backend.rewriteQuery(sql); // Execute the query Statement s = c.createStatement(); DriverCompliance driverCompliance = backend.getDriverCompliance(); if (driverCompliance.supportSetQueryTimeout()) s.setQueryTimeout(request.getTimeout()); if ((request.getCursorName() != null) && (driverCompliance.supportSetCursorName())) s.setCursorName(request.getCursorName()); if ((request.getFetchSize() != 0) && driverCompliance.supportSetFetchSize()) s.setFetchSize(request.getFetchSize()); if ((request.getMaxRows() > 0) && driverCompliance.supportSetMaxRows()) s.setMaxRows(request.getMaxRows()); rs = s.executeQuery(sql); } catch (SQLException e) { // Something bad happened if (backend.isValidConnection(c)) throw e; // Connection is valid, throw the exception else throw new BadConnectionException(); } finally { backend.removePendingRequest(request); } return rs; }

java.sql.ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.executeStoredProcedureOnBackend (  StoredProcedure  proc, DatabaseBackend  backend )  throws SQLException, UnreachableBackendException [protected]

Execute a stored procedure on the selected backend. 引数: proc  the stored procedure to execute backend  the backend that will execute the request 戻り値: the ResultSet 例外: SQLException  if an error occurs RAIDb2.java の 658 行で定義されています。 { // Handle macros proc.setSQL(RequestManager.handleSQLMacros(proc.getSQL(), timestampResolution, false)); // Ok, we have a backend, let's execute the request AbstractConnectionManager cm = backend .getConnectionManager(proc.getLogin()); // Sanity check if (cm == null) { String msg = Translate.get("loadbalancer.connectionmanager.not.found", new String[]{proc.getLogin(), backend.getName()}); logger.error(msg); throw new SQLException(msg); } // Execute the query if (proc.isAutoCommit()) { if (waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) // We could do something finer grain here by waiting // only for writes that depend on the tables we need // but is that really worth the overhead ? waitForAllWritesToComplete(backend); // Use a connection just for this request Connection c = null; try { c = cm.getConnection(); } catch (UnreachableBackendException e1) { logger.error(Translate.get( "loadbalancer.backend.disabling.unreachable", backend.getName())); backend.disable(); throw new UnreachableBackendException(Translate.get( "loadbalancer.backend.unreacheable", backend.getName())); } // Sanity check if (c == null) throw new SQLException(Translate.get( "loadbalancer.backend.no.connection", backend.getName())); // Execute Query ResultSet rs = null; try { // We suppose here that the request does not modify the schema since // it is a read-only query. CallableStatement cs = c.prepareCall(proc.getSQL()); if (backend.getDriverCompliance().supportSetQueryTimeout()) cs.setQueryTimeout(proc.getTimeout()); if ((proc.getMaxRows() > 0) && backend.getDriverCompliance().supportSetMaxRows()) cs.setMaxRows(proc.getMaxRows()); rs = cs.executeQuery(); } catch (SQLException e) { throw new SQLException(Translate.get( "loadbalancer.storedprocedure.failed.on.backend", new String[]{ proc.getSQLShortForm(vdb.getSQLShortFormLength()), backend.getName(), e.getMessage()})); } finally { cm.releaseConnection(c); } if (logger.isDebugEnabled()) logger.debug(Translate.get("loadbalancer.storedprocedure.on", new String[]{String.valueOf(proc.getId()), backend.getName()})); return rs; } else { // Inside a transaction Connection c; long tid = proc.getTransactionId(); Long lTid = new Long(tid); // Wait for previous writes to complete if (waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) waitForAllWritesToComplete(backend, proc.getTransactionId()); if (!backend.isStartedTransaction(lTid)) { // transaction has not been started yet on this backend try { c = cm.getConnection(tid); } catch (UnreachableBackendException e1) { logger.error(Translate.get( "loadbalancer.backend.disabling.unreachable", backend.getName())); backend.disable(); throw new SQLException(Translate.get( "loadbalancer.backend.unreacheable", backend.getName())); } // Sanity check if (c == null) throw new SQLException(Translate.get( "loadbalancer.unable.get.connection", new String[]{ String.valueOf(tid), backend.getName()})); // begin transaction backend.startTransaction(lTid); c.setAutoCommit(false); } else { // Re-use the connection used by this transaction c = cm.retrieveConnection(tid); // Sanity check if (c == null) throw new SQLException(Translate.get( "loadbalancer.unable.retrieve.connection", new String[]{ String.valueOf(tid), backend.getName()})); } // Execute Query ResultSet rs; try { // We suppose here that the request does not modify the schema since // it is a read-only query. CallableStatement cs = c.prepareCall(proc.getSQL()); if (backend.getDriverCompliance().supportSetQueryTimeout()) cs.setQueryTimeout(proc.getTimeout()); if ((proc.getMaxRows() > 0) && backend.getDriverCompliance().supportSetMaxRows()) cs.setMaxRows(proc.getMaxRows()); rs = cs.executeQuery(); } catch (SQLException e) { throw new SQLException(Translate.get( "loadbalancer.storedprocedure.failed.on.backend", new String[]{ proc.getSQLShortForm(vdb.getSQLShortFormLength()), backend.getName(), e.getMessage()})); } if (logger.isDebugEnabled()) logger.debug(Translate.get("loadbalancer.execute.transaction.on", new String[]{String.valueOf(tid), String.valueOf(proc.getId()), backend.getName()})); return rs; } }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest (  AbstractWriteRequest  request, boolean  useKeys )  throws AllBackendsFailedException, SQLException [private]

Common code for execWriteRequest(AbstractWriteRequest) and execWriteRequestWithKeys(AbstractWriteRequest). The result is given back using member variables execWriteRequestResult and execWriteRequestWithKeysResult defined above. 引数: request  the request to execute useKeys  true if this must give an auto generated keys ResultSet 例外: AllBackendsFailedException  if all backends failed to execute the request SQLException  if an error occurs RAIDb2.java の 209 行で定義されています。 参照先 org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.acquireRead(), org.objectweb.cjdbc.common.log.Trace.debug(), org.objectweb.cjdbc.common.log.Trace.error(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getBackends(), org.objectweb.cjdbc.controller.loadbalancer.policies.createtable.CreateTableRule.getBackends(), org.objectweb.cjdbc.controller.loadbalancer.policies.createtable.CreateTablePolicy.getDefaultRule(), org.objectweb.cjdbc.controller.loadbalancer.policies.WaitForCompletionPolicy.getPolicy(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getSQLShortFormLength(), org.objectweb.cjdbc.controller.loadbalancer.policies.createtable.CreateTablePolicy.getTableRule(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.hasTable(), org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.waitForAllWritesToComplete(), と org.objectweb.cjdbc.common.log.Trace.warn(). { ArrayList backendThreads; ReadPrioritaryFIFOWriteLock lock; // Handle macros request.setSQL(RequestManager.handleSQLMacros(request.getSQL(), timestampResolution, false)); // Determine which list (blocking or not) to use if (request.mightBlock()) { // Blocking backendThreads = backendBlockingThreads; lock = backendBlockingThreadsRWLock; } else { // Non-blocking backendThreads = backendNonBlockingThreads; lock = backendNonBlockingThreadsRWLock; if ((waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) && (request.getTransactionId() != 0)) waitForAllWritesToComplete(request.getTransactionId()); } try { lock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendThreads.size(); ArrayList writeList = new ArrayList(); String tableName = request.getTableName(); if (request.isCreate()) { // Choose the backend according to the defined policy CreateTableRule rule = createTablePolicy.getTableRule(request .getTableName()); if (rule == null) rule = createTablePolicy.getDefaultRule(); // Ask the rule to pickup the backends ArrayList chosen; try { chosen = rule.getBackends(vdb.getBackends()); } catch (CreateTableException e) { throw new SQLException(Translate.get( "loadbalancer.create.table.rule.failed", e.getMessage())); } // Build the thread list from the backend list if (chosen != null) { for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); if (chosen.contains(thread.getBackend())) writeList.add(thread); } } } else { // Build the list of backends that need to execute this request for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); if (thread.getBackend().hasTable(tableName)) writeList.add(thread); } } nbOfThreads = writeList.size(); if (nbOfThreads == 0) { String msg = Translate.get("loadbalancer.execute.no.backend.found", request.getSQLShortForm(vdb.getSQLShortFormLength())); logger.warn(msg); throw new SQLException(msg); } else logger.debug(Translate.get("loadbalancer.execute.on.several", new String[]{String.valueOf(request.getId()), String.valueOf(nbOfThreads)})); // Create the task AbstractTask task; if (useKeys) task = new WriteRequestWithKeysTask(getNbToWait(nbOfThreads), nbOfThreads, request); else task = new WriteRequestTask(getNbToWait(nbOfThreads), nbOfThreads, request); synchronized (task) { if (waitForCompletionPolicy.getPolicy() == WaitForCompletionPolicy.ALL) { // Post the task in each backendThread tasklist and wakeup the threads for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.addTask(task); thread.notify(); } } } else { // We have to first post the request on each backend before letting the // first backend to execute the request. Therefore we have 2 phases: // 1. post the task in each thread queue // 2. notify each thread to execute the query // 1. Post the task if (request.mightBlock()) { for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.addTask(task, request.getTransactionId()); } } } else { for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.addTask(task); } } } // 2. Start the task execution on each backend for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.notify(); } } } lock.releaseRead(); // Wait for completion (notified by the task) try { // Wait on task long timeout = request.getTimeout() * 1000; if (timeout > 0) { long start = System.currentTimeMillis(); task.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining <= 0) { String msg = Translate.get("loadbalancer.request.timeout", new String[]{String.valueOf(request.getId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())}); // Try to remove the request from the task list lock.acquireRead(); nbOfThreads = backendThreads.size(); for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.removeTask(task); } } lock.releaseRead(); logger.warn(msg); throw new SQLException(msg); } // No need to update request timeout since the execution is finished } else task.wait(); } catch (InterruptedException e) { // Try to remove the request from the task list try { lock.acquireRead(); nbOfThreads = backendThreads.size(); } catch (InterruptedException ignore) { nbOfThreads = 0; // Give up } for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendThreads .get(i); synchronized (thread) { thread.removeTask(task); } } lock.releaseRead(); throw new SQLException(Translate.get("loadbalancer.request.timeout", new String[]{String.valueOf(request.getId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())})); } if (task.getSuccess() > 0) { if (useKeys) execWriteRequestWithKeysResult = ((WriteRequestWithKeysTask) task) .getResult(); else execWriteRequestResult = ((WriteRequestTask) task).getResult(); } else { // All tasks failed ArrayList exceptions = task.getExceptions(); if (exceptions == null) throw new AllBackendsFailedException(Translate.get( "loadbalancer.request.failed.all", request.getId())); else { String errorMsg = Translate.get("loadbalancer.request.failed.stack", request.getId()) + "\n"; for (int i = 0; i < exceptions.size(); i++) errorMsg += ((SQLException) exceptions.get(i)).getMessage() + "\n"; logger.error(errorMsg); throw new SQLException(errorMsg); } } } }

int org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest (  AbstractWriteRequest  request  )  throws AllBackendsFailedException, SQLException [virtual]

Performs a write request. This request is broadcasted to all nodes that owns the table to be written. 引数: request  an AbstractWriteRequest 戻り値: number of rows affected by the request 例外: AllBackendsFailedException  if all backends failed to execute the request SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 174 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestResult. 参照元 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestWithKeys(). { execWriteRequest(request, false); return execWriteRequestResult; }

ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestWithKeys (  AbstractWriteRequest  request  )  throws AllBackendsFailedException, SQLException [virtual]

Perform a write request and return the auto generated keys. 引数: request  the request to execute 戻り値: auto generated keys. 例外: AllBackendsFailedException  if all backends failed to execute the request SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 190 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest(), と org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestWithKeysResult. { execWriteRequest(request, true); return execWriteRequestWithKeysResult; }

int org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteStoredProcedure (  StoredProcedure  proc  )  throws SQLException [virtual]

参照: org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.execWriteStoredProcedure(org.objectweb.cjdbc.common.sql.StoredProcedure) org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 827 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.tasks.WriteStoredProcedureTask.getResult(). { WriteStoredProcedureTask task = (WriteStoredProcedureTask) callStoredProcedure( proc, false); return task.getResult(); }

abstract String org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getInformation (   )  [pure virtual, inherited]

Get information about the Request Load Balancer 戻り値: String containing information org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_LPRF, org.objectweb.cjdbc.controller.loadbalancer.paralleldb.ParallelDB_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_LPRF, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_WRR, と org.objectweb.cjdbc.controller.loadbalancer.singledb.SingleDBを実装しています.

int org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.getNbToWait (  int  nbOfThreads  )  [private]

Returns the number of nodes to wait for according to the defined waitForCompletion policy. 引数: nbOfThreads  total number of threads 戻り値: int number of threads to wait for RAIDb2.java の 140 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.policies.WaitForCompletionPolicy.getPolicy(), と org.objectweb.cjdbc.common.log.Trace.warn(). { int nbToWait; switch (waitForCompletionPolicy.getPolicy()) { case WaitForCompletionPolicy.FIRST : nbToWait = 1; break; case WaitForCompletionPolicy.MAJORITY : nbToWait = nbOfThreads / 2 + 1; break; default : logger .warn(Translate.get("loadbalancer.waitforcompletion.unsupported")); case WaitForCompletionPolicy.ALL : nbToWait = nbOfThreads; break; } return nbToWait; }

int org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getParsingGranularity (   )  [inherited]

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

abstract String org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.getRaidb2Xml (   )  [pure virtual]

return xml formatted information about this raidb2 load balancer 戻り値: xml formatted string org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_LPRF, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_RR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_RR, と org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_WRRを実装しています.

int org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getRAIDbLevel (   )  [inherited]

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

String org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getXml (   )  [inherited]

参照: org.objectweb.cjdbc.common.xml.XmlComponent.getXml() AbstractLoadBalancer.java の 385 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getXmlImpl(). { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_LoadBalancer + ">"); info.append(getXmlImpl()); info.append("</" + DatabasesXmlTags.ELT_LoadBalancer + ">"); return info.toString(); }

String org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.getXmlImpl (   )  [virtual]

参照: org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getXmlImpl org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ecで再定義されています。 RAIDb2.java の 1515 行で定義されています。 { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_RAIDb_2 + " " + DatabasesXmlTags.ATT_timestampResolution + "=\"" + timestampResolution + "\" >"); if (createTablePolicy != null) info.append(createTablePolicy.getXml()); if (waitForCompletionPolicy != null) info.append(waitForCompletionPolicy.getXml()); this.getRaidb2Xml(); info.append("</" + DatabasesXmlTags.ELT_RAIDb_2 + ">"); return info.toString(); }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.rollback (  TransactionMarkerMetaData  tm  )  throws SQLException [virtual]

Rollbacks a transaction. 引数: tm  the transaction marker metadata 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. RAIDb2.java の 1131 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addTask(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getFailed(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getSuccess(), と org.objectweb.cjdbc.controller.backend.DatabaseBackend.isStartedTransaction(). { if (waitForCompletionPolicy.getPolicy() != WaitForCompletionPolicy.ALL) waitForAllWritesToComplete(tm.getTransactionId()); try { backendNonBlockingThreadsRWLock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendNonBlockingThreads.size(); ArrayList rollbackList = new ArrayList(); Long iTid = new Long(tm.getTransactionId()); // Build the list of backend that need to rollback this transaction for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendNonBlockingThreads .get(i); if (thread.getBackend().isStartedTransaction(iTid)) rollbackList.add(thread); } nbOfThreads = rollbackList.size(); if (nbOfThreads == 0) { backendNonBlockingThreadsRWLock.releaseRead(); return; } // Create the task RollbackTask task = new RollbackTask(getNbToWait(nbOfThreads), nbOfThreads, tm.getTimeout(), tm.getLogin(), tm.getTransactionId()); synchronized (task) { // Post the task in each backendThread tasklist and wakeup the threads for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) rollbackList.get(i); synchronized (thread) { thread.addTask(task); thread.notify(); } } backendNonBlockingThreadsRWLock.releaseRead(); // Wait for completion (notified by the task) try { // Wait on task long timeout = tm.getTimeout(); if (timeout > 0) { long start = System.currentTimeMillis(); task.wait(timeout); long end = System.currentTimeMillis(); long remaining = timeout - (end - start); if (remaining <= 0) { String msg = Translate.get("loadbalancer.rollback.timeout", new String[]{String.valueOf(tm.getTransactionId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())}); logger.warn(msg); throw new SQLException(msg); } } else task.wait(); } catch (InterruptedException e) { throw new SQLException(Translate.get("loadbalancer.rollback.timeout", new String[]{String.valueOf(tm.getTransactionId()), String.valueOf(task.getSuccess()), String.valueOf(task.getFailed())})); } if (task.getSuccess() > 0) return; else { // All tasks failed ArrayList exceptions = task.getExceptions(); if (exceptions == null) throw new SQLException(Translate.get( "loadbalancer.rollback.all.failed", tm.getTransactionId())); else { String errorMsg = Translate.get("loadbalancer.rollback.failed.stack", tm.getTransactionId()) + "\n"; for (int i = 0; i < exceptions.size(); i++) errorMsg += ((SQLException) exceptions.get(i)).getMessage() + "\n"; logger.error(errorMsg); throw new SQLException(errorMsg); } } } }

void org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.setParsingGranularity (  int  parsingGranularity  )  [inherited]

Set the needed query parsing granularity. 引数: parsingGranularity  the granularity to set AbstractLoadBalancer.java の 161 行で定義されています。 { this.parsingGranularity = parsingGranularity; }

void org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.setRAIDbLevel (  int  raidbLevel  )  [inherited]

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

void org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.setWeight (  String  name, int  w )  throws SQLException [inherited]

Associate a weight to a backend identified by its logical name. 引数: name  the backend name w  the weight 例外: SQLException  if an error occurs org.objectweb.cjdbc.controller.loadbalancer.raidb0.RAIDb0, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ec_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2_WRR, org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ec_WRR, と org.objectweb.cjdbc.controller.loadbalancer.singledb.SingleDBで再定義されています。 AbstractLoadBalancer.java の 359 行で定義されています。 { throw new SQLException("Weight is not supported by this load balancer"); }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.waitForAllWritesToComplete (  DatabaseBackend  backend  )  throws SQLException [protected]

Waits for all writes in the blocking thread queue of the given backend to complete. 参照: executeRequestOnBackend RAIDb2.java の 1312 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(), と org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.waitForAllTasksToComplete(). { try { backendBlockingThreadsRWLock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendBlockingThreads.size(); for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendBlockingThreads .get(i); if (thread.getBackend() == backend) thread.waitForAllTasksToComplete(); } backendBlockingThreadsRWLock.releaseRead(); }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.waitForAllWritesToComplete (  DatabaseBackend  backend, long  transactionId )  throws SQLException [protected]

Waits for all writes of the given transaction in the blocking thread queue of the given backend to complete before being able to complete the transaction. 参照: executeRequestOnBackend RAIDb2.java の 1278 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(), と org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.waitForAllTasksToComplete(). { try { backendBlockingThreadsRWLock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendBlockingThreads.size(); for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendBlockingThreads .get(i); if (thread.getBackend() == backend) thread.waitForAllTasksToComplete(transactionId); } backendBlockingThreadsRWLock.releaseRead(); }

void org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.waitForAllWritesToComplete (  long  transactionId  )  throws SQLException [protected]

Waits for all writes of the given transaction in the blocking thread queue to complete before being able to complete the transaction. RAIDb2.java の 1244 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.waitForAllTasksToComplete(). 参照元 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest(). { try { backendBlockingThreadsRWLock.acquireRead(); } catch (InterruptedException e) { String msg = Translate.get( "loadbalancer.backendlist.acquire.readlock.failed", e); logger.error(msg); throw new SQLException(msg); } int nbOfThreads = backendBlockingThreads.size(); for (int i = 0; i < nbOfThreads; i++) { BackendWorkerThread thread = (BackendWorkerThread) backendBlockingThreads .get(i); thread.waitForAllTasksToComplete(transactionId); } backendBlockingThreadsRWLock.releaseRead(); }

---

変数

ArrayList org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.backendBlockingThreads [protected]

RAIDb2.java の 87 行で定義されています。

ReadPrioritaryFIFOWriteLock org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.backendBlockingThreadsRWLock = new ReadPrioritaryFIFOWriteLock() [protected]

RAIDb2.java の 89 行で定義されています。

ArrayList org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.backendNonBlockingThreads [protected]

RAIDb2.java の 88 行で定義されています。

ReadPrioritaryFIFOWriteLock org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.backendNonBlockingThreadsRWLock = new ReadPrioritaryFIFOWriteLock() [protected]

RAIDb2.java の 90 行で定義されています。

CreateTablePolicy org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.createTablePolicy [protected]

RAIDb2.java の 93 行で定義されています。

int org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestResult = 0 [private]

RAIDb2.java の 161 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequest().

ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestWithKeysResult = null [private]

RAIDb2.java の 162 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.execWriteRequestWithKeys().

Trace org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.logger [static, protected]

初期値: Trace .getLogger("org.objectweb.cjdbc.controller.loadbalancer.raidb2") org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerを再定義しています。 org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2ecで再定義されています。 RAIDb2.java の 96 行で定義されています。

int org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.parsingGranularity [protected, inherited]

AbstractLoadBalancer.java の 74 行で定義されています。

int org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.raidbLevel [protected, inherited]

AbstractLoadBalancer.java の 73 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer(), と org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getRAIDbLevel().

long org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.timestampResolution [private]

RAIDb2.java の 94 行で定義されています。

VirtualDatabase org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.vdb [protected, inherited]

AbstractLoadBalancer.java の 72 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.AbstractLoadBalancer().

WaitForCompletionPolicy org.objectweb.cjdbc.controller.loadbalancer.raidb2.RAIDb2.waitForCompletionPolicy [protected]

RAIDb2.java の 92 行で定義されています。

---

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

• RAIDb2.java

---