Package org.postgresql

Class Driver.ConnectTask

java.lang.Object

org.postgresql.Driver.ConnectTask

All Implemented Interfaces:

Runnable

Enclosing class:

Driver

private static class Driver.ConnectTask
extends Object
implements Runnable

Perform a connect in a separate thread; supports getting the results from the original thread while enforcing a login timeout.

If the caller times out or is interrupted, we mark the attempt as abandoned and try to cancel the worker thread. Cancellation is best-effort: if the connection attempt does not stop immediately, the worker closes any connection it manages to establish after abandonment so that it does not leak.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	abandoned
private final AtomicReference<Connection>	establishedConnection
private final FutureTask<Connection>	futureTask

Constructor Summary

Constructors

Constructor	Description
ConnectTask(String url, Properties props)

Method Summary

Modifier and Type	Method	Description
private void	abandon()
private static void	closeConnection(Connection conn)
(package private) Connection	getResult(long timeout)	Get the connection result from this (assumed running) task.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

abandoned

private volatile boolean abandoned

establishedConnection

private final AtomicReference<Connection> establishedConnection

futureTask

private final FutureTask<Connection> futureTask

Constructor Details

ConnectTask

ConnectTask(String url,
 Properties props)

Method Details

run

public void run()

Specified by:

run in interface Runnable

getResult

Connection getResult(long timeout)
              throws SQLException

Get the connection result from this (assumed running) task. If the timeout is reached without a result being available, a SQLException is thrown.

Parameters:

timeout - timeout in milliseconds

Returns:

the new connection, if successful

Throws:

SQLException - if a connection error occurs or the timeout is reached

abandon

private void abandon()

closeConnection

private static void closeConnection(Connection conn)