Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Adding check back in place 

This was to avoid one failing test making other tests to fail in cascade around libaio.
This commit is contained in:
Clebert Suconic 2016-06-28 15:55:34 -04:00
parent 2585ecd5ca
commit a2f936c340
1 changed files with 20 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java
View File

@ -2030,31 +2030,26 @@ public abstract class ActiveMQTestBase extends Assert {
long timeout = System.currentTimeMillis() + 15000;
// while (AsynchronousFileImpl.getTotalMaxIO() != 0 && System.currentTimeMillis() > timeout)
// {
// try
// {
// Thread.sleep(100);
// }
// catch (Exception ignored)
// {
// }
// }
//
// int invmSize = InVMRegistry.instance.size();
// if (invmSize > 0)
// {
// InVMRegistry.instance.clear();
// log.info(threadDump("Thread dump"));
// fail("invm registry still had acceptors registered");
// }
//
// final int totalMaxIO = AsynchronousFileImpl.getTotalMaxIO();
// if (totalMaxIO != 0)
// {
// AsynchronousFileImpl.resetMaxAIO();
// Assert.fail("test did not close all its files " + totalMaxIO);
// }
while (LibaioContext.getTotalMaxIO() != 0 && System.currentTimeMillis() > timeout) {
try {
Thread.sleep(100);
}
catch (Exception ignored) {
}
}
int invmSize = InVMRegistry.instance.size();
if (invmSize > 0) {
InVMRegistry.instance.clear();
log.info(threadDump("Thread dump"));
fail("invm registry still had acceptors registered");
}
final long totalMaxIO = LibaioContext.getTotalMaxIO();
if (totalMaxIO != 0) {
LibaioContext.resetMaxAIO();
Assert.fail("test did not close all its files " + totalMaxIO);
}
}
private void cleanupPools() {