| | |
| | | { |
| | | private static final class ModifyPerformanceRunner extends PerformanceRunner |
| | | { |
| | | private final class ModifyWorkerThread extends ConnectionWorker |
| | | private final class ModifyWorkerThread extends WorkerThread |
| | | { |
| | | private ModifyRequest mr; |
| | | private Object[] data; |
| | |
| | | data = DataSource.generateData(dataSources, data); |
| | | } |
| | | mr = newModifyRequest(data); |
| | | return connection.modify(mr, new UpdateStatsResultHandler<Result>( |
| | | startTime, connection, this)); |
| | | return connection.modify(mr, |
| | | new UpdateStatsResultHandler<Result>(startTime)); |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | |
| | | @Override |
| | | ConnectionWorker newConnectionWorker( |
| | | WorkerThread newWorkerThread( |
| | | final AsynchronousConnection connection, |
| | | final ConnectionFactory connectionFactory) |
| | | { |