}
}
- protected Member[] readMembers(ObjectInput in) throws IOException, ClassNotFoundException {
+ protected Member[] readMembers(ObjectInput in) throws IOException {
int nodecount = in.readInt();
Member[] members = new Member[nodecount];
for ( int i=0; i<members.length; i++ ) {
// get an iterator over the set of selected keys
Iterator<SelectionKey> it = (selector!=null)?selector.selectedKeys().iterator():null;
// look at each key in the selected set
- while (selector!=null && it.hasNext()) {
+ while (it!=null && it.hasNext()) {
SelectionKey key = it.next();
// Is a new connection coming in?
if (key.isAcceptable()) {
package org.apache.catalina.tribes.util;
-import java.util.Collection;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
super();
}
- public TaskQueue(int initialCapacity) {
- super(initialCapacity);
- }
-
- public TaskQueue(Collection<? extends Runnable> c) {
- super(c);
- }
-
public void setParent(ThreadPoolExecutor tp) {
parent = tp;
}
- public boolean force(Runnable o) {
- if ( parent.isShutdown() ) throw new RejectedExecutionException("Executor not running, can't force a command into the queue");
- return super.offer(o); //forces the item onto the queue, to be used if the task is rejected
- }
-
@Override
public boolean offer(Runnable o) {
//we can't do any checks
public class GenericNamingResourcesFactory implements ObjectFactory {
private static final Log log = LogFactory.getLog(GenericNamingResourcesFactory.class);
+ @Override
public Object getObjectInstance(Object obj, Name name, Context nameCtx, Hashtable<?, ?> environment) throws Exception {
if ((obj == null) || !(obj instanceof Reference)) {
return null;
params[1] = value;
if (setPropertyMethodBool != null) {
try {
- return (Boolean) setPropertyMethodBool.invoke(o, params);
+ return ((Boolean) setPropertyMethodBool.invoke(o, params)).booleanValue();
}catch (IllegalArgumentException biae) {
//the boolean method had the wrong
//parameter types. lets try the other
protected PooledConnection createConnection(long now, PooledConnection notUsed, String username, String password) throws SQLException {
//no connections where available we'll create one
PooledConnection con = create(false);
- if (username!=null) con.getAttributes().put(con.PROP_USER, username);
- if (password!=null) con.getAttributes().put(con.PROP_PASSWORD, password);
+ if (username!=null) con.getAttributes().put(
+ PooledConnection.PROP_USER, username);
+ if (password!=null) con.getAttributes().put(
+ PooledConnection.PROP_PASSWORD, password);
boolean error = false;
try {
//connect and validate the connection
/**
* {@inheritDoc}
*/
+ @Override
public boolean cancel(boolean mayInterruptIfRunning) {
if (pc!=null) {
return false;
/**
* {@inheritDoc}
*/
+ @Override
public Connection get() throws InterruptedException, ExecutionException {
try {
return get(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
/**
* {@inheritDoc}
*/
+ @Override
public Connection get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
PooledConnection pc = this.pc!=null?this.pc:pcFuture.get(timeout,unit);
if (pc!=null) {
/**
* {@inheritDoc}
*/
+ @Override
public boolean isCancelled() {
return pc==null && (pcFuture.isCancelled() || cancelled.get());
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean isDone() {
return pc!=null || pcFuture.isDone();
}
/**
* run method to be executed when cancelled by an executor
*/
+ @Override
public void run() {
try {
Connection con = get(); //complete this future
* Unregisters the underlying connection pool mbean.<br/>
* {@inheritDoc}
*/
+ @Override
public void postDeregister() {
if (oname!=null) unregisterJmx();
}
* no-op<br/>
* {@inheritDoc}
*/
+ @Override
public void postRegister(Boolean registrationDone) {
// NOOP
}
* no-op<br/>
* {@inheritDoc}
*/
+ @Override
public void preDeregister() throws Exception {
// NOOP
}
* If the connection pool MBean exists, it will be registered during this operation.<br/>
* {@inheritDoc}
*/
+ @Override
public ObjectName preRegister(MBeanServer server, ObjectName name) throws Exception {
try {
this.oname = createObjectName(name);
package org.apache.tomcat.jdbc.pool;
-import java.io.IOException;
import java.sql.Connection;
import java.util.Hashtable;
import java.util.Properties;
*
* @exception Exception if an exception occurs creating the instance
*/
+ @Override
public Object getObjectInstance(Object obj, Name name, Context nameCtx,
Hashtable<?,?> environment) throws Exception {
return createDataSource(properties,nameCtx,XA);
}
- public static PoolConfiguration parsePoolProperties(Properties properties) throws IOException{
+ public static PoolConfiguration parsePoolProperties(Properties properties) {
PoolConfiguration poolProperties = new PoolProperties();
String value = null;
}
if (jndiDS==null) {
try {
- context = (Context) (new InitialContext());
+ context = new InitialContext();
jndiDS = context.lookup(poolProperties.getDataSourceJNDI());
} catch (NamingException e) {
log.warn("The name \""+poolProperties.getDataSourceJNDI()+"\" can not be found in the InitialContext.");
* @return Properties
* @throws Exception
*/
- static protected Properties getProperties(String propText) throws IOException {
+ static protected Properties getProperties(String propText) {
return PoolProperties.getProperties(propText,null);
}
}
+ @Override
public String toString() {
return super.toString()+"{"+getPoolProperties()+"}";
}
* {@inheritDoc}
*/
+ @Override
public String getPoolName() {
return pool.getName();
}
* {@inheritDoc}
*/
+ @Override
public void setDriverClassName(String driverClassName) {
this.poolProperties.setDriverClassName(driverClassName);
}
* {@inheritDoc}
*/
+ @Override
public void setInitialSize(int initialSize) {
this.poolProperties.setInitialSize(initialSize);
}
* {@inheritDoc}
*/
+ @Override
public void setInitSQL(String initSQL) {
this.poolProperties.setInitSQL(initSQL);
}
* {@inheritDoc}
*/
+ @Override
public void setLogAbandoned(boolean logAbandoned) {
this.poolProperties.setLogAbandoned(logAbandoned);
}
* {@inheritDoc}
*/
+ @Override
public void setMaxActive(int maxActive) {
this.poolProperties.setMaxActive(maxActive);
}
* {@inheritDoc}
*/
+ @Override
public void setMaxIdle(int maxIdle) {
this.poolProperties.setMaxIdle(maxIdle);
}
* {@inheritDoc}
*/
+ @Override
public void setMaxWait(int maxWait) {
this.poolProperties.setMaxWait(maxWait);
}
* {@inheritDoc}
*/
+ @Override
public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
this.poolProperties.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
}
* {@inheritDoc}
*/
+ @Override
public void setMinIdle(int minIdle) {
this.poolProperties.setMinIdle(minIdle);
}
* {@inheritDoc}
*/
+ @Override
public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) {
this.poolProperties.setNumTestsPerEvictionRun(numTestsPerEvictionRun);
}
* {@inheritDoc}
*/
+ @Override
public void setPassword(String password) {
this.poolProperties.setPassword(password);
this.poolProperties.getDbProperties().setProperty("password",this.poolProperties.getPassword());
* {@inheritDoc}
*/
+ @Override
public void setRemoveAbandoned(boolean removeAbandoned) {
this.poolProperties.setRemoveAbandoned(removeAbandoned);
}
* {@inheritDoc}
*/
+ @Override
public void setRemoveAbandonedTimeout(int removeAbandonedTimeout) {
this.poolProperties.setRemoveAbandonedTimeout(removeAbandonedTimeout);
}
* {@inheritDoc}
*/
+ @Override
public void setTestOnBorrow(boolean testOnBorrow) {
this.poolProperties.setTestOnBorrow(testOnBorrow);
}
* {@inheritDoc}
*/
+ @Override
public void setTestOnConnect(boolean testOnConnect) {
this.poolProperties.setTestOnConnect(testOnConnect);
}
* {@inheritDoc}
*/
+ @Override
public void setTestOnReturn(boolean testOnReturn) {
this.poolProperties.setTestOnReturn(testOnReturn);
}
* {@inheritDoc}
*/
+ @Override
public void setTestWhileIdle(boolean testWhileIdle) {
this.poolProperties.setTestWhileIdle(testWhileIdle);
}
* {@inheritDoc}
*/
+ @Override
public void setTimeBetweenEvictionRunsMillis(int timeBetweenEvictionRunsMillis) {
this.poolProperties.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
}
* {@inheritDoc}
*/
+ @Override
public void setUrl(String url) {
this.poolProperties.setUrl(url);
}
* {@inheritDoc}
*/
+ @Override
public void setUsername(String username) {
this.poolProperties.setUsername(username);
this.poolProperties.getDbProperties().setProperty("user",getPoolProperties().getUsername());
* {@inheritDoc}
*/
+ @Override
public void setValidationInterval(long validationInterval) {
this.poolProperties.setValidationInterval(validationInterval);
}
* {@inheritDoc}
*/
+ @Override
public void setValidationQuery(String validationQuery) {
this.poolProperties.setValidationQuery(validationQuery);
}
* {@inheritDoc}
*/
+ @Override
public void setValidatorClassName(String className) {
this.poolProperties.setValidatorClassName(className);
}
* {@inheritDoc}
*/
+ @Override
public void setJdbcInterceptors(String interceptors) {
this.getPoolProperties().setJdbcInterceptors(interceptors);
}
* {@inheritDoc}
*/
+ @Override
public void setJmxEnabled(boolean enabled) {
this.getPoolProperties().setJmxEnabled(enabled);
}
* {@inheritDoc}
*/
+ @Override
public void setFairQueue(boolean fairQueue) {
this.getPoolProperties().setFairQueue(fairQueue);
}
* {@inheritDoc}
*/
+ @Override
public void setUseLock(boolean useLock) {
this.getPoolProperties().setUseLock(useLock);
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultCatalog(String catalog) {
this.getPoolProperties().setDefaultCatalog(catalog);
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultAutoCommit(Boolean autocommit) {
this.getPoolProperties().setDefaultAutoCommit(autocommit);
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultTransactionIsolation(int defaultTransactionIsolation) {
this.getPoolProperties().setDefaultTransactionIsolation(defaultTransactionIsolation);
}
* {@inheritDoc}
*/
+ @Override
public void setConnectionProperties(String properties) {
try {
java.util.Properties prop = DataSourceFactory
* {@inheritDoc}
*/
+ @Override
public void setUseEquals(boolean useEquals) {
this.getPoolProperties().setUseEquals(useEquals);
}
* {@inheritDoc}
*/
+ @Override
public int getSuspectTimeout() {
return getPoolProperties().getSuspectTimeout();
}
* {@inheritDoc}
*/
+ @Override
public void setSuspectTimeout(int seconds) {
getPoolProperties().setSuspectTimeout(seconds);
}
* {@inheritDoc}
*/
+ @Override
public String getConnectionProperties() {
return getPoolProperties().getConnectionProperties();
}
* {@inheritDoc}
*/
+ @Override
public Properties getDbProperties() {
return getPoolProperties().getDbProperties();
}
* {@inheritDoc}
*/
+ @Override
public String getDefaultCatalog() {
return getPoolProperties().getDefaultCatalog();
}
* {@inheritDoc}
*/
+ @Override
public int getDefaultTransactionIsolation() {
return getPoolProperties().getDefaultTransactionIsolation();
}
* {@inheritDoc}
*/
+ @Override
public String getDriverClassName() {
return getPoolProperties().getDriverClassName();
}
* {@inheritDoc}
*/
+ @Override
public int getInitialSize() {
return getPoolProperties().getInitialSize();
}
* {@inheritDoc}
*/
+ @Override
public String getInitSQL() {
return getPoolProperties().getInitSQL();
}
* {@inheritDoc}
*/
+ @Override
public String getJdbcInterceptors() {
return getPoolProperties().getJdbcInterceptors();
}
* {@inheritDoc}
*/
+ @Override
public int getMaxActive() {
return getPoolProperties().getMaxActive();
}
* {@inheritDoc}
*/
+ @Override
public int getMaxIdle() {
return getPoolProperties().getMaxIdle();
}
* {@inheritDoc}
*/
+ @Override
public int getMaxWait() {
return getPoolProperties().getMaxWait();
}
* {@inheritDoc}
*/
+ @Override
public int getMinEvictableIdleTimeMillis() {
return getPoolProperties().getMinEvictableIdleTimeMillis();
}
* {@inheritDoc}
*/
+ @Override
public int getMinIdle() {
return getPoolProperties().getMinIdle();
}
* {@inheritDoc}
*/
+ @Override
public long getMaxAge() {
return getPoolProperties().getMaxAge();
}
* {@inheritDoc}
*/
+ @Override
public String getName() {
return getPoolProperties().getName();
}
* {@inheritDoc}
*/
+ @Override
public int getNumTestsPerEvictionRun() {
return getPoolProperties().getNumTestsPerEvictionRun();
}
/**
* @return DOES NOT RETURN THE PASSWORD, IT WOULD SHOW UP IN JMX
*/
+ @Override
public String getPassword() {
return "Password not available as DataSource/JMX operation.";
}
* {@inheritDoc}
*/
+ @Override
public int getRemoveAbandonedTimeout() {
return getPoolProperties().getRemoveAbandonedTimeout();
}
* {@inheritDoc}
*/
+ @Override
public int getTimeBetweenEvictionRunsMillis() {
return getPoolProperties().getTimeBetweenEvictionRunsMillis();
}
* {@inheritDoc}
*/
+ @Override
public String getUrl() {
return getPoolProperties().getUrl();
}
* {@inheritDoc}
*/
+ @Override
public String getUsername() {
return getPoolProperties().getUsername();
}
* {@inheritDoc}
*/
+ @Override
public long getValidationInterval() {
return getPoolProperties().getValidationInterval();
}
* {@inheritDoc}
*/
+ @Override
public String getValidationQuery() {
return getPoolProperties().getValidationQuery();
}
* {@inheritDoc}
*/
+ @Override
public String getValidatorClassName() {
return getPoolProperties().getValidatorClassName();
}
* {@inheritDoc}
*/
+ @Override
public Validator getValidator() {
return getPoolProperties().getValidator();
}
/**
* {@inheritDoc}
*/
+ @Override
public void setValidator(Validator validator) {
getPoolProperties().setValidator(validator);
}
* {@inheritDoc}
*/
+ @Override
public boolean isAccessToUnderlyingConnectionAllowed() {
return getPoolProperties().isAccessToUnderlyingConnectionAllowed();
}
* {@inheritDoc}
*/
+ @Override
public Boolean isDefaultAutoCommit() {
return getPoolProperties().isDefaultAutoCommit();
}
* {@inheritDoc}
*/
+ @Override
public Boolean isDefaultReadOnly() {
return getPoolProperties().isDefaultReadOnly();
}
* {@inheritDoc}
*/
+ @Override
public boolean isLogAbandoned() {
return getPoolProperties().isLogAbandoned();
}
* {@inheritDoc}
*/
+ @Override
public boolean isPoolSweeperEnabled() {
return getPoolProperties().isPoolSweeperEnabled();
}
* {@inheritDoc}
*/
+ @Override
public boolean isRemoveAbandoned() {
return getPoolProperties().isRemoveAbandoned();
}
* {@inheritDoc}
*/
+ @Override
public int getAbandonWhenPercentageFull() {
return getPoolProperties().getAbandonWhenPercentageFull();
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestOnBorrow() {
return getPoolProperties().isTestOnBorrow();
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestOnConnect() {
return getPoolProperties().isTestOnConnect();
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestOnReturn() {
return getPoolProperties().isTestOnReturn();
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestWhileIdle() {
return getPoolProperties().isTestWhileIdle();
}
* {@inheritDoc}
*/
+ @Override
public Boolean getDefaultAutoCommit() {
return getPoolProperties().getDefaultAutoCommit();
}
* {@inheritDoc}
*/
+ @Override
public Boolean getDefaultReadOnly() {
return getPoolProperties().getDefaultReadOnly();
}
* {@inheritDoc}
*/
+ @Override
public InterceptorDefinition[] getJdbcInterceptorsAsArray() {
return getPoolProperties().getJdbcInterceptorsAsArray();
}
* {@inheritDoc}
*/
+ @Override
public boolean getUseLock() {
return getPoolProperties().getUseLock();
}
* {@inheritDoc}
*/
+ @Override
public boolean isFairQueue() {
return getPoolProperties().isFairQueue();
}
* {@inheritDoc}
*/
+ @Override
public boolean isJmxEnabled() {
return getPoolProperties().isJmxEnabled();
}
* {@inheritDoc}
*/
+ @Override
public boolean isUseEquals() {
return getPoolProperties().isUseEquals();
}
* {@inheritDoc}
*/
+ @Override
public void setAbandonWhenPercentageFull(int percentage) {
getPoolProperties().setAbandonWhenPercentageFull(percentage);
}
* {@inheritDoc}
*/
+ @Override
public void setAccessToUnderlyingConnectionAllowed(boolean accessToUnderlyingConnectionAllowed) {
getPoolProperties().setAccessToUnderlyingConnectionAllowed(accessToUnderlyingConnectionAllowed);
}
* {@inheritDoc}
*/
+ @Override
public void setDbProperties(Properties dbProperties) {
getPoolProperties().setDbProperties(dbProperties);
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultReadOnly(Boolean defaultReadOnly) {
getPoolProperties().setDefaultReadOnly(defaultReadOnly);
}
* {@inheritDoc}
*/
+ @Override
public void setMaxAge(long maxAge) {
getPoolProperties().setMaxAge(maxAge);
}
* {@inheritDoc}
*/
+ @Override
public void setName(String name) {
getPoolProperties().setName(name);
}
/**
* {@inheritDoc}
*/
+ @Override
public void setDataSource(Object ds) {
getPoolProperties().setDataSource(ds);
}
/**
* {@inheritDoc}
*/
+ @Override
public Object getDataSource() {
return getPoolProperties().getDataSource();
}
/**
* {@inheritDoc}
*/
+ @Override
public void setDataSourceJNDI(String jndiDS) {
getPoolProperties().setDataSourceJNDI(jndiDS);
}
/**
* {@inheritDoc}
*/
+ @Override
public String getDataSourceJNDI() {
return getPoolProperties().getDataSourceJNDI();
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean isAlternateUsernameAllowed() {
return getPoolProperties().isAlternateUsernameAllowed();
}
/**
* {@inheritDoc}
*/
+ @Override
public void setAlternateUsernameAllowed(boolean alternateUsernameAllowed) {
getPoolProperties().setAlternateUsernameAllowed(alternateUsernameAllowed);
}
* Will always return true, queue is unbounded.
* {@inheritDoc}
*/
+ @Override
public boolean offer(E e) {
//during the offer, we will grab the main lock
final ReentrantLock lock = this.lock;
* Once a lock has been acquired, the
* {@inheritDoc}
*/
+ @Override
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
return offer(e);
}
* Objects are returned in the order the threads requested them.
* {@inheritDoc}
*/
+ @Override
public E poll(long timeout, TimeUnit unit) throws InterruptedException {
E result = null;
final ReentrantLock lock = this.lock;
/**
* {@inheritDoc}
*/
+ @Override
public boolean remove(Object e) {
final ReentrantLock lock = this.lock;
lock.lock();
/**
* {@inheritDoc}
*/
+ @Override
public int size() {
return items.size();
}
/**
* {@inheritDoc}
*/
+ @Override
public Iterator<E> iterator() {
return new FairIterator();
}
/**
* {@inheritDoc}
*/
+ @Override
public E poll() {
final ReentrantLock lock = this.lock;
lock.lock();
/**
* {@inheritDoc}
*/
+ @Override
public boolean contains(Object e) {
final ReentrantLock lock = this.lock;
lock.lock();
/**
* {@inheritDoc}
*/
+ @Override
public boolean add(E e) {
return offer(e);
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public int drainTo(Collection<? super E> c, int maxElements) {
throw new UnsupportedOperationException("int drainTo(Collection<? super E> c, int maxElements)");
}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public int drainTo(Collection<? super E> c) {
return drainTo(c,Integer.MAX_VALUE);
}
/**
* {@inheritDoc}
*/
+ @Override
public void put(E e) throws InterruptedException {
offer(e);
}
/**
* {@inheritDoc}
*/
+ @Override
public int remainingCapacity() {
return Integer.MAX_VALUE - size();
}
/**
* {@inheritDoc}
*/
+ @Override
public E take() throws InterruptedException {
return this.poll(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean addAll(Collection<? extends E> c) {
Iterator<? extends E> i = c.iterator();
while (i.hasNext()) {
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public void clear() {
throw new UnsupportedOperationException("void clear()");
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public boolean containsAll(Collection<?> c) {
throw new UnsupportedOperationException("boolean containsAll(Collection<?> c)");
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean isEmpty() {
return size() == 0;
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public boolean removeAll(Collection<?> c) {
throw new UnsupportedOperationException("boolean removeAll(Collection<?> c)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public boolean retainAll(Collection<?> c) {
throw new UnsupportedOperationException("boolean retainAll(Collection<?> c)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public Object[] toArray() {
throw new UnsupportedOperationException("Object[] toArray()");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public <T> T[] toArray(T[] a) {
throw new UnsupportedOperationException("<T> T[] toArray(T[] a)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public E element() {
throw new UnsupportedOperationException("E element()");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public E peek() {
throw new UnsupportedOperationException("E peek()");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public E remove() {
throw new UnsupportedOperationException("E remove()");
}
this.latch = latch;
}
+ @Override
public boolean cancel(boolean mayInterruptIfRunning) {
return false; //don't allow cancel for now
}
+ @Override
public T get() throws InterruptedException, ExecutionException {
if (item!=null) {
return item;
}
}
+ @Override
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
if (item!=null) {
return item;
}
}
+ @Override
public boolean isCancelled() {
return false;
}
+ @Override
public boolean isDone() {
return (item!=null || latch.getItem()!=null);
}
lock.unlock();
}
}
+ @Override
public boolean hasNext() {
return index<elements.length;
}
+ @Override
public E next() {
if (!hasNext()) {
throw new NoSuchElementException();
return element;
}
+ @Override
public void remove() {
final ReentrantLock lock = FairBlockingQueue.this.lock;
lock.lock();
* {@inheritDoc}
*/
+ @Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if (getNext()!=null) return getNext().invoke(this,method,args);
else throw new NullPointerException();
* Will always return true, queue is unbounded.
* {@inheritDoc}
*/
+ @Override
public boolean offer(E e) {
int idx = getNextPut();
//during the offer, we will grab the main lock
* Once a lock has been acquired, the
* {@inheritDoc}
*/
+ @Override
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
return offer(e);
}
* Objects are returned in the order the threads requested them.
* {@inheritDoc}
*/
+ @Override
public E poll(long timeout, TimeUnit unit) throws InterruptedException {
int idx = getNextPoll();
E result = null;
/**
* {@inheritDoc}
*/
+ @Override
public boolean remove(Object e) {
for (int idx=0; idx<LOCK_COUNT; idx++) {
final ReentrantLock lock = this.locks[idx];
/**
* {@inheritDoc}
*/
+ @Override
public int size() {
int size = 0;
for (int idx=0; idx<LOCK_COUNT; idx++) {
/**
* {@inheritDoc}
*/
+ @Override
public Iterator<E> iterator() {
return new FairIterator();
}
/**
* {@inheritDoc}
*/
+ @Override
public E poll() {
int idx = getNextPoll();
final ReentrantLock lock = this.locks[idx];
/**
* {@inheritDoc}
*/
+ @Override
public boolean contains(Object e) {
for (int idx=0; idx<LOCK_COUNT; idx++) {
boolean result = items[idx].contains(e);
/**
* {@inheritDoc}
*/
+ @Override
public boolean add(E e) {
return offer(e);
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public int drainTo(Collection<? super E> c, int maxElements) {
throw new UnsupportedOperationException("int drainTo(Collection<? super E> c, int maxElements)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public int drainTo(Collection<? super E> c) {
return drainTo(c,Integer.MAX_VALUE);
}
/**
* {@inheritDoc}
*/
+ @Override
public void put(E e) throws InterruptedException {
offer(e);
}
/**
* {@inheritDoc}
*/
+ @Override
public int remainingCapacity() {
return Integer.MAX_VALUE - size();
}
/**
* {@inheritDoc}
*/
+ @Override
public E take() throws InterruptedException {
return this.poll(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean addAll(Collection<? extends E> c) {
Iterator<? extends E> i = c.iterator();
while (i.hasNext()) {
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public void clear() {
throw new UnsupportedOperationException("void clear()");
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public boolean containsAll(Collection<?> c) {
throw new UnsupportedOperationException("boolean containsAll(Collection<?> c)");
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean isEmpty() {
return size() == 0;
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public boolean removeAll(Collection<?> c) {
throw new UnsupportedOperationException("boolean removeAll(Collection<?> c)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public boolean retainAll(Collection<?> c) {
throw new UnsupportedOperationException("boolean retainAll(Collection<?> c)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public Object[] toArray() {
throw new UnsupportedOperationException("Object[] toArray()");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public <T> T[] toArray(T[] a) {
throw new UnsupportedOperationException("<T> T[] toArray(T[] a)");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public E element() {
throw new UnsupportedOperationException("E element()");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public E peek() {
throw new UnsupportedOperationException("E peek()");
}
* {@inheritDoc}
* @throws UnsupportedOperationException - this operation is not supported
*/
+ @Override
public E remove() {
throw new UnsupportedOperationException("E remove()");
}
this.latch = latch;
}
+ @Override
public boolean cancel(boolean mayInterruptIfRunning) {
return false; //don't allow cancel for now
}
+ @Override
public T get() throws InterruptedException, ExecutionException {
if (item!=null) {
return item;
}
}
+ @Override
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
if (item!=null) {
return item;
}
}
+ @Override
public boolean isCancelled() {
return false;
}
+ @Override
public boolean isDone() {
return (item!=null || latch.getItem()!=null);
}
elements = (E[]) new Object[list.size()];
list.toArray(elements);
}
+ @Override
public boolean hasNext() {
return index<elements.length;
}
+ @Override
public E next() {
if (!hasNext()) {
throw new NoSuchElementException();
return element;
}
+ @Override
public void remove() {
for (int idx=0; idx<LOCK_COUNT; idx++) {
final ReentrantLock lock = MultiLockFairBlockingQueue.this.locks[idx];
* {@inheritDoc}
*/
+ @Override
public void setAbandonWhenPercentageFull(int percentage) {
if (percentage<0) abandonWhenPercentageFull = 0;
else if (percentage>100) abandonWhenPercentageFull = 100;
* {@inheritDoc}
*/
+ @Override
public int getAbandonWhenPercentageFull() {
return abandonWhenPercentageFull;
}
* {@inheritDoc}
*/
+ @Override
public boolean isFairQueue() {
return fairQueue;
}
* {@inheritDoc}
*/
+ @Override
public void setFairQueue(boolean fairQueue) {
this.fairQueue = fairQueue;
}
* {@inheritDoc}
*/
+ @Override
public boolean isAccessToUnderlyingConnectionAllowed() {
return accessToUnderlyingConnectionAllowed;
}
* {@inheritDoc}
*/
+ @Override
public String getConnectionProperties() {
return connectionProperties;
}
* {@inheritDoc}
*/
+ @Override
public Properties getDbProperties() {
return dbProperties;
}
* {@inheritDoc}
*/
+ @Override
public Boolean isDefaultAutoCommit() {
return defaultAutoCommit;
}
* {@inheritDoc}
*/
+ @Override
public String getDefaultCatalog() {
return defaultCatalog;
}
* {@inheritDoc}
*/
+ @Override
public Boolean isDefaultReadOnly() {
return defaultReadOnly;
}
* {@inheritDoc}
*/
+ @Override
public int getDefaultTransactionIsolation() {
return defaultTransactionIsolation;
}
* {@inheritDoc}
*/
+ @Override
public String getDriverClassName() {
return driverClassName;
}
* {@inheritDoc}
*/
+ @Override
public int getInitialSize() {
return initialSize;
}
* {@inheritDoc}
*/
+ @Override
public boolean isLogAbandoned() {
return logAbandoned;
}
* {@inheritDoc}
*/
+ @Override
public int getMaxActive() {
return maxActive;
}
* {@inheritDoc}
*/
+ @Override
public int getMaxIdle() {
return maxIdle;
}
* {@inheritDoc}
*/
+ @Override
public int getMaxWait() {
return maxWait;
}
* {@inheritDoc}
*/
+ @Override
public int getMinEvictableIdleTimeMillis() {
return minEvictableIdleTimeMillis;
}
* {@inheritDoc}
*/
+ @Override
public int getMinIdle() {
return minIdle;
}
* {@inheritDoc}
*/
+ @Override
public String getName() {
return name;
}
* {@inheritDoc}
*/
+ @Override
public int getNumTestsPerEvictionRun() {
return numTestsPerEvictionRun;
}
* {@inheritDoc}
*/
+ @Override
public String getPassword() {
return password;
}
* {@inheritDoc}
*/
+ @Override
public String getPoolName() {
return getName();
}
* {@inheritDoc}
*/
+ @Override
public boolean isRemoveAbandoned() {
return removeAbandoned;
}
* {@inheritDoc}
*/
+ @Override
public int getRemoveAbandonedTimeout() {
return removeAbandonedTimeout;
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestOnBorrow() {
return testOnBorrow;
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestOnReturn() {
return testOnReturn;
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestWhileIdle() {
return testWhileIdle;
}
* {@inheritDoc}
*/
+ @Override
public int getTimeBetweenEvictionRunsMillis() {
return timeBetweenEvictionRunsMillis;
}
* {@inheritDoc}
*/
+ @Override
public String getUrl() {
return url;
}
* {@inheritDoc}
*/
+ @Override
public String getUsername() {
return username;
}
* {@inheritDoc}
*/
+ @Override
public String getValidationQuery() {
return validationQuery;
}
* {@inheritDoc}
*/
+ @Override
public String getValidatorClassName() {
return validatorClassName;
}
* {@inheritDoc}
*/
+ @Override
public Validator getValidator() {
return validator;
}
/**
* {@inheritDoc}
*/
+ @Override
public void setValidator(Validator validator) {
this.validator = validator;
if (validator!=null) {
* {@inheritDoc}
*/
+ @Override
public long getValidationInterval() {
return validationInterval;
}
* {@inheritDoc}
*/
+ @Override
public String getInitSQL() {
return initSQL;
}
* {@inheritDoc}
*/
+ @Override
public boolean isTestOnConnect() {
return testOnConnect;
}
* {@inheritDoc}
*/
+ @Override
public String getJdbcInterceptors() {
return jdbcInterceptors;
}
* {@inheritDoc}
*/
+ @Override
public InterceptorDefinition[] getJdbcInterceptorsAsArray() {
if (interceptors == null) {
if (jdbcInterceptors==null) {
* {@inheritDoc}
*/
+ @Override
public void setAccessToUnderlyingConnectionAllowed(boolean accessToUnderlyingConnectionAllowed) {
// NOOP
}
* {@inheritDoc}
*/
+ @Override
public void setConnectionProperties(String connectionProperties) {
this.connectionProperties = connectionProperties;
getProperties(connectionProperties, getDbProperties());
* {@inheritDoc}
*/
+ @Override
public void setDbProperties(Properties dbProperties) {
this.dbProperties = dbProperties;
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultAutoCommit(Boolean defaultAutoCommit) {
this.defaultAutoCommit = defaultAutoCommit;
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultCatalog(String defaultCatalog) {
this.defaultCatalog = defaultCatalog;
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultReadOnly(Boolean defaultReadOnly) {
this.defaultReadOnly = defaultReadOnly;
}
* {@inheritDoc}
*/
+ @Override
public void setDefaultTransactionIsolation(int defaultTransactionIsolation) {
this.defaultTransactionIsolation = defaultTransactionIsolation;
}
* {@inheritDoc}
*/
+ @Override
public void setDriverClassName(String driverClassName) {
this.driverClassName = driverClassName;
}
* {@inheritDoc}
*/
+ @Override
public void setInitialSize(int initialSize) {
this.initialSize = initialSize;
}
* {@inheritDoc}
*/
+ @Override
public void setLogAbandoned(boolean logAbandoned) {
this.logAbandoned = logAbandoned;
}
* {@inheritDoc}
*/
+ @Override
public void setMaxActive(int maxActive) {
this.maxActive = maxActive;
}
* {@inheritDoc}
*/
+ @Override
public void setMaxIdle(int maxIdle) {
this.maxIdle = maxIdle;
}
* {@inheritDoc}
*/
+ @Override
public void setMaxWait(int maxWait) {
this.maxWait = maxWait;
}
* {@inheritDoc}
*/
+ @Override
public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
}
* {@inheritDoc}
*/
+ @Override
public void setMinIdle(int minIdle) {
this.minIdle = minIdle;
}
* {@inheritDoc}
*/
+ @Override
public void setName(String name) {
this.name = name;
}
* {@inheritDoc}
*/
+ @Override
public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) {
this.numTestsPerEvictionRun = numTestsPerEvictionRun;
}
* {@inheritDoc}
*/
+ @Override
public void setPassword(String password) {
this.password = password;
}
* {@inheritDoc}
*/
+ @Override
public void setRemoveAbandoned(boolean removeAbandoned) {
this.removeAbandoned = removeAbandoned;
}
* {@inheritDoc}
*/
+ @Override
public void setRemoveAbandonedTimeout(int removeAbandonedTimeout) {
this.removeAbandonedTimeout = removeAbandonedTimeout;
}
* {@inheritDoc}
*/
+ @Override
public void setTestOnBorrow(boolean testOnBorrow) {
this.testOnBorrow = testOnBorrow;
}
* {@inheritDoc}
*/
+ @Override
public void setTestWhileIdle(boolean testWhileIdle) {
this.testWhileIdle = testWhileIdle;
}
* {@inheritDoc}
*/
+ @Override
public void setTestOnReturn(boolean testOnReturn) {
this.testOnReturn = testOnReturn;
}
* {@inheritDoc}
*/
+ @Override
public void setTimeBetweenEvictionRunsMillis(int
timeBetweenEvictionRunsMillis) {
this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
* {@inheritDoc}
*/
+ @Override
public void setUrl(String url) {
this.url = url;
}
* {@inheritDoc}
*/
+ @Override
public void setUsername(String username) {
this.username = username;
}
* {@inheritDoc}
*/
+ @Override
public void setValidationInterval(long validationInterval) {
this.validationInterval = validationInterval;
}
* {@inheritDoc}
*/
+ @Override
public void setValidationQuery(String validationQuery) {
this.validationQuery = validationQuery;
}
* {@inheritDoc}
*/
+ @Override
public void setValidatorClassName(String className) {
this.validatorClassName = className;
* {@inheritDoc}
*/
+ @Override
public void setInitSQL(String initSQL) {
this.initSQL = initSQL;
}
* {@inheritDoc}
*/
+ @Override
public void setTestOnConnect(boolean testOnConnect) {
this.testOnConnect = testOnConnect;
}
* {@inheritDoc}
*/
+ @Override
public void setJdbcInterceptors(String jdbcInterceptors) {
this.jdbcInterceptors = jdbcInterceptors;
this.interceptors = null;
}
+ @Override
public String toString() {
StringBuilder buf = new StringBuilder("ConnectionPool[");
try {
* {@inheritDoc}
*/
+ @Override
public boolean isJmxEnabled() {
return jmxEnabled;
}
* {@inheritDoc}
*/
+ @Override
public void setJmxEnabled(boolean jmxEnabled) {
this.jmxEnabled = jmxEnabled;
}
* {@inheritDoc}
*/
+ @Override
public Boolean getDefaultAutoCommit() {
return defaultAutoCommit;
}
* {@inheritDoc}
*/
+ @Override
public Boolean getDefaultReadOnly() {
return defaultReadOnly;
}
* {@inheritDoc}
*/
+ @Override
public int getSuspectTimeout() {
return this.suspectTimeout;
}
* {@inheritDoc}
*/
+ @Override
public void setSuspectTimeout(int seconds) {
this.suspectTimeout = seconds;
}
* {@inheritDoc}
*/
+ @Override
public boolean isPoolSweeperEnabled() {
boolean timer = getTimeBetweenEvictionRunsMillis()>0;
boolean result = timer && (isRemoveAbandoned() && getRemoveAbandonedTimeout()>0);
}
}
+ @Override
public int hashCode() {
return name.hashCode();
}
+ @Override
public boolean equals(Object o) {
if (o==this) return true;
if (o instanceof InterceptorProperty) {
* {@inheritDoc}
*/
+ @Override
public boolean isUseEquals() {
return useEquals;
}
* {@inheritDoc}
*/
+ @Override
public void setUseEquals(boolean useEquals) {
this.useEquals = useEquals;
}
* {@inheritDoc}
*/
+ @Override
public long getMaxAge() {
return maxAge;
}
* {@inheritDoc}
*/
+ @Override
public void setMaxAge(long maxAge) {
this.maxAge = maxAge;
}
* {@inheritDoc}
*/
+ @Override
public boolean getUseLock() {
return useLock;
}
* {@inheritDoc}
*/
+ @Override
public void setUseLock(boolean useLock) {
this.useLock = useLock;
}
/**
* {@inheritDoc}
*/
+ @Override
public void setDataSource(Object ds) {
this.dataSource = ds;
}
/**
* {@inheritDoc}
*/
+ @Override
public Object getDataSource() {
return dataSource;
}
/**
* {@inheritDoc}
*/
+ @Override
public void setDataSourceJNDI(String jndiDS) {
this.dataSourceJNDI = jndiDS;
}
/**
* {@inheritDoc}
*/
+ @Override
public String getDataSourceJNDI() {
return this.dataSourceJNDI;
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean isAlternateUsernameAllowed() {
return alternateUsernameAllowed;
}
/**
* {@inheritDoc}
*/
+ @Override
public void setAlternateUsernameAllowed(boolean alternateUsernameAllowed) {
this.alternateUsernameAllowed = alternateUsernameAllowed;
}
if (compare(UNWRAP_VAL,method)) {
return unwrap((Class<?>)args[0]);
} else if (compare(ISWRAPPERFOR_VAL,method)) {
- return this.isWrapperFor((Class<?>)args[0]);
+ return Boolean.valueOf(this.isWrapperFor((Class<?>)args[0]));
}
try {
PooledConnection poolc = connection;
this.query = query;
}
+ @Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
//get the name of the method for comparison
final String name = method.getName();
//create the map to hold our stats
//however TODO we need to improve the eviction
//selection
- queries = new ConcurrentHashMap<String,QueryStats>() {
-
- };
+ queries = new ConcurrentHashMap<String,QueryStats>();
if (perPoolStats.putIfAbsent(pool.getName(), queries)!=null) {
//there already was one
queries = SlowQueryReport.perPoolStats.get(pool.getName());
//==============================JMX STUFF========================
protected volatile NotificationBroadcasterSupport notifier = new NotificationBroadcasterSupport();
+ @Override
public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException {
notifier.addNotificationListener(listener, filter, handback);
}
+ @Override
public MBeanNotificationInfo[] getNotificationInfo() {
return notifier.getNotificationInfo();
}
+ @Override
public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException {
notifier.removeNotificationListener(listener);
}
+ @Override
public void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException {
notifier.removeNotificationListener(listener, filter, handback);
* JMX operation - returns all the queries we have collected.
* @return - the slow query report as composite data.
*/
+ @Override
public CompositeData[] getSlowQueriesCD() throws OpenDataException {
CompositeDataSupport[] result = null;
ConcurrentHashMap<String,QueryStats> queries = perPoolStats.get(poolName);
Object statement, Constructor<?> constructor, String sql)
throws InstantiationException, IllegalAccessException, InvocationTargetException {
Object result = null;
- StatementProxy statementProxy = new StatementProxy<Statement>((Statement)statement,sql);
+ StatementProxy<Statement> statementProxy =
+ new StatementProxy<Statement>((Statement)statement,sql);
result = constructor.newInstance(new Object[] { statementProxy });
statementProxy.setActualProxy(result);
statementProxy.setConnection(proxy);
delegate = null;
}
+ @Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if (compare(TOSTRING_VAL,method)) {
return toString();
return result;
}
+ @Override
public String toString() {
StringBuffer buf = new StringBuffer(StatementProxy.class.getName());
buf.append("[Proxy=");
this.delegate = delegate;
}
+ @Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if (method.getName().equals("getStatement")) {
return this.st;
// POOL STATS
//=================================================================
+ @Override
public int getSize() {
return pool.getSize();
}
+ @Override
public int getIdle() {
return pool.getIdle();
}
+ @Override
public int getActive() {
return pool.getActive();
}
+ @Override
public int getNumIdle() {
return getIdle();
}
+ @Override
public int getNumActive() {
return getActive();
}
+ @Override
public int getWaitCount() {
return pool.getWaitCount();
}
//=================================================================
// POOL OPERATIONS
//=================================================================
+ @Override
public void checkIdle() {
pool.checkIdle();
}
+ @Override
public void checkAbandoned() {
pool.checkAbandoned();
}
+ @Override
public void testIdle() {
pool.testAllIdle();
}
//=========================================================
+ @Override
public String getConnectionProperties() {
return getPoolProperties().getConnectionProperties();
}
+ @Override
public Properties getDbProperties() {
return PoolUtilities.cloneWithoutPassword(getPoolProperties().getDbProperties());
}
+ @Override
public String getDefaultCatalog() {
return getPoolProperties().getDefaultCatalog();
}
+ @Override
public int getDefaultTransactionIsolation() {
return getPoolProperties().getDefaultTransactionIsolation();
}
+ @Override
public String getDriverClassName() {
return getPoolProperties().getDriverClassName();
}
+ @Override
public int getInitialSize() {
return getPoolProperties().getInitialSize();
}
+ @Override
public String getInitSQL() {
return getPoolProperties().getInitSQL();
}
+ @Override
public String getJdbcInterceptors() {
return getPoolProperties().getJdbcInterceptors();
}
+ @Override
public int getMaxActive() {
return getPoolProperties().getMaxActive();
}
+ @Override
public int getMaxIdle() {
return getPoolProperties().getMaxIdle();
}
+ @Override
public int getMaxWait() {
return getPoolProperties().getMaxWait();
}
+ @Override
public int getMinEvictableIdleTimeMillis() {
return getPoolProperties().getMinEvictableIdleTimeMillis();
}
+ @Override
public int getMinIdle() {
return getPoolProperties().getMinIdle();
}
+ @Override
public long getMaxAge() {
return getPoolProperties().getMaxAge();
}
+ @Override
public String getName() {
return this.getPoolName();
}
+ @Override
public int getNumTestsPerEvictionRun() {
return getPoolProperties().getNumTestsPerEvictionRun();
}
/**
* @return DOES NOT RETURN THE PASSWORD, IT WOULD SHOW UP IN JMX
*/
+ @Override
public String getPassword() {
return "Password not available as DataSource/JMX operation.";
}
+ @Override
public int getRemoveAbandonedTimeout() {
return getPoolProperties().getRemoveAbandonedTimeout();
}
+ @Override
public int getTimeBetweenEvictionRunsMillis() {
return getPoolProperties().getTimeBetweenEvictionRunsMillis();
}
+ @Override
public String getUrl() {
return getPoolProperties().getUrl();
}
+ @Override
public String getUsername() {
return getPoolProperties().getUsername();
}
+ @Override
public long getValidationInterval() {
return getPoolProperties().getValidationInterval();
}
+ @Override
public String getValidationQuery() {
return getPoolProperties().getValidationQuery();
}
* {@inheritDoc}
*/
+ @Override
public String getValidatorClassName() {
return getPoolProperties().getValidatorClassName();
}
* {@inheritDoc}
*/
+ @Override
public Validator getValidator() {
return getPoolProperties().getValidator();
}
+ @Override
public boolean isAccessToUnderlyingConnectionAllowed() {
return getPoolProperties().isAccessToUnderlyingConnectionAllowed();
}
+ @Override
public Boolean isDefaultAutoCommit() {
return getPoolProperties().isDefaultAutoCommit();
}
+ @Override
public Boolean isDefaultReadOnly() {
return getPoolProperties().isDefaultReadOnly();
}
+ @Override
public boolean isLogAbandoned() {
return getPoolProperties().isLogAbandoned();
}
+ @Override
public boolean isPoolSweeperEnabled() {
return getPoolProperties().isPoolSweeperEnabled();
}
+ @Override
public boolean isRemoveAbandoned() {
return getPoolProperties().isRemoveAbandoned();
}
+ @Override
public int getAbandonWhenPercentageFull() {
return getPoolProperties().getAbandonWhenPercentageFull();
}
+ @Override
public boolean isTestOnBorrow() {
return getPoolProperties().isTestOnBorrow();
}
+ @Override
public boolean isTestOnConnect() {
return getPoolProperties().isTestOnConnect();
}
+ @Override
public boolean isTestOnReturn() {
return getPoolProperties().isTestOnReturn();
}
+ @Override
public boolean isTestWhileIdle() {
return getPoolProperties().isTestWhileIdle();
}
+ @Override
public Boolean getDefaultAutoCommit() {
return getPoolProperties().getDefaultAutoCommit();
}
+ @Override
public Boolean getDefaultReadOnly() {
return getPoolProperties().getDefaultReadOnly();
}
+ @Override
public InterceptorDefinition[] getJdbcInterceptorsAsArray() {
return getPoolProperties().getJdbcInterceptorsAsArray();
}
+ @Override
public boolean getUseLock() {
return getPoolProperties().getUseLock();
}
+ @Override
public boolean isFairQueue() {
return getPoolProperties().isFairQueue();
}
+ @Override
public boolean isJmxEnabled() {
return getPoolProperties().isJmxEnabled();
}
+ @Override
public boolean isUseEquals() {
return getPoolProperties().isUseEquals();
}
+ @Override
public void setAbandonWhenPercentageFull(int percentage) {
getPoolProperties().setAbandonWhenPercentageFull(percentage);
}
+ @Override
public void setAccessToUnderlyingConnectionAllowed(boolean accessToUnderlyingConnectionAllowed) {
getPoolProperties().setAccessToUnderlyingConnectionAllowed(accessToUnderlyingConnectionAllowed);
}
+ @Override
public void setDbProperties(Properties dbProperties) {
getPoolProperties().setDbProperties(dbProperties);
}
+ @Override
public void setDefaultReadOnly(Boolean defaultReadOnly) {
getPoolProperties().setDefaultReadOnly(defaultReadOnly);
}
+ @Override
public void setMaxAge(long maxAge) {
getPoolProperties().setMaxAge(maxAge);
}
+ @Override
public void setName(String name) {
getPoolProperties().setName(name);
}
+ @Override
public String getPoolName() {
return getPoolProperties().getName();
}
+ @Override
public void setConnectionProperties(String connectionProperties) {
getPoolProperties().setConnectionProperties(connectionProperties);
}
+ @Override
public void setDefaultAutoCommit(Boolean defaultAutoCommit) {
getPoolProperties().setDefaultAutoCommit(defaultAutoCommit);
}
+ @Override
public void setDefaultCatalog(String defaultCatalog) {
getPoolProperties().setDefaultCatalog(defaultCatalog);
}
+ @Override
public void setDefaultTransactionIsolation(int defaultTransactionIsolation) {
getPoolProperties().setDefaultTransactionIsolation(defaultTransactionIsolation);
}
+ @Override
public void setDriverClassName(String driverClassName) {
getPoolProperties().setDriverClassName(driverClassName);
}
+ @Override
public void setFairQueue(boolean fairQueue) {
getPoolProperties().setFairQueue(fairQueue);
}
+ @Override
public void setInitialSize(int initialSize) {
// TODO Auto-generated method stub
}
+ @Override
public void setInitSQL(String initSQL) {
// TODO Auto-generated method stub
}
+ @Override
public void setJdbcInterceptors(String jdbcInterceptors) {
// TODO Auto-generated method stub
}
+ @Override
public void setJmxEnabled(boolean jmxEnabled) {
// TODO Auto-generated method stub
}
+ @Override
public void setLogAbandoned(boolean logAbandoned) {
// TODO Auto-generated method stub
}
+ @Override
public void setMaxActive(int maxActive) {
// TODO Auto-generated method stub
}
+ @Override
public void setMaxIdle(int maxIdle) {
// TODO Auto-generated method stub
}
+ @Override
public void setMaxWait(int maxWait) {
// TODO Auto-generated method stub
}
+ @Override
public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
// TODO Auto-generated method stub
}
+ @Override
public void setMinIdle(int minIdle) {
// TODO Auto-generated method stub
}
+ @Override
public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) {
// TODO Auto-generated method stub
}
+ @Override
public void setPassword(String password) {
// TODO Auto-generated method stub
}
+ @Override
public void setRemoveAbandoned(boolean removeAbandoned) {
// TODO Auto-generated method stub
}
+ @Override
public void setRemoveAbandonedTimeout(int removeAbandonedTimeout) {
// TODO Auto-generated method stub
}
+ @Override
public void setTestOnBorrow(boolean testOnBorrow) {
// TODO Auto-generated method stub
}
+ @Override
public void setTestOnConnect(boolean testOnConnect) {
// TODO Auto-generated method stub
}
+ @Override
public void setTestOnReturn(boolean testOnReturn) {
// TODO Auto-generated method stub
}
+ @Override
public void setTestWhileIdle(boolean testWhileIdle) {
// TODO Auto-generated method stub
}
+ @Override
public void setTimeBetweenEvictionRunsMillis(int timeBetweenEvictionRunsMillis) {
// TODO Auto-generated method stub
}
+ @Override
public void setUrl(String url) {
// TODO Auto-generated method stub
}
+ @Override
public void setUseEquals(boolean useEquals) {
// TODO Auto-generated method stub
}
+ @Override
public void setUseLock(boolean useLock) {
// TODO Auto-generated method stub
}
+ @Override
public void setUsername(String username) {
// TODO Auto-generated method stub
}
+ @Override
public void setValidationInterval(long validationInterval) {
// TODO Auto-generated method stub
}
+ @Override
public void setValidationQuery(String validationQuery) {
// TODO Auto-generated method stub
* {@inheritDoc}
*/
+ @Override
public void setValidatorClassName(String className) {
getPoolProperties().setValidatorClassName(className);
}
* {@inheritDoc}
*/
+ @Override
public int getSuspectTimeout() {
return getPoolProperties().getSuspectTimeout();
}
* {@inheritDoc}
*/
+ @Override
public void setSuspectTimeout(int seconds) {
//no op
}
/**
* {@inheritDoc}
*/
+ @Override
public void setDataSource(Object ds) {
getPoolProperties().setDataSource(ds);
}
/**
* {@inheritDoc}
*/
+ @Override
public Object getDataSource() {
return getPoolProperties().getDataSource();
}
/**
* {@inheritDoc}
*/
+ @Override
public void setDataSourceJNDI(String jndiDS) {
//noop
}
/**
* {@inheritDoc}
*/
+ @Override
public String getDataSourceJNDI() {
return getPoolProperties().getDataSourceJNDI();
}
/**
* {@inheritDoc}
*/
+ @Override
public boolean isAlternateUsernameAllowed() {
return getPoolProperties().isAlternateUsernameAllowed();
}
/**
* {@inheritDoc}
*/
+ @Override
public void setAlternateUsernameAllowed(boolean alternateUsernameAllowed) {
//noop
}
/**
* {@inheritDoc}
*/
+ @Override
public void setValidator(Validator validator) {
//noop
}
public int getActive();
- public boolean isPoolSweeperEnabled();
-
public int getNumIdle();
public int getNumActive();
projects / tomcat7.0 / commitdiff