new Thread() {
@Override
public void run() {
start.countDown();
try {
EventSource src = new NoNlASCIISynthSource(count, 100);
Context ctx = new ReportTestingContext();
EventSink snk = new CompositeSink(ctx, "counter(\"total." + idx
+ "\")");
// use the same wal, but different counter.
snk = new NaiveFileWALDeco<EventSink>(ctx, snk, wal,
new TimeTrigger(new ProcessTagger(), 1000000),
new AckListener.Empty(), 1000000);
start.await();
// allow for contention on the open call.
src.open();
snk.open();
EventUtil.dumpAll(src, snk);
src.close();
snk.close();
} catch (Exception e) {
LOG.error("failure", e);
// fail("e");
} finally {