Java 类org.apache.hadoop.hbase.security.token.AuthenticationTokenSecretManager 实例源码

项目:pbase    文件:RpcServer.java   
/** Starts the service.  Must be called before any calls will be handled. */
@Override
public synchronized void start() {
  if (started) return;
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);
  responder.start();
  listener.start();
  scheduler.start();
  started = true;
}
项目:PyroDB    文件:RpcServer.java   
/** Starts the service.  Must be called before any calls will be handled. */
@Override
public synchronized void start() {
  if (started) return;
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);
  responder.start();
  listener.start();
  scheduler.start();
  started = true;
}
项目:c5    文件:RpcServer.java   
/**
 * Starts the service threads but does not allow requests to be responded yet.
 * Client will get {@link ServerNotRunningYetException} instead.
 */
@Override
public synchronized void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);
  responder.start();
  listener.start();
  handlers = startHandlers(callQueue, handlerCount);
  priorityHandlers = startHandlers(priorityCallQueue, priorityHandlerCount);
  replicationHandlers = startHandlers(replicationQueue, numOfReplicationHandlers);
}
项目:ditb    文件:RpcServer.java   
private AuthenticationTokenSecretManager createSecretManager() {
  if (!isSecurityEnabled) return null;
  if (server == null) return null;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:pbase    文件:RpcServer.java   
private AuthenticationTokenSecretManager createSecretManager() {
  if (!isSecurityEnabled) return null;
  if (server == null) return null;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:HIndex    文件:RpcServer.java   
/**
 * Starts the service threads but does not allow requests to be responded yet.
 * Client will get {@link ServerNotRunningYetException} instead.
 */
@Override
public synchronized void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);
  responder.start();
  listener.start();
  scheduler.start();
}
项目:HIndex    文件:RpcServer.java   
private AuthenticationTokenSecretManager createSecretManager() {
  if (!isSecurityEnabled) return null;
  if (serverInstance == null) return null;
  if (!(serverInstance instanceof org.apache.hadoop.hbase.Server)) return null;
  org.apache.hadoop.hbase.Server server = (org.apache.hadoop.hbase.Server)serverInstance;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:IRIndex    文件:SecureRpcEngine.java   
public AuthenticationTokenSecretManager createSecretManager(){
  if (instance instanceof org.apache.hadoop.hbase.Server) {
    org.apache.hadoop.hbase.Server server =
        (org.apache.hadoop.hbase.Server)instance;
    Configuration conf = server.getConfiguration();
    long keyUpdateInterval =
        conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
    long maxAge =
        conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
    return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
        server.getServerName().toString(), keyUpdateInterval, maxAge);
  }
  return null;
}
项目:IRIndex    文件:SecureRpcEngine.java   
@Override
public void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);

  // continue with base startup
  super.startThreads();
}
项目:hbase    文件:RpcServer.java   
protected AuthenticationTokenSecretManager createSecretManager() {
  if (!isSecurityEnabled) return null;
  if (server == null) return null;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:PyroDB    文件:RpcServer.java   
private AuthenticationTokenSecretManager createSecretManager() {
  if (!isSecurityEnabled) return null;
  if (server == null) return null;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:c5    文件:RpcServer.java   
private AuthenticationTokenSecretManager createSecretManager() {
  if (!isSecurityEnabled) return null;
  if (serverInstance == null) return null;
  if (!(serverInstance instanceof org.apache.hadoop.hbase.Server)) return null;
  org.apache.hadoop.hbase.Server server = (org.apache.hadoop.hbase.Server)serverInstance;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:HBase-Research    文件:SecureRpcEngine.java   
public AuthenticationTokenSecretManager createSecretManager(){
  if (instance instanceof org.apache.hadoop.hbase.Server) {
    org.apache.hadoop.hbase.Server server =
        (org.apache.hadoop.hbase.Server)instance;
    Configuration conf = server.getConfiguration();
    long keyUpdateInterval =
        conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
    long maxAge =
        conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
    return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
        server.getServerName().toString(), keyUpdateInterval, maxAge);
  }
  return null;
}
项目:HBase-Research    文件:SecureRpcEngine.java   
@Override
public void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);

  // continue with base startup
  super.startThreads();
}
项目:hbase-0.94.8-qod    文件:SecureRpcEngine.java   
public AuthenticationTokenSecretManager createSecretManager(){
  if (instance instanceof org.apache.hadoop.hbase.Server) {
    org.apache.hadoop.hbase.Server server =
        (org.apache.hadoop.hbase.Server)instance;
    Configuration conf = server.getConfiguration();
    long keyUpdateInterval =
        conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
    long maxAge =
        conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
    return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
        server.getServerName().toString(), keyUpdateInterval, maxAge);
  }
  return null;
}
项目:hbase-0.94.8-qod    文件:SecureRpcEngine.java   
@Override
public void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);

  // continue with base startup
  super.startThreads();
}
项目:hbase-0.94.8-qod    文件:SecureRpcEngine.java   
public AuthenticationTokenSecretManager createSecretManager(){
  if (instance instanceof org.apache.hadoop.hbase.Server) {
    org.apache.hadoop.hbase.Server server =
        (org.apache.hadoop.hbase.Server)instance;
    Configuration conf = server.getConfiguration();
    long keyUpdateInterval =
        conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
    long maxAge =
        conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
    return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
        server.getServerName().toString(), keyUpdateInterval, maxAge);
  }
  return null;
}
项目:hbase-0.94.8-qod    文件:SecureRpcEngine.java   
@Override
public void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);

  // continue with base startup
  super.startThreads();
}
项目:DominoHBase    文件:ProtobufRpcServerEngine.java   
private AuthenticationTokenSecretManager createSecretManager(){
  if (!isSecurityEnabled ||
      !(instance instanceof org.apache.hadoop.hbase.Server)) {
    return null;
  }
  org.apache.hadoop.hbase.Server server =
      (org.apache.hadoop.hbase.Server)instance;
  Configuration conf = server.getConfiguration();
  long keyUpdateInterval =
      conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
  long maxAge =
      conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
  return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
      server.getServerName().toString(), keyUpdateInterval, maxAge);
}
项目:DominoHBase    文件:ProtobufRpcServerEngine.java   
@Override
public void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);

  // continue with base startup
  super.startThreads();
}
项目:hindex    文件:SecureRpcEngine.java   
public AuthenticationTokenSecretManager createSecretManager(){
  if (instance instanceof org.apache.hadoop.hbase.Server) {
    org.apache.hadoop.hbase.Server server =
        (org.apache.hadoop.hbase.Server)instance;
    Configuration conf = server.getConfiguration();
    long keyUpdateInterval =
        conf.getLong("hbase.auth.key.update.interval", 24*60*60*1000);
    long maxAge =
        conf.getLong("hbase.auth.token.max.lifetime", 7*24*60*60*1000);
    return new AuthenticationTokenSecretManager(conf, server.getZooKeeper(),
        server.getServerName().toString(), keyUpdateInterval, maxAge);
  }
  return null;
}
项目:hindex    文件:SecureRpcEngine.java   
@Override
public void startThreads() {
  AuthenticationTokenSecretManager mgr = createSecretManager();
  if (mgr != null) {
    setSecretManager(mgr);
    mgr.start();
  }
  this.authManager = new ServiceAuthorizationManager();
  HBasePolicyProvider.init(conf, authManager);

  // continue with base startup
  super.startThreads();
}