mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

andrug
06.28.2008 2d19af24b1bc5d0c2f6625d17c16a5f138da5c8f
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
<?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="verdictOpends"/>
 
 
  <!-- ************************************************************ -->
  <!-- Client is automatically called by the scheduler and must     -->
  <!-- always define all the parameters below                       -->
  <function name="verdictOpends" 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       -->
      <!-- nb of failed is still managed by ERR_NUM[0]          -->
      <script>
        errNum   = STAXGlobal(0)
        fileList = STAXGlobal([])
      </script>
      
      <!--== Get the list of opends instances in the topology == -->
      <call function="'getOpendsInstancesInATopology'">
        { 'suffix' : suffix }
      </call>
      <script>
        opendsInstances = STAXResult
      </script>
      <paralleliterate in="opendsInstances" var="instance">
        <sequence>
          <!-- parallel process, all variables defined        -->
          <!-- and values set below are local to the sequence -->
          <call function="'getLogFileName'">
            { 'type'   : 'instance',
              'object' : instance,
              'prefix' : '%s_id%s' % (client.getName(),client.getId())
            }
          </call>
          <script>
            logFile = STAXResult
            
            fileList.append(logFile)
            
            cFileFd = open(logFile,'w')
          </script>
          <call function="'writeStartTagInstance'">
          {
            'instance'  : instance,
            'fileFd'    : cFileFd
          }
          </call>
          
          <import machine="'%s' % (STAF_LOCAL_HOSTNAME)"
           file="'%s/phases/shared/functions/opendstools.xml' % TESTS_DIR"/>
          <call function="'verdict4OpendsInstance'">
          {
            'instance'  : instance,
            'instances' : opendsInstances,
            'suffix'    : suffix,
            'fileFd'    : cFileFd
          }
          </call>
          <script>
            errNum += STAXResult
          </script>
          
          <call function="'writeEndTagInstance'">
            {'fileFd' : cFileFd}
          </call>
          <script>
            cFileFd.close()
          </script>
        </sequence>
      </paralleliterate>
      
      <!--==========  Merge files    ==========-->
      <call function="'mergeFiles'">
        {
          'fileList' : fileList,
          'fileFd'   : fileFd
        }
      </call>
      
      <return> errNum </return>
    </sequence>
  </function>
  
  
  
</stax>