クラス org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1

org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1に対する継承グラフ

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

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

---

説明

RAIDb-1 load balancer.

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

作者:

Emmanuel Cecchet

バージョン:

1.0

RAIDb1.java の 72 行で定義されています。

Public メソッド
	RAIDb1 (VirtualDatabase vdb, WaitForCompletionPolicy waitForCompletionPolicy, long timestampResolution) throws SQLException
abstract java.sql.ResultSet	execReadRequest (SelectRequest request) throws SQLException
int	execWriteRequest (AbstractWriteRequest request) throws AllBackendsFailedException, SQLException
ResultSet	execWriteRequestWithKeys (AbstractWriteRequest request) throws AllBackendsFailedException, 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	getRaidb1Xml ()
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
VirtualDatabase	vdb
int	raidbLevel
int	parsingGranularity
Static Protected 変数
Trace	logger
Private メソッド
int	getNbToWait (int nbOfThreads)
AbstractTask	execWriteRequest (AbstractWriteRequest request, boolean useKeys) throws AllBackendsFailedException, SQLException
AbstractTask	callStoredProcedure (StoredProcedure proc, boolean isRead) throws SQLException
Private 変数
long	timestampResolution

---

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

org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.RAIDb1 (  VirtualDatabase  vdb, WaitForCompletionPolicy  waitForCompletionPolicy, 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? timestampResolution  timestamp resolution for NOW macros 例外: SQLException  if an error occurs RAIDb1.java の 104 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.backendBlockingThreads, org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.backendNonBlockingThreads, と org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.waitForCompletionPolicy. { super(vdb, RAIDbLevels.RAIDb1, ParsingGranularities.NO_PARSING); this.waitForCompletionPolicy = waitForCompletionPolicy; this.timestampResolution = timestampResolution; backendBlockingThreads = new ArrayList(); backendNonBlockingThreads = new ArrayList(); }

---

メソッド

final void org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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に実装されています. RAIDb1.java の 910 行で定義されています。 { }

AbstractTask org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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 RAIDb1.java の 761 行で定義されています。 参照先 org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.acquireRead(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getFailed(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getSuccess(), org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.releaseRead(), と org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.removeTask(). { 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) { // 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) { if ((waitForCompletionPolicy.getPolicy() == WaitForCompletionPolicy.ALL)) thread.addTask(task); else thread.addTask(task, proc.getTransactionId()); thread.notify(); } } 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.raidb1.RAIDb1.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に実装されています. RAIDb1.java の 920 行で定義されています。 参照先 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 lTid = 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(lTid)) 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.raidb1.RAIDb1.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.raidb1.RAIDb1ecで再定義されています。 RAIDb1.java の 1326 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addPriorityTask(), org.objectweb.cjdbc.controller.backend.DatabaseBackend.equals(), と org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.getBackend(). { if (db.isWriteEnabled()) { // Starts with backendBlockingThreads 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())); // Remove it from the backendBlockingThread list backendBlockingThreads.remove(thread); synchronized (thread) { // Kill the thread thread.addPriorityTask(new KillThreadTask(1, 1)); thread.notify(); } break; } } backendBlockingThreadsRWLock.releaseWrite(); // Continue with backendNonBlockingThreads 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())); // Remove it from the backendNonBlockingThreads list 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.raidb1.RAIDb1.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.raidb1.RAIDb1ecで再定義されています。 RAIDb1.java の 1261 行で定義されています。 参照先 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.raidb1.RAIDb1.execReadRequest (  SelectRequest  request  )  throws SQLException [pure virtual]

参照: AbstractLoadBalancer.execReadRequest(SelectRequest) org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. 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を実装しています.

ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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に実装されています. RAIDb1.java の 734 行で定義されています。 参照先 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.raidb1.RAIDb1.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 RAIDb1.java の 162 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.error(). { // 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 SQLException(Translate.get( "loadbalancer.backend.no.connection", 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 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 = 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.raidb1.RAIDb1.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 RAIDb1.java の 576 行で定義されています。 { // 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 UnreachableBackendException(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; } }

AbstractTask org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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 RAIDb1.java の 367 行で定義されています。 参照先 org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.acquireRead(), org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.addTask(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getFailed(), org.objectweb.cjdbc.controller.loadbalancer.tasks.AbstractTask.getSuccess(), org.objectweb.cjdbc.common.util.ReadPrioritaryFIFOWriteLock.releaseRead(), と org.objectweb.cjdbc.controller.loadbalancer.BackendWorkerThread.removeTask(). { 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(); // 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) return task; 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.raidb1.RAIDb1.execWriteRequest (  AbstractWriteRequest  request  )  throws AllBackendsFailedException, SQLException [virtual]

Performs a write request. This request is broadcasted to all nodes. 引数: 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に実装されています. RAIDb1.java の 329 行で定義されています。 { if (!request.isParsed() && (request.isCreate() || request.isDrop())) request.parse(null, ParsingGranularities.TABLE, true); return ((WriteRequestTask) execWriteRequest(request, false)).getResult(); }

ResultSet org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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に実装されています. RAIDb1.java の 346 行で定義されています。 { if (!request.isParsed() && (request.isCreate() || request.isDrop())) request.parse(null, ParsingGranularities.TABLE, true); return ((WriteRequestWithKeysTask) execWriteRequest(request, false)) .getResult(); }

int org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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に実装されています. RAIDb1.java の 745 行で定義されています。 参照先 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.raidb1.RAIDb1.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 RAIDb1.java の 127 行で定義されています。 参照先 org.objectweb.cjdbc.controller.loadbalancer.policies.WaitForCompletionPolicy.getPolicy(), org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.waitForCompletionPolicy, と 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.raidb1.RAIDb1.getRaidb1Xml (   )  [pure virtual]

Surrounding raidb1 tags can be treated by getXmlImpl above, but more detailed content have to be returned by the method getRaidb1Xml below. 戻り値: content of Raidb1 xml 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を実装しています.

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.raidb1.RAIDb1.getXmlImpl (   )  [virtual]

参照: org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.getXmlImpl org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancerに実装されています. org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1ecで再定義されています。 RAIDb1.java の 1422 行で定義されています。 { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_RAIDb_1 + " " + DatabasesXmlTags.ATT_timestampResolution + "=\"" + timestampResolution + "\" >"); if (waitForCompletionPolicy != null) info.append(waitForCompletionPolicy.getXml()); info.append(getRaidb1Xml()); info.append("</" + DatabasesXmlTags.ELT_RAIDb_1 + ">"); return info.toString(); }

void org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.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に実装されています. RAIDb1.java の 1036 行で定義されています。 参照先 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 lTid = 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(lTid)) 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.raidb1.RAIDb1.waitForAllWritesToComplete (  DatabaseBackend  backend  )  throws SQLException [protected]

Waits for all writes in the blocking thread queue of the given backend to complete. 参照: executeRequestOnBackend RAIDb1.java の 1217 行で定義されています。 参照先 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.raidb1.RAIDb1.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 RAIDb1.java の 1183 行で定義されています。 参照先 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.raidb1.RAIDb1.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. RAIDb1.java の 1149 行で定義されています。 参照先 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); thread.waitForAllTasksToComplete(transactionId); } backendBlockingThreadsRWLock.releaseRead(); }

---

変数

ArrayList org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.backendBlockingThreads [protected]

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

ReadPrioritaryFIFOWriteLock org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.backendBlockingThreadsRWLock = new ReadPrioritaryFIFOWriteLock() [protected]

RAIDb1.java の 81 行で定義されています。

ArrayList org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.backendNonBlockingThreads [protected]

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

ReadPrioritaryFIFOWriteLock org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.backendNonBlockingThreadsRWLock = new ReadPrioritaryFIFOWriteLock() [protected]

RAIDb1.java の 82 行で定義されています。

Trace org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.logger [static, protected]

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

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.raidb1.RAIDb1.timestampResolution [private]

RAIDb1.java の 85 行で定義されています。

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.raidb1.RAIDb1.waitForCompletionPolicy [protected]

RAIDb1.java の 84 行で定義されています。 参照元 org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.getNbToWait(), と org.objectweb.cjdbc.controller.loadbalancer.raidb1.RAIDb1.RAIDb1().

---

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

• RAIDb1.java

---