private void doTest(int numOfUsers,int numOfPuts,boolean[] postAuthzAllowed,final AuthzCredentialGenerator authzGenerator,final Boolean keepAlive) throws Exception {
  CredentialGenerator credentialGenerator=authzGenerator.getCredentialGenerator();
  Properties extraAuthProps=credentialGenerator.getSystemProperties();
  Properties javaProps=credentialGenerator.getJavaProperties();
  Properties extraAuthzProps=authzGenerator.getSystemProperties();
  String authenticator=credentialGenerator.getAuthenticator();
  String accessor=authzGenerator.getAuthorizationCallback();
  String authInit=credentialGenerator.getAuthInit();
  TestAuthzCredentialGenerator tgen=new TestAuthzCredentialGenerator(authzGenerator);
  Properties serverProps=buildProperties(authenticator,accessor,true,extraAuthProps,extraAuthzProps);
  Properties opCredentials;
  credentialGenerator=tgen.getCredentialGenerator();
  final Properties javaProps2=credentialGenerator != null ? credentialGenerator.getJavaProperties() : null;
  int[] indices=new int[numOfPuts];
  for (int index=0; index < numOfPuts; ++index) {
    indices[index]=index;
  }
  Random random=new Random();
  Properties[] authProps=new Properties[numOfUsers];
  String durableClientId="multiuser_durable_client_1";
  Properties client2Credentials=null;
  for (int i=0; i < numOfUsers; i++) {
    int rand=random.nextInt(100) + 1;
    if (postAuthzAllowed[i]) {
      opCredentials=tgen.getAllowedCredentials(new OperationCode[]{OperationCode.EXECUTE_CQ,OperationCode.GET},new String[]{regionName},indices,rand);
    }
 else {
      opCredentials=tgen.getDisallowedCredentials(new OperationCode[]{OperationCode.GET},new String[]{regionName},indices,rand);
    }
    authProps[i]=concatProperties(new Properties[]{opCredentials,extraAuthProps,extraAuthzProps});
    if (client2Credentials == null) {
      client2Credentials=tgen.getAllowedCredentials(new OperationCode[]{OperationCode.PUT},new String[]{regionName},indices,rand);
    }
  }
  int[] randomAvailableTCPPorts=AvailablePortHelper.getRandomAvailableTCPPorts(3);
  int port1=randomAvailableTCPPorts[0];
  int port2=randomAvailableTCPPorts[1];
  int locatorPort=randomAvailableTCPPorts[2];
  server1.invoke(null);
  server2.invoke(null);
  server1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  if (keepAlive == null) {
    client1.invoke(null);
  }
 else {
    client1.invoke(null);
  }
  server1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  if (!postAuthzAllowed[0] || keepAlive == null || !keepAlive) {
    Thread.sleep(1000);
  }
 else {
    client1.invoke(null);
  }
  int numOfCreates=keepAlive == null ? 0 : (keepAlive ? numOfPuts + 1 : 0);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  client1.invoke(null);
  server1.invoke(null);
  if (!postAuthzAllowed[0] || keepAlive == null || !keepAlive) {
    Thread.sleep(1000);
  }
 else {
    client1.invoke(null);
  }
  int numOfUpdates=numOfPuts + 1;
  client1.invoke(null);
}

private void doTest ( int numOfUsers , int numOfPuts , boolean [ ] postAuthzAllowed , final AuthzCredentialGenerator authzGenerator , final Boolean keepAlive ) throws Exception { CredentialGenerator credentialGenerator = authzGenerator . getCredentialGenerator ( ) ; Properties extraAuthProps = credentialGenerator . getSystemProperties ( ) ; Properties javaProps = credentialGenerator . getJavaProperties ( ) ; Properties extraAuthzProps = authzGenerator . getSystemProperties ( ) ; String authenticator = credentialGenerator . getAuthenticator ( ) ; String accessor = authzGenerator . getAuthorizationCallback ( ) ; String authInit = credentialGenerator . getAuthInit ( ) ; TestAuthzCredentialGenerator tgen = new TestAuthzCredentialGenerator ( authzGenerator ) ; Properties serverProps = buildProperties ( authenticator , accessor , true , extraAuthProps , extraAuthzProps ) ; Properties opCredentials ; credentialGenerator = tgen . getCredentialGenerator ( ) ; final Properties javaProps2 = credentialGenerator != null ? credentialGenerator . getJavaProperties ( ) : null ; int [ ] indices = new int [ numOfPuts ] ; for ( int index = 0 ; index < numOfPuts ; ++ index ) { indices [ index ] = index ; } Random random = new Random ( ) ; Properties [ ] authProps = new Properties [ numOfUsers ] ; String durableClientId = "multiuser_durable_client_1" ; Properties client2Credentials = null ; for ( int i = 0 ; i < numOfUsers ; i ++ ) { int rand = random . nextInt ( 100 ) + 1 ; if ( postAuthzAllowed [ i ] ) { opCredentials = tgen . getAllowedCredentials ( new OperationCode [ ] { OperationCode . EXECUTE_CQ , OperationCode . GET } , new String [ ] { regionName } , indices , rand ) ; } else { opCredentials = tgen . getDisallowedCredentials ( new OperationCode [ ] { OperationCode . GET } , new String [ ] { regionName } , indices , rand ) ; } authProps [ i ] = concatProperties ( new Properties [ ] { opCredentials , extraAuthProps , extraAuthzProps } ) ; if ( client2Credentials == null ) { client2Credentials = tgen . getAllowedCredentials ( new OperationCode [ ] { OperationCode . PUT } , new String [ ] { regionName } , indices , rand ) ; } } int [ ] randomAvailableTCPPorts = AvailablePortHelper . getRandomAvailableTCPPorts ( 3 ) ; int port1 = randomAvailableTCPPorts [ 0 ] ; int port2 = randomAvailableTCPPorts [ 1 ] ; int locatorPort = randomAvailableTCPPorts [ 2 ] ; server1 . invoke ( null ) ; server2 . invoke ( null ) ; server1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; if ( keepAlive == null ) { client1 . invoke ( null ) ; } else { client1 . invoke ( null ) ; } server1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; if ( ! postAuthzAllowed [ 0 ] || keepAlive == null || ! keepAlive ) { Thread . sleep ( 1000 ) ; } else { client1 . invoke ( null ) ; } int numOfCreates = keepAlive == null ? 0 : ( keepAlive ? numOfPuts + 1 : 0 ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; client1 . invoke ( null ) ; server1 . invoke ( null ) ; if ( ! postAuthzAllowed [ 0 ] || keepAlive == null || ! keepAlive ) { Thread . sleep ( 1000 ) ; } else { client1 . invoke ( null ) ; } int numOfUpdates = numOfPuts + 1 ; client1 . invoke ( null ) ; }
warning : " final boolean keepalive " is treated as a ternary value : null , true , false
