Java 类org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionServerInfo 实例源码

public int getRegionServerInfoPort(final ServerName sn) {
  RegionServerInfo info = this.regionServerTracker.getRegionServerInfo(sn);
  if (info == null || info.getInfoPort() == 0) {
    return conf.getInt(HConstants.REGIONSERVER_INFO_PORT,
      HConstants.DEFAULT_REGIONSERVER_INFOPORT);
  }
  return info.getInfoPort();
}

public String getRegionServerVersion(final ServerName sn) {
  RegionServerInfo info = this.regionServerTracker.getRegionServerInfo(sn);
  if (info != null && info.hasVersionInfo()) {
    return info.getVersionInfo().getVersion();
  }
  return "Unknown";
}

private void createMyEphemeralNode() throws KeeperException, IOException {
  RegionServerInfo.Builder rsInfo = RegionServerInfo.newBuilder();
  rsInfo.setInfoPort(infoServer != null ? infoServer.getPort() : -1);
  rsInfo.setVersionInfo(ProtobufUtil.getVersionInfo());
  byte[] data = ProtobufUtil.prependPBMagic(rsInfo.build().toByteArray());
  ZKUtil.createEphemeralNodeAndWatch(this.zooKeeper, getMyEphemeralNodePath(), data);
}

public int getRegionServerInfoPort(final ServerName sn) {
    RegionServerInfo info = this.regionServerTracker.getRegionServerInfo(sn);
    if (info == null || info.getInfoPort() == 0) {
        return conf.getInt(HConstants.REGIONSERVER_INFO_PORT,
                HConstants.DEFAULT_REGIONSERVER_INFOPORT);
    }
    return info.getInfoPort();
}

private void createMyEphemeralNode() throws KeeperException, IOException {
    RegionServerInfo.Builder rsInfo = RegionServerInfo.newBuilder();
    rsInfo.setInfoPort(infoServer != null ? infoServer.getPort() : -1);
    byte[] data = ProtobufUtil.prependPBMagic(rsInfo.build().toByteArray());
    ZKUtil.createEphemeralNodeAndWatch(this.zooKeeper,
            getMyEphemeralNodePath(), data);
}

public int getRegionServerInfoPort(final ServerName sn) {
  RegionServerInfo info = this.regionServerTracker.getRegionServerInfo(sn);
  if (info == null || info.getInfoPort() == 0) {
    return conf.getInt(HConstants.REGIONSERVER_INFO_PORT,
      HConstants.DEFAULT_REGIONSERVER_INFOPORT);
  }
  return info.getInfoPort();
}

public int getRegionServerInfoPort(final ServerName sn) {
  RegionServerInfo info = this.regionServerTracker.getRegionServerInfo(sn);
  if (info == null || info.getInfoPort() == 0) {
    return conf.getInt(HConstants.REGIONSERVER_INFO_PORT,
      HConstants.DEFAULT_REGIONSERVER_INFOPORT);
  }
  return info.getInfoPort();
}

private void createMyEphemeralNode() throws KeeperException, IOException {
  RegionServerInfo.Builder rsInfo = RegionServerInfo.newBuilder();
  rsInfo.setInfoPort(infoServer != null ? infoServer.getPort() : -1);
  byte[] data = ProtobufUtil.prependPBMagic(rsInfo.build().toByteArray());
  ZKUtil.createEphemeralNodeAndWatch(this.zooKeeper,
    getMyEphemeralNodePath(), data);
}

public RegionServerInfo getRegionServerInfo(final ServerName sn) {
  return regionServers.get(sn);
}

public RegionServerInfo getRegionServerInfo(final ServerName sn) {
  return regionServers.get(sn);
}

public RegionServerInfo getRegionServerInfo(final ServerName sn) {
  return regionServers.get(sn);
}

public RegionServerInfo getRegionServerInfo(final ServerName sn) {
  return regionServers.get(sn);
}