public void setUp()

in src/main/java/org/apache/accumulo/testing/randomwalk/security/SecurityFixture.java [37:85]
38 lines of code
7 McCabe index (conditional complexity)

  public void setUp(State state, RandWalkEnv env) throws Exception {
    String secTableName, systemUserName, tableUserName, secNamespaceName;
    // A best-effort sanity check to guard against not password-based auth
    if (env.getClientProps().getProperty(ClientProperty.AUTH_TYPE.getKey()).equals("kerberos")) {
      throw new IllegalStateException(
          "Security module currently cannot support Kerberos/SASL instances");
    }

    AccumuloClient client = env.getAccumuloClient();

    String hostname = InetAddress.getLocalHost().getHostName().replaceAll("[-.]", "_");

    systemUserName = String.format("system_%s", hostname);
    tableUserName = String.format("table_%s", hostname);
    secTableName = String.format("security_%s", hostname);
    secNamespaceName = String.format("securityNs_%s", hostname);

    if (client.tableOperations().exists(secTableName))
      client.tableOperations().delete(secTableName);
    Set<String> users = client.securityOperations().listLocalUsers();
    if (users.contains(tableUserName))
      client.securityOperations().dropLocalUser(tableUserName);
    if (users.contains(systemUserName))
      client.securityOperations().dropLocalUser(systemUserName);

    PasswordToken sysUserPass = new PasswordToken("sysUser");
    client.securityOperations().createLocalUser(systemUserName, sysUserPass);

    WalkingSecurity.get(state, env).setTableName(secTableName);
    WalkingSecurity.get(state, env).setNamespaceName(secNamespaceName);
    state.set("rootUserPass", env.getToken());

    WalkingSecurity.get(state, env).setSysUserName(systemUserName);
    WalkingSecurity.get(state, env).createUser(systemUserName, sysUserPass);

    WalkingSecurity.get(state, env).changePassword(tableUserName, new PasswordToken(new byte[0]));

    WalkingSecurity.get(state, env).setTabUserName(tableUserName);

    for (TablePermission tp : TablePermission.values()) {
      WalkingSecurity.get(state, env).revokeTablePermission(systemUserName, secTableName, tp);
      WalkingSecurity.get(state, env).revokeTablePermission(tableUserName, secTableName, tp);
    }
    for (SystemPermission sp : SystemPermission.values()) {
      WalkingSecurity.get(state, env).revokeSystemPermission(systemUserName, sp);
      WalkingSecurity.get(state, env).revokeSystemPermission(tableUserName, sp);
    }
    WalkingSecurity.get(state, env).changeAuthorizations(tableUserName, new Authorizations());
  }