1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.util;
20
21 import junit.framework.TestCase;
22 import org.apache.hadoop.hbase.HBaseTestingUtility;
23 import org.apache.hadoop.hbase.testclassification.MediumTests;
24 import org.apache.hadoop.hbase.security.UserProvider;
25 import org.junit.Test;
26 import org.junit.experimental.categories.Category;
27
28 @Category({MediumTests.class})
29 public class TestConnectionCache extends TestCase {
30 private static final HBaseTestingUtility UTIL = new HBaseTestingUtility();
31
32
33
34
35 @Test
36 public void testConnectionChore() throws Exception {
37 UTIL.startMiniCluster();
38
39
40 ConnectionCache cache = new ConnectionCache(UTIL.getConfiguration(),
41 UserProvider.instantiate(UTIL.getConfiguration()), 1000, 5000);
42 ConnectionCache.ConnectionInfo info = cache.getCurrentConnection();
43
44 assertEquals(false, info.connection.isClosed());
45
46 Thread.sleep(7000);
47
48 assertEquals(true, info.connection.isClosed());
49 UTIL.shutdownMiniCluster();
50 }
51
52 }
53