← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to tests/lib/dbqp_modes/randgen/randgen_test_execution.py

  • Committer: patrick crews
  • Date: 2011-10-05 20:40:33 UTC
  • mfrom: (2337.1.24 dbqp_revamp2)
  • mto: This revision was merged to the branch mainline in revision 2435.
  • Revision ID: gleebix@gmail.com-20111005204033-5m6kvcii1q87yur6
Merge with trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
tests/lib/dbqp_modes/randgen/randgen_test_execution.py
37
37
 
38
38
import lib.test_mgmt.test_execution as test_execution
39
39
 
40
 
class randgenTestExecutor(test_execution.testExecutor):
 
40
class testExecutor(test_execution.testExecutor):
41
41
    """ randgen-specific testExecutor 
42
42
 
43
43
    """
86
86
        randgen_output.close()
87
87
        randgen_file = open(randgen_outfile,'r')
88
88
        output = ''.join(randgen_file.readlines())
89
 
        if self.debug:
90
 
            self.logging.debug(output)
 
89
        self.logging.debug(output)
91
90
        randgen_file.close()
92
91
 
93
 
        if self.debug:
94
 
            self.logging.debug("randgen_retcode: %d" %(retcode))
 
92
        self.logging.debug("randgen_retcode: %d" %(retcode))
95
93
        self.current_test_retcode = retcode
96
94
        self.current_test_output = output
97
95
        self.current_test_exec_time = execution_time
104
102
        else:
105
103
            return 'fail'
106
104
 
107
 
    def handle_system_reqs(self):
108
 
        """ We check our test case and see what we need to do
109
 
            system-wise to get ready.  This is likely to be 
110
 
            mode-dependent and this is just a placeholder
111
 
            method
112
 
 
113
 
        """
114
 
 
115
 
        self.process_environment_reqs()
116
 
        self.process_symlink_reqs()
117
 
        self.process_master_sh()  
118
 
        return
119
 
 
120
 
    def process_master_sh(self):
121
 
        """ We do what we need to if we have a master.sh file """
122
 
        if self.current_testcase.master_sh:
123
 
            retcode, output = self.system_manager.execute_cmd("/bin/sh %s" %(self.current_testcase.master_sh))
124
 
            if self.debug:
125
 
                self.logging.info("retcode: %retcode")
126
 
                self.logging.info("%output")
127
 
 
128
 
    def process_environment_reqs(self):
129
 
        """ We generate the ENV vars we need set
130
 
            and then ask systemManager to do so
131
 
 
132
 
        """
133
 
        env_reqs = {  'DRIZZLETEST_VARDIR': self.master_server.vardir
134
 
                   ,  'DRIZZLE_TMP_DIR': self.master_server.tmpdir
135
 
                   ,  'MASTER_MYSOCK': self.master_server.socket_file
136
 
                   ,  'MASTER_MYPORT': str(self.master_server.master_port)
137
 
                   ,  'MC_PORT': str(self.master_server.mc_port)
138
 
                   ,  'PBMS_PORT': str(self.master_server.pbms_port)
139
 
                   ,  'RABBITMQ_NODE_PORT': str(self.master_server.rabbitmq_node_port)
140
 
                   ,  'DRIZZLE_TCP_PORT': str(self.master_server.drizzle_tcp_port)
141
 
                   ,  'EXE_DRIZZLE': self.master_server.drizzle_client
142
 
                   ,  'MASTER_SERVER_SLAVE_CONFIG' : self.master_server.slave_config_file
143
 
                   ,  'DRIZZLE_DUMP': "%s --no-defaults -uroot -p%d" %( self.master_server.drizzledump
144
 
                                                        , self.master_server.master_port)
145
 
                   ,  'DRIZZLE_SLAP': "%s -uroot -p%d" %( self.master_server.drizzleslap
146
 
                                                        , self.master_server.master_port)
147
 
                   ,  'DRIZZLE_IMPORT': "%s -uroot -p%d" %( self.master_server.drizzleimport
148
 
                                                          , self.master_server.master_port)
149
 
                   ,  'DRIZZLE': "%s -uroot -p%d" %( self.master_server.drizzle_client
150
 
                                                   , self.master_server.master_port)
151
 
                   ,  'DRIZZLE_BASEDIR' : self.system_manager.code_tree.basedir
152
 
                   ,  'DRIZZLE_TRX_READER' : self.system_manager.code_tree.drizzle_trx_reader
153
 
                   }     
154
 
 
155
 
 
156
 
        self.working_environment = self.system_manager.create_working_environment(env_reqs)
157
 
 
158
 
 
159
 
    def process_symlink_reqs(self):
160
 
        """ Create any symlinks we may need """
161
 
        needed_symlinks = []
162
 
 
163
 
        self.system_manager.create_symlinks(needed_symlinks)
164
 
 
165
 
    
166
 
   
167
 
 
168