package com.cloudera.flume.master;
import java.io.IOException;
import org.junit.Test;
import com.cloudera.flume.conf.FlumeBuilder;
import com.cloudera.flume.conf.FlumeSpecException;
import com.cloudera.flume.core.EventSink;
import com.cloudera.flume.core.EventSource;
import com.cloudera.util.Benchmark;
@Test
Benchmark b = new Benchmark("connection exhaust");
EventSource src = FlumeBuilder.buildSource("thrift(31337)");
EventSink snk = FlumeBuilder.buildSink("thrift(\"0.0.0.0\",31337)");
src.open();
int i = 0;
try {
for (i = 0; true; i++) {
snk.open();
System.out.println(i + " connections...");
}
} catch (IOException io) {
System.out.println(io);
b.mark("conns", i);
}
src.close();
b.done();
}
@Test
Benchmark b = new Benchmark("connection exhaust");
EventSource src = FlumeBuilder.buildSource("thrift(31337)");
src.open();
for (int i = 0; i < 10000; i++) {
EventSink snk = FlumeBuilder.buildSink("thrift(\"0.0.0.0\",31337)");
snk.open();
System.out.println(i + " connections...");
snk.close();
}
src.close();
b.done();
}
}