Java 类org.apache.hadoop.security.protocolPB.RefreshUserMappingsProtocolPB 实例源码

项目：hadoop 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：aliyun-oss-hadoop-fs 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：aliyun-oss-hadoop-fs 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：big-c 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：big-c 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-plus 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：FlexMap 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：FlexMap 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hops 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hops 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol createNNProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy =
      (RefreshUserMappingsProtocolPB) createNameNodeProxy(address, conf, ugi,
          RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-TCP 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hardfs 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-on-lustre2 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-on-lustre2 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}

项目：hadoop-on-lustre2 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(
      JHAdminConfig.MR_HISTORY_BIND_HOST,
      JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  // Enable service authorization?
  if (conf.getBoolean(
      CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
      false)) {
    clientRpcServer.refreshServiceAcl(conf, new ClientHSPolicyProvider());
  }

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}

项目：aliyun-oss-hadoop-fs 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(
      JHAdminConfig.MR_HISTORY_BIND_HOST,
      JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  // Enable service authorization?
  if (conf.getBoolean(
      CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
      false)) {
    clientRpcServer.refreshServiceAcl(conf, new ClientHSPolicyProvider());
  }

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}

项目：big-c 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(
      JHAdminConfig.MR_HISTORY_BIND_HOST,
      JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  // Enable service authorization?
  if (conf.getBoolean(
      CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
      false)) {
    clientRpcServer.refreshServiceAcl(conf, new ClientHSPolicyProvider());
  }

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}

项目：hadoop-2.6.0-cdh5.4.3 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(
      JHAdminConfig.MR_HISTORY_BIND_HOST,
      JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  // Enable service authorization?
  if (conf.getBoolean(
      CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
      false)) {
    clientRpcServer.refreshServiceAcl(conf, new ClientHSPolicyProvider());
  }

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}

项目：FlexMap 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(
      JHAdminConfig.MR_HISTORY_BIND_HOST,
      JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}

项目：hops 文件：HSAdminServer.java

@Override
public void serviceInit(Configuration conf) throws Exception {
  RPC.setProtocolEngine(conf, RefreshUserMappingsProtocolPB.class,
      ProtobufRpcEngine.class);

  RefreshUserMappingsProtocolServerSideTranslatorPB refreshUserMappingXlator = new RefreshUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshUserMappingService = RefreshUserMappingsProtocolService
      .newReflectiveBlockingService(refreshUserMappingXlator);

  GetUserMappingsProtocolServerSideTranslatorPB getUserMappingXlator = new GetUserMappingsProtocolServerSideTranslatorPB(
      this);
  BlockingService getUserMappingService = GetUserMappingsProtocolService
      .newReflectiveBlockingService(getUserMappingXlator);

  HSAdminRefreshProtocolServerSideTranslatorPB refreshHSAdminProtocolXlator = new HSAdminRefreshProtocolServerSideTranslatorPB(
      this);
  BlockingService refreshHSAdminProtocolService = HSAdminRefreshProtocolService
      .newReflectiveBlockingService(refreshHSAdminProtocolXlator);

  WritableRpcEngine.ensureInitialized();

  clientRpcAddress = conf.getSocketAddr(
      JHAdminConfig.MR_HISTORY_BIND_HOST,
      JHAdminConfig.JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ADDRESS,
      JHAdminConfig.DEFAULT_JHS_ADMIN_PORT);
  clientRpcServer = new RPC.Builder(conf)
      .setProtocol(RefreshUserMappingsProtocolPB.class)
      .setInstance(refreshUserMappingService)
      .setBindAddress(clientRpcAddress.getHostName())
      .setPort(clientRpcAddress.getPort()).setVerbose(false).build();

  addProtocol(conf, GetUserMappingsProtocolPB.class, getUserMappingService);
  addProtocol(conf, HSAdminRefreshProtocolPB.class,
      refreshHSAdminProtocolService);

  // Enable service authorization?
  if (conf.getBoolean(
      CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
      false)) {
    clientRpcServer.refreshServiceAcl(conf, new ClientHSPolicyProvider());
  }

  adminAcl = new AccessControlList(conf.get(JHAdminConfig.JHS_ADMIN_ACL,
      JHAdminConfig.DEFAULT_JHS_ADMIN_ACL));

}