Java 类javax.security.auth.login.AppConfigurationEntry.LoginModuleControlFlag 实例源码

项目：kafka-0.11.0.0-src-with-comment 文件：JaasConfig.java

private LoginModuleControlFlag loginModuleControlFlag(String flag) {
    LoginModuleControlFlag controlFlag;
    switch (flag.toUpperCase(Locale.ROOT)) {
        case "REQUIRED":
            controlFlag = LoginModuleControlFlag.REQUIRED;
            break;
        case "REQUISITE":
            controlFlag = LoginModuleControlFlag.REQUISITE;
            break;
        case "SUFFICIENT":
            controlFlag = LoginModuleControlFlag.SUFFICIENT;
            break;
        case "OPTIONAL":
            controlFlag = LoginModuleControlFlag.OPTIONAL;
            break;
        default:
            throw new IllegalArgumentException("Invalid login module control flag '" + flag + "' in JAAS config");
    }
    return controlFlag;
}

项目：kafka-0.11.0.0-src-with-comment 文件：JaasConfig.java

private AppConfigurationEntry parseAppConfigurationEntry(StreamTokenizer tokenizer) throws IOException {
    String loginModule = tokenizer.sval;
    if (tokenizer.nextToken() == StreamTokenizer.TT_EOF)
        throw new IllegalArgumentException("Login module control flag not specified in JAAS config");
    LoginModuleControlFlag controlFlag = loginModuleControlFlag(tokenizer.sval);
    Map<String, String> options = new HashMap<>();
    while (tokenizer.nextToken() != StreamTokenizer.TT_EOF && tokenizer.ttype != ';') {
        String key = tokenizer.sval;
        if (tokenizer.nextToken() != '=' || tokenizer.nextToken() == StreamTokenizer.TT_EOF || tokenizer.sval == null)
            throw new IllegalArgumentException("Value not specified for key '" + key + "' in JAAS config");
        String value = tokenizer.sval;
        options.put(key, value);
    }
    if (tokenizer.ttype != ';')
        throw new IllegalArgumentException("JAAS config entry not terminated by semi-colon");
    return new AppConfigurationEntry(loginModule, controlFlag, options);
}

项目：Wiab.pro 文件：AuthTestUtil.java

public static Configuration makeConfiguration() {
  return new Configuration() {
    @Override
    public AppConfigurationEntry[] getAppConfigurationEntry(String name) {
      if (name.equals("Wave")) {
        AppConfigurationEntry entry =
            new AppConfigurationEntry(AccountStoreLoginModule.class.getName(),
                LoginModuleControlFlag.REQUIRED, new HashMap<String, Object>());

        return new AppConfigurationEntry[] {entry};
      } else {
        return null;
      }
    }
  };
}

项目：jvfsftpd 文件：FileFtpConfiguration.java

public FileFtpConfiguration(File configFile)
  {
    try
{
    doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(configFile);
    String useUsers = evalXPath("/ftpd/use-users/text()");
    if(!StringUtils.isEmpty(useUsers))
    {
        boolean use = Boolean.parseBoolean(useUsers);
        if(use)
        {
            securityDomain = RandomStringUtils.randomAlphabetic(5);
            AppConfigurationEntry entry = new AppConfigurationEntry(FileConfigLoginModule.class.getName(),LoginModuleControlFlag.REQUIRED, new HashMap());
            DeligateConfiguration deligateConfiguration = new DeligateConfiguration(getJAASConfiguration(),securityDomain,new AppConfigurationEntry[]{entry});
            Configuration.setConfiguration(deligateConfiguration);
        }
    }
} 
    catch (Exception e)
{
    throw new IncorrectConfigurationException(e);
} 
  }

项目：incubator-wave 文件：AuthTestUtil.java

public static Configuration makeConfiguration() {
  return new Configuration() {
    @Override
    public AppConfigurationEntry[] getAppConfigurationEntry(String name) {
      if (name.equals("Wave")) {
        AppConfigurationEntry entry =
            new AppConfigurationEntry(AccountStoreLoginModule.class.getName(),
                LoginModuleControlFlag.REQUIRED, new HashMap<String, Object>());

        return new AppConfigurationEntry[] {entry};
      } else {
        return null;
      }
    }
  };
}

