Java 类org.apache.zookeeper.KeeperException.AuthFailedException 实例源码

项目：ditb 文件：HBaseReplicationEndpoint.java

/**
 * A private method used to re-establish a zookeeper session with a peer cluster.
 * @param ke
 */
protected void reconnect(KeeperException ke) {
  if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException
      || ke instanceof AuthFailedException) {
    String clusterKey = ctx.getPeerConfig().getClusterKey();
    LOG.warn("Lost the ZooKeeper connection for peer " + clusterKey, ke);
    try {
      reloadZkWatcher();
    } catch (IOException io) {
      LOG.warn("Creation of ZookeeperWatcher failed for peer " + clusterKey, io);
    }
  }
}

项目：pbase 文件：HBaseReplicationEndpoint.java

/**
 * A private method used to re-establish a zookeeper session with a peer cluster.
 * @param ke
 */
protected void reconnect(KeeperException ke) {
  if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException
      || ke instanceof AuthFailedException) {
    String clusterKey = ctx.getPeerConfig().getClusterKey();
    LOG.warn("Lost the ZooKeeper connection for peer " + clusterKey, ke);
    try {
      reloadZkWatcher();
    } catch (IOException io) {
      LOG.warn("Creation of ZookeeperWatcher failed for peer " + clusterKey, io);
    }
  }
}

项目：HIndex 文件：ReplicationPeersZKImpl.java

/**
 * A private method used to re-establish a zookeeper session with a peer cluster.
 * @param ke
 * @param peer
 */
private void reconnectPeer(KeeperException ke, ReplicationPeer peer) {
  if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException
      || ke instanceof AuthFailedException) {
    LOG.warn("Lost the ZooKeeper connection for peer " + peer.getClusterKey(), ke);
    try {
      peer.reloadZkWatcher();
      peer.getZkw().registerListener(new PeerRegionServerListener(peer));
    } catch (IOException io) {
      LOG.warn("Creation of ZookeeperWatcher failed for peer " + peer.getClusterKey(), io);
    }
  }
}

项目：hbase 文件：HBaseReplicationEndpoint.java

/**
 * A private method used to re-establish a zookeeper session with a peer cluster.
 * @param ke
 */
protected void reconnect(KeeperException ke) {
  if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException
      || ke instanceof AuthFailedException) {
    String clusterKey = ctx.getPeerConfig().getClusterKey();
    LOG.warn("Lost the ZooKeeper connection for peer " + clusterKey, ke);
    try {
      reloadZkWatcher();
    } catch (IOException io) {
      LOG.warn("Creation of ZookeeperWatcher failed for peer " + clusterKey, io);
    }
  }
}

项目：PyroDB 文件：ReplicationPeersZKImpl.java

/**
 * A private method used to re-establish a zookeeper session with a peer cluster.
 * @param ke
 * @param peer
 */
private void reconnectPeer(KeeperException ke, ReplicationPeer peer) {
  if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException
      || ke instanceof AuthFailedException) {
    LOG.warn("Lost the ZooKeeper connection for peer " + peer.getClusterKey(), ke);
    try {
      peer.reloadZkWatcher();
      peer.getZkw().registerListener(new PeerRegionServerListener(peer));
    } catch (IOException io) {
      LOG.warn("Creation of ZookeeperWatcher failed for peer " + peer.getClusterKey(), io);
    }
  }
}