package system-tests.scenario.single.clients.secureSearch.src.OK-tests.scenario.single.clients.searchLoad.src.OK;
|
// CDDL HEADER START
|
//
|
// The contents of this file are subject to the terms of the
|
// Common Development and Distribution License, Version 1.0 only
|
// (the "License"). You may not use this file except in compliance
|
// with the License.
|
//
|
// You can obtain a copy of the license at
|
// trunk/opends/resource/legal-notices/OpenDS.LICENSE
|
// or https://OpenDS.dev.java.net/OpenDS.LICENSE.
|
// See the License for the specific language governing permissions
|
// and limitations under the License.
|
//
|
// When distributing Covered Code, include this CDDL HEADER in each
|
// file and include the License file at
|
// trunk/opends/resource/legal-notices/OpenDS.LICENSE. If applicable,
|
// add the following below this CDDL HEADER, with the fields enclosed
|
// information:
|
// Portions Copyright [yyyy] [name of copyright owner]
|
//
|
// CDDL HEADER END
|
//
|
//
|
// Copyright 2008 Sun Microsystems, Inc.
|
import netscape.ldap.*;
|
import netscape.ldap.util.*;
|
|
import java.util.*;
|
import java.io.*;
|
import java.lang.Thread;
|
import javax.naming.*;
|
|
import javax.naming.directory.SearchControls;
|
import javax.naming.directory.DirContext;
|
import javax.naming.Context;
|
import javax.naming.directory.InitialDirContext;
|
|
|
public class Worker extends Thread {
|
|
Server server;
|
Client client;
|
|
public Worker (Client client, Server server) {
|
|
super();
|
try {
|
|
this.server = server;
|
this.client = client;
|
this.start();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
public void run () {
|
|
String value="";
|
String[] attributes = new String []{client.attr};
|
|
String provider = "ldap://"+server.host+":"+server.port+"/";
|
println ("INFO","provider = " + provider);
|
try {
|
|
Properties envLdap = System.getProperties();
|
envLdap.put("java.naming.factory.initial",
|
"com.sun.jndi.ldap.LdapCtxFactory");
|
|
envLdap.put(Context.PROVIDER_URL, provider);
|
envLdap.put(Context.SECURITY_AUTHENTICATION, "EXTERNAL");
|
envLdap.put(Context.SECURITY_PROTOCOL, "ssl");
|
|
while (true) {
|
|
DirContext ctx = null;
|
ctx = new InitialDirContext(envLdap);
|
|
|
String filter = "(objectclass=*)";
|
|
SearchControls constraints = new SearchControls();
|
|
Exception exc = null;
|
int count = 0;
|
|
|
// client.inc_srchs_started();
|
// value=(String) client.ValueList.get(client.random.nextInt(client.ValueList.size()));
|
NamingEnumeration results = ctx.search(client.suffix, filter, constraints);
|
|
|
try {
|
while (results != null && results.hasMore()) {
|
results.next();
|
println ("INFO " ," res " + results.toString());
|
count++;
|
}
|
|
} catch (Exception ex) {
|
exc = ex;
|
}
|
if ( exc != null ) {
|
throw exc;
|
}
|
// client.inc_srchs_done();
|
|
ctx.close();
|
}
|
} catch (Exception e) {
|
|
println ("INFO", "Failed: expected error code 3 ");
|
|
e.printStackTrace();
|
System.exit(1);
|
}
|
}
|
|
private String getDate() {
|
|
// Initialize the today's date string
|
String DATE_FORMAT = "yyyy/MM/dd:HH:mm:ss";
|
java.text.SimpleDateFormat sdf =
|
new java.text.SimpleDateFormat(DATE_FORMAT);
|
Calendar c1 = Calendar.getInstance(); // today
|
return("[" + sdf.format(c1.getTime()) + "]");
|
}
|
|
private void println(String level, String msg) {
|
System.out.println (getDate() + " - " + level + ": (" + server + ") " + msg );
|
}
|
|
}
|