项目：pentaho-kettle 文件：KerberosUtil.java

public LoginContext getLoginContextFromUsernamePassword( final String principal, final String password ) throws LoginException {
  Map<String, String> opts = new HashMap<String, String>( LOGIN_CONFIG_OPTS_KERBEROS_USER );
  opts.put( "principal", principal );
  AppConfigurationEntry[] appConfigurationEntries =
      new AppConfigurationEntry[] { new AppConfigurationEntry( Krb5LoginModule.class.getName(),
          LoginModuleControlFlag.REQUIRED, opts ) };
  return new LoginContext( KERBEROS_APP_NAME, new Subject(), new CallbackHandler() {

    @Override
    public void handle( Callback[] callbacks ) throws IOException, UnsupportedCallbackException {
      for ( Callback callback : callbacks ) {
        if ( callback instanceof NameCallback ) {
          ( (NameCallback) callback ).setName( principal );
        } else if ( callback instanceof PasswordCallback ) {
          ( (PasswordCallback) callback ).setPassword( password.toCharArray() );
        } else {
          throw new UnsupportedCallbackException( callback );
        }
      }
    }
  }, new PentahoLoginConfiguration( appConfigurationEntries ) );
}

项目：directory-ldap-api 文件：Krb5LoginConfiguration.java

/**
 * Creates a new instance of Krb5LoginConfiguration.
 */
public Krb5LoginConfiguration()
{
    String loginModule = "com.sun.security.auth.module.Krb5LoginModule";

    HashMap<String, Object> options = new HashMap<>();

    // TODO: this only works for Sun JVM
    options.put( "refreshKrb5Config", "true" );

    LoginModuleControlFlag flag = LoginModuleControlFlag.REQUIRED;
    configList[0] = new AppConfigurationEntry( loginModule, flag, options );
}

项目：unitimes 文件：LoginConfiguration.java

public void init() {
    Debug.info("Configuring authentication service ...");
    String m = ApplicationProperty.AuthenticationModules.value();
    String[] modules = (m == null || m.isEmpty() ? new String[] {} : m.split(";"));
    sEntries = new AppConfigurationEntry[modules.length];
    for (int idx = 0; idx < modules.length; idx++) {
        HashMap<String, Object> options = new HashMap<String, Object>();
        String[] module = modules[idx].split(" ");
        LoginModuleControlFlag flag = LoginModuleControlFlag.SUFFICIENT;
        String name = module[module.length == 1 ? 0 : 1];
        if (module.length > 1) {
            String f = module[0];
            if (f.equalsIgnoreCase("sufficient")) flag = LoginModuleControlFlag.SUFFICIENT;
            else if (f.equalsIgnoreCase("optional")) flag = LoginModuleControlFlag.OPTIONAL;
            else if (f.equalsIgnoreCase("required")) flag = LoginModuleControlFlag.REQUIRED;
            else if (f.equalsIgnoreCase("requisite")) flag = LoginModuleControlFlag.REQUISITE;
        }
        if (module.length > 2)
            for (int i = 2; i < module.length; i++) {
                String[] option = module[i].split("=");
                if (option.length == 1)
                    options.put(option[0], "true");
                else
                    options.put(option[0], option[1]);
            }
        Debug.info("  Using " + flag + " " + name + " " + options);
        sEntries[idx] = new AppConfigurationEntry(name, flag, options);
    }
}

项目：kafka-0.11.0.0-src-with-comment 文件：TestJaasConfig.java

public void addEntry(String name, String loginModule, Map<String, Object> options) {
    AppConfigurationEntry entry = new AppConfigurationEntry(loginModule, LoginModuleControlFlag.REQUIRED, options);
    AppConfigurationEntry[] existing = entryMap.get(name);
    AppConfigurationEntry[] newEntries = existing == null ? new AppConfigurationEntry[1] : Arrays.copyOf(existing, existing.length + 1);
    newEntries[newEntries.length - 1] = entry;
    entryMap.put(name, newEntries);
}