client supports starttls

smaguin

24.44.2008 a94eff9bd079b85a96fd15bf7336c762c948e769

client supports starttls

 opends/tests/system-tests/scenario/singleServer/clients/secureSearch/src/Client.java

@@ -27,11 +27,15 @@
import java.io.*;
import java.lang.Thread;
import javax.naming.*;
import javax.naming.directory.InitialDirContext;
//import javax.naming.directory.InitialDirContext;
import javax.naming.directory.SearchControls;
import javax.naming.directory.DirContext;
//import javax.naming.directory.DirContext;
import javax.naming.directory.SearchResult;
import javax.naming.directory.Attributes;
import javax.naming.ldap.*;
import javax.naming.ldap.StartTlsResponse;
import javax.naming.ldap.StartTlsRequest;
import javax.net.ssl.*;

public class Client {
    
@@ -61,6 +65,7 @@
    static ArrayList<String> uidList;
    static long delayCnx=1000;
    static long delaySec=1;    
    static long delayPrint=60000;
    
    public Client()
    {
@@ -72,8 +77,8 @@

            Hashtable envLdap = set_properties_LDAP_simpleBind();
            
        DirContext ctx = null;
            ctx = new InitialDirContext(envLdap);
        LdapContext ctx = null;
            ctx = new InitialLdapContext(envLdap,null);

        // Search options
        String filter = "(objectclass=inetorgperson)";
@@ -145,12 +150,13 @@

            int seconds=0;
            long t1=System.currentTimeMillis();
            long print_t1=System.currentTimeMillis();

        // work until Max duration is reached
            while (true) {

                long new_t1=System.currentTimeMillis();

                long print_t2=System.currentTimeMillis(); 
        // end of the  system test. Exit
                if ( ( timeTostopTest != 0 ) && ( new_t1 > timeTostopTest ) ) { 
                  
@@ -161,10 +167,25 @@
                  break; 
                }
               
                   // status every delayPrint
                 if ( (print_t2 - print_t1) >= delayPrint ) {
                        duration=((print_t2-print_t1)/1000);
                        println("INFO",  "Rate: " + (total_nb_srchs/duration) + " srchs/sec");
                        print_t1=System.currentTimeMillis();
                        try {
                          synchronized(this) {
                            total_nb_srchs=0;
                          }
                        } catch ( Exception e2 ) {
                          System.out.println("E2");
                          e2.printStackTrace();
                        }
                 }  
                
        // status every second
                if ( (new_t1 - t1) >= delayCnx ) {
                 
                    println("INFO",  (nb_srchs_done/delaySec) + "  srch/sec.");                 
                 //   println("INFO",  (nb_srchs_done/delaySec) + "  srch/sec.");                 
              
            // inform all the threads the max nb searchs has been reached
            synchronized (this) {
@@ -191,11 +212,6 @@
            e1.printStackTrace();
            }

                    if ( (seconds++) >= 9 ) {
                        duration=((new_t1-startup)/1000);
                        println("INFO",  "Avg rate: " + (total_nb_srchs/duration) + " srchs/sec. after " + getTime(duration));
                        seconds=0;
                    }
                    t1=new_t1;
                }
            }
@@ -233,32 +249,32 @@

    // BaseDN
    suffix = System.getProperty("suffix"); 
    println ("INFO" , "suffix " + suffix);
    println ("INFO" , "CONFIG suffix " + suffix);
    
    // nb_threads
    String snb_threads = System.getProperty("nb_threads"); 
    nb_threads = Integer.parseInt(snb_threads);
    
    println ("INFO" , "nb_threads " + snb_threads);
    println ("INFO" , "CONFIG nb_threads " + snb_threads);
    
    // test duration
    String sMaxDuration = System.getProperty("maxDuration"); 
    maxDuration = Long.parseLong(sMaxDuration);
    println ("INFO" , "maxDuration " + maxDuration);
    println ("INFO" , "CONFIG maxDuration " + maxDuration);
        
    // credential for simple bind
    bindDN = System.getProperty("bindDN"); 
    bindPW = System.getProperty("bindPW"); 
    println ("INFO" , "bindDN " + bindDN);
    println ("INFO" , "CONFIG bindDN " + bindDN);
    
    // attribute to search 
    attributeName = System.getProperty("attributeName");
    println ("INFO" , "attributeName " + attributeName);        
    println ("INFO" , "CONFIG attributeName " + attributeName);        
        
    // Max number of searchs
    String sNB_MAX_srchs = System.getProperty("NB_MAX_srchs"); 
    NB_MAX_srchs = Integer.parseInt(sNB_MAX_srchs);
    println ("INFO" , "sNB_MAX_srchs " + sNB_MAX_srchs);
    println ("INFO" , "CONFIG sNB_MAX_srchs " + sNB_MAX_srchs);
    
    // hostname
    hostname = System.getProperty("hostname");
@@ -266,17 +282,17 @@

    // protocol : SSL or TLS
    protocol = System.getProperty("protocol");
    println ("INFO" , "protocol " + protocol);        
    println ("INFO" , "CONFIG protocol " + protocol);        
        
        // authentication : EXTERNAL or simple
    authentication = System.getProperty("authentication");
    println ("INFO" , "authentication " + authentication);    
    println ("INFO" , "CONFIG authentication " + authentication);    

        // delay Sec  before closing conx
        String sdelaySec = System.getProperty("delaySec"); 
    delaySec =  Long.parseLong(sdelaySec);
        delayCnx = delaySec * 1000;
    println ("INFO" , "delayCnx " + delayCnx);
    println ("INFO" , "CONFIG delayCnx " + delayCnx);
        

        if ( maxDuration != 0 ) {
@@ -384,7 +400,9 @@
     envLdap.put("java.naming.factory.initial",
      "com.sun.jndi.ldap.LdapCtxFactory");
     
     if ( ! protocol.equals("starttls")) {
     envLdap.put(Context.SECURITY_AUTHENTICATION, authentication);
     }
     
     if ( protocol.equals("ssl")) {
       provider = "ldaps://"+server.host+":"+server.port+"/";

 opends/tests/system-tests/scenario/singleServer/clients/secureSearch/src/Worker.java

@@ -32,10 +32,13 @@
import javax.naming.directory.SearchResult;
import javax.naming.directory.Attributes;
import javax.naming.directory.Attribute;
import javax.naming.directory.DirContext;
//import javax.naming.directory.DirContext;
import javax.naming.Context;
import javax.naming.directory.InitialDirContext;

//import javax.naming.directory.InitialDirContext;
import javax.naming.ldap.*;
import javax.naming.ldap.StartTlsResponse;
import javax.naming.ldap.StartTlsRequest;
import javax.net.ssl.*;

public class Worker extends Thread {
  
@@ -64,7 +67,8 @@

    try {
      
      DirContext ctx = null;
     LdapContext ctx = null; 
     StartTlsResponse tls = null;
      
      // Set the properties 
     Hashtable envLdap = client.set_properties_LDAP();
@@ -88,7 +92,16 @@
         
        }
        // bind
        ctx = new InitialDirContext(envLdap);
        ctx = new InitialLdapContext(envLdap,null);
   
        if ( client.protocol.equals("starttls")) {
          // Start TLS
          tls = (StartTlsResponse) ctx.extendedOperation(new StartTlsRequest());
          SSLSession sess = tls.negotiate();
   
          ctx.addToEnvironment(Context.SECURITY_AUTHENTICATION, client.authentication);
          
        }
        
        
        //String filter = "(objectclass=*)";
@@ -119,6 +132,9 @@
              
              client.inc_srchs_done();
            } else {
              if ( client.protocol.equals("starttls")) {
                tls.close();
              }
              ctx.close();
              client.thread_go_to_sleep();
              break;