279280281282283284285286287288289
ctx.addThread(scanner); } ctx.startThreads(); ctx.waitFor(millisToRun); ctx.stop(); LOG.info("Loaders:"); LOG.info(" loaded " + loader.numBulkLoads.get()); LOG.info(" compations " + loader.numCompactions.get());
266267268269270271272273274275276
ctx.addThread(scanner); } ctx.startThreads(); ctx.waitFor(millisToRun); ctx.stop(); LOG.info("Finished test. Writers:"); for (AtomicityWriter writer : writers) { LOG.info(" wrote " + writer.numWritten.get()); }
308309310311312313314315316317318
311312313314315316317318319320321