クラス org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager

org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManagerに対する継承グラフ

[凡例]org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManagerのコラボレーション図

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

---

説明

This connection manager returns null when the pool is empty. Therefore all requests fail fast until connections are freed.

作者:

Emmanuel Cecchet

Nicolas Modrzyk

バージョン:

1.0

FailFastPoolConnectionManager.java の 43 行で定義されています。

Public メソッド
	FailFastPoolConnectionManager (String backendUrl, String backendName, String login, String password, String driverPath, String driverClassName, int poolSize)
Connection	getConnection () throws UnreachableBackendException
synchronized void	releaseConnection (Connection c)
synchronized void	deleteConnection (Connection c)
String	getXmlImpl ()
Protected メソッド
Object	clone () throws CloneNotSupportedException

---

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

org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager.FailFastPoolConnectionManager (  String  backendUrl, String  backendName, String  login, String  password, String  driverPath, String  driverClassName, int  poolSize )

Creates a new FailFastPoolConnectionManager instance. 引数: backendUrl  URL of the DatabaseBackend owning this connection manager backendName  name of the DatabaseBackend owning this connection manager login  backend connection login to be used by this connection manager password  backend connection password to be used by this connection manager driverPath  path for driver driverClassName  class name for driver poolSize  size of the connection pool FailFastPoolConnectionManager.java の 63 行で定義されています。 { super(backendUrl, backendName, login, password, driverPath, driverClassName, poolSize); }

---

メソッド

Object org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager.clone (   )  throws CloneNotSupportedException [protected, virtual]

参照: java.lang.Object#clone() org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. FailFastPoolConnectionManager.java の 196 行で定義されています。 { return new FailFastPoolConnectionManager(backendUrl, backendName, rLogin, rPassword, driverPath, driverClassName, poolSize); }

synchronized void org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager.deleteConnection (  Connection  c  )  [virtual]

参照: org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.deleteConnection(Connection) org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. FailFastPoolConnectionManager.java の 155 行で定義されています。 { if (!initialized) return; // We probably have been disabled if (activeConnections.remove(c)) { Connection newConnection = getConnectionFromDriver(); if (newConnection == null) { if (logger.isDebugEnabled()) logger.error(Translate .get("connection.replaced.failed", c.toString())); } else { freeConnections.push(newConnection); if (logger.isDebugEnabled()) logger.debug(Translate.get("connection.replaced.success", c .toString())); } } else logger.error(Translate.get("connection.replaced.failed.exception", c .toString())); }

Connection org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager.getConnection (   )  throws UnreachableBackendException [virtual]

Gets a connection from the pool. Returns null if the pool is empty. 戻り値: a connection from the pool or null if the pool is exhausted 例外: UnreachableBackendException  if the backend must be disabled 参照: org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getConnection() org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. FailFastPoolConnectionManager.java の 80 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.error(), org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getConnectionFromDriver(), org.objectweb.cjdbc.common.log.Trace.info(), org.objectweb.cjdbc.common.log.Trace.isWarnEnabled(), と org.objectweb.cjdbc.common.log.Trace.warn(). { if (!initialized) { logger.error(Translate.get("connection.request.not.initialized")); return null; } try { // Both freeConnections and activeConnections are synchronized Connection c = (Connection) freeConnections.pop(); activeConnections.add(c); return c; } catch (EmptyStackException e) { synchronized (this) { int missing = poolSize - (activeConnections.size() + freeConnections.size()); if (missing > 0) { // Re-allocate missing connections logger.info(Translate.get("connection.reallocate.missing", missing)); Connection connectionToBeReturned = null; while (missing > 0) { Connection c = getConnectionFromDriver(); if (c == null) { if (missing == poolSize) { logger.error(Translate.get("connection.backend.unreachable", backendName)); throw new UnreachableBackendException(); } logger.warn(Translate .get("connection.reallocate.failed", missing)); break; } else { if (connectionToBeReturned == null) connectionToBeReturned = c; else freeConnections.add(c); } missing--; } return connectionToBeReturned; } } if (logger.isWarnEnabled()) logger.warn(Translate.get("connection.backend.out.of.connections", new String[]{backendName, String.valueOf(poolSize)})); return null; } }

String org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager.getXmlImpl (   )  [virtual]

参照: org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getXmlImpl() org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. FailFastPoolConnectionManager.java の 185 行で定義されています。 { StringBuffer info = new StringBuffer(); info.append("<" + DatabasesXmlTags.ELT_FailFastPoolConnectionManager + " " + DatabasesXmlTags.ATT_poolSize + "=\"" + poolSize / 1000 + "\"/>"); return info.toString(); }

synchronized void org.objectweb.cjdbc.controller.connection.FailFastPoolConnectionManager.releaseConnection (  Connection  c  )  [virtual]

参照: org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.releaseConnection(Connection) org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. FailFastPoolConnectionManager.java の 141 行で定義されています。 { if (!initialized) return; // We probably have been disabled if (activeConnections.remove(c)) freeConnections.push(c); else logger.error(Translate.get("connection.release.failed", c.toString())); }

---

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

• src/org/objectweb/cjdbc/controller/connection/FailFastPoolConnectionManager.java

---