55     def __init__(self):  argument
56         threading.Thread.__init__(self)
58         self.tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
59         self.tcp_server_socket.bind((self.IP, self.PORT))
60         self.tcp_server_socket.listen(128)
62         self.config = self.read_data_from_json(self.config_file_name)
63         self.test_group_index = 0
66     def send_message(self, conn, info):  argument
72     def init_data(self):  argument
73         self.test_case_index = 0
74         self.test_case = self.config['testGroup'][self.test_group_index]['test_case']
75         self.test_case_dir = self.config['testGroup'][self.test_group_index]['test_case_dir']
77         if len(self.config['testGroup'][self.test_group_index]['test_case']) <= 0:
78 …self.test_case = self.traverasl_files(self.config['testGroup'][self.test_group_index]['test_case_d…
79             print(self.test_case)
82     def tcp_connect(self, conn, addr):  argument
86         self.init_data()
87         self.start_test(conn)
92             if data == self.C_S_MAIN_ID_REQUEST_TEST_INFO:
94                 self.test_case_index = 0
95                 self.send_test_info(conn)
96             elif data == self.C_S_MAIN_ID_TEST_FINISH_INFO:
97                 self.test_case_index += 1
98                 self.send_test_info(conn)
101     def send_all_test_finish(self, conn):  argument
102         send_config =  {'main_id':self.S_C_MAIN_ID_All_TESTS_COMPLETE}
103         self.send_message(conn, send_config)
105         self.test_group_index += 1
106         if self.test_group_index >= len(self.config['testGroup']):
107             self.test_group_index = 0
110         print("send_all_test_finish------test_group_index=", self.test_group_index,\
111                 "------len=", len(self.config['testGroup']))
112         self.start_client_process()
115     def send_test_info(self, conn):  argument
116         if len(self.test_case):
117             if self.test_case_index < len(self.test_case):
118 …json_data = self.read_data_from_json(self.test_case_dir + '/' + self.test_case[self.test_case_inde…
119                 json_data['main_id'] = self.S_C_MAIN_ID_SEND_TEST_INFO
121                 self.send_message(conn, json_data)
123                 self.send_all_test_finish(conn)
126     def start_test(self, conn):  argument
127         send_config = self.config['testGroup'][self.test_group_index]
133         if test_mode == self.TestModeBase:
134             self.clear_directory(base_dir)
135         elif test_mode == self.TestModeRun:
136             self.clear_directory(run_dir)
138         send_config =  {'main_id': self.S_C_MAIN_ID_SEND_CONFIG_INFO,\
144         self.send_message(conn, send_config)
147     def read_data_from_json(self, filename):  argument
154     def start_client_process(self):  argument
156         process_dir = self.config['testGroup'][self.test_group_index]['process_dir']
157         process_name = self.config['testGroup'][self.test_group_index]['process_name']
165     def traverasl_files(self, path):  argument
166         self.filelist = []
170                 self.filelist.append(entry.name)
172         return self.filelist
175     def clear_directory(self, filepath):  argument
183     def run(self):  argument
186             conn, addr = self.tcp_server_socket.accept()
188             thread_recv = threading.Thread(target=self.tcp_connect, args=(conn, addr))
191         self.tcp_server_socket.close()