| | |
| | | |
| | | |
| | | private class ModifyWorkerThread extends |
| | | WorkerThread<ResultHandler<Result, Void>> |
| | | WorkerThread<ResultHandler<Result>> |
| | | { |
| | | private ModifyRequest mr; |
| | | private Object[] data; |
| | |
| | | |
| | | |
| | | |
| | | public ResultHandler<Result, Void> getHandler(long startTime) |
| | | public ResultHandler<Result> getHandler(long startTime) |
| | | { |
| | | return new UpdateStatsResultHandler<Result>(startTime); |
| | | } |
| | |
| | | |
| | | public ResultFuture<?> performOperation( |
| | | AsynchronousConnection connection, |
| | | ResultHandler<Result, Void> handler, DataSource[] dataSources) |
| | | ResultHandler<Result> handler, DataSource[] dataSources) |
| | | { |
| | | if (dataSources != null) |
| | | { |
| | | data = DataSource.generateData(dataSources, data); |
| | | } |
| | | mr = newModifyRequest(data); |
| | | return connection.modify(mr, handler, null); |
| | | return connection.modify(mr, handler); |
| | | } |
| | | |
| | | |