package com.cloudera.flume.handlers.syslog;
import java.io.IOException;
import org.junit.Assert;
import org.junit.Test;
@Test
SyslogTcpSourceThreads svr = new SyslogTcpSourceThreads(5140);
for (int i = 0; i < 100; i++) {
SyslogTcpSourceThreads.LOG.info("same source opening " + i);
svr.open();
SyslogTcpSourceThreads.LOG.info("same source closing " + i);
svr.close();
}
}
@Test
for (int i = 0; i < 100; i++) {
SyslogTcpSourceThreads srv = new SyslogTcpSourceThreads(5140);
SyslogTcpSourceThreads.LOG.info("new Source opening " + i);
srv.open();
SyslogTcpSourceThreads.LOG.info("new Source closing " + i);
srv.close();
}
}
SyslogTcpSourceThreads srv1 = new SyslogTcpSourceThreads(5140);
SyslogTcpSourceThreads srv2 = new SyslogTcpSourceThreads(5140);
srv1.open();
try {
srv2.open();
} catch (IOException e) {
return;
} finally {
srv2.close();
srv1.close();
}
Assert.fail("this is not supposed to happen");
}
@Test
SyslogTcpSourceThreads srv1 = new SyslogTcpSourceThreads(5140);
SyslogTcpSourceThreads srv2 = new SyslogTcpSourceThreads(5141);
try {
srv1.open();
srv2.open();
} catch (IOException e) {
Assert.fail("this is not supposed to happen");
} finally {
srv2.close();
srv1.close();
}
}
}