Java 类org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetServerInfoResponse 实例源码

项目：ditb 文件：RSRpcServices.java

/**
 * Get some information of the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.ADMIN_QOS)
public GetServerInfoResponse getServerInfo(final RpcController controller,
    final GetServerInfoRequest request) throws ServiceException {
  try {
    checkOpen();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
  requestCount.increment();
  int infoPort = regionServer.infoServer != null ? regionServer.infoServer.getPort() : -1;
  return ResponseConverter.buildGetServerInfoResponse(regionServer.serverName, infoPort);
}

项目：ditb 文件：ResponseConverter.java

/**
 * A utility to build a GetServerInfoResponse.
 *
 * @param serverName
 * @param webuiPort
 * @return the response
 */
public static GetServerInfoResponse buildGetServerInfoResponse(
    final ServerName serverName, final int webuiPort) {
  GetServerInfoResponse.Builder builder = GetServerInfoResponse.newBuilder();
  ServerInfo.Builder serverInfoBuilder = ServerInfo.newBuilder();
  serverInfoBuilder.setServerName(ProtobufUtil.toServerName(serverName));
  if (webuiPort >= 0) {
    serverInfoBuilder.setWebuiPort(webuiPort);
  }
  builder.setServerInfo(serverInfoBuilder.build());
  return builder.build();
}

项目：ditb 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 * @return the server name
 */
public static ServerInfo getServerInfo(final RpcController controller,
    final AdminService.BlockingInterface admin)
