import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
@Override
public void setUp() throws Exception {
  // skip tests on Windows until after resolution of ZooKeeper client bug
  assumeTrue(!Shell.WINDOWS);
  super.setUp();
  
  zkServer = getServer(serverFactory);

  for (int i = 0; i < NUM_ELECTORS; i++) {
    cbs[i] =  Mockito.mock(ActiveStandbyElectorCallback.class);
    appDatas[i] = Ints.toByteArray(i);
    electors[i] = new ActiveStandbyElector(
        hostPort, 5000, PARENT_DIR, Ids.OPEN_ACL_UNSAFE,
        Collections.<ZKAuthInfo>emptyList(), cbs[i]);
  }
}
 

import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
@Override
public void setUp() throws Exception {
  super.setUp();
  
  zkServer = getServer(serverFactory);

  for (int i = 0; i < NUM_ELECTORS; i++) {
    cbs[i] =  Mockito.mock(ActiveStandbyElectorCallback.class);
    appDatas[i] = Ints.toByteArray(i);
    electors[i] = new ActiveStandbyElector(hostPort, 5000, PARENT_DIR,
        Ids.OPEN_ACL_UNSAFE, Collections.<ZKAuthInfo> emptyList(), cbs[i],
        CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
  }
}
 

import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
ActiveStandbyElectorTester(String hostPort, int timeout, String parent,
    List<ACL> acl, ActiveStandbyElectorCallback app) throws IOException,
    KeeperException {
  super(hostPort, timeout, parent, acl, Collections
      .<ZKAuthInfo> emptyList(), app,
      CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
}
 

import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
@Before
public void init() throws IOException, KeeperException {
  count = 0;
  mockZK = Mockito.mock(ZooKeeper.class);
  mockApp = Mockito.mock(ActiveStandbyElectorCallback.class);
  elector = new ActiveStandbyElectorTester("hostPort", 1000, ZK_PARENT_NAME,
      Ids.OPEN_ACL_UNSAFE, mockApp);
}
 

import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
@Override
public void setUp() throws Exception {
  super.setUp();
  
  zkServer = getServer(serverFactory);

  for (int i = 0; i < NUM_ELECTORS; i++) {
    cbs[i] =  Mockito.mock(ActiveStandbyElectorCallback.class);
    appDatas[i] = Ints.toByteArray(i);
    electors[i] = new ActiveStandbyElector(
        hostPort, 5000, PARENT_DIR, Ids.OPEN_ACL_UNSAFE,
        Collections.<ZKAuthInfo>emptyList(), cbs[i]);
  }
}
 

import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
@Test(timeout=15000)
public void testHandleSessionExpiration() throws Exception {
  ActiveStandbyElectorCallback cb = cbs[0];
  byte[] appData = appDatas[0];
  ActiveStandbyElector elector = electors[0];
  
  // Let the first elector become active
  elector.ensureParentZNode();
  elector.joinElection(appData);
  ZooKeeperServer zks = getServer(serverFactory);
  ActiveStandbyElectorTestUtil.waitForActiveLockData(null,
      zks, PARENT_DIR, appData);
  Mockito.verify(cb, Mockito.timeout(1000)).becomeActive();
  checkFatalsAndReset();
  
  LOG.info("========================== Expiring session");
  zks.closeSession(elector.getZKSessionIdForTests());

  // Should enter neutral mode when disconnected
  Mockito.verify(cb, Mockito.timeout(1000)).enterNeutralMode();

  // Should re-join the election and regain active
  ActiveStandbyElectorTestUtil.waitForActiveLockData(null,
      zks, PARENT_DIR, appData);
  Mockito.verify(cb, Mockito.timeout(1000)).becomeActive();
  checkFatalsAndReset();
  
  LOG.info("========================== Quitting election");
  elector.quitElection(false);
  ActiveStandbyElectorTestUtil.waitForActiveLockData(null,
      zks, PARENT_DIR, null);

  // Double check that we don't accidentally re-join the election
  // due to receiving the "expired" event.
  Thread.sleep(1000);
  Mockito.verify(cb, Mockito.never()).becomeActive();
  ActiveStandbyElectorTestUtil.waitForActiveLockData(null,
      zks, PARENT_DIR, null);

  checkFatalsAndReset();
}
 

import org.apache.hadoop.ha.ActiveStandbyElector.ActiveStandbyElectorCallback; //导入依赖的package包/类
ActiveStandbyElectorTester(String hostPort, int timeout, String parent,
    List<ACL> acl, ActiveStandbyElectorCallback app) throws IOException,
    KeeperException {
  super(hostPort, timeout, parent, acl,
      Collections.<ZKAuthInfo>emptyList(), app);
}