| | |
| | | private final class BindUpdateStatsResultHandler extends |
| | | UpdateStatsResultHandler<BindResult> |
| | | { |
| | | private BindUpdateStatsResultHandler(final long startTime, |
| | | final AsynchronousConnection connection, final ConnectionWorker worker) |
| | | private BindUpdateStatsResultHandler(final long startTime) |
| | | { |
| | | super(startTime, connection, worker); |
| | | super(startTime); |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | |
| | | |
| | | private final class BindWorkerThread extends ConnectionWorker |
| | | private final class BindWorkerThread extends WorkerThread |
| | | { |
| | | private SearchRequest sr; |
| | | private BindRequest br; |
| | |
| | | |
| | | final RecursiveFutureResult<SearchResultEntry, BindResult> future = |
| | | new RecursiveFutureResult<SearchResultEntry, BindResult>( |
| | | new BindUpdateStatsResultHandler(startTime, connection, this)) |
| | | new BindUpdateStatsResultHandler(startTime)) |
| | | { |
| | | @Override |
| | | protected FutureResult<? extends BindResult> chainResult( |
| | |
| | | else |
| | | { |
| | | return performBind(connection, data, |
| | | new BindUpdateStatsResultHandler(startTime, connection, this)); |
| | | new BindUpdateStatsResultHandler(startTime)); |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | |
| | | @Override |
| | | ConnectionWorker newConnectionWorker( |
| | | WorkerThread newWorkerThread( |
| | | final AsynchronousConnection connection, |
| | | final ConnectionFactory connectionFactory) |
| | | { |