Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19135 TestWeakObjectPool time out

This commit is contained in:
Michael Stack 2017-10-31 09:38:38 -07:00
parent 9382f391c8
commit d7cf88947c
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-common/src/test/java/org/apache/hadoop/hbase/util/TestWeakObjectPool.java
View File

@ -22,15 +22,20 @@ import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import org.apache.hadoop.hbase.CategoryBasedTimeout;
import org.apache.hadoop.hbase.testclassification.MiscTests; import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.apache.hadoop.hbase.testclassification.SmallTests; import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
import org.junit.rules.TestRule;
@Category({MiscTests.class, SmallTests.class}) @Category({MiscTests.class, SmallTests.class})
public class TestWeakObjectPool { public class TestWeakObjectPool {
@Rule public final TestRule timeout = CategoryBasedTimeout.builder().withTimeout(this.getClass()).
withLookingForStuckThread(true).build();
ObjectPool<String, Object> pool; ObjectPool<String, Object> pool;
@Before @Before
@ -89,7 +94,7 @@ public class TestWeakObjectPool {
Assert.assertNotEquals(hash1, System.identityHashCode(obj3)); Assert.assertNotEquals(hash1, System.identityHashCode(obj3));
} }
@Test(timeout=1000) @Test
public void testCongestion() throws Exception { public void testCongestion() throws Exception {
final int THREAD_COUNT = 100; final int THREAD_COUNT = 100;