1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.master;
19
20 import static org.junit.Assert.assertFalse;
21 import static org.junit.Assert.assertTrue;
22
23 import org.junit.Test;
24
25
26 public class TestDeadServer {
27 @Test public void testIsDead() {
28 DeadServer ds = new DeadServer(2);
29 final String hostname123 = "127.0.0.1,123,3";
30 assertFalse(ds.isDeadServer(hostname123, false));
31 assertFalse(ds.isDeadServer(hostname123, true));
32 ds.add(hostname123);
33 assertTrue(ds.isDeadServer(hostname123, false));
34 assertFalse(ds.isDeadServer("127.0.0.1:1", true));
35 assertFalse(ds.isDeadServer("127.0.0.1:1234", true));
36 assertTrue(ds.isDeadServer("127.0.0.1:123", true));
37 assertTrue(ds.areDeadServersInProgress());
38 ds.finish(hostname123);
39 assertFalse(ds.areDeadServersInProgress());
40 final String hostname1234 = "127.0.0.2,1234,4";
41 ds.add(hostname1234);
42 assertTrue(ds.isDeadServer(hostname123, false));
43 assertTrue(ds.isDeadServer(hostname1234, false));
44 assertTrue(ds.areDeadServersInProgress());
45 ds.finish(hostname1234);
46 assertFalse(ds.areDeadServersInProgress());
47 final String hostname12345 = "127.0.0.2,12345,4";
48 ds.add(hostname12345);
49 assertTrue(ds.isDeadServer(hostname1234, false));
50 assertTrue(ds.isDeadServer(hostname12345, false));
51 assertTrue(ds.areDeadServersInProgress());
52 ds.finish(hostname12345);
53 assertFalse(ds.areDeadServersInProgress());
54
55
56
57
58 final String deadServer = "127.0.0.1,9090,112321";
59 assertFalse(ds.cleanPreviousInstance(deadServer));
60 ds.add(deadServer);
61 assertTrue(ds.isDeadServer(deadServer));
62 final String deadServerHostComingAlive = "127.0.0.1,9090,112321";
63 assertTrue(ds.cleanPreviousInstance(deadServerHostComingAlive));
64 assertFalse(ds.isDeadServer(deadServer));
65 assertFalse(ds.cleanPreviousInstance(deadServerHostComingAlive));
66
67 }
68 }