Java 类org.apache.hadoop.hbase.master.MetricsMasterWrapperImpl 实例源码

@Test
public void testInfo() {
  HMaster master = TEST_UTIL.getHBaseCluster().getMaster();
  MetricsMasterWrapperImpl info = new MetricsMasterWrapperImpl(master);
  Assert.assertEquals(master.getAverageLoad(), info.getAverageLoad());
  Assert.assertEquals(master.getClusterId(), info.getClusterId());
  Assert.assertEquals(master.getMasterActiveTime(),
      info.getActiveTime());
  Assert.assertEquals(master.getMasterStartTime(),
      info.getStartTime());
  Assert.assertEquals(master.getCoprocessors().length,
      info.getCoprocessors().length);
  Assert.assertEquals(master.getServerManager().getOnlineServersList().size(),
      info.getRegionServers());
  Assert.assertTrue(info.getRegionServers() == 4);

  String zkServers = info.getZookeeperQuorum();
  Assert.assertEquals(zkServers.split(",").length,
      TEST_UTIL.getZkCluster().getZooKeeperServerNum());

  TEST_UTIL.getMiniHBaseCluster().stopRegionServer(3, false);
  TEST_UTIL.getMiniHBaseCluster().waitOnRegionServer(3);
  Assert.assertTrue(info.getRegionServers() == 3);
  Assert.assertTrue(info.getDeadRegionServers() == 1);

}

@Test (timeout = 30000)
public void testInfo() {
  HMaster master = TEST_UTIL.getHBaseCluster().getMaster();
  MetricsMasterWrapperImpl info = new MetricsMasterWrapperImpl(master);
  assertEquals(master.getAverageLoad(), info.getAverageLoad(), 0);
  assertEquals(master.getClusterId(), info.getClusterId());
  assertEquals(master.getMasterActiveTime(), info.getActiveTime());
  assertEquals(master.getMasterStartTime(), info.getStartTime());
  assertEquals(master.getCoprocessors().length, info.getCoprocessors().length);
  assertEquals(master.getServerManager().getOnlineServersList().size(), info.getNumRegionServers());
  assertTrue(info.getNumRegionServers() == 4);

  String zkServers = info.getZookeeperQuorum();
  assertEquals(zkServers.split(",").length, TEST_UTIL.getZkCluster().getZooKeeperServerNum());

  final int index = 3;
  LOG.info("Stopping " + TEST_UTIL.getMiniHBaseCluster().getRegionServer(index));
  TEST_UTIL.getMiniHBaseCluster().stopRegionServer(index, false);
  TEST_UTIL.getMiniHBaseCluster().waitOnRegionServer(index);
  // We stopped the regionserver but could take a while for the master to notice it so hang here
  // until it does... then move forward to see if metrics wrapper notices.
  while (TEST_UTIL.getHBaseCluster().getMaster().getServerManager().getOnlineServers().size() !=
      index) {
    Threads.sleep(10);
  }
  assertTrue(info.getNumRegionServers() == 3);
  assertTrue(info.getNumDeadRegionServers() == 1);
}

@Test (timeout = 30000)
public void testInfo() {
  HMaster master = TEST_UTIL.getHBaseCluster().getMaster();
  MetricsMasterWrapperImpl info = new MetricsMasterWrapperImpl(master);
  assertEquals(master.getAverageLoad(), info.getAverageLoad(), 0);
  assertEquals(master.getClusterId(), info.getClusterId());
  assertEquals(master.getMasterActiveTime(), info.getActiveTime());
  assertEquals(master.getMasterStartTime(), info.getStartTime());
  assertEquals(master.getMasterCoprocessors().length, info.getCoprocessors().length);
  assertEquals(master.getServerManager().getOnlineServersList().size(), info.getNumRegionServers());
  assertEquals(5, info.getNumRegionServers());

  String zkServers = info.getZookeeperQuorum();
  assertEquals(zkServers.split(",").length, TEST_UTIL.getZkCluster().getZooKeeperServerNum());

  final int index = 3;
  LOG.info("Stopping " + TEST_UTIL.getMiniHBaseCluster().getRegionServer(index));
  TEST_UTIL.getMiniHBaseCluster().stopRegionServer(index, false);
  TEST_UTIL.getMiniHBaseCluster().waitOnRegionServer(index);
  // We stopped the regionserver but could take a while for the master to notice it so hang here
  // until it does... then move forward to see if metrics wrapper notices.
  while (TEST_UTIL.getHBaseCluster().getMaster().getServerManager().getOnlineServers().size() !=
      4) {
    Threads.sleep(10);
  }
  assertEquals(4, info.getNumRegionServers());
  assertEquals(1, info.getNumDeadRegionServers());
}

@Test (timeout = 30000)
public void testInfo() {
  HMaster master = TEST_UTIL.getHBaseCluster().getMaster();
  MetricsMasterWrapperImpl info = new MetricsMasterWrapperImpl(master);
  assertEquals(master.getAverageLoad(), info.getAverageLoad(), 0);
  assertEquals(master.getClusterId(), info.getClusterId());
  assertEquals(master.getMasterActiveTime(), info.getActiveTime());
  assertEquals(master.getMasterStartTime(), info.getStartTime());
  assertEquals(master.getCoprocessors().length, info.getCoprocessors().length);
  assertEquals(master.getServerManager().getOnlineServersList().size(), info.getRegionServers());
  assertTrue(info.getRegionServers() == 4);

  String zkServers = info.getZookeeperQuorum();
  assertEquals(zkServers.split(",").length, TEST_UTIL.getZkCluster().getZooKeeperServerNum());

  final int index = 3;
  LOG.info("Stopping " + TEST_UTIL.getMiniHBaseCluster().getRegionServer(index));
  TEST_UTIL.getMiniHBaseCluster().stopRegionServer(index, false);
  TEST_UTIL.getMiniHBaseCluster().waitOnRegionServer(index);
  // We stopped the regionserver but could take a while for the master to notice it so hang here
  // until it does... then move forward to see if metrics wrapper notices.
  while (TEST_UTIL.getHBaseCluster().getMaster().getServerManager().getOnlineServers().size() !=
      index) {
    Threads.sleep(10);
  }
  assertTrue(info.getRegionServers() == 3);
  assertTrue(info.getDeadRegionServers() == 1);
}