From 25ffc3de6386080af8effd27509c0c691ee788e5 Mon Sep 17 00:00:00 2001 From: Duo Zhang Date: Fri, 26 Oct 2018 15:35:22 +0800 Subject: [PATCH] HBASE-21237 Use CompatRemoteProcedureResolver to dispatch open/close region requests to RS --- .../procedure/RSProcedureDispatcher.java | 55 ++----------------- 1 file changed, 4 insertions(+), 51 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java index 638f9d3461..4c68740587 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java @@ -109,17 +109,10 @@ public class RSProcedureDispatcher protected void remoteDispatch(final ServerName serverName, final Set remoteProcedures) { final int rsVersion = master.getServerManager().getVersionNumber(serverName); - if (rsVersion >= RS_VERSION_WITH_EXEC_PROCS) { - LOG.trace("Using procedure batch rpc execution for serverName={} version={}", serverName, - rsVersion); - submitTask(new ExecuteProceduresRemoteCall(serverName, remoteProcedures)); - } else if (rsVersion == 0 && !master.getServerManager().isServerOnline(serverName)) { + if (rsVersion == 0 && !master.getServerManager().isServerOnline(serverName)) { submitTask(new DeadRSRemoteCall(serverName, remoteProcedures)); } else { - LOG.info(String.format( - "Fallback to compat rpc execution for serverName=%s version=%s", - serverName, rsVersion)); - submitTask(new CompatRemoteProcedureResolver(serverName, remoteProcedures)); + submitTask(new ExecuteProceduresRemoteCall(serverName, remoteProcedures)); } } @@ -325,14 +318,14 @@ public class RSProcedureDispatcher @Override public void dispatchOpenRequests(final MasterProcedureEnv env, final List operations) { - request.addOpenRegion(buildOpenRegionRequest(env, getServerName(), operations)); + submitTask(new OpenRegionRemoteCall(getServerName(), operations)); } @Override public void dispatchCloseRequests(final MasterProcedureEnv env, final List operations) { for (RegionCloseOperation op: operations) { - request.addCloseRegion(op.buildCloseRegionRequest(getServerName())); + submitTask(new CloseRegionRemoteCall(getServerName(), op)); } } @@ -469,46 +462,6 @@ public class RSProcedureDispatcher } } - /** - * Compatibility class to open and close regions using old endpoints (openRegion/closeRegion) in - * {@link AdminService}. - */ - protected class CompatRemoteProcedureResolver implements Callable, RemoteProcedureResolver { - private final Set operations; - private final ServerName serverName; - - public CompatRemoteProcedureResolver(final ServerName serverName, - final Set operations) { - this.serverName = serverName; - this.operations = operations; - } - - @Override - public Void call() { - splitAndResolveOperation(serverName, operations, this); - return null; - } - - @Override - public void dispatchOpenRequests(final MasterProcedureEnv env, - final List operations) { - submitTask(new OpenRegionRemoteCall(serverName, operations)); - } - - @Override - public void dispatchCloseRequests(final MasterProcedureEnv env, - final List operations) { - for (RegionCloseOperation op: operations) { - submitTask(new CloseRegionRemoteCall(serverName, op)); - } - } - - @Override - public void dispatchServerOperations(MasterProcedureEnv env, List operations) { - throw new UnsupportedOperationException(); - } - } - // ========================================================================== // RPC Messages // - ServerOperation: refreshConfig, grant, revoke, ... (TODO) -- 2.17.1