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

/**
 * Stop the designated regionserver
 * @param hostnamePort Hostname and port delimited by a <code>:</code> as in
 * <code>example.org:1234</code>
 * @throws IOException if a remote or network exception occurs
 */
@Override
public synchronized void stopRegionServer(final String hostnamePort)
throws IOException {
  String hostname = Addressing.parseHostname(hostnamePort);
  int port = Addressing.parsePort(hostnamePort);
  AdminService.BlockingInterface admin =
    this.connection.getAdmin(ServerName.valueOf(hostname, port, 0));
  StopServerRequest request = RequestConverter.buildStopServerRequest(
    "Called by admin client " + this.connection.toString());
  PayloadCarryingRpcController controller = rpcControllerFactory.newController();

  controller.setPriority(HConstants.HIGH_QOS);
  try {
    // TODO: this does not do retries, it should. Set priority and timeout in controller
    admin.stopServer(controller, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

/**
 * Stop the designated regionserver
 * @param hostnamePort Hostname and port delimited by a <code>:</code> as in
 * <code>example.org:1234</code>
 * @throws IOException if a remote or network exception occurs
 */
@Override
public synchronized void stopRegionServer(final String hostnamePort)
throws IOException {
  String hostname = Addressing.parseHostname(hostnamePort);
  int port = Addressing.parsePort(hostnamePort);
  AdminService.BlockingInterface admin =
    this.connection.getAdmin(ServerName.valueOf(hostname, port, 0));
  StopServerRequest request = RequestConverter.buildStopServerRequest(
    "Called by admin client " + this.connection.toString());
  try {
    admin.stopServer(null, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

/**
 * Stop the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.ADMIN_QOS)
public StopServerResponse stopServer(final RpcController controller,
    final StopServerRequest request) throws ServiceException {
  requestCount.increment();
  String reason = request.getReason();
  regionServer.stop(reason);
  return StopServerResponse.newBuilder().build();
}

/**
 * Stop the region server.
 *
 * @param controller the RPC controller
 * @param request    the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority = HConstants.ADMIN_QOS)
public StopServerResponse stopServer(final RpcController controller,
                                     final StopServerRequest request) throws ServiceException {
    requestCount.increment();
    String reason = request.getReason();
    regionServer.stop(reason);
    return StopServerResponse.newBuilder().build();
}

/**
 * Stop the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public StopServerResponse stopServer(final RpcController controller,
    final StopServerRequest request) throws ServiceException {
  requestCount.increment();
  String reason = request.getReason();
  stop(reason);
  return StopServerResponse.newBuilder().build();
}

/**
 * Stop the designated regionserver
 * @param hostnamePort Hostname and port delimited by a <code>:</code> as in
 * <code>example.org:1234</code>
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void stopRegionServer(final String hostnamePort)
throws IOException {
  String hostname = Addressing.parseHostname(hostnamePort);
  int port = Addressing.parsePort(hostnamePort);
  AdminService.BlockingInterface admin =
    this.connection.getAdmin(ServerName.valueOf(hostname, port, 0));
  StopServerRequest request = RequestConverter.buildStopServerRequest(
    "Called by admin client " + this.connection.toString());
  try {
    admin.stopServer(null, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

/**
 * Stop the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public StopServerResponse stopServer(final RpcController controller,
    final StopServerRequest request) throws ServiceException {
  requestCount.increment();
  String reason = request.getReason();
  regionServer.stop(reason);
  return StopServerResponse.newBuilder().build();
}

/**
 * Stop the designated regionserver
 * @param hostnamePort Hostname and port delimited by a <code>:</code> as in
 * <code>example.org:1234</code>
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void stopRegionServer(final String hostnamePort)
throws IOException {
  String hostname = Addressing.parseHostname(hostnamePort);
  int port = Addressing.parsePort(hostnamePort);
  AdminService.BlockingInterface admin =
    this.connection.getAdmin(ServerName.valueOf(hostname, port, 0));
  StopServerRequest request = RequestConverter.buildStopServerRequest(
    "Called by admin client " + this.connection.toString());
  try {
    admin.stopServer(null, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

/**
 * Stop the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public StopServerResponse stopServer(final RpcController controller,
    final StopServerRequest request) throws ServiceException {
  requestCount.increment();
  String reason = request.getReason();
  stop(reason);
  return StopServerResponse.newBuilder().build();
}

/**
 * Stop the designated regionserver
 * @param hostnamePort Hostname and port delimited by a <code>:</code> as in
 * <code>example.org:1234</code>
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void stopRegionServer(final String hostnamePort)
throws IOException {
  String hostname = Addressing.parseHostname(hostnamePort);
  int port = Addressing.parsePort(hostnamePort);
  AdminService.BlockingInterface admin =
    this.connection.getAdmin(ServerName.valueOf(hostname, port, 0));
  StopServerRequest request = RequestConverter.buildStopServerRequest(
    "Called by admin client " + this.connection.toString());
  try {
    admin.stopServer(null, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

/**
 * Stop the designated regionserver
 * @param hostnamePort Hostname and port delimited by a <code>:</code> as in
 * <code>example.org:1234</code>
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void stopRegionServer(final String hostnamePort)
throws IOException {
  String hostname = Addressing.parseHostname(hostnamePort);
  int port = Addressing.parsePort(hostnamePort);
  AdminProtocol admin =
    this.connection.getAdmin(hostname, port);
  StopServerRequest request = RequestConverter.buildStopServerRequest(
    "Called by admin client " + this.connection.toString());
  try {
    admin.stopServer(null, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

/**
 * Stop the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public StopServerResponse stopServer(final RpcController controller,
    final StopServerRequest request) throws ServiceException {
  requestCount.increment();
  String reason = request.getReason();
  stop(reason);
  return StopServerResponse.newBuilder().build();
}

@Override
public StopServerResponse stopServer(RpcController controller,
    StopServerRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public StopServerResponse stopServer(RpcController controller,
    StopServerRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public StopServerResponse stopServer(RpcController controller,
    StopServerRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public StopServerResponse stopServer(RpcController controller,
    StopServerRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public StopServerResponse stopServer(RpcController controller,
    StopServerRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public StopServerResponse stopServer(RpcController controller,
    StopServerRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

/**
 * Create a new StopServerRequest
 *
 * @param reason the reason to stop the server
 * @return a StopServerRequest
 */
public static StopServerRequest buildStopServerRequest(final String reason) {
  StopServerRequest.Builder builder = StopServerRequest.newBuilder();
  builder.setReason(reason);
  return builder.build();
}

/**
 * Create a new StopServerRequest
 *
 * @param reason the reason to stop the server
 * @return a StopServerRequest
 */
public static StopServerRequest buildStopServerRequest(final String reason) {
  StopServerRequest.Builder builder = StopServerRequest.newBuilder();
  builder.setReason(reason);
  return builder.build();
}

/**
 * Create a new StopServerRequest
 *
 * @param reason the reason to stop the server
 * @return a StopServerRequest
 */
public static StopServerRequest buildStopServerRequest(final String reason) {
  StopServerRequest.Builder builder = StopServerRequest.newBuilder();
  builder.setReason(reason);
  return builder.build();
}

/**
 * Create a new StopServerRequest
 *
 * @param reason the reason to stop the server
 * @return a StopServerRequest
 */
public static StopServerRequest buildStopServerRequest(final String reason) {
  StopServerRequest.Builder builder = StopServerRequest.newBuilder();
  builder.setReason(reason);
  return builder.build();
}

/**
 * Create a new StopServerRequest
 *
 * @param reason the reason to stop the server
 * @return a StopServerRequest
 */
public static StopServerRequest buildStopServerRequest(final String reason) {
  StopServerRequest.Builder builder = StopServerRequest.newBuilder();
  builder.setReason(reason);
  return builder.build();
}

/**
 * Create a new StopServerRequest
 *
 * @param reason the reason to stop the server
 * @return a StopServerRequest
 */
public static StopServerRequest buildStopServerRequest(final String reason) {
  StopServerRequest.Builder builder = StopServerRequest.newBuilder();
  builder.setReason(reason);
  return builder.build();
}