| | |
| | | private final class SearchStatsHandler extends |
| | | UpdateStatsResultHandler<Result> implements SearchResultHandler |
| | | { |
| | | private SearchStatsHandler(final long startTime, |
| | | final AsynchronousConnection connection, final ConnectionWorker worker) |
| | | private SearchStatsHandler(final long startTime) |
| | | { |
| | | super(startTime, connection, worker); |
| | | super(startTime); |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | |
| | | |
| | | private final class SearchWorkerThread extends ConnectionWorker |
| | | private final class SearchWorkerThread extends WorkerThread |
| | | { |
| | | private SearchRequest sr; |
| | | |
| | |
| | | sr.setFilter(String.format(filter, data)); |
| | | sr.setName(String.format(baseDN, data)); |
| | | } |
| | | return connection.search(sr, new SearchStatsHandler(startTime, |
| | | connection, this)); |
| | | return connection.search(sr, new SearchStatsHandler(startTime)); |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | |
| | | @Override |
| | | ConnectionWorker newConnectionWorker( |
| | | WorkerThread newWorkerThread( |
| | | final AsynchronousConnection connection, |
| | | final ConnectionFactory connectionFactory) |
| | | { |