1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetServerInfoRequest

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

项目：HIndex    文件：TestRSStatusServlet.java    
@Before
public void setupBasicMocks() throws IOException, ServiceException {
  rs = Mockito.mock(HRegionServer.class);
  Mockito.doReturn(HBaseConfiguration.create())
    .when(rs).getConfiguration();
  Mockito.doReturn(fakeResponse).when(rs).getServerInfo(
    (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
  // Fake ZKW
  ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
  Mockito.doReturn("fakequorum").when(zkw).getQuorum();
  Mockito.doReturn(zkw).when(rs).getZooKeeper();

  // Fake MasterAddressTracker
  MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
  Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
  Mockito.doReturn(mat).when(rs).getMasterAddressTracker();

  MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
  Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();
  Mockito.doReturn(rms).when(rs).getMetrics();
}
项目：PyroDB    文件：TestRSStatusServlet.java    
@Before
public void setupBasicMocks() throws IOException, ServiceException {
  rs = Mockito.mock(HRegionServer.class);
  rpcServices = Mockito.mock(RSRpcServices.class);
  Mockito.doReturn(HBaseConfiguration.create())
    .when(rs).getConfiguration();
  Mockito.doReturn(rpcServices).when(rs).getRSRpcServices();
  Mockito.doReturn(fakeResponse).when(rpcServices).getServerInfo(
    (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
  // Fake ZKW
  ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
  Mockito.doReturn("fakequorum").when(zkw).getQuorum();
  Mockito.doReturn(zkw).when(rs).getZooKeeper();

  // Fake MasterAddressTracker
  MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
  Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
  Mockito.doReturn(mat).when(rs).getMasterAddressTracker();

  MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
  Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();
  Mockito.doReturn(rms).when(rs).getRegionServerMetrics();
}
项目：c5    文件：TestRSStatusServlet.java    
@Before
public void setupBasicMocks() throws IOException, ServiceException {
  rs = Mockito.mock(HRegionServer.class);
  Mockito.doReturn(HBaseConfiguration.create())
    .when(rs).getConfiguration();
  Mockito.doReturn(fakeResponse).when(rs).getServerInfo(
    (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
  // Fake ZKW
  ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
  Mockito.doReturn("fakequorum").when(zkw).getQuorum();
  Mockito.doReturn(zkw).when(rs).getZooKeeper();

  // Fake MasterAddressTracker
  MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
  Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
  Mockito.doReturn(mat).when(rs).getMasterAddressManager();

  MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
  Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();
  Mockito.doReturn(rms).when(rs).getMetrics();
}
项目：DominoHBase    文件：TestRSStatusServlet.java    
@Before
public void setupBasicMocks() throws IOException, ServiceException {
  rs = Mockito.mock(HRegionServer.class);
  Mockito.doReturn(HBaseConfiguration.create())
    .when(rs).getConfiguration();
  Mockito.doReturn(fakeResponse).when(rs).getServerInfo(
    (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
  // Fake ZKW
  ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
  Mockito.doReturn("fakequorum").when(zkw).getQuorum();
  Mockito.doReturn(zkw).when(rs).getZooKeeper();

  // Fake MasterAddressTracker
  MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
  Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
  Mockito.doReturn(mat).when(rs).getMasterAddressManager();

  MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
  Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();
  Mockito.doReturn(rms).when(rs).getMetrics();
}
项目：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    文件：TestRSStatusServlet.java    
@Before
public void setupBasicMocks() throws IOException, ServiceException {
  rs = Mockito.mock(HRegionServer.class);
  rpcServices = Mockito.mock(RSRpcServices.class);
  rpcServer = Mockito.mock(RpcServerInterface.class);
  Mockito.doReturn(HBaseConfiguration.create())
    .when(rs).getConfiguration();
  Mockito.doReturn(rpcServices).when(rs).getRSRpcServices();
  Mockito.doReturn(rpcServer).when(rs).getRpcServer();
  Mockito.doReturn(fakeResponse).when(rpcServices).getServerInfo(
    (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
  // Fake ZKW
  ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
  Mockito.doReturn("fakequorum").when(zkw).getQuorum();
  Mockito.doReturn(zkw).when(rs).getZooKeeper();

  // Fake CacheConfig
  LOG.warn("The " + HConstants.HFILE_BLOCK_CACHE_SIZE_KEY + " is set to 0");
  CacheConfig cacheConf = Mockito.mock(CacheConfig.class);
  Mockito.doReturn(null).when(cacheConf).getBlockCache();
  Mockito.doReturn(cacheConf).when(rs).getCacheConfig();

  // Fake MasterAddressTracker
  MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
  Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
  Mockito.doReturn(mat).when(rs).getMasterAddressTracker();

  MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
  Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();
  Mockito.doReturn(rms).when(rs).getRegionServerMetrics();

  MetricsHBaseServer ms = Mockito.mock(MetricsHBaseServer.class);
  Mockito.doReturn(new MetricsHBaseServerWrapperStub()).when(ms).getHBaseServerWrapper();
  Mockito.doReturn(ms).when(rpcServer).getMetrics();
}
项目：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    文件：TestRSStatusServlet.java    
@Before
public void setupBasicMocks() throws IOException, ServiceException {
  rs = Mockito.mock(HRegionServer.class);
  rpcServices = Mockito.mock(RSRpcServices.class);
  Mockito.doReturn(HBaseConfiguration.create())
    .when(rs).getConfiguration();
  Mockito.doReturn(rpcServices).when(rs).getRSRpcServices();
  Mockito.doReturn(fakeResponse).when(rpcServices).getServerInfo(
    (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
  // Fake ZKW
  ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
  Mockito.doReturn("fakequorum").when(zkw).getQuorum();
  Mockito.doReturn(zkw).when(rs).getZooKeeper();

  // Fake CacheConfig
  LOG.warn("The " + HConstants.HFILE_BLOCK_CACHE_SIZE_KEY + " is set to 0");
  CacheConfig cacheConf = Mockito.mock(CacheConfig.class);
  Mockito.doReturn(null).when(cacheConf).getBlockCache();
  Mockito.doReturn(cacheConf).when(rs).getCacheConfig();

  // Fake MasterAddressTracker
  MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
  Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
  Mockito.doReturn(mat).when(rs).getMasterAddressTracker();

  MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
  Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();
  Mockito.doReturn(rms).when(rs).getRegionServerMetrics();
}
项目：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    文件：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    文件：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    文件：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    文件：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;
}
项目：ditb    文件：RequestConverter.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  return GET_SERVER_INFO_REQUEST;
}
项目：pbase    文件：RequestConverter.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  return GET_SERVER_INFO_REQUEST;
}
项目：HIndex    文件：RequestConverter.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  return GET_SERVER_INFO_REQUEST;
}
项目：hbase    文件：ProtobufUtil.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  return GET_SERVER_INFO_REQUEST;
}
项目：PyroDB    文件：RequestConverter.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  return GET_SERVER_INFO_REQUEST;
}
项目：c5    文件：RequestConverter.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  return GET_SERVER_INFO_REQUEST;
}
项目：DominoHBase    文件：RequestConverter.java    
/**
 * Create a new GetServerInfoRequest
 *
 * @return a GetServerInfoRequest
 */
public static GetServerInfoRequest buildGetServerInfoRequest() {
  GetServerInfoRequest.Builder builder =  GetServerInfoRequest.newBuilder();
  return builder.build();
}