1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.ipc;
19
20 import static org.junit.Assert.assertFalse;
21 import static org.junit.Assert.assertNotNull;
22 import static org.junit.Assert.assertNotSame;
23 import static org.junit.Assert.assertSame;
24
25 import org.apache.hadoop.conf.Configuration;
26 import org.apache.hadoop.hbase.HBaseConfiguration;
27 import org.apache.hadoop.hbase.HConstants;
28 import org.apache.hadoop.hbase.testclassification.SmallTests;
29 import org.junit.Test;
30 import org.junit.experimental.categories.Category;
31
32 @Category({ SmallTests.class })
33 public class TestGlobalEventLoopGroup {
34
35 @Test
36 public void test() {
37 Configuration conf = HBaseConfiguration.create();
38 conf.setBoolean(AsyncRpcClient.USE_GLOBAL_EVENT_LOOP_GROUP, true);
39 AsyncRpcClient client = new AsyncRpcClient(conf, HConstants.CLUSTER_ID_DEFAULT, null);
40 assertNotNull(AsyncRpcClient.GLOBAL_EVENT_LOOP_GROUP);
41 AsyncRpcClient client1 = new AsyncRpcClient(conf, HConstants.CLUSTER_ID_DEFAULT, null);
42 assertSame(client.bootstrap.group(), client1.bootstrap.group());
43 client1.close();
44 assertFalse(client.bootstrap.group().isShuttingDown());
45
46 conf.setBoolean(AsyncRpcClient.USE_GLOBAL_EVENT_LOOP_GROUP, false);
47 AsyncRpcClient client2 = new AsyncRpcClient(conf, HConstants.CLUSTER_ID_DEFAULT, null);
48 assertNotSame(client.bootstrap.group(), client2.bootstrap.group());
49 client2.close();
50
51 client.close();
52 }
53 }