ConnectTest.py
Go to the documentation of this file.
1 #!/usr/bin/env python
2 # -*- coding: utf-8 -*-
3 # -*- Python -*-
4 
5 #
6 ## ConnectTest.py
7 
10 
11 from rtc_handle10_11 import *
12 from BasicDataType_idl import *
13 import time
14 import commands
15 import SDOPackage
16 import os
17 import sys
18 
19 ##--------------------------------------------------------------------
20 g_test_name = "<< component connection test >>"
21 
22 ## ネームサーバー定義
23 #env = RtmEnv(sys.argv, ["localhost:2809"])
24 #list0 = env.name_space["localhost:2809"].list_obj()
25 #env.name_space['localhost:2809'].rtc_handles.keys()
26 #ns = env.name_space['localhost:2809']
27 env = RtmEnv(sys.argv, ["localhost:2809"])
28 list0 = env.name_space["localhost:2809"].list_obj()
29 env.name_space['localhost:2809'].rtc_handles.keys()
30 ns = env.name_space['localhost:2809']
31 
32 g_compo_send = ns.rtc_handles["AutoTestOut0.rtc"]
33 g_compo_recv = ns.rtc_handles["AutoTestIn0.rtc"]
34 
35 ec_send = g_compo_send.rtc_ref.get_owned_contexts()
36 ec_recv = g_compo_recv.rtc_ref.get_owned_contexts()
37 
38 g_out_ports = g_compo_send.rtc_ref.get_ports()
39 g_in_ports = g_compo_recv.rtc_ref.get_ports()
40 #print "<<< g_out_ports.length=",len(g_out_ports)
41 #SeqOutの場合
42 #length=8 [0]:Short [1]:Long [2]:Float [3]:Double [4]:ShortSeq [5]:LongSeq [6]:FloatSeq [7]:DoubleSeq
43 #print "<<< g_in_ports.length=",len(g_in_ports)
44 
45 time.sleep(2)
46 
47 ##--------------------------------------------------------------------
48 ## コネクタープロファイルデフォルト定義
49 g_interface_type1 = "corba_cdr"
50 g_dataflow_type = "push"
51 g_subscription_type = "flush"
52 g_push_policy = "NEW"
53 g_push_rate = "2000"
54 g_skip_count = "4"
55 #g_skip_count = "0"
56 
57 ## ポート番号指定 ( get_ports()より )
58 g_port1 = 0
59 g_port2 = 1
60 g_port3 = 2
61 
62 ## ConnectorProfile(name, connector_id, ports, properties)
63 ## String name
64 ## String connector_id
65 ## RTC.PortService ports[]
66 ## SDOPackage.NameValue properties[]
67 
68 ## データポート TimedFloat
69 g_name1 = "out"
70 g_connector_id1 = "001"
71 g_data_type1 = "TimedFloat"
72 
73 g_conprof1 = RTC.ConnectorProfile(g_name1, g_connector_id1, [g_out_ports[g_port1], g_in_ports[g_port1]], [SDOPackage.NameValue("dataport.data_type",any.to_any(g_data_type1)),SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type1)),SDOPackage.NameValue("dataport.dataflow_type",any.to_any(g_dataflow_type)),SDOPackage.NameValue("dataport.subscription_type",any.to_any(g_subscription_type)),SDOPackage.NameValue("dataport.publisher.push_policy",any.to_any(g_push_policy)),SDOPackage.NameValue("dataport.publisher.push_rate",any.to_any(g_push_rate)),SDOPackage.NameValue("dataport.publisher.skip_count",any.to_any(g_skip_count))])
74 
75 ## データポート TimedFloatSeq
76 g_name2 = "seqout"
77 g_connector_id2 = "002"
78 g_data_type2 = "TimedFloatSeq"
79 
80 g_conprof2 = RTC.ConnectorProfile(g_name2, g_connector_id2, [g_out_ports[g_port2], g_in_ports[g_port2]], [SDOPackage.NameValue("dataport.data_type",any.to_any(g_data_type2)),SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type1)),SDOPackage.NameValue("dataport.dataflow_type",any.to_any(g_dataflow_type)),SDOPackage.NameValue("dataport.subscription_type",any.to_any(g_subscription_type)),SDOPackage.NameValue("dataport.publisher.push_policy",any.to_any(g_push_policy)),SDOPackage.NameValue("dataport.publisher.push_rate",any.to_any(g_push_rate)),SDOPackage.NameValue("dataport.publisher.skip_count",any.to_any(g_skip_count))])
81 
82 ## サービスポート
83 g_name3 = "MyService"
84 g_connector_id3 = "003"
85 g_interface_type3 = "MyService"
86 
87 g_conprof3 = RTC.ConnectorProfile(g_name3, g_connector_id3, [g_out_ports[g_port3], g_in_ports[g_port3]], [SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type3))])
88 
89 ##--------------------------------------------------------------------
90 ## 送受信結果判定関連
91 g_diff_send_file = "./original-data"
92 g_diff_recv_file = "./received-data"
93 g_check_message = g_diff_recv_file + " file not found."
94 g_test_result_file = "./ResultTest.log"
95 g_test_case = "case"
96 g_test_cnt = "count"
97 g_test_ok = "OK."
98 g_test_ng = "NG detected."
99 g_test_ng_message = " < received-data >"
100 g_mess_header = "< "
101 g_mess_footer = " > "
102 # テスト結果内容
103 # 例)ケース1、1回目 -> "<<< case1 count1 >>> OK."
104 # 例)ケース1、2回目 -> "<<< case1 count2 >>> NG detected."
105 
106 ##--------------------------------------------------------------------
107 ## 内部関数：コネクタープロファイル設定(データポート)
108 
114 def make_connecter_profile(subscription_type, push_policy, connect_direction):
115  global g_conprof1, g_conprof2, g_conprof3
116 
117  if connect_direction == 0:
118  ## outport -> inport Set
119  g_conprof1 = RTC.ConnectorProfile(g_name1, g_connector_id1, [g_out_ports[g_port1], g_in_ports[g_port1]], [SDOPackage.NameValue("dataport.data_type",any.to_any(g_data_type1)),SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type1)),SDOPackage.NameValue("dataport.dataflow_type",any.to_any(g_dataflow_type)),SDOPackage.NameValue("dataport.subscription_type",any.to_any(subscription_type)),SDOPackage.NameValue("dataport.publisher.push_policy",any.to_any(push_policy)),SDOPackage.NameValue("dataport.publisher.push_rate",any.to_any(g_push_rate)),SDOPackage.NameValue("dataport.publisher.skip_count",any.to_any(g_skip_count))])
120 
121  g_conprof2 = RTC.ConnectorProfile(g_name2, g_connector_id2, [g_out_ports[g_port2], g_in_ports[g_port2]], [SDOPackage.NameValue("dataport.data_type",any.to_any(g_data_type2)),SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type1)),SDOPackage.NameValue("dataport.dataflow_type",any.to_any(g_dataflow_type)),SDOPackage.NameValue("dataport.subscription_type",any.to_any(subscription_type)),SDOPackage.NameValue("dataport.publisher.push_policy",any.to_any(push_policy)),SDOPackage.NameValue("dataport.publisher.push_rate",any.to_any(g_push_rate)),SDOPackage.NameValue("dataport.publisher.skip_count",any.to_any(g_skip_count))])
122 
123  #print "outport -> inport set >>>"
124  #print "g_conprof1=",g_conprof1
125  #print "g_conprof2=",g_conprof2
126  else:
127  ## inport -> outport Set
128  g_conprof1 = RTC.ConnectorProfile(g_name1, g_connector_id1, [g_in_ports[g_port1], g_out_ports[g_port1]], [SDOPackage.NameValue("dataport.data_type",any.to_any(g_data_type1)),SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type1)),SDOPackage.NameValue("dataport.dataflow_type",any.to_any(g_dataflow_type)),SDOPackage.NameValue("dataport.subscription_type",any.to_any(subscription_type)),SDOPackage.NameValue("dataport.publisher.push_policy",any.to_any(push_policy)),SDOPackage.NameValue("dataport.publisher.push_rate",any.to_any(g_push_rate)),SDOPackage.NameValue("dataport.publisher.skip_count",any.to_any(g_skip_count))])
129 
130  g_conprof2 = RTC.ConnectorProfile(g_name2, g_connector_id2, [g_in_ports[g_port2], g_out_ports[g_port2]], [SDOPackage.NameValue("dataport.data_type",any.to_any(g_data_type2)),SDOPackage.NameValue("dataport.interface_type",any.to_any(g_interface_type1)),SDOPackage.NameValue("dataport.dataflow_type",any.to_any(g_dataflow_type)),SDOPackage.NameValue("dataport.subscription_type",any.to_any(subscription_type)),SDOPackage.NameValue("dataport.publisher.push_policy",any.to_any(push_policy)),SDOPackage.NameValue("dataport.publisher.push_rate",any.to_any(g_push_rate)),SDOPackage.NameValue("dataport.publisher.skip_count",any.to_any(g_skip_count))])
131 
132  #print "inport -> outport set >>>"
133  #print "g_conprof1=",g_conprof1
134  #print "g_conprof2=",g_conprof2
135  return
136 
137 
138 ##--------------------------------------------------------------------
139 ## 内部関数：受信ファイル削除
140 
144 def delete_recv_file():
145  ## ファイルが存在する場合
146  if os.path.isfile(g_diff_recv_file) == True:
147  os.remove(g_diff_recv_file)
148  return
149 
150 
151 ##--------------------------------------------------------------------
152 ## 内部関数：送受信ファイルのデータ比較
153 
158 def diff_file():
159  bret = True
160 
161  ## if connect_direction == 0:
162  ## else:
163  ## 送信ファイル有無判定
164  if os.path.isfile(g_diff_send_file) == False:
165  print "send_file (%s) not found." % send_file
166  return False
167 
168  ## 受信ファイル有無判定
169  if os.path.isfile(g_diff_recv_file) == False:
170  print "recv_file (%s) not found." % recv_file
171  return False
172 
173  ## 送受信データ差分判定
174  f_send = open(g_diff_send_file, 'r')
175  f_recv = open(g_diff_recv_file, 'r')
176 
177  while(1):
178  str_send = f_send.readline()
179  str_recv = f_recv.readline()
180  if len(str_send) == 0:
181  break
182 
183  #print "original send date=(%s)" % str_send
184  #print ''.join(['%x ' % ord(s) for s in str_send])
185  #print "original recv date=(%s)" % str_recv
186  #print ''.join(['%x ' % ord(s) for s in str_recv])
187 
188  ## 末尾の改行、復帰コード削除
189  str_send2 = str_send.rstrip('\n')
190  str_send2 = str_send2.rstrip('\r')
191  str_recv2 = str_recv.rstrip('\n')
192  str_recv2 = str_recv2.rstrip('\r')
193 
194  #print "rstrip after send date=(%s)" % str_send2
195  #print "rstrip after recv date=(%s)" % str_recv2
196 
197  ## データ比較
198  if str_send2 != str_recv2:
199  #print "data difference"
200  #print "send date=(%s)" % str_send2
201  #print "recv date=(%s)" % str_recv2
202  bret = False
203  break;
204 
205  f_recv.close()
206  f_send.close()
207  return bret
208 
209 ##--------------------------------------------------------------------
210 ## テストケース番号の初期値設定
211 ## 上から連番を振っている
212 case_no = 0
213 
214 ## ケース毎のテスト回数
215 loop_count = 3
216 
217 ## 受信側activate_componentから送信側activate_componentまでのスリープ時間(秒数)
218 sleep_recv_act_time = 1
219 
220 ## activate_componentからdeactivate_componentまでのスリープ時間(秒数)
221 sleep_act_time = 10
222 
223 ## forループのスリープ時間(秒数)
224 sleep_for_time = 2
225 
226 ## connectからdisconnectまでのスリープ時間(秒数)
227 sleep_connect_time = 2
228 
229 # テスト結果ファイルの作成
230 fout = open(g_test_result_file, 'w')
231 fout.write(g_test_name + '\n')
232 fout.close()
233 #print g_test_name
234 
235 time.sleep(1)
236 
237 ##--------------------------------------------------------------------
238 ## 接続タイプ：flush 方向：out->in 接続・切断テスト2
239 ##--------------------------------------------------------------------
240 case_no = case_no + 1
241 fout = open(g_test_result_file, 'a')
242 message = g_mess_header + g_test_case + str(case_no) + " "
243 message = message + "Connect(out->in, flush) -> Disconnect"
244 message = message + g_mess_footer
245 fout.write(message + '\n')
246 fout.close()
247 print message
248 
249 for i in range(loop_count):
250 
251  ## 1 コネクタープロファイル設定
252  make_connecter_profile("flush", "", 0)
253 
254  ## 3 ポート接続
255  # データポート1 TimedFloat
256  ret0 = g_out_ports[g_port1].connect(g_conprof1)
257 
258  # データポート2 TimedFloatSeq
259  ret1 = g_out_ports[g_port2].connect(g_conprof2)
260 
261  # サービスポート MyService
262  ret2 = g_out_ports[g_port3].connect(g_conprof3)
263 
264  time.sleep(sleep_connect_time)
265 
266  ## 6 ポート切断
267  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
268  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
269  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
270 
271  ## テスト結果出力
272  fout = open(g_test_result_file, 'a')
273  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
274  message = message + g_test_ok
275  print message
276  fout.write(message + '\n')
277  fout.close()
278 
279  time.sleep(sleep_for_time)
280 
281 ##--------------------------------------------------------------------
282 ## 接続タイプ：flush 方向：in->out 接続・切断テスト1
283 ##--------------------------------------------------------------------
284 case_no = case_no + 1
285 fout = open(g_test_result_file, 'a')
286 message = g_mess_header + g_test_case + str(case_no) + " "
287 message = message + "Connect(in->out, flush) -> Disconnect"
288 message = message + g_mess_footer
289 fout.write(message + '\n')
290 fout.close()
291 print message
292 
293 for i in range(loop_count):
294 
295  ## 1 コネクタープロファイル設定
296  make_connecter_profile("flush", "", 1)
297 
298  ## 3 ポート接続
299  # データポート1 TimedFloat
300  ret0 = g_out_ports[g_port1].connect(g_conprof1)
301 
302  # データポート2 TimedFloatSeq
303  ret1 = g_out_ports[g_port2].connect(g_conprof2)
304 
305  # サービスポート MyService
306  ret2 = g_out_ports[g_port3].connect(g_conprof3)
307 
308  time.sleep(sleep_connect_time)
309 
310  ## 6 ポート切断
311  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
312  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
313  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
314 
315  ## テスト結果出力
316  fout = open(g_test_result_file, 'a')
317  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
318  message = message + g_test_ok
319  print message
320  fout.write(message + '\n')
321  fout.close()
322 
323  time.sleep(sleep_for_time)
324 
325 ##--------------------------------------------------------------------
326 ## 接続タイプ：flush 方向：out->in Activate・Deactivateテスト1
327 ##--------------------------------------------------------------------
328 case_no = case_no + 1
329 fout = open(g_test_result_file, 'a')
330 message = g_mess_header + g_test_case + str(case_no) + " "
331 message = message + "Connecting(out->in, flush), Activate -> send/recv -> Deactivate"
332 message = message + g_mess_footer
333 fout.write(message + '\n')
334 fout.close()
335 print message
336 
337 ## 1 コネクタープロファイル設定
338 make_connecter_profile("flush", "", 0)
339 
340 ## 3 ポート接続
341 # データポート1 TimedFloat
342 ret0 = g_out_ports[g_port1].connect(g_conprof1)
343 
344 # データポート2 TimedFloatSeq
345 ret1 = g_out_ports[g_port2].connect(g_conprof2)
346 
347 # サービスポート MyService
348 ret2 = g_out_ports[g_port3].connect(g_conprof3)
349 
350 for i in range(loop_count):
351 
352  ## 2 受信データファイル削除
353  delete_recv_file()
354 
355  ## 4 アクティベート
356  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
357  time.sleep(sleep_recv_act_time)
358  ec_send[0].activate_component(g_compo_send.rtc_ref)
359 
360  time.sleep(sleep_act_time)
361 
362  ## 5 ディアクティベート
363  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
364  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
365 
366  ## 受信ファイル有無判定
367  if os.path.isfile(g_diff_recv_file) == False:
368  fout = open(g_test_result_file, 'a')
369  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
370  message = message + g_check_message
371  fout.write(message + '\n')
372  fout.close()
373  print message
374  time.sleep(sleep_for_time)
375  continue
376 
377  ## 7 送受信データ比較
378  time.sleep(sleep_act_time)
379  bret = diff_file()
380 
381  ## 差分ファイルからテスト結果出力
382  fout = open(g_test_result_file, 'a')
383  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
384  # bret==True なら送受信データ一致
385  if bret == True:
386  # テスト結果 OK
387  message = message + g_test_ok
388  print message
389  fout.write(message + '\n')
390  else:
391  # テスト結果 NG
392  message = message + g_test_ng
393  print message
394  message = message + g_test_ng_message
395  fout.write(message + '\n')
396  # 受信データをテスト結果ファイルへコピー
397  fin2 = open(g_diff_recv_file, 'r')
398  while(1):
399  s2 = fin2.readline()
400  if len(s2) == 0:
401  break
402  fout.write(s2)
403  fin2.close()
404  fout.close()
405 
406  time.sleep(sleep_for_time)
407 
408 ## 6 ポート切断
409 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
410 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
411 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
412 
413 ##--------------------------------------------------------------------
414 ## 接続タイプ：flush 方向：in->out Activate・Deactivateテスト1
415 ##--------------------------------------------------------------------
416 case_no = case_no + 1
417 fout = open(g_test_result_file, 'a')
418 message = g_mess_header + g_test_case + str(case_no) + " "
419 message = message + "Connecting(in->out, flush), Activate -> send/recv -> Deactivate"
420 message = message + g_mess_footer
421 fout.write(message + '\n')
422 fout.close()
423 print message
424 
425 ## 1 コネクタープロファイル設定
426 make_connecter_profile("flush", "", 1)
427 
428 ## 3 ポート接続
429 # データポート1 TimedFloat
430 ret0 = g_out_ports[g_port1].connect(g_conprof1)
431 
432 # データポート2 TimedFloatSeq
433 ret1 = g_out_ports[g_port2].connect(g_conprof2)
434 
435 # サービスポート MyService
436 ret2 = g_out_ports[g_port3].connect(g_conprof3)
437 
438 for i in range(loop_count):
439 
440  ## 2 受信データファイル削除
441  delete_recv_file()
442 
443  ## 4 アクティベート
444  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
445  time.sleep(sleep_recv_act_time)
446  ec_send[0].activate_component(g_compo_send.rtc_ref)
447 
448  time.sleep(sleep_act_time)
449 
450  ## 5 ディアクティベート
451  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
452  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
453 
454  ## 受信ファイル有無判定
455  if os.path.isfile(g_diff_recv_file) == False:
456  fout = open(g_test_result_file, 'a')
457  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
458  message = message + g_check_message
459  fout.write(message + '\n')
460  fout.close()
461  print message
462  time.sleep(sleep_for_time)
463  continue
464 
465  ## 7 送受信データ比較
466  time.sleep(sleep_act_time)
467  bret = diff_file()
468 
469  ## 差分ファイルからテスト結果出力
470  fout = open(g_test_result_file, 'a')
471  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
472  # bret==True なら送受信データ一致
473  if bret == True:
474  # テスト結果 OK
475  message = message + g_test_ok
476  print message
477  fout.write(message + '\n')
478  else:
479  # テスト結果 NG
480  message = message + g_test_ng
481  print message
482  message = message + g_test_ng_message
483  fout.write(message + '\n')
484  # 受信データをテスト結果ファイルへコピー
485  fin2 = open(g_diff_recv_file, 'r')
486  while(1):
487  s2 = fin2.readline()
488  if len(s2) == 0:
489  break
490  fout.write(s2)
491  fin2.close()
492  fout.close()
493 
494  time.sleep(sleep_for_time)
495 
496 ## 6 ポート切断
497 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
498 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
499 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
500 
501 ##--------------------------------------------------------------------
502 ## 接続タイプ：flush 方向：out->in Activate・Deactivateテスト10
503 ##--------------------------------------------------------------------
504 case_no = case_no + 1
505 fout = open(g_test_result_file, 'a')
506 message = g_mess_header + g_test_case + str(case_no) + " "
507 message = message + "Not Connect(out->in, flush), Activate -> Deactivate"
508 message = message + g_mess_footer
509 fout.write(message + '\n')
510 fout.close()
511 print message
512 
513 for i in range(loop_count):
514 
515  ## 1 コネクタープロファイル設定
516  make_connecter_profile("flush", "", 0)
517 
518  ## 4 アクティベート
519  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
520  time.sleep(sleep_recv_act_time)
521  ec_send[0].activate_component(g_compo_send.rtc_ref)
522 
523  time.sleep(sleep_act_time)
524 
525  ## 5 ディアクティベート
526  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
527  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
528 
529  ## テスト結果出力
530  fout = open(g_test_result_file, 'a')
531  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
532  message = message + g_test_ok
533  print message
534  fout.write(message + '\n')
535  fout.close()
536 
537  time.sleep(sleep_for_time)
538 
539 ##--------------------------------------------------------------------
540 ## 接続タイプ：flush 方向：out->in 接続・切断・Activate・Deactivateテスト1
541 ##--------------------------------------------------------------------
542 case_no = case_no + 1
543 fout = open(g_test_result_file, 'a')
544 message = g_mess_header + g_test_case + str(case_no) + " "
545 message = message + "Connect(out->in, flush) -> Activate -> send/recv -> Deactivate -> Disconnect"
546 message = message + g_mess_footer
547 fout.write(message + '\n')
548 fout.close()
549 print message
550 
551 for i in range(loop_count):
552 
553  ## 2 受信データファイル削除
554  delete_recv_file()
555 
556  ## 1 コネクタープロファイル設定
557  make_connecter_profile("flush", "", 0)
558 
559  ## 3 ポート接続
560  # データポート1 TimedFloat
561  ret0 = g_out_ports[g_port1].connect(g_conprof1)
562 
563  # データポート2 TimedFloatSeq
564  ret1 = g_out_ports[g_port2].connect(g_conprof2)
565 
566  # サービスポート MyService
567  ret2 = g_out_ports[g_port3].connect(g_conprof3)
568 
569  ## 4 アクティベート
570  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
571  time.sleep(sleep_recv_act_time)
572  ec_send[0].activate_component(g_compo_send.rtc_ref)
573 
574  time.sleep(sleep_act_time)
575 
576  ## 5 ディアクティベート
577  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
578  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
579 
580  ## 6 ポート切断
581  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
582  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
583  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
584 
585  ## 受信ファイル有無判定
586  if os.path.isfile(g_diff_recv_file) == False:
587  fout = open(g_test_result_file, 'a')
588  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
589  message = message + g_check_message
590  fout.write(message + '\n')
591  fout.close()
592  print message
593  time.sleep(sleep_for_time)
594  continue
595 
596  ## 7 送受信データ比較
597  time.sleep(sleep_act_time)
598  bret = diff_file()
599 
600  ## 差分ファイルからテスト結果出力
601  fout = open(g_test_result_file, 'a')
602  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
603  # bret==True なら送受信データ一致
604  if bret == True:
605  # テスト結果 OK
606  message = message + g_test_ok
607  print message
608  fout.write(message + '\n')
609  else:
610  # テスト結果 NG
611  message = message + g_test_ng
612  print message
613  message = message + g_test_ng_message
614  fout.write(message + '\n')
615  # 受信データをテスト結果ファイルへコピー
616  fin2 = open(g_diff_recv_file, 'r')
617  while(1):
618  s2 = fin2.readline()
619  if len(s2) == 0:
620  break
621  fout.write(s2)
622  fin2.close()
623  fout.close()
624 
625  time.sleep(sleep_for_time)
626 
627 ##--------------------------------------------------------------------
628 ## 接続タイプ：flush 方向：in->out 接続・切断・Activate・Deactivateテスト1
629 ##--------------------------------------------------------------------
630 case_no = case_no + 1
631 fout = open(g_test_result_file, 'a')
632 message = g_mess_header + g_test_case + str(case_no) + " "
633 message = message + "Connect(in->out, flush) -> Activate -> send/recv -> Deactivate -> Disconnect"
634 message = message + g_mess_footer
635 fout.write(message + '\n')
636 fout.close()
637 print message
638 
639 for i in range(loop_count):
640 
641  ## 2 受信データファイル削除
642  delete_recv_file()
643 
644  ## 1 コネクタープロファイル設定
645  make_connecter_profile("flush", "", 1)
646 
647  ## 3 ポート接続
648  # データポート1 TimedFloat
649  ret0 = g_out_ports[g_port1].connect(g_conprof1)
650 
651  # データポート2 TimedFloatSeq
652  ret1 = g_out_ports[g_port2].connect(g_conprof2)
653 
654  # サービスポート MyService
655  ret2 = g_out_ports[g_port3].connect(g_conprof3)
656 
657  ## 4 アクティベート
658  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
659  time.sleep(sleep_recv_act_time)
660  ec_send[0].activate_component(g_compo_send.rtc_ref)
661 
662  time.sleep(sleep_act_time)
663 
664  ## 5 ディアクティベート
665  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
666  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
667 
668  ## 6 ポート切断
669  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
670  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
671  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
672 
673  ## 受信ファイル有無判定
674  if os.path.isfile(g_diff_recv_file) == False:
675  fout = open(g_test_result_file, 'a')
676  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
677  message = message + g_check_message
678  fout.write(message + '\n')
679  fout.close()
680  print message
681  time.sleep(sleep_for_time)
682  continue
683 
684  ## 7 送受信データ比較
685  time.sleep(sleep_act_time)
686  bret = diff_file()
687 
688  ## 差分ファイルからテスト結果出力
689  fout = open(g_test_result_file, 'a')
690  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
691  # bret==True なら送受信データ一致
692  if bret == True:
693  # テスト結果 OK
694  message = message + g_test_ok
695  print message
696  fout.write(message + '\n')
697  else:
698  # テスト結果 NG
699  message = message + g_test_ng
700  print message
701  message = message + g_test_ng_message
702  fout.write(message + '\n')
703  # 受信データをテスト結果ファイルへコピー
704  fin2 = open(g_diff_recv_file, 'r')
705  while(1):
706  s2 = fin2.readline()
707  if len(s2) == 0:
708  break
709  fout.write(s2)
710  fin2.close()
711  fout.close()
712 
713  time.sleep(sleep_for_time)
714 
715 ##--------------------------------------------------------------------
716 ## 接続タイプ：flush 方向：out->in 接続・切断・Activate・Deactivateテスト2
717 ##--------------------------------------------------------------------
718 case_no = case_no + 1
719 fout = open(g_test_result_file, 'a')
720 message = g_mess_header + g_test_case + str(case_no) + " "
721 message = message + "Connect(out->in, flush) -> Activate -> send/recv -> Disconnect -> Deactivate"
722 message = message + g_mess_footer
723 fout.write(message + '\n')
724 fout.close()
725 print message
726 
727 for i in range(loop_count):
728 
729  ## 2 受信データファイル削除
730  delete_recv_file()
731 
732  ## 1 コネクタープロファイル設定
733  make_connecter_profile("flush", "", 0)
734 
735  ## 3 ポート接続
736  # データポート1 TimedFloat
737  ret0 = g_out_ports[g_port1].connect(g_conprof1)
738 
739  # データポート2 TimedFloatSeq
740  ret1 = g_out_ports[g_port2].connect(g_conprof2)
741 
742  # サービスポート MyService
743  ret2 = g_out_ports[g_port3].connect(g_conprof3)
744 
745  ## 4 アクティベート
746  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
747  time.sleep(sleep_recv_act_time)
748  ec_send[0].activate_component(g_compo_send.rtc_ref)
749 
750  time.sleep(sleep_act_time)
751 
752  ## 6 ポート切断
753  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
754  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
755  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
756 
757  ## 5 ディアクティベート
758  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
759  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
760 
761  ## 受信ファイル有無判定
762  if os.path.isfile(g_diff_recv_file) == False:
763  fout = open(g_test_result_file, 'a')
764  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
765  message = message + g_check_message
766  fout.write(message + '\n')
767  fout.close()
768  print message
769  time.sleep(sleep_for_time)
770  continue
771 
772  ## 7 送受信データ比較
773  time.sleep(sleep_act_time)
774  bret = diff_file()
775 
776  ## 差分ファイルからテスト結果出力
777  fout = open(g_test_result_file, 'a')
778  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
779  # bret==True なら送受信データ一致
780  if bret == True:
781  # テスト結果 OK
782  message = message + g_test_ok
783  print message
784  fout.write(message + '\n')
785  else:
786  # テスト結果 NG
787  message = message + g_test_ng
788  print message
789  message = message + g_test_ng_message
790  fout.write(message + '\n')
791  # 受信データをテスト結果ファイルへコピー
792  fin2 = open(g_diff_recv_file, 'r')
793  while(1):
794  s2 = fin2.readline()
795  if len(s2) == 0:
796  break
797  fout.write(s2)
798  fin2.close()
799  fout.close()
800 
801  time.sleep(sleep_for_time)
802 
803 ##--------------------------------------------------------------------
804 ## 接続タイプ：flush 方向：in->out 接続・切断・Activate・Deactivateテスト2
805 ##--------------------------------------------------------------------
806 case_no = case_no + 1
807 fout = open(g_test_result_file, 'a')
808 message = g_mess_header + g_test_case + str(case_no) + " "
809 message = message + "Connect(in->out, flush) -> Activate -> send/recv -> Disconnect -> Deactivate"
810 message = message + g_mess_footer
811 fout.write(message + '\n')
812 fout.close()
813 print message
814 
815 for i in range(loop_count):
816 
817  ## 2 受信データファイル削除
818  delete_recv_file()
819 
820  ## 1 コネクタープロファイル設定
821  make_connecter_profile("flush", "", 1)
822 
823  ## 3 ポート接続
824  # データポート1 TimedFloat
825  ret0 = g_out_ports[g_port1].connect(g_conprof1)
826 
827  # データポート2 TimedFloatSeq
828  ret1 = g_out_ports[g_port2].connect(g_conprof2)
829 
830  # サービスポート MyService
831  ret2 = g_out_ports[g_port3].connect(g_conprof3)
832 
833  ## 4 アクティベート
834  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
835  time.sleep(sleep_recv_act_time)
836  ec_send[0].activate_component(g_compo_send.rtc_ref)
837 
838  time.sleep(sleep_act_time)
839 
840  ## 6 ポート切断
841  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
842  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
843  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
844 
845  ## 5 ディアクティベート
846  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
847  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
848 
849  ## 受信ファイル有無判定
850  if os.path.isfile(g_diff_recv_file) == False:
851  fout = open(g_test_result_file, 'a')
852  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
853  message = message + g_check_message
854  fout.write(message + '\n')
855  fout.close()
856  print message
857  time.sleep(sleep_for_time)
858  continue
859 
860  ## 7 送受信データ比較
861  time.sleep(sleep_act_time)
862  bret = diff_file()
863 
864  ## 差分ファイルからテスト結果出力
865  fout = open(g_test_result_file, 'a')
866  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
867  # bret==True なら送受信データ一致
868  if bret == True:
869  # テスト結果 OK
870  message = message + g_test_ok
871  print message
872  fout.write(message + '\n')
873  else:
874  # テスト結果 NG
875  message = message + g_test_ng
876  print message
877  message = message + g_test_ng_message
878  fout.write(message + '\n')
879  # 受信データをテスト結果ファイルへコピー
880  fin2 = open(g_diff_recv_file, 'r')
881  while(1):
882  s2 = fin2.readline()
883  if len(s2) == 0:
884  break
885  fout.write(s2)
886  fin2.close()
887  fout.close()
888 
889  time.sleep(sleep_for_time)
890 
891 
892 ##--------------------------------------------------------------------
893 ## 接続タイプ：flush 方向：out->in 接続・切断・Activate・Deactivateテスト3
894 ##--------------------------------------------------------------------
895 ## ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
896 case_no = case_no + 1
897 fout = open(g_test_result_file, 'a')
898 message = g_mess_header + g_test_case + str(case_no) + " "
899 message = message + "Activate -> Connect(out->in, flush) -> send/recv -> Deactivate -> Disconnect"
900 message = message + g_mess_footer
901 fout.write(message + '\n')
902 fout.close()
903 print message
904 
905 for i in range(loop_count):
906 
907  ## 2 受信データファイル削除
908  delete_recv_file()
909 
910  ## 1 コネクタープロファイル設定
911  make_connecter_profile("flush", "", 0)
912 
913  ## 4 アクティベート
914  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
915  time.sleep(sleep_recv_act_time)
916  ec_send[0].activate_component(g_compo_send.rtc_ref)
917 
918  ## 3 ポート接続
919  # データポート1 TimedFloat
920  ret0 = g_out_ports[g_port1].connect(g_conprof1)
921 
922  # データポート2 TimedFloatSeq
923  ret1 = g_out_ports[g_port2].connect(g_conprof2)
924 
925  # サービスポート MyService
926  ret2 = g_out_ports[g_port3].connect(g_conprof3)
927 
928  time.sleep(sleep_act_time)
929 
930  ## 5 ディアクティベート
931  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
932  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
933 
934  ## 6 ポート切断
935  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
936  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
937  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
938 
939  ## 受信ファイル有無判定
940  if os.path.isfile(g_diff_recv_file) == False:
941  fout = open(g_test_result_file, 'a')
942  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
943  message = message + g_check_message
944  fout.write(message + '\n')
945  fout.close()
946  print message
947  time.sleep(sleep_for_time)
948  continue
949 
950  ## 7 送受信データ比較
951  time.sleep(sleep_act_time)
952  bret = diff_file()
953 
954  ## 差分ファイルからテスト結果出力
955  fout = open(g_test_result_file, 'a')
956  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
957  # bret==True なら送受信データ一致
958  if bret == True:
959  # テスト結果 OK
960  message = message + g_test_ok
961  print message
962  fout.write(message + '\n')
963  else:
964  # テスト結果 NG
965  message = message + g_test_ng
966  print message
967  message = message + g_test_ng_message
968  fout.write(message + '\n')
969  # 受信データをテスト結果ファイルへコピー
970  fin2 = open(g_diff_recv_file, 'r')
971  while(1):
972  s2 = fin2.readline()
973  if len(s2) == 0:
974  break
975  fout.write(s2)
976  fin2.close()
977  fout.close()
978 
979  time.sleep(sleep_for_time)
980 
981 ##--------------------------------------------------------------------
982 ## 接続タイプ：flush 方向：in->out 接続・切断・Activate・Deactivateテスト3
983 ##--------------------------------------------------------------------
984 ## ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
985 case_no = case_no + 1
986 fout = open(g_test_result_file, 'a')
987 message = g_mess_header + g_test_case + str(case_no) + " "
988 message = message + "Activate -> Connect(in->out, flush) -> send/recv -> Deactivate -> Disconnect"
989 message = message + g_mess_footer
990 fout.write(message + '\n')
991 fout.close()
992 print message
993 
994 for i in range(loop_count):
995 
996  ## 2 受信データファイル削除
997  delete_recv_file()
998 
999  ## 1 コネクタープロファイル設定
1000  make_connecter_profile("flush", "", 1)
1001 
1002  ## 4 アクティベート
1003  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1004  time.sleep(sleep_recv_act_time)
1005  ec_send[0].activate_component(g_compo_send.rtc_ref)
1006 
1007  ## 3 ポート接続
1008  # データポート1 TimedFloat
1009  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1010 
1011  # データポート2 TimedFloatSeq
1012  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1013 
1014  # サービスポート MyService
1015  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1016 
1017  time.sleep(sleep_act_time)
1018 
1019  ## 5 ディアクティベート
1020  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1021  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1022 
1023  ## 6 ポート切断
1024  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1025  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1026  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1027 
1028  ## 受信ファイル有無判定
1029  if os.path.isfile(g_diff_recv_file) == False:
1030  fout = open(g_test_result_file, 'a')
1031  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1032  message = message + g_check_message
1033  fout.write(message + '\n')
1034  fout.close()
1035  print message
1036  time.sleep(sleep_for_time)
1037  continue
1038 
1039  ## 7 送受信データ比較
1040  time.sleep(sleep_act_time)
1041  bret = diff_file()
1042 
1043  ## 差分ファイルからテスト結果出力
1044  fout = open(g_test_result_file, 'a')
1045  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1046  # bret==True なら送受信データ一致
1047  if bret == True:
1048  # テスト結果 OK
1049  message = message + g_test_ok
1050  print message
1051  fout.write(message + '\n')
1052  else:
1053  # テスト結果 NG
1054  message = message + g_test_ng
1055  print message
1056  message = message + g_test_ng_message
1057  fout.write(message + '\n')
1058  # 受信データをテスト結果ファイルへコピー
1059  fin2 = open(g_diff_recv_file, 'r')
1060  while(1):
1061  s2 = fin2.readline()
1062  if len(s2) == 0:
1063  break
1064  fout.write(s2)
1065  fin2.close()
1066  fout.close()
1067 
1068  time.sleep(sleep_for_time)
1069 
1070 ##--------------------------------------------------------------------
1071 ## 接続タイプ：flush 方向：out->in 接続・切断・Activate・Deactivateテスト4
1072 ##--------------------------------------------------------------------
1073 ## ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
1074 case_no = case_no + 1
1075 fout = open(g_test_result_file, 'a')
1076 message = g_mess_header + g_test_case + str(case_no) + " "
1077 message = message + "Activate -> Connect(out->in, flush) -> send/recv -> Disconnect -> Deactivate"
1078 message = message + g_mess_footer
1079 fout.write(message + '\n')
1080 fout.close()
1081 print message
1082 
1083 for i in range(loop_count):
1084 
1085  ## 2 受信データファイル削除
1086  delete_recv_file()
1087 
1088  ## 1 コネクタープロファイル設定
1089  make_connecter_profile("flush", "", 0)
1090 
1091  ## 4 アクティベート
1092  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1093  time.sleep(sleep_recv_act_time)
1094  ec_send[0].activate_component(g_compo_send.rtc_ref)
1095 
1096  ## 3 ポート接続
1097  # データポート1 TimedFloat
1098  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1099 
1100  # データポート2 TimedFloatSeq
1101  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1102 
1103  # サービスポート MyService
1104  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1105 
1106  time.sleep(sleep_act_time)
1107 
1108  ## 6 ポート切断
1109  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1110  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1111  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1112 
1113  ## 5 ディアクティベート
1114  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1115  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1116 
1117  ## 受信ファイル有無判定
1118  if os.path.isfile(g_diff_recv_file) == False:
1119  fout = open(g_test_result_file, 'a')
1120  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1121  message = message + g_check_message
1122  fout.write(message + '\n')
1123  fout.close()
1124  print message
1125  time.sleep(sleep_for_time)
1126  continue
1127 
1128  ## 7 送受信データ比較
1129  time.sleep(sleep_act_time)
1130  bret = diff_file()
1131 
1132  ## 差分ファイルからテスト結果出力
1133  fout = open(g_test_result_file, 'a')
1134  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1135  # bret==True なら送受信データ一致
1136  if bret == True:
1137  # テスト結果 OK
1138  message = message + g_test_ok
1139  print message
1140  fout.write(message + '\n')
1141  else:
1142  # テスト結果 NG
1143  message = message + g_test_ng
1144  print message
1145  message = message + g_test_ng_message
1146  fout.write(message + '\n')
1147  # 受信データをテスト結果ファイルへコピー
1148  fin2 = open(g_diff_recv_file, 'r')
1149  while(1):
1150  s2 = fin2.readline()
1151  if len(s2) == 0:
1152  break
1153  fout.write(s2)
1154  fin2.close()
1155  fout.close()
1156 
1157  time.sleep(sleep_for_time)
1158 
1159 ##--------------------------------------------------------------------
1160 ## 接続タイプ：flush 方向：in->out 接続・切断・Activate・Deactivateテスト4
1161 ##--------------------------------------------------------------------
1162 ## ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
1163 case_no = case_no + 1
1164 fout = open(g_test_result_file, 'a')
1165 message = g_mess_header + g_test_case + str(case_no) + " "
1166 message = message + "Activate -> Connect(in->out, flush) -> send/recv -> Disconnect -> Deactivate"
1167 message = message + g_mess_footer
1168 fout.write(message + '\n')
1169 fout.close()
1170 print message
1171 
1172 for i in range(loop_count):
1173 
1174  ## 2 受信データファイル削除
1175  delete_recv_file()
1176 
1177  ## 1 コネクタープロファイル設定
1178  make_connecter_profile("flush", "", 1)
1179 
1180  ## 4 アクティベート
1181  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1182  time.sleep(sleep_recv_act_time)
1183  ec_send[0].activate_component(g_compo_send.rtc_ref)
1184 
1185  ## 3 ポート接続
1186  # データポート1 TimedFloat
1187  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1188 
1189  # データポート2 TimedFloatSeq
1190  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1191 
1192  # サービスポート MyService
1193  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1194 
1195  time.sleep(sleep_act_time)
1196 
1197  ## 6 ポート切断
1198  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1199  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1200  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1201 
1202  ## 5 ディアクティベート
1203  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1204  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1205 
1206  ## 受信ファイル有無判定
1207  if os.path.isfile(g_diff_recv_file) == False:
1208  fout = open(g_test_result_file, 'a')
1209  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1210  message = message + g_check_message
1211  fout.write(message + '\n')
1212  fout.close()
1213  print message
1214  time.sleep(sleep_for_time)
1215  continue
1216 
1217  ## 7 送受信データ比較
1218  time.sleep(sleep_act_time)
1219  bret = diff_file()
1220 
1221  ## 差分ファイルからテスト結果出力
1222  fout = open(g_test_result_file, 'a')
1223  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1224  # bret==True なら送受信データ一致
1225  if bret == True:
1226  # テスト結果 OK
1227  message = message + g_test_ok
1228  print message
1229  fout.write(message + '\n')
1230  else:
1231  # テスト結果 NG
1232  message = message + g_test_ng
1233  print message
1234  message = message + g_test_ng_message
1235  fout.write(message + '\n')
1236  # 受信データをテスト結果ファイルへコピー
1237  fin2 = open(g_diff_recv_file, 'r')
1238  while(1):
1239  s2 = fin2.readline()
1240  if len(s2) == 0:
1241  break
1242  fout.write(s2)
1243  fin2.close()
1244  fout.close()
1245 
1246  time.sleep(sleep_for_time)
1247 
1248 ##--------------------------------------------------------------------
1249 ##--------------------------------------------------------------------
1250 ## 接続タイプ：new 方向：out->in ポリシー：ALL 接続・切断テスト3
1251 ##--------------------------------------------------------------------
1252 case_no = case_no + 1
1253 fout = open(g_test_result_file, 'a')
1254 message = g_mess_header + g_test_case + str(case_no) + " "
1255 message = message + "Connect(out->in, new,ALL) -> Disconnect"
1256 message = message + g_mess_footer
1257 fout.write(message + '\n')
1258 fout.close()
1259 print message
1260 
1261 for i in range(loop_count):
1262 
1263  ## 1 コネクタープロファイル設定
1264  make_connecter_profile("new", "ALL", 0)
1265 
1266  ## 3 ポート接続
1267  # データポート1 TimedFloat
1268  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1269 
1270  # データポート2 TimedFloatSeq
1271  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1272 
1273  # サービスポート MyService
1274  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1275 
1276  time.sleep(sleep_connect_time)
1277 
1278  ## 6 ポート切断
1279  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1280  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1281  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1282 
1283  ## テスト結果出力
1284  fout = open(g_test_result_file, 'a')
1285  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1286  message = message + g_test_ok
1287  print message
1288  fout.write(message + '\n')
1289  fout.close()
1290 
1291  time.sleep(sleep_for_time)
1292 
1293 ##--------------------------------------------------------------------
1294 ## 接続タイプ：new 方向：out->in ポリシー：FIFO 接続・切断テスト4
1295 ##--------------------------------------------------------------------
1296 case_no = case_no + 1
1297 fout = open(g_test_result_file, 'a')
1298 message = g_mess_header + g_test_case + str(case_no) + " "
1299 message = message + "Connect(out->in, new,FIFO) -> Disconnect"
1300 message = message + g_mess_footer
1301 fout.write(message + '\n')
1302 fout.close()
1303 print message
1304 
1305 for i in range(loop_count):
1306 
1307  ## 1 コネクタープロファイル設定
1308  make_connecter_profile("new", "FIFO", 0)
1309 
1310  ## 3 ポート接続
1311  # データポート1 TimedFloat
1312  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1313 
1314  # データポート2 TimedFloatSeq
1315  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1316 
1317  # サービスポート MyService
1318  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1319 
1320  time.sleep(sleep_connect_time)
1321 
1322  ## 6 ポート切断
1323  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1324  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1325  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1326 
1327  ## テスト結果出力
1328  fout = open(g_test_result_file, 'a')
1329  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1330  message = message + g_test_ok
1331  print message
1332  fout.write(message + '\n')
1333  fout.close()
1334 
1335  time.sleep(sleep_for_time)
1336 
1337 ##--------------------------------------------------------------------
1338 ## 接続タイプ：new 方向：out->in ポリシー：NEW 接続・切断テスト6
1339 ##--------------------------------------------------------------------
1340 case_no = case_no + 1
1341 fout = open(g_test_result_file, 'a')
1342 message = g_mess_header + g_test_case + str(case_no) + " "
1343 message = message + "Connect(out->in, new,NEW) -> Disconnect"
1344 message = message + g_mess_footer
1345 fout.write(message + '\n')
1346 fout.close()
1347 print message
1348 
1349 for i in range(loop_count):
1350 
1351  ## 1 コネクタープロファイル設定
1352  make_connecter_profile("new", "NEW", 0)
1353 
1354  ## 3 ポート接続
1355  # データポート1 TimedFloat
1356  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1357 
1358  # データポート2 TimedFloatSeq
1359  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1360 
1361  # サービスポート MyService
1362  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1363 
1364  time.sleep(sleep_connect_time)
1365 
1366  ## 6 ポート切断
1367  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1368  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1369  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1370 
1371  ## テスト結果出力
1372  fout = open(g_test_result_file, 'a')
1373  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1374  message = message + g_test_ok
1375  print message
1376  fout.write(message + '\n')
1377  fout.close()
1378 
1379  time.sleep(sleep_for_time)
1380 
1381 ##--------------------------------------------------------------------
1382 ## 接続タイプ：new 方向：out->in ポリシー：SKIP 接続・切断テスト5
1383 ##--------------------------------------------------------------------
1384 case_no = case_no + 1
1385 fout = open(g_test_result_file, 'a')
1386 message = g_mess_header + g_test_case + str(case_no) + " "
1387 message = message + "Connect(out->in, new,SKIP) -> Disconnect"
1388 message = message + g_mess_footer
1389 fout.write(message + '\n')
1390 fout.close()
1391 print message
1392 
1393 for i in range(loop_count):
1394 
1395  ## 1 コネクタープロファイル設定
1396  make_connecter_profile("new", "SKIP", 0)
1397 
1398  ## 3 ポート接続
1399  # データポート1 TimedFloat
1400  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1401 
1402  # データポート2 TimedFloatSeq
1403  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1404 
1405  # サービスポート MyService
1406  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1407 
1408  time.sleep(sleep_connect_time)
1409 
1410  ## 6 ポート切断
1411  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1412  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1413  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1414 
1415  ## テスト結果出力
1416  fout = open(g_test_result_file, 'a')
1417  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1418  message = message + g_test_ok
1419  print message
1420  fout.write(message + '\n')
1421  fout.close()
1422 
1423  time.sleep(sleep_for_time)
1424 
1425 ##--------------------------------------------------------------------
1426 ## 接続タイプ：new 方向：in->out ポリシー：ALL 接続・切断テスト3
1427 ##--------------------------------------------------------------------
1428 case_no = case_no + 1
1429 fout = open(g_test_result_file, 'a')
1430 message = g_mess_header + g_test_case + str(case_no) + " "
1431 message = message + "Connect(in->out, new,ALL) -> Disconnect"
1432 message = message + g_mess_footer
1433 fout.write(message + '\n')
1434 fout.close()
1435 print message
1436 
1437 for i in range(loop_count):
1438 
1439  ## 1 コネクタープロファイル設定
1440  make_connecter_profile("new", "ALL", 1)
1441 
1442  ## 3 ポート接続
1443  # データポート1 TimedFloat
1444  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1445 
1446  # データポート2 TimedFloatSeq
1447  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1448 
1449  # サービスポート MyService
1450  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1451 
1452  time.sleep(sleep_connect_time)
1453 
1454  ## 6 ポート切断
1455  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1456  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1457  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1458 
1459  ## テスト結果出力
1460  fout = open(g_test_result_file, 'a')
1461  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1462  message = message + g_test_ok
1463  print message
1464  fout.write(message + '\n')
1465  fout.close()
1466 
1467  time.sleep(sleep_for_time)
1468 
1469 ##--------------------------------------------------------------------
1470 ## 接続タイプ：new 方向：in->out ポリシー：FIFO 接続・切断テスト4
1471 ##--------------------------------------------------------------------
1472 case_no = case_no + 1
1473 fout = open(g_test_result_file, 'a')
1474 message = g_mess_header + g_test_case + str(case_no) + " "
1475 message = message + "Connect(in->out, new,FIFO) -> Disconnect"
1476 message = message + g_mess_footer
1477 fout.write(message + '\n')
1478 fout.close()
1479 print message
1480 
1481 for i in range(loop_count):
1482 
1483  ## 1 コネクタープロファイル設定
1484  make_connecter_profile("new", "FIFO", 1)
1485 
1486  ## 3 ポート接続
1487  # データポート1 TimedFloat
1488  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1489 
1490  # データポート2 TimedFloatSeq
1491  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1492 
1493  # サービスポート MyService
1494  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1495 
1496  time.sleep(sleep_connect_time)
1497 
1498  ## 6 ポート切断
1499  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1500  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1501  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1502 
1503  ## テスト結果出力
1504  fout = open(g_test_result_file, 'a')
1505  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1506  message = message + g_test_ok
1507  print message
1508  fout.write(message + '\n')
1509  fout.close()
1510 
1511  time.sleep(sleep_for_time)
1512 
1513 ##--------------------------------------------------------------------
1514 ## 接続タイプ：new 方向：in->out ポリシー：NEW 接続・切断テスト6
1515 ##--------------------------------------------------------------------
1516 case_no = case_no + 1
1517 fout = open(g_test_result_file, 'a')
1518 message = g_mess_header + g_test_case + str(case_no) + " "
1519 message = message + "Connect(in->out, new,NEW) -> Disconnect"
1520 message = message + g_mess_footer
1521 fout.write(message + '\n')
1522 fout.close()
1523 print message
1524 
1525 for i in range(loop_count):
1526 
1527  ## 1 コネクタープロファイル設定
1528  make_connecter_profile("new", "NEW", 1)
1529 
1530  ## 3 ポート接続
1531  # データポート1 TimedFloat
1532  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1533 
1534  # データポート2 TimedFloatSeq
1535  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1536 
1537  # サービスポート MyService
1538  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1539 
1540  time.sleep(sleep_connect_time)
1541 
1542  ## 6 ポート切断
1543  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1544  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1545  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1546 
1547  ## テスト結果出力
1548  fout = open(g_test_result_file, 'a')
1549  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1550  message = message + g_test_ok
1551  print message
1552  fout.write(message + '\n')
1553  fout.close()
1554 
1555  time.sleep(sleep_for_time)
1556 
1557 ##--------------------------------------------------------------------
1558 ## 接続タイプ：new 方向：in->out ポリシー：SKIP 接続・切断テスト5
1559 ##--------------------------------------------------------------------
1560 case_no = case_no + 1
1561 fout = open(g_test_result_file, 'a')
1562 message = g_mess_header + g_test_case + str(case_no) + " "
1563 message = message + "Connect(in->out, new,SKIP) -> Disconnect"
1564 message = message + g_mess_footer
1565 fout.write(message + '\n')
1566 fout.close()
1567 print message
1568 
1569 for i in range(loop_count):
1570 
1571  ## 1 コネクタープロファイル設定
1572  make_connecter_profile("new", "SKIP", 1)
1573 
1574  ## 3 ポート接続
1575  # データポート1 TimedFloat
1576  ret0 = g_out_ports[g_port1].connect(g_conprof1)
1577 
1578  # データポート2 TimedFloatSeq
1579  ret1 = g_out_ports[g_port2].connect(g_conprof2)
1580 
1581  # サービスポート MyService
1582  ret2 = g_out_ports[g_port3].connect(g_conprof3)
1583 
1584  time.sleep(sleep_connect_time)
1585 
1586  ## 6 ポート切断
1587  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1588  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1589  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1590 
1591  ## テスト結果出力
1592  fout = open(g_test_result_file, 'a')
1593  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1594  message = message + g_test_ok
1595  print message
1596  fout.write(message + '\n')
1597  fout.close()
1598 
1599  time.sleep(sleep_for_time)
1600 
1601 ##--------------------------------------------------------------------
1602 ## 接続タイプ：new 方向：out->in ポリシー：ALL Activate・Deactivateテスト2
1603 ##--------------------------------------------------------------------
1604 case_no = case_no + 1
1605 fout = open(g_test_result_file, 'a')
1606 message = g_mess_header + g_test_case + str(case_no) + " "
1607 message = message + "Connecting(out->in, new,ALL), Activate -> send/recv -> Deactivate"
1608 message = message + g_mess_footer
1609 fout.write(message + '\n')
1610 fout.close()
1611 print message
1612 
1613 ## 1 コネクタープロファイル設定
1614 make_connecter_profile("new", "ALL", 0)
1615 
1616 ## 3 ポート接続
1617 # データポート1 TimedFloat
1618 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1619 
1620 # データポート2 TimedFloatSeq
1621 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1622 
1623 # サービスポート MyService
1624 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1625 
1626 for i in range(loop_count):
1627 
1628  ## 2 受信データファイル削除
1629  delete_recv_file()
1630 
1631  ## 4 アクティベート
1632  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1633  time.sleep(sleep_recv_act_time)
1634  ec_send[0].activate_component(g_compo_send.rtc_ref)
1635 
1636  time.sleep(sleep_act_time)
1637 
1638  ## 5 ディアクティベート
1639  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1640  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1641 
1642  ## 受信ファイル有無判定
1643  if os.path.isfile(g_diff_recv_file) == False:
1644  fout = open(g_test_result_file, 'a')
1645  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1646  message = message + g_check_message
1647  fout.write(message + '\n')
1648  fout.close()
1649  print message
1650  time.sleep(sleep_for_time)
1651  continue
1652 
1653  ## 7 送受信データ比較
1654  time.sleep(sleep_act_time)
1655  bret = diff_file()
1656 
1657  ## 差分ファイルからテスト結果出力
1658  fout = open(g_test_result_file, 'a')
1659  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1660  # bret==True なら送受信データ一致
1661  if bret == True:
1662  # テスト結果 OK
1663  message = message + g_test_ok
1664  print message
1665  fout.write(message + '\n')
1666  else:
1667  # テスト結果 NG
1668  message = message + g_test_ng
1669  print message
1670  message = message + g_test_ng_message
1671  fout.write(message + '\n')
1672  # 受信データをテスト結果ファイルへコピー
1673  fin2 = open(g_diff_recv_file, 'r')
1674  while(1):
1675  s2 = fin2.readline()
1676  if len(s2) == 0:
1677  break
1678  fout.write(s2)
1679  fin2.close()
1680  fout.close()
1681 
1682  time.sleep(sleep_for_time)
1683 
1684 ## 6 ポート切断
1685 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1686 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1687 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1688 
1689 ##--------------------------------------------------------------------
1690 ## 接続タイプ：new 方向：out->in ポリシー：FIFO Activate・Deactivateテスト3
1691 ##--------------------------------------------------------------------
1692 case_no = case_no + 1
1693 fout = open(g_test_result_file, 'a')
1694 message = g_mess_header + g_test_case + str(case_no) + " "
1695 message = message + "Connecting(out->in, new,FIFO), Activate -> send/recv -> Deactivate"
1696 message = message + g_mess_footer
1697 fout.write(message + '\n')
1698 fout.close()
1699 print message
1700 
1701 ## 1 コネクタープロファイル設定
1702 make_connecter_profile("new", "FIFO", 0)
1703 
1704 ## 3 ポート接続
1705 # データポート1 TimedFloat
1706 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1707 
1708 # データポート2 TimedFloatSeq
1709 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1710 
1711 # サービスポート MyService
1712 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1713 
1714 for i in range(loop_count):
1715 
1716  ## 2 受信データファイル削除
1717  delete_recv_file()
1718 
1719  ## 4 アクティベート
1720  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1721  time.sleep(sleep_recv_act_time)
1722  ec_send[0].activate_component(g_compo_send.rtc_ref)
1723 
1724  time.sleep(sleep_act_time)
1725 
1726  ## 5 ディアクティベート
1727  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1728  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1729 
1730  ## 受信ファイル有無判定
1731  if os.path.isfile(g_diff_recv_file) == False:
1732  fout = open(g_test_result_file, 'a')
1733  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1734  message = message + g_check_message
1735  fout.write(message + '\n')
1736  fout.close()
1737  print message
1738  time.sleep(sleep_for_time)
1739  continue
1740 
1741  ## 7 送受信データ比較
1742  time.sleep(sleep_act_time)
1743  bret = diff_file()
1744 
1745  ## 差分ファイルからテスト結果出力
1746  fout = open(g_test_result_file, 'a')
1747  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1748  # bret==True なら送受信データ一致
1749  if bret == True:
1750  # テスト結果 OK
1751  message = message + g_test_ok
1752  print message
1753  fout.write(message + '\n')
1754  else:
1755  # テスト結果 NG
1756  message = message + g_test_ng
1757  print message
1758  message = message + g_test_ng_message
1759  fout.write(message + '\n')
1760  # 受信データをテスト結果ファイルへコピー
1761  fin2 = open(g_diff_recv_file, 'r')
1762  while(1):
1763  s2 = fin2.readline()
1764  if len(s2) == 0:
1765  break
1766  fout.write(s2)
1767  fin2.close()
1768  fout.close()
1769 
1770  time.sleep(sleep_for_time)
1771 
1772 ## 6 ポート切断
1773 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1774 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1775 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1776 
1777 ##--------------------------------------------------------------------
1778 ## 接続タイプ：new 方向：out->in ポリシー：NEW Activate・Deactivateテスト5
1779 ##--------------------------------------------------------------------
1780 case_no = case_no + 1
1781 fout = open(g_test_result_file, 'a')
1782 message = g_mess_header + g_test_case + str(case_no) + " "
1783 message = message + "Connecting(out->in, new,NEW), Activate -> send/recv -> Deactivate"
1784 message = message + g_mess_footer
1785 fout.write(message + '\n')
1786 fout.close()
1787 print message
1788 
1789 ## 1 コネクタープロファイル設定
1790 make_connecter_profile("new", "NEW", 0)
1791 
1792 ## 3 ポート接続
1793 # データポート1 TimedFloat
1794 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1795 
1796 # データポート2 TimedFloatSeq
1797 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1798 
1799 # サービスポート MyService
1800 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1801 
1802 for i in range(loop_count):
1803 
1804  ## 2 受信データファイル削除
1805  delete_recv_file()
1806 
1807  ## 4 アクティベート
1808  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1809  time.sleep(sleep_recv_act_time)
1810  ec_send[0].activate_component(g_compo_send.rtc_ref)
1811 
1812  time.sleep(sleep_act_time)
1813 
1814  ## 5 ディアクティベート
1815  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1816  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1817 
1818  ## 受信ファイル有無判定
1819  if os.path.isfile(g_diff_recv_file) == False:
1820  fout = open(g_test_result_file, 'a')
1821  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1822  message = message + g_check_message
1823  fout.write(message + '\n')
1824  fout.close()
1825  print message
1826  time.sleep(sleep_for_time)
1827  continue
1828 
1829  ## 7 送受信データ比較
1830  time.sleep(sleep_act_time)
1831  bret = diff_file()
1832 
1833  ## 差分ファイルからテスト結果出力
1834  fout = open(g_test_result_file, 'a')
1835  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1836  # bret==True なら送受信データ一致
1837  if bret == True:
1838  # テスト結果 OK
1839  message = message + g_test_ok
1840  print message
1841  fout.write(message + '\n')
1842  else:
1843  # テスト結果 NG
1844  message = message + g_test_ng
1845  print message
1846  message = message + g_test_ng_message
1847  fout.write(message + '\n')
1848  # 受信データをテスト結果ファイルへコピー
1849  fin2 = open(g_diff_recv_file, 'r')
1850  while(1):
1851  s2 = fin2.readline()
1852  if len(s2) == 0:
1853  break
1854  fout.write(s2)
1855  fin2.close()
1856  fout.close()
1857 
1858  time.sleep(sleep_for_time)
1859 
1860 ## 6 ポート切断
1861 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1862 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1863 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1864 
1865 ##--------------------------------------------------------------------
1866 ## 接続タイプ：new 方向：out->in ポリシー：SKIP Activate・Deactivateテスト4
1867 ##--------------------------------------------------------------------
1868 case_no = case_no + 1
1869 fout = open(g_test_result_file, 'a')
1870 message = g_mess_header + g_test_case + str(case_no) + " "
1871 message = message + "Connecting(out->in, new,SKIP), Activate -> send/recv -> Deactivate"
1872 message = message + g_mess_footer
1873 fout.write(message + '\n')
1874 fout.close()
1875 print message
1876 
1877 ## 1 コネクタープロファイル設定
1878 make_connecter_profile("new", "SKIP", 0)
1879 
1880 ## 3 ポート接続
1881 # データポート1 TimedFloat
1882 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1883 
1884 # データポート2 TimedFloatSeq
1885 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1886 
1887 # サービスポート MyService
1888 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1889 
1890 for i in range(loop_count):
1891 
1892  ## 2 受信データファイル削除
1893  delete_recv_file()
1894 
1895  ## 4 アクティベート
1896  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1897  time.sleep(sleep_recv_act_time)
1898  ec_send[0].activate_component(g_compo_send.rtc_ref)
1899 
1900  time.sleep(sleep_act_time)
1901 
1902  ## 5 ディアクティベート
1903  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1904  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1905 
1906  ## 受信ファイル有無判定
1907  if os.path.isfile(g_diff_recv_file) == False:
1908  fout = open(g_test_result_file, 'a')
1909  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1910  message = message + g_check_message
1911  fout.write(message + '\n')
1912  fout.close()
1913  print message
1914  time.sleep(sleep_for_time)
1915  continue
1916 
1917  ## 7 送受信データ比較
1918  time.sleep(sleep_act_time)
1919  bret = diff_file()
1920 
1921  ## 差分ファイルからテスト結果出力
1922  fout = open(g_test_result_file, 'a')
1923  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1924  # bret==True なら送受信データ一致
1925  if bret == True:
1926  # テスト結果 OK
1927  message = message + g_test_ok
1928  print message
1929  fout.write(message + '\n')
1930  else:
1931  # テスト結果 NG
1932  message = message + g_test_ng
1933  print message
1934  message = message + g_test_ng_message
1935  fout.write(message + '\n')
1936  # 受信データをテスト結果ファイルへコピー
1937  fin2 = open(g_diff_recv_file, 'r')
1938  while(1):
1939  s2 = fin2.readline()
1940  if len(s2) == 0:
1941  break
1942  fout.write(s2)
1943  fin2.close()
1944  fout.close()
1945 
1946  time.sleep(sleep_for_time)
1947 
1948 ## 6 ポート切断
1949 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1950 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1951 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1952 
1953 ##--------------------------------------------------------------------
1954 ## 接続タイプ：new 方向：in->out ポリシー：ALL Activate・Deactivateテスト2
1955 ##--------------------------------------------------------------------
1956 case_no = case_no + 1
1957 fout = open(g_test_result_file, 'a')
1958 message = g_mess_header + g_test_case + str(case_no) + " "
1959 message = message + "Connecting(in->out, new,ALL), Activate -> send/recv -> Deactivate"
1960 message = message + g_mess_footer
1961 fout.write(message + '\n')
1962 fout.close()
1963 print message
1964 
1965 ## 1 コネクタープロファイル設定
1966 make_connecter_profile("new", "ALL", 1)
1967 
1968 ## 3 ポート接続
1969 # データポート1 TimedFloat
1970 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1971 
1972 # データポート2 TimedFloatSeq
1973 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1974 
1975 # サービスポート MyService
1976 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1977 
1978 for i in range(loop_count):
1979 
1980  ## 2 受信データファイル削除
1981  delete_recv_file()
1982 
1983  ## 4 アクティベート
1984  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1985  time.sleep(sleep_recv_act_time)
1986  ec_send[0].activate_component(g_compo_send.rtc_ref)
1987 
1988  time.sleep(sleep_act_time)
1989 
1990  ## 5 ディアクティベート
1991  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1992  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1993 
1994  ## 受信ファイル有無判定
1995  if os.path.isfile(g_diff_recv_file) == False:
1996  fout = open(g_test_result_file, 'a')
1997  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
1998  message = message + g_check_message
1999  fout.write(message + '\n')
2000  fout.close()
2001  print message
2002  time.sleep(sleep_for_time)
2003  continue
2004 
2005  ## 7 送受信データ比較
2006  time.sleep(sleep_act_time)
2007  bret = diff_file()
2008 
2009  ## 差分ファイルからテスト結果出力
2010  fout = open(g_test_result_file, 'a')
2011  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2012  # bret==True なら送受信データ一致
2013  if bret == True:
2014  # テスト結果 OK
2015  message = message + g_test_ok
2016  print message
2017  fout.write(message + '\n')
2018  else:
2019  # テスト結果 NG
2020  message = message + g_test_ng
2021  print message
2022  message = message + g_test_ng_message
2023  fout.write(message + '\n')
2024  # 受信データをテスト結果ファイルへコピー
2025  fin2 = open(g_diff_recv_file, 'r')
2026  while(1):
2027  s2 = fin2.readline()
2028  if len(s2) == 0:
2029  break
2030  fout.write(s2)
2031  fin2.close()
2032  fout.close()
2033 
2034  time.sleep(sleep_for_time)
2035 
2036 ## 6 ポート切断
2037 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2038 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2039 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2040 
2041 ##--------------------------------------------------------------------
2042 ## 接続タイプ：new 方向：in->out ポリシー：FIFO Activate・Deactivateテスト3
2043 ##--------------------------------------------------------------------
2044 case_no = case_no + 1
2045 fout = open(g_test_result_file, 'a')
2046 message = g_mess_header + g_test_case + str(case_no) + " "
2047 message = message + "Connecting(in->out, new,FIFO), Activate -> send/recv -> Deactivate"
2048 message = message + g_mess_footer
2049 fout.write(message + '\n')
2050 fout.close()
2051 print message
2052 
2053 ## 1 コネクタープロファイル設定
2054 make_connecter_profile("new", "FIFO", 1)
2055 
2056 ## 3 ポート接続
2057 # データポート1 TimedFloat
2058 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2059 
2060 # データポート2 TimedFloatSeq
2061 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2062 
2063 # サービスポート MyService
2064 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2065 
2066 for i in range(loop_count):
2067 
2068  ## 2 受信データファイル削除
2069  delete_recv_file()
2070 
2071  ## 4 アクティベート
2072  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2073  time.sleep(sleep_recv_act_time)
2074  ec_send[0].activate_component(g_compo_send.rtc_ref)
2075 
2076  time.sleep(sleep_act_time)
2077 
2078  ## 5 ディアクティベート
2079  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2080  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2081 
2082  ## 受信ファイル有無判定
2083  if os.path.isfile(g_diff_recv_file) == False:
2084  fout = open(g_test_result_file, 'a')
2085  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2086  message = message + g_check_message
2087  fout.write(message + '\n')
2088  fout.close()
2089  print message
2090  time.sleep(sleep_for_time)
2091  continue
2092 
2093  ## 7 送受信データ比較
2094  time.sleep(sleep_act_time)
2095  bret = diff_file()
2096 
2097  ## 差分ファイルからテスト結果出力
2098  fout = open(g_test_result_file, 'a')
2099  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2100  # bret==True なら送受信データ一致
2101  if bret == True:
2102  # テスト結果 OK
2103  message = message + g_test_ok
2104  print message
2105  fout.write(message + '\n')
2106  else:
2107  # テスト結果 NG
2108  message = message + g_test_ng
2109  print message
2110  message = message + g_test_ng_message
2111  fout.write(message + '\n')
2112  # 受信データをテスト結果ファイルへコピー
2113  fin2 = open(g_diff_recv_file, 'r')
2114  while(1):
2115  s2 = fin2.readline()
2116  if len(s2) == 0:
2117  break
2118  fout.write(s2)
2119  fin2.close()
2120  fout.close()
2121 
2122  time.sleep(sleep_for_time)
2123 
2124 ## 6 ポート切断
2125 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2126 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2127 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2128 
2129 ##--------------------------------------------------------------------
2130 ## 接続タイプ：new 方向：in->out ポリシー：NEW Activate・Deactivateテスト5
2131 ##--------------------------------------------------------------------
2132 case_no = case_no + 1
2133 fout = open(g_test_result_file, 'a')
2134 message = g_mess_header + g_test_case + str(case_no) + " "
2135 message = message + "Connecting(in->out, new,NEW), Activate -> send/recv -> Deactivate"
2136 message = message + g_mess_footer
2137 fout.write(message + '\n')
2138 fout.close()
2139 print message
2140 
2141 ## 1 コネクタープロファイル設定
2142 make_connecter_profile("new", "NEW", 1)
2143 
2144 ## 3 ポート接続
2145 # データポート1 TimedFloat
2146 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2147 
2148 # データポート2 TimedFloatSeq
2149 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2150 
2151 # サービスポート MyService
2152 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2153 
2154 for i in range(loop_count):
2155 
2156  ## 2 受信データファイル削除
2157  delete_recv_file()
2158 
2159  ## 4 アクティベート
2160  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2161  time.sleep(sleep_recv_act_time)
2162  ec_send[0].activate_component(g_compo_send.rtc_ref)
2163 
2164  time.sleep(sleep_act_time)
2165 
2166  ## 5 ディアクティベート
2167  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2168  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2169 
2170  ## 受信ファイル有無判定
2171  if os.path.isfile(g_diff_recv_file) == False:
2172  fout = open(g_test_result_file, 'a')
2173  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2174  message = message + g_check_message
2175  fout.write(message + '\n')
2176  fout.close()
2177  print message
2178  time.sleep(sleep_for_time)
2179  continue
2180 
2181  ## 7 送受信データ比較
2182  time.sleep(sleep_act_time)
2183  bret = diff_file()
2184 
2185  ## 差分ファイルからテスト結果出力
2186  fout = open(g_test_result_file, 'a')
2187  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2188  # bret==True なら送受信データ一致
2189  if bret == True:
2190  # テスト結果 OK
2191  message = message + g_test_ok
2192  print message
2193  fout.write(message + '\n')
2194  else:
2195  # テスト結果 NG
2196  message = message + g_test_ng
2197  print message
2198  message = message + g_test_ng_message
2199  fout.write(message + '\n')
2200  # 受信データをテスト結果ファイルへコピー
2201  fin2 = open(g_diff_recv_file, 'r')
2202  while(1):
2203  s2 = fin2.readline()
2204  if len(s2) == 0:
2205  break
2206  fout.write(s2)
2207  fin2.close()
2208  fout.close()
2209 
2210  time.sleep(sleep_for_time)
2211 
2212 ## 6 ポート切断
2213 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2214 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2215 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2216 
2217 ##--------------------------------------------------------------------
2218 ## 接続タイプ：new 方向：in->out ポリシー：SKIP Activate・Deactivateテスト4
2219 ##--------------------------------------------------------------------
2220 case_no = case_no + 1
2221 fout = open(g_test_result_file, 'a')
2222 message = g_mess_header + g_test_case + str(case_no) + " "
2223 message = message + "Connecting(in->out, new,SKIP), Activate -> send/recv -> Deactivate"
2224 message = message + g_mess_footer
2225 fout.write(message + '\n')
2226 fout.close()
2227 print message
2228 
2229 ## 1 コネクタープロファイル設定
2230 make_connecter_profile("new", "SKIP", 1)
2231 
2232 ## 3 ポート接続
2233 # データポート1 TimedFloat
2234 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2235 
2236 # データポート2 TimedFloatSeq
2237 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2238 
2239 # サービスポート MyService
2240 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2241 
2242 for i in range(loop_count):
2243 
2244  ## 2 受信データファイル削除
2245  delete_recv_file()
2246 
2247  ## 4 アクティベート
2248  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2249  time.sleep(sleep_recv_act_time)
2250  ec_send[0].activate_component(g_compo_send.rtc_ref)
2251 
2252  time.sleep(sleep_act_time)
2253 
2254  ## 5 ディアクティベート
2255  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2256  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2257 
2258  ## 受信ファイル有無判定
2259  if os.path.isfile(g_diff_recv_file) == False:
2260  fout = open(g_test_result_file, 'a')
2261  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2262  message = message + g_check_message
2263  fout.write(message + '\n')
2264  fout.close()
2265  print message
2266  time.sleep(sleep_for_time)
2267  continue
2268 
2269  ## 7 送受信データ比較
2270  time.sleep(sleep_act_time)
2271  bret = diff_file()
2272 
2273  ## 差分ファイルからテスト結果出力
2274  fout = open(g_test_result_file, 'a')
2275  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2276  # bret==True なら送受信データ一致
2277  if bret == True:
2278  # テスト結果 OK
2279  message = message + g_test_ok
2280  print message
2281  fout.write(message + '\n')
2282  else:
2283  # テスト結果 NG
2284  message = message + g_test_ng
2285  print message
2286  message = message + g_test_ng_message
2287  fout.write(message + '\n')
2288  # 受信データをテスト結果ファイルへコピー
2289  fin2 = open(g_diff_recv_file, 'r')
2290  while(1):
2291  s2 = fin2.readline()
2292  if len(s2) == 0:
2293  break
2294  fout.write(s2)
2295  fin2.close()
2296  fout.close()
2297 
2298  time.sleep(sleep_for_time)
2299 
2300 ## 6 ポート切断
2301 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2302 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2303 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2304 
2305 ##--------------------------------------------------------------------
2306 ## 接続タイプ：new 方向：out->in ポリシー：ALL 接続・切断・Activate・Deactivateテスト1
2307 ##--------------------------------------------------------------------
2308 case_no = case_no + 1
2309 fout = open(g_test_result_file, 'a')
2310 message = g_mess_header + g_test_case + str(case_no) + " "
2311 message = message + "Connect(out->in, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
2312 message = message + g_mess_footer
2313 fout.write(message + '\n')
2314 fout.close()
2315 print message
2316 
2317 for i in range(loop_count):
2318 
2319  ## 2 受信データファイル削除
2320  delete_recv_file()
2321 
2322  ## 1 コネクタープロファイル設定
2323  make_connecter_profile("new", "ALL", 0)
2324 
2325  ## 3 ポート接続
2326  # データポート1 TimedFloat
2327  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2328 
2329  # データポート2 TimedFloatSeq
2330  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2331 
2332  # サービスポート MyService
2333  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2334 
2335  ## 4 アクティベート
2336  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2337  time.sleep(sleep_recv_act_time)
2338  ec_send[0].activate_component(g_compo_send.rtc_ref)
2339 
2340  time.sleep(sleep_act_time)
2341 
2342  ## 5 ディアクティベート
2343  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2344  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2345 
2346  ## 6 ポート切断
2347  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2348  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2349  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2350 
2351  ## 受信ファイル有無判定
2352  if os.path.isfile(g_diff_recv_file) == False:
2353  fout = open(g_test_result_file, 'a')
2354  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2355  message = message + g_check_message
2356  fout.write(message + '\n')
2357  fout.close()
2358  print message
2359  time.sleep(sleep_for_time)
2360  continue
2361 
2362  ## 7 送受信データ比較
2363  time.sleep(sleep_act_time)
2364  bret = diff_file()
2365 
2366  ## 差分ファイルからテスト結果出力
2367  fout = open(g_test_result_file, 'a')
2368  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2369  # bret==True なら送受信データ一致
2370  if bret == True:
2371  # テスト結果 OK
2372  message = message + g_test_ok
2373  print message
2374  fout.write(message + '\n')
2375  else:
2376  # テスト結果 NG
2377  message = message + g_test_ng
2378  print message
2379  message = message + g_test_ng_message
2380  fout.write(message + '\n')
2381  # 受信データをテスト結果ファイルへコピー
2382  fin2 = open(g_diff_recv_file, 'r')
2383  while(1):
2384  s2 = fin2.readline()
2385  if len(s2) == 0:
2386  break
2387  fout.write(s2)
2388  fin2.close()
2389  fout.close()
2390 
2391  time.sleep(sleep_for_time)
2392 
2393 ##--------------------------------------------------------------------
2394 ## 接続タイプ：new 方向：out->in ポリシー：FIFO 接続・切断・Activate・Deactivateテスト1
2395 ##--------------------------------------------------------------------
2396 case_no = case_no + 1
2397 fout = open(g_test_result_file, 'a')
2398 message = g_mess_header + g_test_case + str(case_no) + " "
2399 message = message + "Connect(out->in, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
2400 message = message + g_mess_footer
2401 fout.write(message + '\n')
2402 fout.close()
2403 print message
2404 
2405 for i in range(loop_count):
2406 
2407  ## 2 受信データファイル削除
2408  delete_recv_file()
2409 
2410  ## 1 コネクタープロファイル設定
2411  make_connecter_profile("new", "FIFO", 0)
2412 
2413  ## 3 ポート接続
2414  # データポート1 TimedFloat
2415  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2416 
2417  # データポート2 TimedFloatSeq
2418  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2419 
2420  # サービスポート MyService
2421  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2422 
2423  ## 4 アクティベート
2424  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2425  time.sleep(sleep_recv_act_time)
2426  ec_send[0].activate_component(g_compo_send.rtc_ref)
2427 
2428  time.sleep(sleep_act_time)
2429 
2430  ## 5 ディアクティベート
2431  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2432  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2433 
2434  ## 6 ポート切断
2435  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2436  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2437  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2438 
2439  ## 受信ファイル有無判定
2440  if os.path.isfile(g_diff_recv_file) == False:
2441  fout = open(g_test_result_file, 'a')
2442  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2443  message = message + g_check_message
2444  fout.write(message + '\n')
2445  fout.close()
2446  print message
2447  time.sleep(sleep_for_time)
2448  continue
2449 
2450  ## 7 送受信データ比較
2451  time.sleep(sleep_act_time)
2452  bret = diff_file()
2453 
2454  ## 差分ファイルからテスト結果出力
2455  fout = open(g_test_result_file, 'a')
2456  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2457  # bret==True なら送受信データ一致
2458  if bret == True:
2459  # テスト結果 OK
2460  message = message + g_test_ok
2461  print message
2462  fout.write(message + '\n')
2463  else:
2464  # テスト結果 NG
2465  message = message + g_test_ng
2466  print message
2467  message = message + g_test_ng_message
2468  fout.write(message + '\n')
2469  # 受信データをテスト結果ファイルへコピー
2470  fin2 = open(g_diff_recv_file, 'r')
2471  while(1):
2472  s2 = fin2.readline()
2473  if len(s2) == 0:
2474  break
2475  fout.write(s2)
2476  fin2.close()
2477  fout.close()
2478 
2479  time.sleep(sleep_for_time)
2480 
2481 ##--------------------------------------------------------------------
2482 ## 接続タイプ：new 方向：out->in ポリシー：NEW 接続・切断・Activate・Deactivateテスト1
2483 ##--------------------------------------------------------------------
2484 case_no = case_no + 1
2485 fout = open(g_test_result_file, 'a')
2486 message = g_mess_header + g_test_case + str(case_no) + " "
2487 message = message + "Connect(out->in, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
2488 message = message + g_mess_footer
2489 fout.write(message + '\n')
2490 fout.close()
2491 print message
2492 
2493 for i in range(loop_count):
2494 
2495  ## 2 受信データファイル削除
2496  delete_recv_file()
2497 
2498  ## 1 コネクタープロファイル設定
2499  make_connecter_profile("new", "NEW", 0)
2500 
2501  ## 3 ポート接続
2502  # データポート1 TimedFloat
2503  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2504 
2505  # データポート2 TimedFloatSeq
2506  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2507 
2508  # サービスポート MyService
2509  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2510 
2511  ## 4 アクティベート
2512  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2513  time.sleep(sleep_recv_act_time)
2514  ec_send[0].activate_component(g_compo_send.rtc_ref)
2515 
2516  time.sleep(sleep_act_time)
2517 
2518  ## 5 ディアクティベート
2519  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2520  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2521 
2522  ## 6 ポート切断
2523  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2524  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2525  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2526 
2527  ## 受信ファイル有無判定
2528  if os.path.isfile(g_diff_recv_file) == False:
2529  fout = open(g_test_result_file, 'a')
2530  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2531  message = message + g_check_message
2532  fout.write(message + '\n')
2533  fout.close()
2534  print message
2535  time.sleep(sleep_for_time)
2536  continue
2537 
2538  ## 7 送受信データ比較
2539  time.sleep(sleep_act_time)
2540  bret = diff_file()
2541 
2542  ## 差分ファイルからテスト結果出力
2543  fout = open(g_test_result_file, 'a')
2544  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2545  # bret==True なら送受信データ一致
2546  if bret == True:
2547  # テスト結果 OK
2548  message = message + g_test_ok
2549  print message
2550  fout.write(message + '\n')
2551  else:
2552  # テスト結果 NG
2553  message = message + g_test_ng
2554  print message
2555  message = message + g_test_ng_message
2556  fout.write(message + '\n')
2557  # 受信データをテスト結果ファイルへコピー
2558  fin2 = open(g_diff_recv_file, 'r')
2559  while(1):
2560  s2 = fin2.readline()
2561  if len(s2) == 0:
2562  break
2563  fout.write(s2)
2564  fin2.close()
2565  fout.close()
2566 
2567  time.sleep(sleep_for_time)
2568 
2569 ##--------------------------------------------------------------------
2570 ## 接続タイプ：new 方向：out->in ポリシー：SKIP 接続・切断・Activate・Deactivateテスト1
2571 ##--------------------------------------------------------------------
2572 case_no = case_no + 1
2573 fout = open(g_test_result_file, 'a')
2574 message = g_mess_header + g_test_case + str(case_no) + " "
2575 message = message + "Connect(out->in, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
2576 message = message + g_mess_footer
2577 fout.write(message + '\n')
2578 fout.close()
2579 print message
2580 
2581 for i in range(loop_count):
2582 
2583  ## 2 受信データファイル削除
2584  delete_recv_file()
2585 
2586  ## 1 コネクタープロファイル設定
2587  make_connecter_profile("new", "SKIP", 0)
2588 
2589  ## 3 ポート接続
2590  # データポート1 TimedFloat
2591  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2592 
2593  # データポート2 TimedFloatSeq
2594  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2595 
2596  # サービスポート MyService
2597  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2598 
2599  ## 4 アクティベート
2600  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2601  time.sleep(sleep_recv_act_time)
2602  ec_send[0].activate_component(g_compo_send.rtc_ref)
2603 
2604  time.sleep(sleep_act_time)
2605 
2606  ## 5 ディアクティベート
2607  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2608  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2609 
2610  ## 6 ポート切断
2611  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2612  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2613  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2614 
2615  ## 受信ファイル有無判定
2616  if os.path.isfile(g_diff_recv_file) == False:
2617  fout = open(g_test_result_file, 'a')
2618  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2619  message = message + g_check_message
2620  fout.write(message + '\n')
2621  fout.close()
2622  print message
2623  time.sleep(sleep_for_time)
2624  continue
2625 
2626  ## 7 送受信データ比較
2627  time.sleep(sleep_act_time)
2628  bret = diff_file()
2629 
2630  ## 差分ファイルからテスト結果出力
2631  fout = open(g_test_result_file, 'a')
2632  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2633  # bret==True なら送受信データ一致
2634  if bret == True:
2635  # テスト結果 OK
2636  message = message + g_test_ok
2637  print message
2638  fout.write(message + '\n')
2639  else:
2640  # テスト結果 NG
2641  message = message + g_test_ng
2642  print message
2643  message = message + g_test_ng_message
2644  fout.write(message + '\n')
2645  # 受信データをテスト結果ファイルへコピー
2646  fin2 = open(g_diff_recv_file, 'r')
2647  while(1):
2648  s2 = fin2.readline()
2649  if len(s2) == 0:
2650  break
2651  fout.write(s2)
2652  fin2.close()
2653  fout.close()
2654 
2655  time.sleep(sleep_for_time)
2656 
2657 ##--------------------------------------------------------------------
2658 ## 接続タイプ：new 方向：in->out ポリシー：ALL 接続・切断・Activate・Deactivateテスト1
2659 ##--------------------------------------------------------------------
2660 case_no = case_no + 1
2661 fout = open(g_test_result_file, 'a')
2662 message = g_mess_header + g_test_case + str(case_no) + " "
2663 message = message + "Connect(in->out, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
2664 message = message + g_mess_footer
2665 fout.write(message + '\n')
2666 fout.close()
2667 print message
2668 
2669 for i in range(loop_count):
2670 
2671  ## 2 受信データファイル削除
2672  delete_recv_file()
2673 
2674  ## 1 コネクタープロファイル設定
2675  make_connecter_profile("new", "ALL", 1)
2676 
2677  ## 3 ポート接続
2678  # データポート1 TimedFloat
2679  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2680 
2681  # データポート2 TimedFloatSeq
2682  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2683 
2684  # サービスポート MyService
2685  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2686 
2687  ## 4 アクティベート
2688  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2689  time.sleep(sleep_recv_act_time)
2690  ec_send[0].activate_component(g_compo_send.rtc_ref)
2691 
2692  time.sleep(sleep_act_time)
2693 
2694  ## 5 ディアクティベート
2695  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2696  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2697 
2698  ## 6 ポート切断
2699  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2700  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2701  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2702 
2703  ## 受信ファイル有無判定
2704  if os.path.isfile(g_diff_recv_file) == False:
2705  fout = open(g_test_result_file, 'a')
2706  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2707  message = message + g_check_message
2708  fout.write(message + '\n')
2709  fout.close()
2710  print message
2711  time.sleep(sleep_for_time)
2712  continue
2713 
2714  ## 7 送受信データ比較
2715  time.sleep(sleep_act_time)
2716  bret = diff_file()
2717 
2718  ## 差分ファイルからテスト結果出力
2719  fout = open(g_test_result_file, 'a')
2720  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2721  # bret==True なら送受信データ一致
2722  if bret == True:
2723  # テスト結果 OK
2724  message = message + g_test_ok
2725  print message
2726  fout.write(message + '\n')
2727  else:
2728  # テスト結果 NG
2729  message = message + g_test_ng
2730  print message
2731  message = message + g_test_ng_message
2732  fout.write(message + '\n')
2733  # 受信データをテスト結果ファイルへコピー
2734  fin2 = open(g_diff_recv_file, 'r')
2735  while(1):
2736  s2 = fin2.readline()
2737  if len(s2) == 0:
2738  break
2739  fout.write(s2)
2740  fin2.close()
2741  fout.close()
2742 
2743  time.sleep(sleep_for_time)
2744 
2745 ##--------------------------------------------------------------------
2746 ## 接続タイプ：new 方向：in->out ポリシー：FIFO 接続・切断・Activate・Deactivateテスト1
2747 ##--------------------------------------------------------------------
2748 case_no = case_no + 1
2749 fout = open(g_test_result_file, 'a')
2750 message = g_mess_header + g_test_case + str(case_no) + " "
2751 message = message + "Connect(in->out, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
2752 message = message + g_mess_footer
2753 fout.write(message + '\n')
2754 fout.close()
2755 print message
2756 
2757 for i in range(loop_count):
2758 
2759  ## 2 受信データファイル削除
2760  delete_recv_file()
2761 
2762  ## 1 コネクタープロファイル設定
2763  make_connecter_profile("new", "FIFO", 1)
2764 
2765  ## 3 ポート接続
2766  # データポート1 TimedFloat
2767  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2768 
2769  # データポート2 TimedFloatSeq
2770  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2771 
2772  # サービスポート MyService
2773  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2774 
2775  ## 4 アクティベート
2776  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2777  time.sleep(sleep_recv_act_time)
2778  ec_send[0].activate_component(g_compo_send.rtc_ref)
2779 
2780  time.sleep(sleep_act_time)
2781 
2782  ## 5 ディアクティベート
2783  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2784  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2785 
2786  ## 6 ポート切断
2787  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2788  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2789  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2790 
2791  ## 受信ファイル有無判定
2792  if os.path.isfile(g_diff_recv_file) == False:
2793  fout = open(g_test_result_file, 'a')
2794  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2795  message = message + g_check_message
2796  fout.write(message + '\n')
2797  fout.close()
2798  print message
2799  time.sleep(sleep_for_time)
2800  continue
2801 
2802  ## 7 送受信データ比較
2803  time.sleep(sleep_act_time)
2804  bret = diff_file()
2805 
2806  ## 差分ファイルからテスト結果出力
2807  fout = open(g_test_result_file, 'a')
2808  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2809  # bret==True なら送受信データ一致
2810  if bret == True:
2811  # テスト結果 OK
2812  message = message + g_test_ok
2813  print message
2814  fout.write(message + '\n')
2815  else:
2816  # テスト結果 NG
2817  message = message + g_test_ng
2818  print message
2819  message = message + g_test_ng_message
2820  fout.write(message + '\n')
2821  # 受信データをテスト結果ファイルへコピー
2822  fin2 = open(g_diff_recv_file, 'r')
2823  while(1):
2824  s2 = fin2.readline()
2825  if len(s2) == 0:
2826  break
2827  fout.write(s2)
2828  fin2.close()
2829  fout.close()
2830 
2831  time.sleep(sleep_for_time)
2832 
2833 ##--------------------------------------------------------------------
2834 ## 接続タイプ：new 方向：in->out ポリシー：NEW 接続・切断・Activate・Deactivateテスト1
2835 ##--------------------------------------------------------------------
2836 case_no = case_no + 1
2837 fout = open(g_test_result_file, 'a')
2838 message = g_mess_header + g_test_case + str(case_no) + " "
2839 message = message + "Connect(in->out, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
2840 message = message + g_mess_footer
2841 fout.write(message + '\n')
2842 fout.close()
2843 print message
2844 
2845 for i in range(loop_count):
2846 
2847  ## 2 受信データファイル削除
2848  delete_recv_file()
2849 
2850  ## 1 コネクタープロファイル設定
2851  make_connecter_profile("new", "NEW", 1)
2852 
2853  ## 3 ポート接続
2854  # データポート1 TimedFloat
2855  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2856 
2857  # データポート2 TimedFloatSeq
2858  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2859 
2860  # サービスポート MyService
2861  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2862 
2863  ## 4 アクティベート
2864  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2865  time.sleep(sleep_recv_act_time)
2866  ec_send[0].activate_component(g_compo_send.rtc_ref)
2867 
2868  time.sleep(sleep_act_time)
2869 
2870  ## 5 ディアクティベート
2871  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2872  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2873 
2874  ## 6 ポート切断
2875  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2876  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2877  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2878 
2879  ## 受信ファイル有無判定
2880  if os.path.isfile(g_diff_recv_file) == False:
2881  fout = open(g_test_result_file, 'a')
2882  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2883  message = message + g_check_message
2884  fout.write(message + '\n')
2885  fout.close()
2886  print message
2887  time.sleep(sleep_for_time)
2888  continue
2889 
2890  ## 7 送受信データ比較
2891  time.sleep(sleep_act_time)
2892  bret = diff_file()
2893 
2894  ## 差分ファイルからテスト結果出力
2895  fout = open(g_test_result_file, 'a')
2896  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2897  # bret==True なら送受信データ一致
2898  if bret == True:
2899  # テスト結果 OK
2900  message = message + g_test_ok
2901  print message
2902  fout.write(message + '\n')
2903  else:
2904  # テスト結果 NG
2905  message = message + g_test_ng
2906  print message
2907  message = message + g_test_ng_message
2908  fout.write(message + '\n')
2909  # 受信データをテスト結果ファイルへコピー
2910  fin2 = open(g_diff_recv_file, 'r')
2911  while(1):
2912  s2 = fin2.readline()
2913  if len(s2) == 0:
2914  break
2915  fout.write(s2)
2916  fin2.close()
2917  fout.close()
2918 
2919  time.sleep(sleep_for_time)
2920 
2921 ##--------------------------------------------------------------------
2922 ## 接続タイプ：new 方向：in->out ポリシー：SKIP 接続・切断・Activate・Deactivateテスト1
2923 ##--------------------------------------------------------------------
2924 case_no = case_no + 1
2925 fout = open(g_test_result_file, 'a')
2926 message = g_mess_header + g_test_case + str(case_no) + " "
2927 message = message + "Connect(in->out, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
2928 message = message + g_mess_footer
2929 fout.write(message + '\n')
2930 fout.close()
2931 print message
2932 
2933 for i in range(loop_count):
2934 
2935  ## 2 受信データファイル削除
2936  delete_recv_file()
2937 
2938  ## 1 コネクタープロファイル設定
2939  make_connecter_profile("new", "SKIP", 1)
2940 
2941  ## 3 ポート接続
2942  # データポート1 TimedFloat
2943  ret0 = g_out_ports[g_port1].connect(g_conprof1)
2944 
2945  # データポート2 TimedFloatSeq
2946  ret1 = g_out_ports[g_port2].connect(g_conprof2)
2947 
2948  # サービスポート MyService
2949  ret2 = g_out_ports[g_port3].connect(g_conprof3)
2950 
2951  ## 4 アクティベート
2952  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2953  time.sleep(sleep_recv_act_time)
2954  ec_send[0].activate_component(g_compo_send.rtc_ref)
2955 
2956  time.sleep(sleep_act_time)
2957 
2958  ## 5 ディアクティベート
2959  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2960  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2961 
2962  ## 6 ポート切断
2963  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2964  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2965  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2966 
2967  ## 受信ファイル有無判定
2968  if os.path.isfile(g_diff_recv_file) == False:
2969  fout = open(g_test_result_file, 'a')
2970  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2971  message = message + g_check_message
2972  fout.write(message + '\n')
2973  fout.close()
2974  print message
2975  time.sleep(sleep_for_time)
2976  continue
2977 
2978  ## 7 送受信データ比較
2979  time.sleep(sleep_act_time)
2980  bret = diff_file()
2981 
2982  ## 差分ファイルからテスト結果出力
2983  fout = open(g_test_result_file, 'a')
2984  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
2985  # bret==True なら送受信データ一致
2986  if bret == True:
2987  # テスト結果 OK
2988  message = message + g_test_ok
2989  print message
2990  fout.write(message + '\n')
2991  else:
2992  # テスト結果 NG
2993  message = message + g_test_ng
2994  print message
2995  message = message + g_test_ng_message
2996  fout.write(message + '\n')
2997  # 受信データをテスト結果ファイルへコピー
2998  fin2 = open(g_diff_recv_file, 'r')
2999  while(1):
3000  s2 = fin2.readline()
3001  if len(s2) == 0:
3002  break
3003  fout.write(s2)
3004  fin2.close()
3005  fout.close()
3006 
3007  time.sleep(sleep_for_time)
3008 
3009 ##--------------------------------------------------------------------
3010 ##--------------------------------------------------------------------
3011 ## 接続タイプ：periodic 方向：out->in ポリシー：ALL 接続・切断テスト7
3012 ##--------------------------------------------------------------------
3013 case_no = case_no + 1
3014 fout = open(g_test_result_file, 'a')
3015 message = g_mess_header + g_test_case + str(case_no) + " "
3016 message = message + "Connect(out->in, periodic,ALL) -> Disconnect"
3017 message = message + g_mess_footer
3018 fout.write(message + '\n')
3019 fout.close()
3020 print message
3021 
3022 for i in range(loop_count):
3023 
3024  ## 1 コネクタープロファイル設定
3025  make_connecter_profile("periodic", "ALL", 0)
3026 
3027  ## 3 ポート接続
3028  # データポート1 TimedFloat
3029  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3030 
3031  # データポート2 TimedFloatSeq
3032  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3033 
3034  # サービスポート MyService
3035  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3036 
3037  time.sleep(sleep_connect_time)
3038 
3039  ## 6 ポート切断
3040  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3041  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3042  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3043 
3044  ## テスト結果出力
3045  fout = open(g_test_result_file, 'a')
3046  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3047  message = message + g_test_ok
3048  print message
3049  fout.write(message + '\n')
3050  fout.close()
3051 
3052  time.sleep(sleep_for_time)
3053 
3054 ##--------------------------------------------------------------------
3055 ## 接続タイプ：periodic 方向：out->in ポリシー：FIFO 接続・切断テスト8
3056 ##--------------------------------------------------------------------
3057 case_no = case_no + 1
3058 fout = open(g_test_result_file, 'a')
3059 message = g_mess_header + g_test_case + str(case_no) + " "
3060 message = message + "Connect(out->in, periodic,FIFO) -> Disconnect"
3061 message = message + g_mess_footer
3062 fout.write(message + '\n')
3063 fout.close()
3064 print message
3065 
3066 for i in range(loop_count):
3067 
3068  ## 1 コネクタープロファイル設定
3069  make_connecter_profile("periodic", "FIFO", 0)
3070 
3071  ## 3 ポート接続
3072  # データポート1 TimedFloat
3073  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3074 
3075  # データポート2 TimedFloatSeq
3076  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3077 
3078  # サービスポート MyService
3079  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3080 
3081  time.sleep(sleep_connect_time)
3082 
3083  ## 6 ポート切断
3084  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3085  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3086  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3087 
3088  ## テスト結果出力
3089  fout = open(g_test_result_file, 'a')
3090  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3091  message = message + g_test_ok
3092  print message
3093  fout.write(message + '\n')
3094  fout.close()
3095 
3096  time.sleep(sleep_for_time)
3097 
3098 ##--------------------------------------------------------------------
3099 ## 接続タイプ：periodic 方向：out->in ポリシー：NEW 接続・切断テスト10
3100 ##--------------------------------------------------------------------
3101 case_no = case_no + 1
3102 fout = open(g_test_result_file, 'a')
3103 message = g_mess_header + g_test_case + str(case_no) + " "
3104 message = message + "Connect(out->in, periodic,NEW) -> Disconnect"
3105 message = message + g_mess_footer
3106 fout.write(message + '\n')
3107 fout.close()
3108 print message
3109 
3110 for i in range(loop_count):
3111 
3112  ## 1 コネクタープロファイル設定
3113  make_connecter_profile("periodic", "NEW", 0)
3114 
3115  ## 3 ポート接続
3116  # データポート1 TimedFloat
3117  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3118 
3119  # データポート2 TimedFloatSeq
3120  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3121 
3122  # サービスポート MyService
3123  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3124 
3125  time.sleep(sleep_connect_time)
3126 
3127  ## 6 ポート切断
3128  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3129  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3130  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3131 
3132  ## テスト結果出力
3133  fout = open(g_test_result_file, 'a')
3134  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3135  message = message + g_test_ok
3136  print message
3137  fout.write(message + '\n')
3138  fout.close()
3139 
3140  time.sleep(sleep_for_time)
3141 
3142 ##--------------------------------------------------------------------
3143 ## 接続タイプ：periodic 方向：out->in ポリシー：SKIP 接続・切断テスト9
3144 ##--------------------------------------------------------------------
3145 case_no = case_no + 1
3146 fout = open(g_test_result_file, 'a')
3147 message = g_mess_header + g_test_case + str(case_no) + " "
3148 message = message + "Connect(out->in, periodic,SKIP) -> Disconnect"
3149 message = message + g_mess_footer
3150 fout.write(message + '\n')
3151 fout.close()
3152 print message
3153 
3154 for i in range(loop_count):
3155 
3156  ## 1 コネクタープロファイル設定
3157  make_connecter_profile("periodic", "SKIP", 0)
3158 
3159  ## 3 ポート接続
3160  # データポート1 TimedFloat
3161  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3162 
3163  # データポート2 TimedFloatSeq
3164  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3165 
3166  # サービスポート MyService
3167  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3168 
3169  time.sleep(sleep_connect_time)
3170 
3171  ## 6 ポート切断
3172  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3173  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3174  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3175 
3176  ## テスト結果出力
3177  fout = open(g_test_result_file, 'a')
3178  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3179  message = message + g_test_ok
3180  print message
3181  fout.write(message + '\n')
3182  fout.close()
3183 
3184  time.sleep(sleep_for_time)
3185 
3186 ##--------------------------------------------------------------------
3187 ## 接続タイプ：periodic 方向：in->out ポリシー：ALL 接続・切断テスト7
3188 ##--------------------------------------------------------------------
3189 case_no = case_no + 1
3190 fout = open(g_test_result_file, 'a')
3191 message = g_mess_header + g_test_case + str(case_no) + " "
3192 message = message + "Connect(in->out, periodic,ALL) -> Disconnect"
3193 message = message + g_mess_footer
3194 fout.write(message + '\n')
3195 fout.close()
3196 print message
3197 
3198 for i in range(loop_count):
3199 
3200  ## 1 コネクタープロファイル設定
3201  make_connecter_profile("periodic", "ALL", 1)
3202 
3203  ## 3 ポート接続
3204  # データポート1 TimedFloat
3205  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3206 
3207  # データポート2 TimedFloatSeq
3208  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3209 
3210  # サービスポート MyService
3211  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3212 
3213  time.sleep(sleep_connect_time)
3214 
3215  ## 6 ポート切断
3216  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3217  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3218  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3219 
3220  ## テスト結果出力
3221  fout = open(g_test_result_file, 'a')
3222  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3223  message = message + g_test_ok
3224  print message
3225  fout.write(message + '\n')
3226  fout.close()
3227 
3228  time.sleep(sleep_for_time)
3229 
3230 ##--------------------------------------------------------------------
3231 ## 接続タイプ：periodic 方向：in->out ポリシー：FIFO 接続・切断テスト8
3232 ##--------------------------------------------------------------------
3233 case_no = case_no + 1
3234 fout = open(g_test_result_file, 'a')
3235 message = g_mess_header + g_test_case + str(case_no) + " "
3236 message = message + "Connect(in->out, periodic,FIFO) -> Disconnect"
3237 message = message + g_mess_footer
3238 fout.write(message + '\n')
3239 fout.close()
3240 print message
3241 
3242 for i in range(loop_count):
3243 
3244  ## 1 コネクタープロファイル設定
3245  make_connecter_profile("periodic", "FIFO", 1)
3246 
3247  ## 3 ポート接続
3248  # データポート1 TimedFloat
3249  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3250 
3251  # データポート2 TimedFloatSeq
3252  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3253 
3254  # サービスポート MyService
3255  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3256 
3257  time.sleep(sleep_connect_time)
3258 
3259  ## 6 ポート切断
3260  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3261  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3262  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3263 
3264  ## テスト結果出力
3265  fout = open(g_test_result_file, 'a')
3266  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3267  message = message + g_test_ok
3268  print message
3269  fout.write(message + '\n')
3270  fout.close()
3271 
3272  time.sleep(sleep_for_time)
3273 
3274 ##--------------------------------------------------------------------
3275 ## 接続タイプ：periodic 方向：in->out ポリシー：NEW 接続・切断テスト10
3276 ##--------------------------------------------------------------------
3277 case_no = case_no + 1
3278 fout = open(g_test_result_file, 'a')
3279 message = g_mess_header + g_test_case + str(case_no) + " "
3280 message = message + "Connect(in->out, periodic,NEW) -> Disconnect"
3281 message = message + g_mess_footer
3282 fout.write(message + '\n')
3283 fout.close()
3284 print message
3285 
3286 for i in range(loop_count):
3287 
3288  ## 1 コネクタープロファイル設定
3289  make_connecter_profile("periodic", "NEW", 1)
3290 
3291  ## 3 ポート接続
3292  # データポート1 TimedFloat
3293  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3294 
3295  # データポート2 TimedFloatSeq
3296  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3297 
3298  # サービスポート MyService
3299  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3300 
3301  time.sleep(sleep_connect_time)
3302 
3303  ## 6 ポート切断
3304  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3305  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3306  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3307 
3308  ## テスト結果出力
3309  fout = open(g_test_result_file, 'a')
3310  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3311  message = message + g_test_ok
3312  print message
3313  fout.write(message + '\n')
3314  fout.close()
3315 
3316  time.sleep(sleep_for_time)
3317 
3318 ##--------------------------------------------------------------------
3319 ## 接続タイプ：periodic 方向：in->out ポリシー：SKIP 接続・切断テスト9
3320 ##--------------------------------------------------------------------
3321 case_no = case_no + 1
3322 fout = open(g_test_result_file, 'a')
3323 message = g_mess_header + g_test_case + str(case_no) + " "
3324 message = message + "Connect(in->out, periodic,SKIP) -> Disconnect"
3325 message = message + g_mess_footer
3326 fout.write(message + '\n')
3327 fout.close()
3328 print message
3329 
3330 for i in range(loop_count):
3331 
3332  ## 1 コネクタープロファイル設定
3333  make_connecter_profile("periodic", "SKIP", 1)
3334 
3335  ## 3 ポート接続
3336  # データポート1 TimedFloat
3337  ret0 = g_out_ports[g_port1].connect(g_conprof1)
3338 
3339  # データポート2 TimedFloatSeq
3340  ret1 = g_out_ports[g_port2].connect(g_conprof2)
3341 
3342  # サービスポート MyService
3343  ret2 = g_out_ports[g_port3].connect(g_conprof3)
3344 
3345  time.sleep(sleep_connect_time)
3346 
3347  ## 6 ポート切断
3348  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3349  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3350  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3351 
3352  ## テスト結果出力
3353  fout = open(g_test_result_file, 'a')
3354  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3355  message = message + g_test_ok
3356  print message
3357  fout.write(message + '\n')
3358  fout.close()
3359 
3360  time.sleep(sleep_for_time)
3361 
3362 ##--------------------------------------------------------------------
3363 ## 接続タイプ：periodic 方向：out->in ポリシー：ALL Activate・Deactivateテスト6
3364 ##--------------------------------------------------------------------
3365 case_no = case_no + 1
3366 fout = open(g_test_result_file, 'a')
3367 message = g_mess_header + g_test_case + str(case_no) + " "
3368 message = message + "Connecting(out->in, periodic,ALL), Activate -> send/recv -> Deactivate"
3369 message = message + g_mess_footer
3370 fout.write(message + '\n')
3371 fout.close()
3372 print message
3373 
3374 ## 1 コネクタープロファイル設定
3375 make_connecter_profile("periodic", "ALL", 0)
3376 
3377 ## 3 ポート接続
3378 # データポート1 TimedFloat
3379 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3380 
3381 # データポート2 TimedFloatSeq
3382 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3383 
3384 # サービスポート MyService
3385 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3386 
3387 for i in range(loop_count):
3388 
3389  ## 2 受信データファイル削除
3390  delete_recv_file()
3391 
3392  ## 4 アクティベート
3393  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3394  time.sleep(sleep_recv_act_time)
3395  ec_send[0].activate_component(g_compo_send.rtc_ref)
3396 
3397  time.sleep(sleep_act_time)
3398 
3399  ## 5 ディアクティベート
3400  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3401  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3402 
3403  ## 受信ファイル有無判定
3404  if os.path.isfile(g_diff_recv_file) == False:
3405  fout = open(g_test_result_file, 'a')
3406  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3407  message = message + g_check_message
3408  fout.write(message + '\n')
3409  fout.close()
3410  print message
3411  time.sleep(sleep_for_time)
3412  continue
3413 
3414  ## 7 送受信データ比較
3415  time.sleep(sleep_act_time)
3416  bret = diff_file()
3417 
3418  ## 差分ファイルからテスト結果出力
3419  fout = open(g_test_result_file, 'a')
3420  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3421  # bret==True なら送受信データ一致
3422  if bret == True:
3423  # テスト結果 OK
3424  message = message + g_test_ok
3425  print message
3426  fout.write(message + '\n')
3427  else:
3428  # テスト結果 NG
3429  message = message + g_test_ng
3430  print message
3431  message = message + g_test_ng_message
3432  fout.write(message + '\n')
3433  # 受信データをテスト結果ファイルへコピー
3434  fin2 = open(g_diff_recv_file, 'r')
3435  while(1):
3436  s2 = fin2.readline()
3437  if len(s2) == 0:
3438  break
3439  fout.write(s2)
3440  fin2.close()
3441  fout.close()
3442 
3443  time.sleep(sleep_for_time)
3444 
3445 ## 6 ポート切断
3446 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3447 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3448 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3449 
3450 ##--------------------------------------------------------------------
3451 ## 接続タイプ：periodic 方向：out->in ポリシー：FIFO Activate・Deactivateテスト7
3452 ##--------------------------------------------------------------------
3453 case_no = case_no + 1
3454 fout = open(g_test_result_file, 'a')
3455 message = g_mess_header + g_test_case + str(case_no) + " "
3456 message = message + "Connecting(out->in, periodic,FIFO), Activate -> send/recv -> Deactivate"
3457 message = message + g_mess_footer
3458 fout.write(message + '\n')
3459 fout.close()
3460 print message
3461 
3462 ## 1 コネクタープロファイル設定
3463 make_connecter_profile("periodic", "FIFO", 0)
3464 
3465 ## 3 ポート接続
3466 # データポート1 TimedFloat
3467 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3468 
3469 # データポート2 TimedFloatSeq
3470 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3471 
3472 # サービスポート MyService
3473 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3474 
3475 for i in range(loop_count):
3476 
3477  ## 2 受信データファイル削除
3478  delete_recv_file()
3479 
3480  ## 4 アクティベート
3481  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3482  time.sleep(sleep_recv_act_time)
3483  ec_send[0].activate_component(g_compo_send.rtc_ref)
3484 
3485  time.sleep(sleep_act_time)
3486 
3487  ## 5 ディアクティベート
3488  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3489  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3490 
3491  ## 受信ファイル有無判定
3492  if os.path.isfile(g_diff_recv_file) == False:
3493  fout = open(g_test_result_file, 'a')
3494  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3495  message = message + g_check_message
3496  fout.write(message + '\n')
3497  fout.close()
3498  print message
3499  time.sleep(sleep_for_time)
3500  continue
3501 
3502  ## 7 送受信データ比較
3503  time.sleep(sleep_act_time)
3504  bret = diff_file()
3505 
3506  ## 差分ファイルからテスト結果出力
3507  fout = open(g_test_result_file, 'a')
3508  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3509  # bret==True なら送受信データ一致
3510  if bret == True:
3511  # テスト結果 OK
3512  message = message + g_test_ok
3513  print message
3514  fout.write(message + '\n')
3515  else:
3516  # テスト結果 NG
3517  message = message + g_test_ng
3518  print message
3519  message = message + g_test_ng_message
3520  fout.write(message + '\n')
3521  # 受信データをテスト結果ファイルへコピー
3522  fin2 = open(g_diff_recv_file, 'r')
3523  while(1):
3524  s2 = fin2.readline()
3525  if len(s2) == 0:
3526  break
3527  fout.write(s2)
3528  fin2.close()
3529  fout.close()
3530 
3531  time.sleep(sleep_for_time)
3532 
3533 ## 6 ポート切断
3534 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3535 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3536 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3537 
3538 ##--------------------------------------------------------------------
3539 ## 接続タイプ：periodic 方向：out->in ポリシー：NEW Activate・Deactivateテスト9
3540 ##--------------------------------------------------------------------
3541 case_no = case_no + 1
3542 fout = open(g_test_result_file, 'a')
3543 message = g_mess_header + g_test_case + str(case_no) + " "
3544 message = message + "Connecting(out->in, periodic,NEW), Activate -> send/recv -> Deactivate"
3545 message = message + g_mess_footer
3546 fout.write(message + '\n')
3547 fout.close()
3548 print message
3549 
3550 ## 1 コネクタープロファイル設定
3551 make_connecter_profile("periodic", "NEW", 0)
3552 
3553 ## 3 ポート接続
3554 # データポート1 TimedFloat
3555 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3556 
3557 # データポート2 TimedFloatSeq
3558 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3559 
3560 # サービスポート MyService
3561 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3562 
3563 for i in range(loop_count):
3564 
3565  ## 2 受信データファイル削除
3566  delete_recv_file()
3567 
3568  ## 4 アクティベート
3569  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3570  time.sleep(sleep_recv_act_time)
3571  ec_send[0].activate_component(g_compo_send.rtc_ref)
3572 
3573  time.sleep(sleep_act_time)
3574 
3575  ## 5 ディアクティベート
3576  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3577  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3578 
3579  ## 受信ファイル有無判定
3580  if os.path.isfile(g_diff_recv_file) == False:
3581  fout = open(g_test_result_file, 'a')
3582  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3583  message = message + g_check_message
3584  fout.write(message + '\n')
3585  fout.close()
3586  print message
3587  time.sleep(sleep_for_time)
3588  continue
3589 
3590  ## 7 送受信データ比較
3591  time.sleep(sleep_act_time)
3592  bret = diff_file()
3593 
3594  ## 差分ファイルからテスト結果出力
3595  fout = open(g_test_result_file, 'a')
3596  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3597  # bret==True なら送受信データ一致
3598  if bret == True:
3599  # テスト結果 OK
3600  message = message + g_test_ok
3601  print message
3602  fout.write(message + '\n')
3603  else:
3604  # テスト結果 NG
3605  message = message + g_test_ng
3606  print message
3607  message = message + g_test_ng_message
3608  fout.write(message + '\n')
3609  # 受信データをテスト結果ファイルへコピー
3610  fin2 = open(g_diff_recv_file, 'r')
3611  while(1):
3612  s2 = fin2.readline()
3613  if len(s2) == 0:
3614  break
3615  fout.write(s2)
3616  fin2.close()
3617  fout.close()
3618 
3619  time.sleep(sleep_for_time)
3620 
3621 ## 6 ポート切断
3622 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3623 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3624 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3625 
3626 ##--------------------------------------------------------------------
3627 ## 接続タイプ：periodic 方向：out->in ポリシー：SKIP Activate・Deactivateテスト8
3628 ##--------------------------------------------------------------------
3629 case_no = case_no + 1
3630 fout = open(g_test_result_file, 'a')
3631 message = g_mess_header + g_test_case + str(case_no) + " "
3632 message = message + "Connecting(out->in, periodic,SKIP), Activate -> send/recv -> Deactivate"
3633 message = message + g_mess_footer
3634 fout.write(message + '\n')
3635 fout.close()
3636 print message
3637 
3638 ## 1 コネクタープロファイル設定
3639 make_connecter_profile("periodic", "SKIP", 0)
3640 
3641 ## 3 ポート接続
3642 # データポート1 TimedFloat
3643 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3644 
3645 # データポート2 TimedFloatSeq
3646 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3647 
3648 # サービスポート MyService
3649 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3650 
3651 for i in range(loop_count):
3652 
3653  ## 2 受信データファイル削除
3654  delete_recv_file()
3655 
3656  ## 4 アクティベート
3657  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3658  time.sleep(sleep_recv_act_time)
3659  ec_send[0].activate_component(g_compo_send.rtc_ref)
3660 
3661  time.sleep(sleep_act_time)
3662 
3663  ## 5 ディアクティベート
3664  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3665  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3666 
3667  ## 受信ファイル有無判定
3668  if os.path.isfile(g_diff_recv_file) == False:
3669  fout = open(g_test_result_file, 'a')
3670  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3671  message = message + g_check_message
3672  fout.write(message + '\n')
3673  fout.close()
3674  print message
3675  time.sleep(sleep_for_time)
3676  continue
3677 
3678  ## 7 送受信データ比較
3679  time.sleep(sleep_act_time)
3680  bret = diff_file()
3681 
3682  ## 差分ファイルからテスト結果出力
3683  fout = open(g_test_result_file, 'a')
3684  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3685  # bret==True なら送受信データ一致
3686  if bret == True:
3687  # テスト結果 OK
3688  message = message + g_test_ok
3689  print message
3690  fout.write(message + '\n')
3691  else:
3692  # テスト結果 NG
3693  message = message + g_test_ng
3694  print message
3695  message = message + g_test_ng_message
3696  fout.write(message + '\n')
3697  # 受信データをテスト結果ファイルへコピー
3698  fin2 = open(g_diff_recv_file, 'r')
3699  while(1):
3700  s2 = fin2.readline()
3701  if len(s2) == 0:
3702  break
3703  fout.write(s2)
3704  fin2.close()
3705  fout.close()
3706 
3707  time.sleep(sleep_for_time)
3708 
3709 ## 6 ポート切断
3710 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3711 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3712 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3713 
3714 ##--------------------------------------------------------------------
3715 ## 接続タイプ：periodic 方向：in->out ポリシー：ALL Activate・Deactivateテスト6
3716 ##--------------------------------------------------------------------
3717 case_no = case_no + 1
3718 fout = open(g_test_result_file, 'a')
3719 message = g_mess_header + g_test_case + str(case_no) + " "
3720 message = message + "Connecting(in->out, periodic,ALL), Activate -> send/recv -> Deactivate"
3721 message = message + g_mess_footer
3722 fout.write(message + '\n')
3723 fout.close()
3724 print message
3725 
3726 ## 1 コネクタープロファイル設定
3727 make_connecter_profile("periodic", "ALL", 1)
3728 
3729 ## 3 ポート接続
3730 # データポート1 TimedFloat
3731 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3732 
3733 # データポート2 TimedFloatSeq
3734 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3735 
3736 # サービスポート MyService
3737 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3738 
3739 for i in range(loop_count):
3740 
3741  ## 2 受信データファイル削除
3742  delete_recv_file()
3743 
3744  ## 4 アクティベート
3745  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3746  time.sleep(sleep_recv_act_time)
3747  ec_send[0].activate_component(g_compo_send.rtc_ref)
3748 
3749  time.sleep(sleep_act_time)
3750 
3751  ## 5 ディアクティベート
3752  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3753  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3754 
3755  ## 受信ファイル有無判定
3756  if os.path.isfile(g_diff_recv_file) == False:
3757  fout = open(g_test_result_file, 'a')
3758  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3759  message = message + g_check_message
3760  fout.write(message + '\n')
3761  fout.close()
3762  print message
3763  time.sleep(sleep_for_time)
3764  continue
3765 
3766  ## 7 送受信データ比較
3767  time.sleep(sleep_act_time)
3768  bret = diff_file()
3769 
3770  ## 差分ファイルからテスト結果出力
3771  fout = open(g_test_result_file, 'a')
3772  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3773  # bret==True なら送受信データ一致
3774  if bret == True:
3775  # テスト結果 OK
3776  message = message + g_test_ok
3777  print message
3778  fout.write(message + '\n')
3779  else:
3780  # テスト結果 NG
3781  message = message + g_test_ng
3782  print message
3783  message = message + g_test_ng_message
3784  fout.write(message + '\n')
3785  # 受信データをテスト結果ファイルへコピー
3786  fin2 = open(g_diff_recv_file, 'r')
3787  while(1):
3788  s2 = fin2.readline()
3789  if len(s2) == 0:
3790  break
3791  fout.write(s2)
3792  fin2.close()
3793  fout.close()
3794 
3795  time.sleep(sleep_for_time)
3796 
3797 ## 6 ポート切断
3798 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3799 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3800 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3801 
3802 ##--------------------------------------------------------------------
3803 ## 接続タイプ：periodic 方向：in->out ポリシー：FIFO Activate・Deactivateテスト7
3804 ##--------------------------------------------------------------------
3805 case_no = case_no + 1
3806 fout = open(g_test_result_file, 'a')
3807 message = g_mess_header + g_test_case + str(case_no) + " "
3808 message = message + "Connecting(in->out, periodic,FIFO), Activate -> send/recv -> Deactivate"
3809 message = message + g_mess_footer
3810 fout.write(message + '\n')
3811 fout.close()
3812 print message
3813 
3814 ## 1 コネクタープロファイル設定
3815 make_connecter_profile("periodic", "FIFO", 1)
3816 
3817 ## 3 ポート接続
3818 # データポート1 TimedFloat
3819 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3820 
3821 # データポート2 TimedFloatSeq
3822 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3823 
3824 # サービスポート MyService
3825 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3826 
3827 for i in range(loop_count):
3828 
3829  ## 2 受信データファイル削除
3830  delete_recv_file()
3831 
3832  ## 4 アクティベート
3833  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3834  time.sleep(sleep_recv_act_time)
3835  ec_send[0].activate_component(g_compo_send.rtc_ref)
3836 
3837  time.sleep(sleep_act_time)
3838 
3839  ## 5 ディアクティベート
3840  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3841  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3842 
3843  ## 受信ファイル有無判定
3844  if os.path.isfile(g_diff_recv_file) == False:
3845  fout = open(g_test_result_file, 'a')
3846  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3847  message = message + g_check_message
3848  fout.write(message + '\n')
3849  fout.close()
3850  print message
3851  time.sleep(sleep_for_time)
3852  continue
3853 
3854  ## 7 送受信データ比較
3855  time.sleep(sleep_act_time)
3856  bret = diff_file()
3857 
3858  ## 差分ファイルからテスト結果出力
3859  fout = open(g_test_result_file, 'a')
3860  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3861  # bret==True なら送受信データ一致
3862  if bret == True:
3863  # テスト結果 OK
3864  message = message + g_test_ok
3865  print message
3866  fout.write(message + '\n')
3867  else:
3868  # テスト結果 NG
3869  message = message + g_test_ng
3870  print message
3871  message = message + g_test_ng_message
3872  fout.write(message + '\n')
3873  # 受信データをテスト結果ファイルへコピー
3874  fin2 = open(g_diff_recv_file, 'r')
3875  while(1):
3876  s2 = fin2.readline()
3877  if len(s2) == 0:
3878  break
3879  fout.write(s2)
3880  fin2.close()
3881  fout.close()
3882 
3883  time.sleep(sleep_for_time)
3884 
3885 ## 6 ポート切断
3886 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3887 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3888 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3889 
3890 ##--------------------------------------------------------------------
3891 ## 接続タイプ：periodic 方向：in->out ポリシー：NEW Activate・Deactivateテスト9
3892 ##--------------------------------------------------------------------
3893 case_no = case_no + 1
3894 fout = open(g_test_result_file, 'a')
3895 message = g_mess_header + g_test_case + str(case_no) + " "
3896 message = message + "Connecting(in->out, periodic,NEW), Activate -> send/recv -> Deactivate"
3897 message = message + g_mess_footer
3898 fout.write(message + '\n')
3899 fout.close()
3900 print message
3901 
3902 ## 1 コネクタープロファイル設定
3903 make_connecter_profile("periodic", "NEW", 1)
3904 
3905 ## 3 ポート接続
3906 # データポート1 TimedFloat
3907 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3908 
3909 # データポート2 TimedFloatSeq
3910 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3911 
3912 # サービスポート MyService
3913 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3914 
3915 for i in range(loop_count):
3916 
3917  ## 2 受信データファイル削除
3918  delete_recv_file()
3919 
3920  ## 4 アクティベート
3921  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3922  time.sleep(sleep_recv_act_time)
3923  ec_send[0].activate_component(g_compo_send.rtc_ref)
3924 
3925  time.sleep(sleep_act_time)
3926 
3927  ## 5 ディアクティベート
3928  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3929  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3930 
3931  ## 受信ファイル有無判定
3932  if os.path.isfile(g_diff_recv_file) == False:
3933  fout = open(g_test_result_file, 'a')
3934  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3935  message = message + g_check_message
3936  fout.write(message + '\n')
3937  fout.close()
3938  print message
3939  time.sleep(sleep_for_time)
3940  continue
3941 
3942  ## 7 送受信データ比較
3943  time.sleep(sleep_act_time)
3944  bret = diff_file()
3945 
3946  ## 差分ファイルからテスト結果出力
3947  fout = open(g_test_result_file, 'a')
3948  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
3949  # bret==True なら送受信データ一致
3950  if bret == True:
3951  # テスト結果 OK
3952  message = message + g_test_ok
3953  print message
3954  fout.write(message + '\n')
3955  else:
3956  # テスト結果 NG
3957  message = message + g_test_ng
3958  print message
3959  message = message + g_test_ng_message
3960  fout.write(message + '\n')
3961  # 受信データをテスト結果ファイルへコピー
3962  fin2 = open(g_diff_recv_file, 'r')
3963  while(1):
3964  s2 = fin2.readline()
3965  if len(s2) == 0:
3966  break
3967  fout.write(s2)
3968  fin2.close()
3969  fout.close()
3970 
3971  time.sleep(sleep_for_time)
3972 
3973 ## 6 ポート切断
3974 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3975 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3976 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3977 
3978 ##--------------------------------------------------------------------
3979 ## 接続タイプ：periodic 方向：in->out ポリシー：SKIP Activate・Deactivateテスト8
3980 ##--------------------------------------------------------------------
3981 case_no = case_no + 1
3982 fout = open(g_test_result_file, 'a')
3983 message = g_mess_header + g_test_case + str(case_no) + " "
3984 message = message + "Connecting(in->out, periodic,SKIP), Activate -> send/recv -> Deactivate"
3985 message = message + g_mess_footer
3986 fout.write(message + '\n')
3987 fout.close()
3988 print message
3989 
3990 ## 1 コネクタープロファイル設定
3991 make_connecter_profile("periodic", "SKIP", 1)
3992 
3993 ## 3 ポート接続
3994 # データポート1 TimedFloat
3995 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3996 
3997 # データポート2 TimedFloatSeq
3998 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3999 
4000 # サービスポート MyService
4001 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4002 
4003 for i in range(loop_count):
4004 
4005  ## 2 受信データファイル削除
4006  delete_recv_file()
4007 
4008  ## 4 アクティベート
4009  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4010  time.sleep(sleep_recv_act_time)
4011  ec_send[0].activate_component(g_compo_send.rtc_ref)
4012 
4013  time.sleep(sleep_act_time)
4014 
4015  ## 5 ディアクティベート
4016  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4017  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4018 
4019  ## 受信ファイル有無判定
4020  if os.path.isfile(g_diff_recv_file) == False:
4021  fout = open(g_test_result_file, 'a')
4022  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4023  message = message + g_check_message
4024  fout.write(message + '\n')
4025  fout.close()
4026  print message
4027  time.sleep(sleep_for_time)
4028  continue
4029 
4030  ## 7 送受信データ比較
4031  time.sleep(sleep_act_time)
4032  bret = diff_file()
4033 
4034  ## 差分ファイルからテスト結果出力
4035  fout = open(g_test_result_file, 'a')
4036  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4037  # bret==True なら送受信データ一致
4038  if bret == True:
4039  # テスト結果 OK
4040  message = message + g_test_ok
4041  print message
4042  fout.write(message + '\n')
4043  else:
4044  # テスト結果 NG
4045  message = message + g_test_ng
4046  print message
4047  message = message + g_test_ng_message
4048  fout.write(message + '\n')
4049  # 受信データをテスト結果ファイルへコピー
4050  fin2 = open(g_diff_recv_file, 'r')
4051  while(1):
4052  s2 = fin2.readline()
4053  if len(s2) == 0:
4054  break
4055  fout.write(s2)
4056  fin2.close()
4057  fout.close()
4058 
4059  time.sleep(sleep_for_time)
4060 
4061 ## 6 ポート切断
4062 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4063 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4064 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4065 
4066 ##--------------------------------------------------------------------
4067 ## 接続タイプ：periodic 方向：out->in ポリシー：ALL 接続・切断・Activate・Deactivateテスト1
4068 ##--------------------------------------------------------------------
4069 case_no = case_no + 1
4070 fout = open(g_test_result_file, 'a')
4071 message = g_mess_header + g_test_case + str(case_no) + " "
4072 message = message + "Connect(out->in, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
4073 message = message + g_mess_footer
4074 fout.write(message + '\n')
4075 fout.close()
4076 print message
4077 
4078 for i in range(loop_count):
4079 
4080  ## 2 受信データファイル削除
4081  delete_recv_file()
4082 
4083  ## 1 コネクタープロファイル設定
4084  make_connecter_profile("periodic", "ALL", 0)
4085 
4086  ## 3 ポート接続
4087  # データポート1 TimedFloat
4088  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4089 
4090  # データポート2 TimedFloatSeq
4091  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4092 
4093  # サービスポート MyService
4094  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4095 
4096  ## 4 アクティベート
4097  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4098  time.sleep(sleep_recv_act_time)
4099  ec_send[0].activate_component(g_compo_send.rtc_ref)
4100 
4101  time.sleep(sleep_act_time)
4102 
4103  ## 5 ディアクティベート
4104  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4105  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4106 
4107  ## 6 ポート切断
4108  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4109  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4110  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4111 
4112  ## 受信ファイル有無判定
4113  if os.path.isfile(g_diff_recv_file) == False:
4114  fout = open(g_test_result_file, 'a')
4115  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4116  message = message + g_check_message
4117  fout.write(message + '\n')
4118  fout.close()
4119  print message
4120  time.sleep(sleep_for_time)
4121  continue
4122 
4123  ## 7 送受信データ比較
4124  time.sleep(sleep_act_time)
4125  bret = diff_file()
4126 
4127  ## 差分ファイルからテスト結果出力
4128  fout = open(g_test_result_file, 'a')
4129  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4130  # bret==True なら送受信データ一致
4131  if bret == True:
4132  # テスト結果 OK
4133  message = message + g_test_ok
4134  print message
4135  fout.write(message + '\n')
4136  else:
4137  # テスト結果 NG
4138  message = message + g_test_ng
4139  print message
4140  message = message + g_test_ng_message
4141  fout.write(message + '\n')
4142  # 受信データをテスト結果ファイルへコピー
4143  fin2 = open(g_diff_recv_file, 'r')
4144  while(1):
4145  s2 = fin2.readline()
4146  if len(s2) == 0:
4147  break
4148  fout.write(s2)
4149  fin2.close()
4150  fout.close()
4151 
4152  time.sleep(sleep_for_time)
4153 
4154 ##--------------------------------------------------------------------
4155 ## 接続タイプ：periodic 方向：out->in ポリシー：FIFO 接続・切断・Activate・Deactivateテスト1
4156 ##--------------------------------------------------------------------
4157 case_no = case_no + 1
4158 fout = open(g_test_result_file, 'a')
4159 message = g_mess_header + g_test_case + str(case_no) + " "
4160 message = message + "Connect(out->in, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
4161 message = message + g_mess_footer
4162 fout.write(message + '\n')
4163 fout.close()
4164 print message
4165 
4166 for i in range(loop_count):
4167 
4168  ## 2 受信データファイル削除
4169  delete_recv_file()
4170 
4171  ## 1 コネクタープロファイル設定
4172  make_connecter_profile("periodic", "FIFO", 0)
4173 
4174  ## 3 ポート接続
4175  # データポート1 TimedFloat
4176  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4177 
4178  # データポート2 TimedFloatSeq
4179  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4180 
4181  # サービスポート MyService
4182  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4183 
4184  ## 4 アクティベート
4185  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4186  time.sleep(sleep_recv_act_time)
4187  ec_send[0].activate_component(g_compo_send.rtc_ref)
4188 
4189  time.sleep(sleep_act_time)
4190 
4191  ## 5 ディアクティベート
4192  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4193  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4194 
4195  ## 6 ポート切断
4196  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4197  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4198  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4199 
4200  ## 受信ファイル有無判定
4201  if os.path.isfile(g_diff_recv_file) == False:
4202  fout = open(g_test_result_file, 'a')
4203  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4204  message = message + g_check_message
4205  fout.write(message + '\n')
4206  fout.close()
4207  print message
4208  time.sleep(sleep_for_time)
4209  continue
4210 
4211  ## 7 送受信データ比較
4212  time.sleep(sleep_act_time)
4213  bret = diff_file()
4214 
4215  ## 差分ファイルからテスト結果出力
4216  fout = open(g_test_result_file, 'a')
4217  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4218  # bret==True なら送受信データ一致
4219  if bret == True:
4220  # テスト結果 OK
4221  message = message + g_test_ok
4222  print message
4223  fout.write(message + '\n')
4224  else:
4225  # テスト結果 NG
4226  message = message + g_test_ng
4227  print message
4228  message = message + g_test_ng_message
4229  fout.write(message + '\n')
4230  # 受信データをテスト結果ファイルへコピー
4231  fin2 = open(g_diff_recv_file, 'r')
4232  while(1):
4233  s2 = fin2.readline()
4234  if len(s2) == 0:
4235  break
4236  fout.write(s2)
4237  fin2.close()
4238  fout.close()
4239 
4240  time.sleep(sleep_for_time)
4241 
4242 ##--------------------------------------------------------------------
4243 ## 接続タイプ：periodic 方向：out->in ポリシー：NEW 接続・切断・Activate・Deactivateテスト1
4244 ##--------------------------------------------------------------------
4245 case_no = case_no + 1
4246 fout = open(g_test_result_file, 'a')
4247 message = g_mess_header + g_test_case + str(case_no) + " "
4248 message = message + "Connect(out->in, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
4249 message = message + g_mess_footer
4250 fout.write(message + '\n')
4251 fout.close()
4252 print message
4253 
4254 for i in range(loop_count):
4255 
4256  ## 2 受信データファイル削除
4257  delete_recv_file()
4258 
4259  ## 1 コネクタープロファイル設定
4260  make_connecter_profile("periodic", "NEW", 0)
4261 
4262  ## 3 ポート接続
4263  # データポート1 TimedFloat
4264  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4265 
4266  # データポート2 TimedFloatSeq
4267  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4268 
4269  # サービスポート MyService
4270  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4271 
4272  ## 4 アクティベート
4273  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4274  time.sleep(sleep_recv_act_time)
4275  ec_send[0].activate_component(g_compo_send.rtc_ref)
4276 
4277  time.sleep(sleep_act_time)
4278 
4279  ## 5 ディアクティベート
4280  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4281  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4282 
4283  ## 6 ポート切断
4284  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4285  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4286  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4287 
4288  ## 受信ファイル有無判定
4289  if os.path.isfile(g_diff_recv_file) == False:
4290  fout = open(g_test_result_file, 'a')
4291  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4292  message = message + g_check_message
4293  fout.write(message + '\n')
4294  fout.close()
4295  print message
4296  time.sleep(sleep_for_time)
4297  continue
4298 
4299  ## 7 送受信データ比較
4300  time.sleep(sleep_act_time)
4301  bret = diff_file()
4302 
4303  ## 差分ファイルからテスト結果出力
4304  fout = open(g_test_result_file, 'a')
4305  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4306  # bret==True なら送受信データ一致
4307  if bret == True:
4308  # テスト結果 OK
4309  message = message + g_test_ok
4310  print message
4311  fout.write(message + '\n')
4312  else:
4313  # テスト結果 NG
4314  message = message + g_test_ng
4315  print message
4316  message = message + g_test_ng_message
4317  fout.write(message + '\n')
4318  # 受信データをテスト結果ファイルへコピー
4319  fin2 = open(g_diff_recv_file, 'r')
4320  while(1):
4321  s2 = fin2.readline()
4322  if len(s2) == 0:
4323  break
4324  fout.write(s2)
4325  fin2.close()
4326  fout.close()
4327 
4328  time.sleep(sleep_for_time)
4329 
4330 ##--------------------------------------------------------------------
4331 ## 接続タイプ：periodic 方向：out->in ポリシー：SKIP 接続・切断・Activate・Deactivateテスト1
4332 ##--------------------------------------------------------------------
4333 case_no = case_no + 1
4334 fout = open(g_test_result_file, 'a')
4335 message = g_mess_header + g_test_case + str(case_no) + " "
4336 message = message + "Connect(out->in, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
4337 message = message + g_mess_footer
4338 fout.write(message + '\n')
4339 fout.close()
4340 print message
4341 
4342 for i in range(loop_count):
4343 
4344  ## 2 受信データファイル削除
4345  delete_recv_file()
4346 
4347  ## 1 コネクタープロファイル設定
4348  make_connecter_profile("periodic", "SKIP", 0)
4349 
4350  ## 3 ポート接続
4351  # データポート1 TimedFloat
4352  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4353 
4354  # データポート2 TimedFloatSeq
4355  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4356 
4357  # サービスポート MyService
4358  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4359 
4360  ## 4 アクティベート
4361  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4362  time.sleep(sleep_recv_act_time)
4363  ec_send[0].activate_component(g_compo_send.rtc_ref)
4364 
4365  time.sleep(sleep_act_time)
4366 
4367  ## 5 ディアクティベート
4368  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4369  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4370 
4371  ## 6 ポート切断
4372  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4373  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4374  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4375 
4376  ## 受信ファイル有無判定
4377  if os.path.isfile(g_diff_recv_file) == False:
4378  fout = open(g_test_result_file, 'a')
4379  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4380  message = message + g_check_message
4381  fout.write(message + '\n')
4382  fout.close()
4383  print message
4384  time.sleep(sleep_for_time)
4385  continue
4386 
4387  ## 7 送受信データ比較
4388  time.sleep(sleep_act_time)
4389  bret = diff_file()
4390 
4391  ## 差分ファイルからテスト結果出力
4392  fout = open(g_test_result_file, 'a')
4393  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4394  # bret==True なら送受信データ一致
4395  if bret == True:
4396  # テスト結果 OK
4397  message = message + g_test_ok
4398  print message
4399  fout.write(message + '\n')
4400  else:
4401  # テスト結果 NG
4402  message = message + g_test_ng
4403  print message
4404  message = message + g_test_ng_message
4405  fout.write(message + '\n')
4406  # 受信データをテスト結果ファイルへコピー
4407  fin2 = open(g_diff_recv_file, 'r')
4408  while(1):
4409  s2 = fin2.readline()
4410  if len(s2) == 0:
4411  break
4412  fout.write(s2)
4413  fin2.close()
4414  fout.close()
4415 
4416  time.sleep(sleep_for_time)
4417 
4418 ##--------------------------------------------------------------------
4419 ## 接続タイプ：periodic 方向：in->out ポリシー：ALL 接続・切断・Activate・Deactivateテスト1
4420 ##--------------------------------------------------------------------
4421 case_no = case_no + 1
4422 fout = open(g_test_result_file, 'a')
4423 message = g_mess_header + g_test_case + str(case_no) + " "
4424 message = message + "Connect(in->out, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
4425 message = message + g_mess_footer
4426 fout.write(message + '\n')
4427 fout.close()
4428 print message
4429 
4430 for i in range(loop_count):
4431 
4432  ## 2 受信データファイル削除
4433  delete_recv_file()
4434 
4435  ## 1 コネクタープロファイル設定
4436  make_connecter_profile("periodic", "ALL", 1)
4437 
4438  ## 3 ポート接続
4439  # データポート1 TimedFloat
4440  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4441 
4442  # データポート2 TimedFloatSeq
4443  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4444 
4445  # サービスポート MyService
4446  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4447 
4448  ## 4 アクティベート
4449  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4450  time.sleep(sleep_recv_act_time)
4451  ec_send[0].activate_component(g_compo_send.rtc_ref)
4452 
4453  time.sleep(sleep_act_time)
4454 
4455  ## 5 ディアクティベート
4456  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4457  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4458 
4459  ## 6 ポート切断
4460  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4461  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4462  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4463 
4464  ## 受信ファイル有無判定
4465  if os.path.isfile(g_diff_recv_file) == False:
4466  fout = open(g_test_result_file, 'a')
4467  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4468  message = message + g_check_message
4469  fout.write(message + '\n')
4470  fout.close()
4471  print message
4472  time.sleep(sleep_for_time)
4473  continue
4474 
4475  ## 7 送受信データ比較
4476  time.sleep(sleep_act_time)
4477  bret = diff_file()
4478 
4479  ## 差分ファイルからテスト結果出力
4480  fout = open(g_test_result_file, 'a')
4481  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4482  # bret==True なら送受信データ一致
4483  if bret == True:
4484  # テスト結果 OK
4485  message = message + g_test_ok
4486  print message
4487  fout.write(message + '\n')
4488  else:
4489  # テスト結果 NG
4490  message = message + g_test_ng
4491  print message
4492  message = message + g_test_ng_message
4493  fout.write(message + '\n')
4494  # 受信データをテスト結果ファイルへコピー
4495  fin2 = open(g_diff_recv_file, 'r')
4496  while(1):
4497  s2 = fin2.readline()
4498  if len(s2) == 0:
4499  break
4500  fout.write(s2)
4501  fin2.close()
4502  fout.close()
4503 
4504  time.sleep(sleep_for_time)
4505 
4506 ##--------------------------------------------------------------------
4507 ## 接続タイプ：periodic 方向：in->out ポリシー：FIFO 接続・切断・Activate・Deactivateテスト1
4508 ##--------------------------------------------------------------------
4509 case_no = case_no + 1
4510 fout = open(g_test_result_file, 'a')
4511 message = g_mess_header + g_test_case + str(case_no) + " "
4512 message = message + "Connect(in->out, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
4513 message = message + g_mess_footer
4514 fout.write(message + '\n')
4515 fout.close()
4516 print message
4517 
4518 for i in range(loop_count):
4519 
4520  ## 2 受信データファイル削除
4521  delete_recv_file()
4522 
4523  ## 1 コネクタープロファイル設定
4524  make_connecter_profile("periodic", "FIFO", 1)
4525 
4526  ## 3 ポート接続
4527  # データポート1 TimedFloat
4528  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4529 
4530  # データポート2 TimedFloatSeq
4531  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4532 
4533  # サービスポート MyService
4534  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4535 
4536  ## 4 アクティベート
4537  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4538  time.sleep(sleep_recv_act_time)
4539  ec_send[0].activate_component(g_compo_send.rtc_ref)
4540 
4541  time.sleep(sleep_act_time)
4542 
4543  ## 5 ディアクティベート
4544  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4545  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4546 
4547  ## 6 ポート切断
4548  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4549  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4550  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4551 
4552  ## 受信ファイル有無判定
4553  if os.path.isfile(g_diff_recv_file) == False:
4554  fout = open(g_test_result_file, 'a')
4555  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4556  message = message + g_check_message
4557  fout.write(message + '\n')
4558  fout.close()
4559  print message
4560  time.sleep(sleep_for_time)
4561  continue
4562 
4563  ## 7 送受信データ比較
4564  time.sleep(sleep_act_time)
4565  bret = diff_file()
4566 
4567  ## 差分ファイルからテスト結果出力
4568  fout = open(g_test_result_file, 'a')
4569  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4570  # bret==True なら送受信データ一致
4571  if bret == True:
4572  # テスト結果 OK
4573  message = message + g_test_ok
4574  print message
4575  fout.write(message + '\n')
4576  else:
4577  # テスト結果 NG
4578  message = message + g_test_ng
4579  print message
4580  message = message + g_test_ng_message
4581  fout.write(message + '\n')
4582  # 受信データをテスト結果ファイルへコピー
4583  fin2 = open(g_diff_recv_file, 'r')
4584  while(1):
4585  s2 = fin2.readline()
4586  if len(s2) == 0:
4587  break
4588  fout.write(s2)
4589  fin2.close()
4590  fout.close()
4591 
4592  time.sleep(sleep_for_time)
4593 
4594 ##--------------------------------------------------------------------
4595 ## 接続タイプ：periodic 方向：in->out ポリシー：NEW 接続・切断・Activate・Deactivateテスト1
4596 ##--------------------------------------------------------------------
4597 case_no = case_no + 1
4598 fout = open(g_test_result_file, 'a')
4599 message = g_mess_header + g_test_case + str(case_no) + " "
4600 message = message + "Connect(in->out, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
4601 message = message + g_mess_footer
4602 fout.write(message + '\n')
4603 fout.close()
4604 print message
4605 
4606 for i in range(loop_count):
4607 
4608  ## 2 受信データファイル削除
4609  delete_recv_file()
4610 
4611  ## 1 コネクタープロファイル設定
4612  make_connecter_profile("periodic", "NEW", 1)
4613 
4614  ## 3 ポート接続
4615  # データポート1 TimedFloat
4616  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4617 
4618  # データポート2 TimedFloatSeq
4619  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4620 
4621  # サービスポート MyService
4622  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4623 
4624  ## 4 アクティベート
4625  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4626  time.sleep(sleep_recv_act_time)
4627  ec_send[0].activate_component(g_compo_send.rtc_ref)
4628 
4629  time.sleep(sleep_act_time)
4630 
4631  ## 5 ディアクティベート
4632  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4633  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4634 
4635  ## 6 ポート切断
4636  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4637  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4638  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4639 
4640  ## 受信ファイル有無判定
4641  if os.path.isfile(g_diff_recv_file) == False:
4642  fout = open(g_test_result_file, 'a')
4643  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4644  message = message + g_check_message
4645  fout.write(message + '\n')
4646  fout.close()
4647  print message
4648  time.sleep(sleep_for_time)
4649  continue
4650 
4651  ## 7 送受信データ比較
4652  time.sleep(sleep_act_time)
4653  bret = diff_file()
4654 
4655  ## 差分ファイルからテスト結果出力
4656  fout = open(g_test_result_file, 'a')
4657  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4658  # bret==True なら送受信データ一致
4659  if bret == True:
4660  # テスト結果 OK
4661  message = message + g_test_ok
4662  print message
4663  fout.write(message + '\n')
4664  else:
4665  # テスト結果 NG
4666  message = message + g_test_ng
4667  print message
4668  message = message + g_test_ng_message
4669  fout.write(message + '\n')
4670  # 受信データをテスト結果ファイルへコピー
4671  fin2 = open(g_diff_recv_file, 'r')
4672  while(1):
4673  s2 = fin2.readline()
4674  if len(s2) == 0:
4675  break
4676  fout.write(s2)
4677  fin2.close()
4678  fout.close()
4679 
4680  time.sleep(sleep_for_time)
4681 
4682 ##--------------------------------------------------------------------
4683 ## 接続タイプ：periodic 方向：in->out ポリシー：SKIP 接続・切断・Activate・Deactivateテスト1
4684 ##--------------------------------------------------------------------
4685 case_no = case_no + 1
4686 fout = open(g_test_result_file, 'a')
4687 message = g_mess_header + g_test_case + str(case_no) + " "
4688 message = message + "Connect(in->out, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
4689 message = message + g_mess_footer
4690 fout.write(message + '\n')
4691 fout.close()
4692 print message
4693 
4694 for i in range(loop_count):
4695 
4696  ## 2 受信データファイル削除
4697  delete_recv_file()
4698 
4699  ## 1 コネクタープロファイル設定
4700  make_connecter_profile("periodic", "SKIP", 1)
4701 
4702  ## 3 ポート接続
4703  # データポート1 TimedFloat
4704  ret0 = g_out_ports[g_port1].connect(g_conprof1)
4705 
4706  # データポート2 TimedFloatSeq
4707  ret1 = g_out_ports[g_port2].connect(g_conprof2)
4708 
4709  # サービスポート MyService
4710  ret2 = g_out_ports[g_port3].connect(g_conprof3)
4711 
4712  ## 4 アクティベート
4713  ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4714  time.sleep(sleep_recv_act_time)
4715  ec_send[0].activate_component(g_compo_send.rtc_ref)
4716 
4717  time.sleep(sleep_act_time)
4718 
4719  ## 5 ディアクティベート
4720  ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4721  ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4722 
4723  ## 6 ポート切断
4724  g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4725  g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4726  g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4727 
4728  ## 受信ファイル有無判定
4729  if os.path.isfile(g_diff_recv_file) == False:
4730  fout = open(g_test_result_file, 'a')
4731  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4732  message = message + g_check_message
4733  fout.write(message + '\n')
4734  fout.close()
4735  print message
4736  time.sleep(sleep_for_time)
4737  continue
4738 
4739  ## 7 送受信データ比較
4740  time.sleep(sleep_act_time)
4741  bret = diff_file()
4742 
4743  ## 差分ファイルからテスト結果出力
4744  fout = open(g_test_result_file, 'a')
4745  message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
4746  # bret==True なら送受信データ一致
4747  if bret == True:
4748  # テスト結果 OK
4749  message = message + g_test_ok
4750  print message
4751  fout.write(message + '\n')
4752  else:
4753  # テスト結果 NG
4754  message = message + g_test_ng
4755  print message
4756  message = message + g_test_ng_message
4757  fout.write(message + '\n')
4758  # 受信データをテスト結果ファイルへコピー
4759  fin2 = open(g_diff_recv_file, 'r')
4760  while(1):
4761  s2 = fin2.readline()
4762  if len(s2) == 0:
4763  break
4764  fout.write(s2)
4765  fin2.close()
4766  fout.close()
4767 
4768  time.sleep(sleep_for_time)
4769 
4770 print "Test Complete."
OpenRTM_aist.examples.AutoTest.rtc_handle10_11.RtmEnv
Definition: rtc_handle10_11.py:22
OpenRTM_aist.examples.AutoTest.ConnectTest.delete_recv_file
def delete_recv_file()
内部関数：受信ファイル削除
Definition: ConnectTest.py:144
OpenRTM_aist.examples.AutoTest.ConnectTest.diff_file
def diff_file()
内部関数：送受信ファイルのデータ比較
Definition: ConnectTest.py:158
OpenRTM_aist.examples.AutoTest.ConnectTest.make_connecter_profile
def make_connecter_profile(subscription_type, push_policy, connect_direction)
内部関数：コネクタープロファイル設定(データポート)
Definition: ConnectTest.py:114

openrtm_aist_python
Author(s): Shinji Kurihara
autogenerated on Thu Jun 6 2019 19:11:34