<?xml version="1.0" encoding="UTF-8" standalone="no"?>
|
<!DOCTYPE stax SYSTEM "../../../../../shared/stax.dtd">
|
<!--
|
! 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
|
! by brackets "[]" replaced with your own identifying information:
|
! Portions Copyright [yyyy] [name of copyright owner]
|
!
|
! CDDL HEADER END
|
!
|
! Copyright 2008 Sun Microsystems, Inc.
|
! -->
|
<stax>
|
|
<defaultcall function="sampleSearchLoad"/>
|
|
|
<!-- ************************************************************ -->
|
<!-- Client is automatically called by the scheduler and must -->
|
<!-- always define all the parameters below -->
|
<function name="sampleSearchLoad" scope="local">
|
<function-map-args>
|
<function-arg-def name="workingDir" type="required"/>
|
<function-arg-def name="client" type="required"/>
|
<function-arg-def name="instances" type="required"/>
|
<function-arg-def name="duration" type="required"/>
|
<function-arg-def name="suffix" type="required"/>
|
<function-arg-def name="outFile" type="required"/>
|
<function-arg-def name="fileFd" type="required"/>
|
</function-map-args>
|
|
<sequence>
|
<!-- =================== Comments =================== -->
|
<!-- client is run under paralleliterate tag -->
|
<!-- each variables defined are internal -->
|
<!-- client should have its own err_num variable in order -->
|
<!-- to inform scheduler if it has pass/fail status -->
|
<script>
|
errNum = 0
|
msg = ''
|
</script>
|
|
<!-- ================== Preamble =================== -->
|
<!-- parse the client parameters : -->
|
<!-- params is [[param1,val1],[param2,val2],...] -->
|
<!-- get the ldap instance parameters -->
|
|
<script>
|
compilDir = '%s/%s_%s' % (workingDir,client.getHost(),client.getId())
|
|
#
|
# Extract client parameters from client.getParams()
|
#
|
cParams = client.getParams()
|
try:
|
serverInstanceFromClient = cParams[0][1]
|
except IndexError:
|
serverInstanceFromClient = NOT_DEFINED
|
msg = '%s\nERROR: serverInstanceFromClient undefined,mandatory' % msg
|
try:
|
baseDn = cParams[1][1]
|
except IndexError:
|
baseDn = NOT_DEFINED
|
msg = '%s\nERROR: baseDn undefined,mandatory' % msg
|
try:
|
nbCnx = cParams[2][1]
|
except IndexError:
|
nbCnx = NOT_DEFINED
|
msg = '%s\nERROR: nbCnx undefined,mandatory' % msg
|
try:
|
nbMaxSearch = cParams[3][1]
|
except IndexError:
|
nbMaxSearch = NOT_DEFINED
|
msg = '%s\nERROR: nbMaxOperations undefined,mandatory' % msg
|
try:
|
attributeName = cParams[4][1]
|
except IndexError:
|
attributeName = NOT_DEFINED
|
|
#
|
# setup parms to run the client
|
#
|
if serverInstanceFromClient != NOT_DEFINED:
|
sys.path.append("%s/phases/scheduler" % TESTS_DIR )
|
from scheduler import getInstance
|
serverInstance = getInstance(serverInstanceFromClient,instances)
|
if (serverInstance == 'ERROR'):
|
msg = '%s\nERROR: cant find client instance named' % msg
|
msg = '%s %s in server instance list' % \
|
(msg,serverInstanceFromClient)
|
|
else:
|
# remove sec, try to finish before timer kill -9 the client
|
duration = duration - 20
|
|
parms=[]
|
parms.append('-h %s -p %s' % \
|
(serverInstance.getHost(),serverInstance.getLDAPPort()))
|
parms.append('-b "%s"' % baseDn)
|
parms.append('-D "%s" -w "%s"' % \
|
(DIRECTORY_INSTANCE_DN,DIRECTORY_INSTANCE_PSWD))
|
parms.append('-t %s -M %s -d %s' % (nbCnx,nbMaxSearch,duration))
|
if attributeName != NOT_DEFINED:
|
parms.append('-a %s' % attributeName)
|
parms = ' '.join(parms)
|
</script>
|
|
<if expr="msg.find('ERROR') != -1">
|
<sequence>
|
<message>'%s' % msg</message>
|
<call function="'writeOperationResult'">
|
{
|
'returncode' : '1',
|
'expected' : '0',
|
'result' : msg,
|
'status' : 'ERROR',
|
'fileFd' : fileFd
|
}
|
</call>
|
<script>
|
errNum += 1
|
</script>
|
</sequence>
|
<else>
|
<sequence>
|
|
<!-- ==== Add execute permission to build.sh file ==== -->
|
<call function="'writeStartTagOperation'">
|
{ 'tagName' : 'chmod',
|
'fileFd' : fileFd }
|
</call>
|
<call function="'writeMessage'">
|
{'content' : 'Add execute permission to build.sh file',
|
'fileFd' : fileFd}
|
</call>
|
|
|
<process name="'%s: chmod +x build.sh' % client.getHost()">
|
<location>client.getHost()</location>
|
<command mode="'shell'">'chmod +x build.sh'</command>
|
<parms/>
|
<workdir>workingDir</workdir>
|
<envs>['PATH=/bin:/usr/bin']</envs>
|
<stderr mode="'stdout'"/>
|
<stdout/>
|
<returnstdout/>
|
</process>
|
<call function="'checkRC'">
|
{ 'returncode' : RC,
|
'result' : STAXResult[0][1],
|
'fileFd' : fileFd }
|
</call>
|
<script>
|
errNum += STAXResult
|
</script>
|
<call function="'writeEndTagOperation'">{'fileFd' : fileFd}</call>
|
|
<!-- ==== build client : run build.sh file ==== -->
|
<call function="'writeStartTagOperation'">
|
{ 'tagName' : 'build',
|
'fileFd' : fileFd }
|
</call>
|
<call function="'writeMessage'">
|
{'content' : 'Build client',
|
'fileFd' : fileFd}
|
</call>
|
|
|
<!-- Build Client in unique directory (compilDir), avoid -->
|
<!-- conflict if same client is run several time at the same time -->
|
<process name="'%s: build %s' % (client.getHost(),client.getName())">
|
<location>client.getHost()</location>
|
<command mode="'shell'">'./build.sh'</command>
|
<parms/>
|
<workdir>workingDir</workdir>
|
<envs>['PATH=%s/bin:/bin:/usr/bin' % JAVA_HOME,'COMPILDIR=%s' % compilDir]</envs>
|
<stderr mode="'stdout'"/>
|
<stdout/>
|
<returnstdout/>
|
</process>
|
<call function="'checkRC'">
|
{ 'returncode' : RC,
|
'result' : STAXResult[0][1],
|
'fileFd' : fileFd }
|
</call>
|
<if expr="RC != 0">
|
<message>
|
'FAILED to build client %s on %s' % \
|
(client.getName(),client.getHost())
|
</message>
|
</if>
|
<script>
|
errNum += STAXResult
|
</script>
|
<call function="'writeEndTagOperation'">{'fileFd' : fileFd}</call>
|
|
|
<!-- ========== Run the client ========== -->
|
<call function="'writeStartTagOperation'">
|
{ 'tagName' : 'run',
|
'fileFd' : fileFd }
|
</call>
|
<call function="'writeMessage'">
|
{ 'fileFd' : fileFd,
|
'content' : 'Do ldapsearchs on %s:%s' % \
|
(serverInstance.getHost(),serverInstance.getLDAPPort())
|
}
|
</call>
|
|
<script>
|
cParam = '-client -Xmx1G -Xms1G'
|
cParam = '%s -XX:NewRatio=1 -XX:SurvivorRatio=100' % cParam
|
cParam = '%s -cp %s/clients/LDAPjdk/ldapjdk.jar' % \
|
(cParam,LOCAL_TESTS_DIR)
|
cParam = '%s:%s/search.jar' % (cParam,compilDir)
|
cParam = '%s Client %s' % (cParam,parms)
|
|
titleName = '%s: run %s on %s' % \
|
(client.getHost(),client.getName(),
|
serverInstance.getName())
|
</script>
|
<process name="'%s' % titleName">
|
<location>client.getHost()</location>
|
<command>'%s/bin/java' % JAVA_HOME</command>
|
<parms>cParam </parms>
|
<workdir>workingDir</workdir>
|
<envs>['PATH=%s/bin:/bin:/usr/bin' % JAVA_HOME]</envs>
|
<stderr mode="'stdout'"/>
|
<stdout>outFile</stdout>
|
<returnstdout/>
|
</process>
|
<!-- TBD : result should be STAXResult[0][1] : problem when
|
javaexception, with carac " and < >-->
|
<call function="'checkRC'">
|
{ 'returncode' : RC ,
|
'result' : '',
|
'fileFd' : fileFd }
|
</call>
|
<script>
|
errNum += STAXResult
|
</script>
|
<call function="'writeEndTagOperation'">{'fileFd' : fileFd}</call>
|
|
<!-- ========== Postamble ========== -->
|
<call function="'writeMessage'">
|
{'content' : 'Output file %s' % outFile,
|
'xlink' : outFile,
|
'fileFd' : fileFd}
|
</call>
|
|
<process name="'%s:%s: Grep' % (client.getHost(),client.getName())">
|
<location>client.getHost()</location>
|
<command mode="'shell'">
|
"grep 'TOTAL' %s | cut -d ' ' -f3-" % outFile
|
</command>
|
<envs>['PATH=/bin:/usr/bin']</envs>
|
<stderr mode="'stdout'"/>
|
<stdout/>
|
<returnstdout/>
|
</process>
|
<script>
|
summary = STAXResult[0][1]
|
</script>
|
<call function="'writeMessage'">
|
{'content' : 'Summary %s' % (summary),
|
'fileFd' : fileFd}
|
</call>
|
|
</sequence>
|
</else>
|
</if>
|
|
<return> errNum </return>
|
|
</sequence>
|
|
</function>
|
|
|
|
</stax>
|