throws IOException {
  GetServerInfoRequest request = RequestConverter.buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(controller, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：pbase 文件：RSRpcServices.java

/**
 * Get some information of the region server.
 *
 * @param controller the RPC controller
 * @param request    the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority = HConstants.ADMIN_QOS)
public GetServerInfoResponse getServerInfo(final RpcController controller,
                                           final GetServerInfoRequest request) throws ServiceException {
    try {
        checkOpen();
    } catch (IOException ie) {
        throw new ServiceException(ie);
    }
    requestCount.increment();
    int infoPort = regionServer.infoServer != null ? regionServer.infoServer.getPort() : -1;
    return ResponseConverter.buildGetServerInfoResponse(regionServer.serverName, infoPort);
}

项目：pbase 文件：ResponseConverter.java

/**
 * A utility to build a GetServerInfoResponse.
 *
 * @param serverName
 * @param webuiPort
 * @return the response
 */
public static GetServerInfoResponse buildGetServerInfoResponse(
    final ServerName serverName, final int webuiPort) {
  GetServerInfoResponse.Builder builder = GetServerInfoResponse.newBuilder();
  ServerInfo.Builder serverInfoBuilder = ServerInfo.newBuilder();
  serverInfoBuilder.setServerName(ProtobufUtil.toServerName(serverName));
  if (webuiPort >= 0) {
    serverInfoBuilder.setWebuiPort(webuiPort);
  }
  builder.setServerInfo(serverInfoBuilder.build());
  return builder.build();
}

项目：pbase 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 *
 * @param admin
 * @return the server name
 * @throws IOException
 */
public static ServerInfo getServerInfo(final AdminService.BlockingInterface admin)
throws IOException {
  GetServerInfoRequest request = RequestConverter.buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(null, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：HIndex 文件：HRegionServer.java

/**
 * Get some information of the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public GetServerInfoResponse getServerInfo(final RpcController controller,
    final GetServerInfoRequest request) throws ServiceException {
  try {
    checkOpen();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
  ServerName serverName = getServerName();
  requestCount.increment();
  return ResponseConverter.buildGetServerInfoResponse(serverName, rsInfo.getInfoPort());
}

项目：HIndex 文件：ResponseConverter.java

/**
 * A utility to build a GetServerInfoResponse.
 *
 * @param serverName
 * @param webuiPort
 * @return the response
 */
public static GetServerInfoResponse buildGetServerInfoResponse(
    final ServerName serverName, final int webuiPort) {
  GetServerInfoResponse.Builder builder = GetServerInfoResponse.newBuilder();
  ServerInfo.Builder serverInfoBuilder = ServerInfo.newBuilder();
  serverInfoBuilder.setServerName(ProtobufUtil.toServerName(serverName));
  if (webuiPort >= 0) {
    serverInfoBuilder.setWebuiPort(webuiPort);
  }
  builder.setServerInfo(serverInfoBuilder.build());
  return builder.build();
}

项目：HIndex 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 *
 * @param admin
 * @return the server name
 * @throws IOException
 */
public static ServerInfo getServerInfo(final AdminService.BlockingInterface admin)
throws IOException {
  GetServerInfoRequest request = RequestConverter.buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(null, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：hbase 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 * @return the server name
 */
public static ServerInfo getServerInfo(final RpcController controller,
    final AdminService.BlockingInterface admin)
throws IOException {
  GetServerInfoRequest request = buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(controller, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：PyroDB 文件：RSRpcServices.java

/**
 * Get some information of the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@SuppressWarnings("deprecation")
public GetServerInfoResponse getServerInfo(final RpcController controller,
    final GetServerInfoRequest request) throws ServiceException {
  try {
    checkOpen();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
  requestCount.increment();
  int infoPort = regionServer.infoServer != null ? regionServer.infoServer.getPort() : -1;
  return ResponseConverter.buildGetServerInfoResponse(regionServer.serverName, infoPort);
}

项目：PyroDB 文件：ResponseConverter.java

/**
 * A utility to build a GetServerInfoResponse.
 *
 * @param serverName
 * @param webuiPort
 * @return the response
 */
public static GetServerInfoResponse buildGetServerInfoResponse(
    final ServerName serverName, final int webuiPort) {
  GetServerInfoResponse.Builder builder = GetServerInfoResponse.newBuilder();
  ServerInfo.Builder serverInfoBuilder = ServerInfo.newBuilder();
  serverInfoBuilder.setServerName(ProtobufUtil.toServerName(serverName));
  if (webuiPort >= 0) {
    serverInfoBuilder.setWebuiPort(webuiPort);
  }
  builder.setServerInfo(serverInfoBuilder.build());
  return builder.build();
}

项目：PyroDB 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 *
 * @param admin
 * @return the server name
 * @throws IOException
 */
public static ServerInfo getServerInfo(final AdminService.BlockingInterface admin)
throws IOException {
  GetServerInfoRequest request = RequestConverter.buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(null, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：c5 文件：HRegionServer.java

/**
 * Get some information of the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public GetServerInfoResponse getServerInfo(final RpcController controller,
    final GetServerInfoRequest request) throws ServiceException {
  ServerName serverName = getServerName();
  requestCount.increment();
  return ResponseConverter.buildGetServerInfoResponse(serverName, webuiport);
}

项目：c5 文件：ResponseConverter.java

/**
 * A utility to build a GetServerInfoResponse.
 *
 * @param serverName
 * @param webuiPort
 * @return the response
 */
public static GetServerInfoResponse buildGetServerInfoResponse(
    final ServerName serverName, final int webuiPort) {
  GetServerInfoResponse.Builder builder = GetServerInfoResponse.newBuilder();
  ServerInfo.Builder serverInfoBuilder = ServerInfo.newBuilder();
  serverInfoBuilder.setServerName(ProtobufUtil.toServerName(serverName));
  if (webuiPort >= 0) {
    serverInfoBuilder.setWebuiPort(webuiPort);
  }
  builder.setServerInfo(serverInfoBuilder.build());
  return builder.build();
}

项目：c5 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 *
 * @param admin
 * @return the server name
 * @throws IOException
 */
public static ServerInfo getServerInfo(final AdminService.BlockingInterface admin)
throws IOException {
  GetServerInfoRequest request = RequestConverter.buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(null, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：DominoHBase 文件：ResponseConverter.java

/**
 * A utility to build a GetServerInfoResponse.
 *
 * @param serverName
 * @param webuiPort
 * @return the response
 */
public static GetServerInfoResponse buildGetServerInfoResponse(
    final ServerName serverName, final int webuiPort) {
  GetServerInfoResponse.Builder builder = GetServerInfoResponse.newBuilder();
  ServerInfo.Builder serverInfoBuilder = ServerInfo.newBuilder();
  serverInfoBuilder.setServerName(ProtobufUtil.toServerName(serverName));
  if (webuiPort >= 0) {
    serverInfoBuilder.setWebuiPort(webuiPort);
  }
  builder.setServerInfo(serverInfoBuilder.build());
  return builder.build();
}

项目：DominoHBase 文件：ProtobufUtil.java

/**
 * A helper to get the info of a region server using admin protocol.
 *
 * @param admin
 * @return the server name
 * @throws IOException
 */
public static ServerInfo getServerInfo(
    final AdminProtocol admin) throws IOException {
  GetServerInfoRequest request = RequestConverter.buildGetServerInfoRequest();
  try {
    GetServerInfoResponse response = admin.getServerInfo(null, request);
    return response.getServerInfo();
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

项目：DominoHBase 文件：HRegionServer.java

/**
 * Get some information of the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public GetServerInfoResponse getServerInfo(final RpcController controller,
    final GetServerInfoRequest request) throws ServiceException {
  ServerName serverName = getServerName();
  requestCount.increment();
  return ResponseConverter.buildGetServerInfoResponse(serverName, webuiport);
}

项目：ditb 文件：MockRegionServer.java

@Override
public GetServerInfoResponse getServerInfo(RpcController controller,
    GetServerInfoRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：pbase 文件：MockRegionServer.java

@Override
public GetServerInfoResponse getServerInfo(RpcController controller,
    GetServerInfoRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：HIndex 文件：MockRegionServer.java

@Override
public GetServerInfoResponse getServerInfo(RpcController controller,
    GetServerInfoRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：PyroDB 文件：MockRegionServer.java

@Override
public GetServerInfoResponse getServerInfo(RpcController controller,
    GetServerInfoRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：c5 文件：MockRegionServer.java

@Override
public GetServerInfoResponse getServerInfo(RpcController controller,
    GetServerInfoRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：DominoHBase 文件：MockRegionServer.java

@Override
public GetServerInfoResponse getServerInfo(RpcController controller,
    GetServerInfoRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}