openrtm_aist_python: ConnectTest.py Source File

Go to the documentation of this file.
00001 #!/usr/bin/env python
00002 # -*- coding: utf-8 -*-
00003 # -*- Python -*-
00004 
00005 #
00006 ## ConnectTest.py
00007 ##
00008 ## コンポーネント接続テスト
00009 ##
00010 
00011 from rtc_handle10_11 import *
00012 from BasicDataType_idl import *
00013 import time
00014 import commands
00015 import SDOPackage
00016 import os
00017 import sys
00018 
00019 ##--------------------------------------------------------------------
00020 g_test_name = "<< component connection test >>"
00021 
00022 ## ネームサーバー定義
00023 #env = RtmEnv(sys.argv, ["localhost:2809"])
00024 #list0 = env.name_space["localhost:2809"].list_obj()
00025 #env.name_space['localhost:2809'].rtc_handles.keys()
00026 #ns = env.name_space['localhost:2809']
00027 env = RtmEnv(sys.argv, ["localhost:2809"])
00028 list0 = env.name_space["localhost:2809"].list_obj()
00029 env.name_space['localhost:2809'].rtc_handles.keys()
00030 ns = env.name_space['localhost:2809']
00031 
00032 g_compo_send = ns.rtc_handles["AutoTestOut0.rtc"]
00033 g_compo_recv = ns.rtc_handles["AutoTestIn0.rtc"]
00034 
00035 ec_send = g_compo_send.rtc_ref.get_owned_contexts()
00036 ec_recv = g_compo_recv.rtc_ref.get_owned_contexts()
00037 
00038 g_out_ports = g_compo_send.rtc_ref.get_ports()
00039 g_in_ports = g_compo_recv.rtc_ref.get_ports()
00040 #print "<<< g_out_ports.length=",len(g_out_ports)
00041 #SeqOutの場合
00042 #length=8 [0]:Short [1]:Long [2]:Float [3]:Double [4]:ShortSeq [5]:LongSeq [6]:FloatSeq [7]:DoubleSeq
00043 #print "<<<  g_in_ports.length=",len(g_in_ports)
00044 
00045 time.sleep(2)
00046 
00047 ##--------------------------------------------------------------------
00048 ## コネクタープロファイルデフォルト定義
00049 g_interface_type1 = "corba_cdr"
00050 g_dataflow_type = "push"
00051 g_subscription_type = "flush"
00052 g_push_policy = "NEW"
00053 g_push_rate = "2000"
00054 g_skip_count = "4"
00055 #g_skip_count = "0"
00056 
00057 ## ポート番号指定 ( get_ports()より )
00058 g_port1 = 0
00059 g_port2 = 1
00060 g_port3 = 2
00061 
00062 ## ConnectorProfile(name, connector_id, ports, properties)
00063 ##   String name
00064 ##   String connector_id
00065 ##   RTC.PortService ports[]
00066 ##   SDOPackage.NameValue properties[]
00067 
00068 ## データポート TimedFloat
00069 g_name1 = "out"
00070 g_connector_id1 = "001"
00071 g_data_type1 = "TimedFloat"
00072 
00073 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))])
00074 
00075 ## データポート TimedFloatSeq
00076 g_name2 = "seqout"
00077 g_connector_id2 = "002"
00078 g_data_type2 = "TimedFloatSeq"
00079 
00080 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))])
00081 
00082 ## サービスポート 
00083 g_name3 = "MyService"
00084 g_connector_id3 = "003"
00085 g_interface_type3 = "MyService"
00086 
00087 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))])
00088 
00089 ##--------------------------------------------------------------------
00090 ## 送受信結果判定関連
00091 g_diff_send_file = "./original-data"
00092 g_diff_recv_file = "./received-data"
00093 g_check_message = g_diff_recv_file + " file not found."
00094 g_test_result_file = "./ResultTest.log"
00095 g_test_case = "case"
00096 g_test_cnt = "count"
00097 g_test_ok = "OK."
00098 g_test_ng = "NG detected."
00099 g_test_ng_message = "  < received-data >"
00100 g_mess_header = "< "
00101 g_mess_footer = " > "
00102 # テスト結果内容
00103 # 例)ケース1、1回目 -> "<<< case1 count1 >>> OK."
00104 # 例)ケース1、2回目 -> "<<< case1 count2 >>> NG detected."
00105 
00106 ##--------------------------------------------------------------------
00107 ## 内部関数：コネクタープロファイル設定(データポート)
00108 ##
00109 ## (引数)
00110 ## subscription_type : "flush", "new", "periodic"
00111 ## push_policy       : "ALL", "FIFO", "SKIP", "NEW", ""
00112 ## connect_direction : 0:outport -> inport, 1:inport -> outport
00113 ##--------------------------------------------------------------------
00114 def make_connecter_profile(subscription_type, push_policy, connect_direction):
00115     global g_conprof1, g_conprof2, g_conprof3
00116 
00117     if connect_direction == 0:
00118         ## outport -> inport Set
00119         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))])
00120 
00121         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))])
00122 
00123         #print "outport -> inport set >>>"
00124         #print "g_conprof1=",g_conprof1
00125         #print "g_conprof2=",g_conprof2
00126     else:
00127         ## inport -> outport Set
00128         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))])
00129 
00130         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))])
00131 
00132         #print "inport -> outport set >>>"
00133         #print "g_conprof1=",g_conprof1
00134         #print "g_conprof2=",g_conprof2
00135     return
00136 
00137 
00138 ##--------------------------------------------------------------------
00139 ## 内部関数：受信ファイル削除
00140 ##
00141 ## (引数)
00142 ## なし
00143 ##--------------------------------------------------------------------
00144 def delete_recv_file():
00145     ## ファイルが存在する場合
00146     if os.path.isfile(g_diff_recv_file) == True:
00147         os.remove(g_diff_recv_file)
00148     return
00149 
00150 
00151 ##--------------------------------------------------------------------
00152 ## 内部関数：送受信ファイルのデータ比較
00153 ##
00154 ## (引数)
00155 ## なし
00156 ## (戻り値)  True : 一致、  False : 不一致
00157 ##--------------------------------------------------------------------
00158 def diff_file():
00159     bret = True
00160 
00161     ## if connect_direction == 0:
00162     ## else:
00163     ## 送信ファイル有無判定
00164     if os.path.isfile(g_diff_send_file) == False:
00165         print "send_file (%s) not found." % send_file
00166         return False
00167 
00168     ## 受信ファイル有無判定
00169     if os.path.isfile(g_diff_recv_file) == False:
00170         print "recv_file (%s) not found." % recv_file
00171         return False
00172 
00173     ## 送受信データ差分判定
00174     f_send = open(g_diff_send_file, 'r')
00175     f_recv = open(g_diff_recv_file, 'r')
00176 
00177     while(1):
00178         str_send = f_send.readline()
00179         str_recv = f_recv.readline()
00180         if len(str_send) == 0:
00181             break
00182 
00183         #print "original send date=(%s)" % str_send
00184         #print ''.join(['%x ' % ord(s) for s in str_send])
00185         #print "original recv date=(%s)" % str_recv
00186         #print ''.join(['%x ' % ord(s) for s in str_recv])
00187 
00188         ## 末尾の改行、復帰コード削除
00189         str_send2 = str_send.rstrip('\n')
00190         str_send2 = str_send2.rstrip('\r')
00191         str_recv2 = str_recv.rstrip('\n')
00192         str_recv2 = str_recv2.rstrip('\r')
00193 
00194         #print "rstrip after send date=(%s)" % str_send2
00195         #print "rstrip after recv date=(%s)" % str_recv2
00196 
00197         ## データ比較
00198         if str_send2 != str_recv2:
00199             #print "data difference"
00200             #print "send date=(%s)" % str_send2
00201             #print "recv date=(%s)" % str_recv2
00202             bret = False
00203             break;
00204 
00205     f_recv.close()
00206     f_send.close()
00207     return bret
00208 
00209 ##--------------------------------------------------------------------
00210 ## テストケース番号の初期値設定
00211 ##  上から連番を振っている
00212 case_no = 0
00213 
00214 ## ケース毎のテスト回数
00215 loop_count = 3
00216 
00217 ## 受信側activate_componentから送信側activate_componentまでのスリープ時間(秒数)
00218 sleep_recv_act_time = 1
00219 
00220 ## activate_componentからdeactivate_componentまでのスリープ時間(秒数)
00221 sleep_act_time = 10
00222 
00223 ## forループのスリープ時間(秒数)
00224 sleep_for_time = 2
00225 
00226 ## connectからdisconnectまでのスリープ時間(秒数)
00227 sleep_connect_time = 2
00228 
00229 # テスト結果ファイルの作成
00230 fout = open(g_test_result_file, 'w')
00231 fout.write(g_test_name + '\n')
00232 fout.close()
00233 #print g_test_name
00234 
00235 time.sleep(1)
00236 
00237 ##--------------------------------------------------------------------
00238 ## 接続タイプ：flush  方向：out->in  接続・切断テスト2
00239 ##--------------------------------------------------------------------
00240 case_no = case_no + 1
00241 fout = open(g_test_result_file, 'a')
00242 message = g_mess_header + g_test_case + str(case_no) + " "
00243 message = message + "Connect(out->in, flush) -> Disconnect"
00244 message = message + g_mess_footer
00245 fout.write(message + '\n')
00246 fout.close()
00247 print message
00248 
00249 for i in range(loop_count):
00250 
00251     ## 1 コネクタープロファイル設定
00252     make_connecter_profile("flush", "", 0)
00253 
00254     ## 3 ポート接続
00255     # データポート1 TimedFloat
00256     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00257 
00258     # データポート2 TimedFloatSeq
00259     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00260 
00261     # サービスポート MyService
00262     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00263 
00264     time.sleep(sleep_connect_time)
00265 
00266     ## 6 ポート切断
00267     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00268     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00269     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00270 
00271     ## テスト結果出力
00272     fout = open(g_test_result_file, 'a')
00273     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00274     message = message + g_test_ok
00275     print message
00276     fout.write(message + '\n')
00277     fout.close()
00278 
00279     time.sleep(sleep_for_time)
00280 
00281 ##--------------------------------------------------------------------
00282 ## 接続タイプ：flush  方向：in->out  接続・切断テスト1
00283 ##--------------------------------------------------------------------
00284 case_no = case_no + 1
00285 fout = open(g_test_result_file, 'a')
00286 message = g_mess_header + g_test_case + str(case_no) + " "
00287 message = message + "Connect(in->out, flush) -> Disconnect"
00288 message = message + g_mess_footer
00289 fout.write(message + '\n')
00290 fout.close()
00291 print message
00292 
00293 for i in range(loop_count):
00294 
00295     ## 1 コネクタープロファイル設定
00296     make_connecter_profile("flush", "", 1)
00297 
00298     ## 3 ポート接続
00299     # データポート1 TimedFloat
00300     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00301 
00302     # データポート2 TimedFloatSeq
00303     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00304 
00305     # サービスポート MyService
00306     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00307 
00308     time.sleep(sleep_connect_time)
00309 
00310     ## 6 ポート切断
00311     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00312     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00313     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00314 
00315     ## テスト結果出力
00316     fout = open(g_test_result_file, 'a')
00317     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00318     message = message + g_test_ok
00319     print message
00320     fout.write(message + '\n')
00321     fout.close()
00322 
00323     time.sleep(sleep_for_time)
00324 
00325 ##--------------------------------------------------------------------
00326 ## 接続タイプ：flush  方向：out->in  Activate・Deactivateテスト1
00327 ##--------------------------------------------------------------------
00328 case_no = case_no + 1
00329 fout = open(g_test_result_file, 'a')
00330 message = g_mess_header + g_test_case + str(case_no) + " "
00331 message = message + "Connecting(out->in, flush), Activate -> send/recv -> Deactivate"
00332 message = message + g_mess_footer
00333 fout.write(message + '\n')
00334 fout.close()
00335 print message
00336 
00337 ## 1 コネクタープロファイル設定
00338 make_connecter_profile("flush", "", 0)
00339 
00340 ## 3 ポート接続
00341 # データポート1 TimedFloat
00342 ret0 = g_out_ports[g_port1].connect(g_conprof1)
00343 
00344 # データポート2 TimedFloatSeq
00345 ret1 = g_out_ports[g_port2].connect(g_conprof2)
00346 
00347 # サービスポート MyService
00348 ret2 = g_out_ports[g_port3].connect(g_conprof3)
00349 
00350 for i in range(loop_count):
00351 
00352     ## 2 受信データファイル削除
00353     delete_recv_file()
00354 
00355     ## 4 アクティベート
00356     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00357     time.sleep(sleep_recv_act_time)
00358     ec_send[0].activate_component(g_compo_send.rtc_ref)
00359 
00360     time.sleep(sleep_act_time)
00361 
00362     ## 5 ディアクティベート
00363     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00364     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00365 
00366     ## 受信ファイル有無判定
00367     if os.path.isfile(g_diff_recv_file) == False:
00368         fout = open(g_test_result_file, 'a')
00369         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00370         message = message + g_check_message
00371         fout.write(message + '\n')
00372         fout.close()
00373         print message
00374         time.sleep(sleep_for_time)
00375         continue
00376 
00377     ## 7 送受信データ比較
00378     time.sleep(sleep_act_time)
00379     bret = diff_file()
00380 
00381     ## 差分ファイルからテスト結果出力
00382     fout = open(g_test_result_file, 'a')
00383     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00384     # bret==True なら送受信データ一致
00385     if bret == True:
00386         # テスト結果 OK
00387         message = message + g_test_ok
00388         print message
00389         fout.write(message + '\n')
00390     else:
00391         # テスト結果 NG
00392         message = message + g_test_ng
00393         print message
00394         message = message + g_test_ng_message
00395         fout.write(message + '\n')
00396         # 受信データをテスト結果ファイルへコピー
00397         fin2 = open(g_diff_recv_file, 'r')
00398         while(1):
00399             s2 = fin2.readline()
00400             if len(s2) == 0:
00401                 break
00402             fout.write(s2)
00403         fin2.close()
00404     fout.close()
00405 
00406     time.sleep(sleep_for_time)
00407 
00408 ## 6 ポート切断
00409 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00410 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00411 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00412 
00413 ##--------------------------------------------------------------------
00414 ## 接続タイプ：flush  方向：in->out  Activate・Deactivateテスト1
00415 ##--------------------------------------------------------------------
00416 case_no = case_no + 1
00417 fout = open(g_test_result_file, 'a')
00418 message = g_mess_header + g_test_case + str(case_no) + " "
00419 message = message + "Connecting(in->out, flush), Activate -> send/recv -> Deactivate"
00420 message = message + g_mess_footer
00421 fout.write(message + '\n')
00422 fout.close()
00423 print message
00424 
00425 ## 1 コネクタープロファイル設定
00426 make_connecter_profile("flush", "", 1)
00427 
00428 ## 3 ポート接続
00429 # データポート1 TimedFloat
00430 ret0 = g_out_ports[g_port1].connect(g_conprof1)
00431 
00432 # データポート2 TimedFloatSeq
00433 ret1 = g_out_ports[g_port2].connect(g_conprof2)
00434 
00435 # サービスポート MyService
00436 ret2 = g_out_ports[g_port3].connect(g_conprof3)
00437 
00438 for i in range(loop_count):
00439 
00440     ## 2 受信データファイル削除
00441     delete_recv_file()
00442 
00443     ## 4 アクティベート
00444     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00445     time.sleep(sleep_recv_act_time)
00446     ec_send[0].activate_component(g_compo_send.rtc_ref)
00447 
00448     time.sleep(sleep_act_time)
00449 
00450     ## 5 ディアクティベート
00451     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00452     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00453 
00454     ## 受信ファイル有無判定
00455     if os.path.isfile(g_diff_recv_file) == False:
00456         fout = open(g_test_result_file, 'a')
00457         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00458         message = message + g_check_message
00459         fout.write(message + '\n')
00460         fout.close()
00461         print message
00462         time.sleep(sleep_for_time)
00463         continue
00464 
00465     ## 7 送受信データ比較
00466     time.sleep(sleep_act_time)
00467     bret = diff_file()
00468 
00469     ## 差分ファイルからテスト結果出力
00470     fout = open(g_test_result_file, 'a')
00471     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00472     # bret==True なら送受信データ一致
00473     if bret == True:
00474         # テスト結果 OK
00475         message = message + g_test_ok
00476         print message
00477         fout.write(message + '\n')
00478     else:
00479         # テスト結果 NG
00480         message = message + g_test_ng
00481         print message
00482         message = message + g_test_ng_message
00483         fout.write(message + '\n')
00484         # 受信データをテスト結果ファイルへコピー
00485         fin2 = open(g_diff_recv_file, 'r')
00486         while(1):
00487             s2 = fin2.readline()
00488             if len(s2) == 0:
00489                 break
00490             fout.write(s2)
00491         fin2.close()
00492     fout.close()
00493 
00494     time.sleep(sleep_for_time)
00495 
00496 ## 6 ポート切断
00497 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00498 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00499 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00500 
00501 ##--------------------------------------------------------------------
00502 ## 接続タイプ：flush  方向：out->in  Activate・Deactivateテスト10
00503 ##--------------------------------------------------------------------
00504 case_no = case_no + 1
00505 fout = open(g_test_result_file, 'a')
00506 message = g_mess_header + g_test_case + str(case_no) + " "
00507 message = message + "Not Connect(out->in, flush), Activate -> Deactivate"
00508 message = message + g_mess_footer
00509 fout.write(message + '\n')
00510 fout.close()
00511 print message
00512 
00513 for i in range(loop_count):
00514 
00515     ## 1 コネクタープロファイル設定
00516     make_connecter_profile("flush", "", 0)
00517 
00518     ## 4 アクティベート
00519     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00520     time.sleep(sleep_recv_act_time)
00521     ec_send[0].activate_component(g_compo_send.rtc_ref)
00522 
00523     time.sleep(sleep_act_time)
00524 
00525     ## 5 ディアクティベート
00526     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00527     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00528 
00529     ## テスト結果出力
00530     fout = open(g_test_result_file, 'a')
00531     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00532     message = message + g_test_ok
00533     print message
00534     fout.write(message + '\n')
00535     fout.close()
00536 
00537     time.sleep(sleep_for_time)
00538 
00539 ##--------------------------------------------------------------------
00540 ## 接続タイプ：flush  方向：out->in  接続・切断・Activate・Deactivateテスト1
00541 ##--------------------------------------------------------------------
00542 case_no = case_no + 1
00543 fout = open(g_test_result_file, 'a')
00544 message = g_mess_header + g_test_case + str(case_no) + " "
00545 message = message + "Connect(out->in, flush) -> Activate -> send/recv -> Deactivate -> Disconnect"
00546 message = message + g_mess_footer
00547 fout.write(message + '\n')
00548 fout.close()
00549 print message
00550 
00551 for i in range(loop_count):
00552 
00553     ## 2 受信データファイル削除
00554     delete_recv_file()
00555 
00556     ## 1 コネクタープロファイル設定
00557     make_connecter_profile("flush", "", 0)
00558 
00559     ## 3 ポート接続
00560     # データポート1 TimedFloat
00561     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00562 
00563     # データポート2 TimedFloatSeq
00564     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00565 
00566     # サービスポート MyService
00567     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00568 
00569     ## 4 アクティベート
00570     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00571     time.sleep(sleep_recv_act_time)
00572     ec_send[0].activate_component(g_compo_send.rtc_ref)
00573 
00574     time.sleep(sleep_act_time)
00575 
00576     ## 5 ディアクティベート
00577     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00578     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00579 
00580     ## 6 ポート切断
00581     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00582     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00583     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00584 
00585     ## 受信ファイル有無判定
00586     if os.path.isfile(g_diff_recv_file) == False:
00587         fout = open(g_test_result_file, 'a')
00588         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00589         message = message + g_check_message
00590         fout.write(message + '\n')
00591         fout.close()
00592         print message
00593         time.sleep(sleep_for_time)
00594         continue
00595 
00596     ## 7 送受信データ比較
00597     time.sleep(sleep_act_time)
00598     bret = diff_file()
00599 
00600     ## 差分ファイルからテスト結果出力
00601     fout = open(g_test_result_file, 'a')
00602     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00603     # bret==True なら送受信データ一致
00604     if bret == True:
00605         # テスト結果 OK
00606         message = message + g_test_ok
00607         print message
00608         fout.write(message + '\n')
00609     else:
00610         # テスト結果 NG
00611         message = message + g_test_ng
00612         print message
00613         message = message + g_test_ng_message
00614         fout.write(message + '\n')
00615         # 受信データをテスト結果ファイルへコピー
00616         fin2 = open(g_diff_recv_file, 'r')
00617         while(1):
00618             s2 = fin2.readline()
00619             if len(s2) == 0:
00620                 break
00621             fout.write(s2)
00622         fin2.close()
00623     fout.close()
00624 
00625     time.sleep(sleep_for_time)
00626 
00627 ##--------------------------------------------------------------------
00628 ## 接続タイプ：flush  方向：in->out  接続・切断・Activate・Deactivateテスト1
00629 ##--------------------------------------------------------------------
00630 case_no = case_no + 1
00631 fout = open(g_test_result_file, 'a')
00632 message = g_mess_header + g_test_case + str(case_no) + " "
00633 message = message + "Connect(in->out, flush) -> Activate -> send/recv -> Deactivate -> Disconnect"
00634 message = message + g_mess_footer
00635 fout.write(message + '\n')
00636 fout.close()
00637 print message
00638 
00639 for i in range(loop_count):
00640 
00641     ## 2 受信データファイル削除
00642     delete_recv_file()
00643 
00644     ## 1 コネクタープロファイル設定
00645     make_connecter_profile("flush", "", 1)
00646 
00647     ## 3 ポート接続
00648     # データポート1 TimedFloat
00649     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00650 
00651     # データポート2 TimedFloatSeq
00652     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00653 
00654     # サービスポート MyService
00655     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00656 
00657     ## 4 アクティベート
00658     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00659     time.sleep(sleep_recv_act_time)
00660     ec_send[0].activate_component(g_compo_send.rtc_ref)
00661 
00662     time.sleep(sleep_act_time)
00663 
00664     ## 5 ディアクティベート
00665     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00666     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00667 
00668     ## 6 ポート切断
00669     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00670     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00671     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00672 
00673     ## 受信ファイル有無判定
00674     if os.path.isfile(g_diff_recv_file) == False:
00675         fout = open(g_test_result_file, 'a')
00676         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00677         message = message + g_check_message
00678         fout.write(message + '\n')
00679         fout.close()
00680         print message
00681         time.sleep(sleep_for_time)
00682         continue
00683 
00684     ## 7 送受信データ比較
00685     time.sleep(sleep_act_time)
00686     bret = diff_file()
00687 
00688     ## 差分ファイルからテスト結果出力
00689     fout = open(g_test_result_file, 'a')
00690     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00691     # bret==True なら送受信データ一致
00692     if bret == True:
00693         # テスト結果 OK
00694         message = message + g_test_ok
00695         print message
00696         fout.write(message + '\n')
00697     else:
00698         # テスト結果 NG
00699         message = message + g_test_ng
00700         print message
00701         message = message + g_test_ng_message
00702         fout.write(message + '\n')
00703         # 受信データをテスト結果ファイルへコピー
00704         fin2 = open(g_diff_recv_file, 'r')
00705         while(1):
00706             s2 = fin2.readline()
00707             if len(s2) == 0:
00708                 break
00709             fout.write(s2)
00710         fin2.close()
00711     fout.close()
00712 
00713     time.sleep(sleep_for_time)
00714 
00715 ##--------------------------------------------------------------------
00716 ## 接続タイプ：flush  方向：out->in  接続・切断・Activate・Deactivateテスト2
00717 ##--------------------------------------------------------------------
00718 case_no = case_no + 1
00719 fout = open(g_test_result_file, 'a')
00720 message = g_mess_header + g_test_case + str(case_no) + " "
00721 message = message + "Connect(out->in, flush) -> Activate -> send/recv -> Disconnect -> Deactivate"
00722 message = message + g_mess_footer
00723 fout.write(message + '\n')
00724 fout.close()
00725 print message
00726 
00727 for i in range(loop_count):
00728 
00729     ## 2 受信データファイル削除
00730     delete_recv_file()
00731 
00732     ## 1 コネクタープロファイル設定
00733     make_connecter_profile("flush", "", 0)
00734 
00735     ## 3 ポート接続
00736     # データポート1 TimedFloat
00737     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00738 
00739     # データポート2 TimedFloatSeq
00740     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00741 
00742     # サービスポート MyService
00743     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00744 
00745     ## 4 アクティベート
00746     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00747     time.sleep(sleep_recv_act_time)
00748     ec_send[0].activate_component(g_compo_send.rtc_ref)
00749 
00750     time.sleep(sleep_act_time)
00751 
00752     ## 6 ポート切断
00753     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00754     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00755     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00756 
00757     ## 5 ディアクティベート
00758     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00759     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00760 
00761     ## 受信ファイル有無判定
00762     if os.path.isfile(g_diff_recv_file) == False:
00763         fout = open(g_test_result_file, 'a')
00764         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00765         message = message + g_check_message
00766         fout.write(message + '\n')
00767         fout.close()
00768         print message
00769         time.sleep(sleep_for_time)
00770         continue
00771 
00772     ## 7 送受信データ比較
00773     time.sleep(sleep_act_time)
00774     bret = diff_file()
00775 
00776     ## 差分ファイルからテスト結果出力
00777     fout = open(g_test_result_file, 'a')
00778     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00779     # bret==True なら送受信データ一致
00780     if bret == True:
00781         # テスト結果 OK
00782         message = message + g_test_ok
00783         print message
00784         fout.write(message + '\n')
00785     else:
00786         # テスト結果 NG
00787         message = message + g_test_ng
00788         print message
00789         message = message + g_test_ng_message
00790         fout.write(message + '\n')
00791         # 受信データをテスト結果ファイルへコピー
00792         fin2 = open(g_diff_recv_file, 'r')
00793         while(1):
00794             s2 = fin2.readline()
00795             if len(s2) == 0:
00796                 break
00797             fout.write(s2)
00798         fin2.close()
00799     fout.close()
00800 
00801     time.sleep(sleep_for_time)
00802 
00803 ##--------------------------------------------------------------------
00804 ## 接続タイプ：flush  方向：in->out  接続・切断・Activate・Deactivateテスト2
00805 ##--------------------------------------------------------------------
00806 case_no = case_no + 1
00807 fout = open(g_test_result_file, 'a')
00808 message = g_mess_header + g_test_case + str(case_no) + " "
00809 message = message + "Connect(in->out, flush) -> Activate -> send/recv -> Disconnect -> Deactivate"
00810 message = message + g_mess_footer
00811 fout.write(message + '\n')
00812 fout.close()
00813 print message
00814 
00815 for i in range(loop_count):
00816 
00817     ## 2 受信データファイル削除
00818     delete_recv_file()
00819 
00820     ## 1 コネクタープロファイル設定
00821     make_connecter_profile("flush", "", 1)
00822 
00823     ## 3 ポート接続
00824     # データポート1 TimedFloat
00825     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00826 
00827     # データポート2 TimedFloatSeq
00828     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00829 
00830     # サービスポート MyService
00831     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00832 
00833     ## 4 アクティベート
00834     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00835     time.sleep(sleep_recv_act_time)
00836     ec_send[0].activate_component(g_compo_send.rtc_ref)
00837 
00838     time.sleep(sleep_act_time)
00839 
00840     ## 6 ポート切断
00841     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00842     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00843     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00844 
00845     ## 5 ディアクティベート
00846     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00847     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00848 
00849     ## 受信ファイル有無判定
00850     if os.path.isfile(g_diff_recv_file) == False:
00851         fout = open(g_test_result_file, 'a')
00852         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00853         message = message + g_check_message
00854         fout.write(message + '\n')
00855         fout.close()
00856         print message
00857         time.sleep(sleep_for_time)
00858         continue
00859 
00860     ## 7 送受信データ比較
00861     time.sleep(sleep_act_time)
00862     bret = diff_file()
00863 
00864     ## 差分ファイルからテスト結果出力
00865     fout = open(g_test_result_file, 'a')
00866     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00867     # bret==True なら送受信データ一致
00868     if bret == True:
00869         # テスト結果 OK
00870         message = message + g_test_ok
00871         print message
00872         fout.write(message + '\n')
00873     else:
00874         # テスト結果 NG
00875         message = message + g_test_ng
00876         print message
00877         message = message + g_test_ng_message
00878         fout.write(message + '\n')
00879         # 受信データをテスト結果ファイルへコピー
00880         fin2 = open(g_diff_recv_file, 'r')
00881         while(1):
00882             s2 = fin2.readline()
00883             if len(s2) == 0:
00884                 break
00885             fout.write(s2)
00886         fin2.close()
00887     fout.close()
00888 
00889     time.sleep(sleep_for_time)
00890 
00891 
00892 ##--------------------------------------------------------------------
00893 ## 接続タイプ：flush  方向：out->in  接続・切断・Activate・Deactivateテスト3
00894 ##--------------------------------------------------------------------
00895 ##  ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
00896 case_no = case_no + 1
00897 fout = open(g_test_result_file, 'a')
00898 message = g_mess_header + g_test_case + str(case_no) + " "
00899 message = message + "Activate -> Connect(out->in, flush) -> send/recv -> Deactivate -> Disconnect"
00900 message = message + g_mess_footer
00901 fout.write(message + '\n')
00902 fout.close()
00903 print message
00904 
00905 for i in range(loop_count):
00906 
00907     ## 2 受信データファイル削除
00908     delete_recv_file()
00909 
00910     ## 1 コネクタープロファイル設定
00911     make_connecter_profile("flush", "", 0)
00912 
00913     ## 4 アクティベート
00914     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
00915     time.sleep(sleep_recv_act_time)
00916     ec_send[0].activate_component(g_compo_send.rtc_ref)
00917 
00918     ## 3 ポート接続
00919     # データポート1 TimedFloat
00920     ret0 = g_out_ports[g_port1].connect(g_conprof1)
00921 
00922     # データポート2 TimedFloatSeq
00923     ret1 = g_out_ports[g_port2].connect(g_conprof2)
00924 
00925     # サービスポート MyService
00926     ret2 = g_out_ports[g_port3].connect(g_conprof3)
00927 
00928     time.sleep(sleep_act_time)
00929 
00930     ## 5 ディアクティベート
00931     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
00932     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
00933 
00934     ## 6 ポート切断
00935     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
00936     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
00937     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
00938 
00939     ## 受信ファイル有無判定
00940     if os.path.isfile(g_diff_recv_file) == False:
00941         fout = open(g_test_result_file, 'a')
00942         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00943         message = message + g_check_message
00944         fout.write(message + '\n')
00945         fout.close()
00946         print message
00947         time.sleep(sleep_for_time)
00948         continue
00949 
00950     ## 7 送受信データ比較
00951     time.sleep(sleep_act_time)
00952     bret = diff_file()
00953 
00954     ## 差分ファイルからテスト結果出力
00955     fout = open(g_test_result_file, 'a')
00956     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
00957     # bret==True なら送受信データ一致
00958     if bret == True:
00959         # テスト結果 OK
00960         message = message + g_test_ok
00961         print message
00962         fout.write(message + '\n')
00963     else:
00964         # テスト結果 NG
00965         message = message + g_test_ng
00966         print message
00967         message = message + g_test_ng_message
00968         fout.write(message + '\n')
00969         # 受信データをテスト結果ファイルへコピー
00970         fin2 = open(g_diff_recv_file, 'r')
00971         while(1):
00972             s2 = fin2.readline()
00973             if len(s2) == 0:
00974                 break
00975             fout.write(s2)
00976         fin2.close()
00977     fout.close()
00978 
00979     time.sleep(sleep_for_time)
00980 
00981 ##--------------------------------------------------------------------
00982 ## 接続タイプ：flush  方向：in->out  接続・切断・Activate・Deactivateテスト3
00983 ##--------------------------------------------------------------------
00984 ##  ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
00985 case_no = case_no + 1
00986 fout = open(g_test_result_file, 'a')
00987 message = g_mess_header + g_test_case + str(case_no) + " "
00988 message = message + "Activate -> Connect(in->out, flush) -> send/recv -> Deactivate -> Disconnect"
00989 message = message + g_mess_footer
00990 fout.write(message + '\n')
00991 fout.close()
00992 print message
00993 
00994 for i in range(loop_count):
00995 
00996     ## 2 受信データファイル削除
00997     delete_recv_file()
00998 
00999     ## 1 コネクタープロファイル設定
01000     make_connecter_profile("flush", "", 1)
01001 
01002     ## 4 アクティベート
01003     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01004     time.sleep(sleep_recv_act_time)
01005     ec_send[0].activate_component(g_compo_send.rtc_ref)
01006 
01007     ## 3 ポート接続
01008     # データポート1 TimedFloat
01009     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01010 
01011     # データポート2 TimedFloatSeq
01012     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01013 
01014     # サービスポート MyService
01015     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01016 
01017     time.sleep(sleep_act_time)
01018 
01019     ## 5 ディアクティベート
01020     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01021     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01022 
01023     ## 6 ポート切断
01024     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01025     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01026     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01027 
01028     ## 受信ファイル有無判定
01029     if os.path.isfile(g_diff_recv_file) == False:
01030         fout = open(g_test_result_file, 'a')
01031         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01032         message = message + g_check_message
01033         fout.write(message + '\n')
01034         fout.close()
01035         print message
01036         time.sleep(sleep_for_time)
01037         continue
01038 
01039     ## 7 送受信データ比較
01040     time.sleep(sleep_act_time)
01041     bret = diff_file()
01042 
01043     ## 差分ファイルからテスト結果出力
01044     fout = open(g_test_result_file, 'a')
01045     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01046     # bret==True なら送受信データ一致
01047     if bret == True:
01048         # テスト結果 OK
01049         message = message + g_test_ok
01050         print message
01051         fout.write(message + '\n')
01052     else:
01053         # テスト結果 NG
01054         message = message + g_test_ng
01055         print message
01056         message = message + g_test_ng_message
01057         fout.write(message + '\n')
01058         # 受信データをテスト結果ファイルへコピー
01059         fin2 = open(g_diff_recv_file, 'r')
01060         while(1):
01061             s2 = fin2.readline()
01062             if len(s2) == 0:
01063                 break
01064             fout.write(s2)
01065         fin2.close()
01066     fout.close()
01067 
01068     time.sleep(sleep_for_time)
01069 
01070 ##--------------------------------------------------------------------
01071 ## 接続タイプ：flush  方向：out->in  接続・切断・Activate・Deactivateテスト4
01072 ##--------------------------------------------------------------------
01073 ##  ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
01074 case_no = case_no + 1
01075 fout = open(g_test_result_file, 'a')
01076 message = g_mess_header + g_test_case + str(case_no) + " "
01077 message = message + "Activate -> Connect(out->in, flush) -> send/recv -> Disconnect -> Deactivate"
01078 message = message + g_mess_footer
01079 fout.write(message + '\n')
01080 fout.close()
01081 print message
01082 
01083 for i in range(loop_count):
01084 
01085     ## 2 受信データファイル削除
01086     delete_recv_file()
01087 
01088     ## 1 コネクタープロファイル設定
01089     make_connecter_profile("flush", "", 0)
01090 
01091     ## 4 アクティベート
01092     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01093     time.sleep(sleep_recv_act_time)
01094     ec_send[0].activate_component(g_compo_send.rtc_ref)
01095 
01096     ## 3 ポート接続
01097     # データポート1 TimedFloat
01098     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01099 
01100     # データポート2 TimedFloatSeq
01101     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01102 
01103     # サービスポート MyService
01104     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01105 
01106     time.sleep(sleep_act_time)
01107 
01108     ## 6 ポート切断
01109     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01110     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01111     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01112 
01113     ## 5 ディアクティベート
01114     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01115     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01116 
01117     ## 受信ファイル有無判定
01118     if os.path.isfile(g_diff_recv_file) == False:
01119         fout = open(g_test_result_file, 'a')
01120         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01121         message = message + g_check_message
01122         fout.write(message + '\n')
01123         fout.close()
01124         print message
01125         time.sleep(sleep_for_time)
01126         continue
01127 
01128     ## 7 送受信データ比較
01129     time.sleep(sleep_act_time)
01130     bret = diff_file()
01131 
01132     ## 差分ファイルからテスト結果出力
01133     fout = open(g_test_result_file, 'a')
01134     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01135     # bret==True なら送受信データ一致
01136     if bret == True:
01137         # テスト結果 OK
01138         message = message + g_test_ok
01139         print message
01140         fout.write(message + '\n')
01141     else:
01142         # テスト結果 NG
01143         message = message + g_test_ng
01144         print message
01145         message = message + g_test_ng_message
01146         fout.write(message + '\n')
01147         # 受信データをテスト結果ファイルへコピー
01148         fin2 = open(g_diff_recv_file, 'r')
01149         while(1):
01150             s2 = fin2.readline()
01151             if len(s2) == 0:
01152                 break
01153             fout.write(s2)
01154         fin2.close()
01155     fout.close()
01156 
01157     time.sleep(sleep_for_time)
01158 
01159 ##--------------------------------------------------------------------
01160 ## 接続タイプ：flush  方向：in->out  接続・切断・Activate・Deactivateテスト4
01161 ##--------------------------------------------------------------------
01162 ##  ●注意：Activateを先に行っている為、受信データは途中からの内容になります。
01163 case_no = case_no + 1
01164 fout = open(g_test_result_file, 'a')
01165 message = g_mess_header + g_test_case + str(case_no) + " "
01166 message = message + "Activate -> Connect(in->out, flush) -> send/recv -> Disconnect -> Deactivate"
01167 message = message + g_mess_footer
01168 fout.write(message + '\n')
01169 fout.close()
01170 print message
01171 
01172 for i in range(loop_count):
01173 
01174     ## 2 受信データファイル削除
01175     delete_recv_file()
01176 
01177     ## 1 コネクタープロファイル設定
01178     make_connecter_profile("flush", "", 1)
01179 
01180     ## 4 アクティベート
01181     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01182     time.sleep(sleep_recv_act_time)
01183     ec_send[0].activate_component(g_compo_send.rtc_ref)
01184 
01185     ## 3 ポート接続
01186     # データポート1 TimedFloat
01187     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01188 
01189     # データポート2 TimedFloatSeq
01190     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01191 
01192     # サービスポート MyService
01193     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01194 
01195     time.sleep(sleep_act_time)
01196 
01197     ## 6 ポート切断
01198     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01199     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01200     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01201 
01202     ## 5 ディアクティベート
01203     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01204     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01205 
01206     ## 受信ファイル有無判定
01207     if os.path.isfile(g_diff_recv_file) == False:
01208         fout = open(g_test_result_file, 'a')
01209         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01210         message = message + g_check_message
01211         fout.write(message + '\n')
01212         fout.close()
01213         print message
01214         time.sleep(sleep_for_time)
01215         continue
01216 
01217     ## 7 送受信データ比較
01218     time.sleep(sleep_act_time)
01219     bret = diff_file()
01220 
01221     ## 差分ファイルからテスト結果出力
01222     fout = open(g_test_result_file, 'a')
01223     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01224     # bret==True なら送受信データ一致
01225     if bret == True:
01226         # テスト結果 OK
01227         message = message + g_test_ok
01228         print message
01229         fout.write(message + '\n')
01230     else:
01231         # テスト結果 NG
01232         message = message + g_test_ng
01233         print message
01234         message = message + g_test_ng_message
01235         fout.write(message + '\n')
01236         # 受信データをテスト結果ファイルへコピー
01237         fin2 = open(g_diff_recv_file, 'r')
01238         while(1):
01239             s2 = fin2.readline()
01240             if len(s2) == 0:
01241                 break
01242             fout.write(s2)
01243         fin2.close()
01244     fout.close()
01245 
01246     time.sleep(sleep_for_time)
01247 
01248 ##--------------------------------------------------------------------
01249 ##--------------------------------------------------------------------
01250 ## 接続タイプ：new  方向：out->in  ポリシー：ALL  接続・切断テスト3
01251 ##--------------------------------------------------------------------
01252 case_no = case_no + 1
01253 fout = open(g_test_result_file, 'a')
01254 message = g_mess_header + g_test_case + str(case_no) + " "
01255 message = message + "Connect(out->in, new,ALL) -> Disconnect"
01256 message = message + g_mess_footer
01257 fout.write(message + '\n')
01258 fout.close()
01259 print message
01260 
01261 for i in range(loop_count):
01262 
01263     ## 1 コネクタープロファイル設定
01264     make_connecter_profile("new", "ALL", 0)
01265 
01266     ## 3 ポート接続
01267     # データポート1 TimedFloat
01268     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01269 
01270     # データポート2 TimedFloatSeq
01271     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01272 
01273     # サービスポート MyService
01274     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01275 
01276     time.sleep(sleep_connect_time)
01277 
01278     ## 6 ポート切断
01279     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01280     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01281     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01282 
01283     ## テスト結果出力
01284     fout = open(g_test_result_file, 'a')
01285     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01286     message = message + g_test_ok
01287     print message
01288     fout.write(message + '\n')
01289     fout.close()
01290 
01291     time.sleep(sleep_for_time)
01292 
01293 ##--------------------------------------------------------------------
01294 ## 接続タイプ：new  方向：out->in  ポリシー：FIFO  接続・切断テスト4
01295 ##--------------------------------------------------------------------
01296 case_no = case_no + 1
01297 fout = open(g_test_result_file, 'a')
01298 message = g_mess_header + g_test_case + str(case_no) + " "
01299 message = message + "Connect(out->in, new,FIFO) -> Disconnect"
01300 message = message + g_mess_footer
01301 fout.write(message + '\n')
01302 fout.close()
01303 print message
01304 
01305 for i in range(loop_count):
01306 
01307     ## 1 コネクタープロファイル設定
01308     make_connecter_profile("new", "FIFO", 0)
01309 
01310     ## 3 ポート接続
01311     # データポート1 TimedFloat
01312     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01313 
01314     # データポート2 TimedFloatSeq
01315     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01316 
01317     # サービスポート MyService
01318     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01319 
01320     time.sleep(sleep_connect_time)
01321 
01322     ## 6 ポート切断
01323     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01324     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01325     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01326 
01327     ## テスト結果出力
01328     fout = open(g_test_result_file, 'a')
01329     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01330     message = message + g_test_ok
01331     print message
01332     fout.write(message + '\n')
01333     fout.close()
01334 
01335     time.sleep(sleep_for_time)
01336 
01337 ##--------------------------------------------------------------------
01338 ## 接続タイプ：new  方向：out->in  ポリシー：NEW  接続・切断テスト6
01339 ##--------------------------------------------------------------------
01340 case_no = case_no + 1
01341 fout = open(g_test_result_file, 'a')
01342 message = g_mess_header + g_test_case + str(case_no) + " "
01343 message = message + "Connect(out->in, new,NEW) -> Disconnect"
01344 message = message + g_mess_footer
01345 fout.write(message + '\n')
01346 fout.close()
01347 print message
01348 
01349 for i in range(loop_count):
01350 
01351     ## 1 コネクタープロファイル設定
01352     make_connecter_profile("new", "NEW", 0)
01353 
01354     ## 3 ポート接続
01355     # データポート1 TimedFloat
01356     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01357 
01358     # データポート2 TimedFloatSeq
01359     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01360 
01361     # サービスポート MyService
01362     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01363 
01364     time.sleep(sleep_connect_time)
01365 
01366     ## 6 ポート切断
01367     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01368     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01369     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01370 
01371     ## テスト結果出力
01372     fout = open(g_test_result_file, 'a')
01373     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01374     message = message + g_test_ok
01375     print message
01376     fout.write(message + '\n')
01377     fout.close()
01378 
01379     time.sleep(sleep_for_time)
01380 
01381 ##--------------------------------------------------------------------
01382 ## 接続タイプ：new  方向：out->in  ポリシー：SKIP  接続・切断テスト5
01383 ##--------------------------------------------------------------------
01384 case_no = case_no + 1
01385 fout = open(g_test_result_file, 'a')
01386 message = g_mess_header + g_test_case + str(case_no) + " "
01387 message = message + "Connect(out->in, new,SKIP) -> Disconnect"
01388 message = message + g_mess_footer
01389 fout.write(message + '\n')
01390 fout.close()
01391 print message
01392 
01393 for i in range(loop_count):
01394 
01395     ## 1 コネクタープロファイル設定
01396     make_connecter_profile("new", "SKIP", 0)
01397 
01398     ## 3 ポート接続
01399     # データポート1 TimedFloat
01400     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01401 
01402     # データポート2 TimedFloatSeq
01403     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01404 
01405     # サービスポート MyService
01406     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01407 
01408     time.sleep(sleep_connect_time)
01409 
01410     ## 6 ポート切断
01411     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01412     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01413     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01414 
01415     ## テスト結果出力
01416     fout = open(g_test_result_file, 'a')
01417     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01418     message = message + g_test_ok
01419     print message
01420     fout.write(message + '\n')
01421     fout.close()
01422 
01423     time.sleep(sleep_for_time)
01424 
01425 ##--------------------------------------------------------------------
01426 ## 接続タイプ：new  方向：in->out  ポリシー：ALL  接続・切断テスト3
01427 ##--------------------------------------------------------------------
01428 case_no = case_no + 1
01429 fout = open(g_test_result_file, 'a')
01430 message = g_mess_header + g_test_case + str(case_no) + " "
01431 message = message + "Connect(in->out, new,ALL) -> Disconnect"
01432 message = message + g_mess_footer
01433 fout.write(message + '\n')
01434 fout.close()
01435 print message
01436 
01437 for i in range(loop_count):
01438 
01439     ## 1 コネクタープロファイル設定
01440     make_connecter_profile("new", "ALL", 1)
01441 
01442     ## 3 ポート接続
01443     # データポート1 TimedFloat
01444     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01445 
01446     # データポート2 TimedFloatSeq
01447     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01448 
01449     # サービスポート MyService
01450     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01451 
01452     time.sleep(sleep_connect_time)
01453 
01454     ## 6 ポート切断
01455     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01456     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01457     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01458 
01459     ## テスト結果出力
01460     fout = open(g_test_result_file, 'a')
01461     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01462     message = message + g_test_ok
01463     print message
01464     fout.write(message + '\n')
01465     fout.close()
01466 
01467     time.sleep(sleep_for_time)
01468 
01469 ##--------------------------------------------------------------------
01470 ## 接続タイプ：new  方向：in->out  ポリシー：FIFO  接続・切断テスト4
01471 ##--------------------------------------------------------------------
01472 case_no = case_no + 1
01473 fout = open(g_test_result_file, 'a')
01474 message = g_mess_header + g_test_case + str(case_no) + " "
01475 message = message + "Connect(in->out, new,FIFO) -> Disconnect"
01476 message = message + g_mess_footer
01477 fout.write(message + '\n')
01478 fout.close()
01479 print message
01480 
01481 for i in range(loop_count):
01482 
01483     ## 1 コネクタープロファイル設定
01484     make_connecter_profile("new", "FIFO", 1)
01485 
01486     ## 3 ポート接続
01487     # データポート1 TimedFloat
01488     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01489 
01490     # データポート2 TimedFloatSeq
01491     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01492 
01493     # サービスポート MyService
01494     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01495 
01496     time.sleep(sleep_connect_time)
01497 
01498     ## 6 ポート切断
01499     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01500     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01501     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01502 
01503     ## テスト結果出力
01504     fout = open(g_test_result_file, 'a')
01505     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01506     message = message + g_test_ok
01507     print message
01508     fout.write(message + '\n')
01509     fout.close()
01510 
01511     time.sleep(sleep_for_time)
01512 
01513 ##--------------------------------------------------------------------
01514 ## 接続タイプ：new  方向：in->out  ポリシー：NEW  接続・切断テスト6
01515 ##--------------------------------------------------------------------
01516 case_no = case_no + 1
01517 fout = open(g_test_result_file, 'a')
01518 message = g_mess_header + g_test_case + str(case_no) + " "
01519 message = message + "Connect(in->out, new,NEW) -> Disconnect"
01520 message = message + g_mess_footer
01521 fout.write(message + '\n')
01522 fout.close()
01523 print message
01524 
01525 for i in range(loop_count):
01526 
01527     ## 1 コネクタープロファイル設定
01528     make_connecter_profile("new", "NEW", 1)
01529 
01530     ## 3 ポート接続
01531     # データポート1 TimedFloat
01532     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01533 
01534     # データポート2 TimedFloatSeq
01535     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01536 
01537     # サービスポート MyService
01538     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01539 
01540     time.sleep(sleep_connect_time)
01541 
01542     ## 6 ポート切断
01543     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01544     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01545     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01546 
01547     ## テスト結果出力
01548     fout = open(g_test_result_file, 'a')
01549     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01550     message = message + g_test_ok
01551     print message
01552     fout.write(message + '\n')
01553     fout.close()
01554 
01555     time.sleep(sleep_for_time)
01556 
01557 ##--------------------------------------------------------------------
01558 ## 接続タイプ：new  方向：in->out  ポリシー：SKIP  接続・切断テスト5
01559 ##--------------------------------------------------------------------
01560 case_no = case_no + 1
01561 fout = open(g_test_result_file, 'a')
01562 message = g_mess_header + g_test_case + str(case_no) + " "
01563 message = message + "Connect(in->out, new,SKIP) -> Disconnect"
01564 message = message + g_mess_footer
01565 fout.write(message + '\n')
01566 fout.close()
01567 print message
01568 
01569 for i in range(loop_count):
01570 
01571     ## 1 コネクタープロファイル設定
01572     make_connecter_profile("new", "SKIP", 1)
01573 
01574     ## 3 ポート接続
01575     # データポート1 TimedFloat
01576     ret0 = g_out_ports[g_port1].connect(g_conprof1)
01577 
01578     # データポート2 TimedFloatSeq
01579     ret1 = g_out_ports[g_port2].connect(g_conprof2)
01580 
01581     # サービスポート MyService
01582     ret2 = g_out_ports[g_port3].connect(g_conprof3)
01583 
01584     time.sleep(sleep_connect_time)
01585 
01586     ## 6 ポート切断
01587     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01588     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01589     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01590 
01591     ## テスト結果出力
01592     fout = open(g_test_result_file, 'a')
01593     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01594     message = message + g_test_ok
01595     print message
01596     fout.write(message + '\n')
01597     fout.close()
01598 
01599     time.sleep(sleep_for_time)
01600 
01601 ##--------------------------------------------------------------------
01602 ## 接続タイプ：new  方向：out->in  ポリシー：ALL  Activate・Deactivateテスト2
01603 ##--------------------------------------------------------------------
01604 case_no = case_no + 1
01605 fout = open(g_test_result_file, 'a')
01606 message = g_mess_header + g_test_case + str(case_no) + " "
01607 message = message + "Connecting(out->in, new,ALL), Activate -> send/recv -> Deactivate"
01608 message = message + g_mess_footer
01609 fout.write(message + '\n')
01610 fout.close()
01611 print message
01612 
01613 ## 1 コネクタープロファイル設定
01614 make_connecter_profile("new", "ALL", 0)
01615 
01616 ## 3 ポート接続
01617 # データポート1 TimedFloat
01618 ret0 = g_out_ports[g_port1].connect(g_conprof1)
01619 
01620 # データポート2 TimedFloatSeq
01621 ret1 = g_out_ports[g_port2].connect(g_conprof2)
01622 
01623 # サービスポート MyService
01624 ret2 = g_out_ports[g_port3].connect(g_conprof3)
01625 
01626 for i in range(loop_count):
01627 
01628     ## 2 受信データファイル削除
01629     delete_recv_file()
01630 
01631     ## 4 アクティベート
01632     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01633     time.sleep(sleep_recv_act_time)
01634     ec_send[0].activate_component(g_compo_send.rtc_ref)
01635 
01636     time.sleep(sleep_act_time)
01637 
01638     ## 5 ディアクティベート
01639     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01640     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01641 
01642     ## 受信ファイル有無判定
01643     if os.path.isfile(g_diff_recv_file) == False:
01644         fout = open(g_test_result_file, 'a')
01645         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01646         message = message + g_check_message
01647         fout.write(message + '\n')
01648         fout.close()
01649         print message
01650         time.sleep(sleep_for_time)
01651         continue
01652 
01653     ## 7 送受信データ比較
01654     time.sleep(sleep_act_time)
01655     bret = diff_file()
01656 
01657     ## 差分ファイルからテスト結果出力
01658     fout = open(g_test_result_file, 'a')
01659     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01660     # bret==True なら送受信データ一致
01661     if bret == True:
01662         # テスト結果 OK
01663         message = message + g_test_ok
01664         print message
01665         fout.write(message + '\n')
01666     else:
01667         # テスト結果 NG
01668         message = message + g_test_ng
01669         print message
01670         message = message + g_test_ng_message
01671         fout.write(message + '\n')
01672         # 受信データをテスト結果ファイルへコピー
01673         fin2 = open(g_diff_recv_file, 'r')
01674         while(1):
01675             s2 = fin2.readline()
01676             if len(s2) == 0:
01677                 break
01678             fout.write(s2)
01679         fin2.close()
01680     fout.close()
01681 
01682     time.sleep(sleep_for_time)
01683 
01684 ## 6 ポート切断
01685 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01686 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01687 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01688 
01689 ##--------------------------------------------------------------------
01690 ## 接続タイプ：new  方向：out->in  ポリシー：FIFO  Activate・Deactivateテスト3
01691 ##--------------------------------------------------------------------
01692 case_no = case_no + 1
01693 fout = open(g_test_result_file, 'a')
01694 message = g_mess_header + g_test_case + str(case_no) + " "
01695 message = message + "Connecting(out->in, new,FIFO), Activate -> send/recv -> Deactivate"
01696 message = message + g_mess_footer
01697 fout.write(message + '\n')
01698 fout.close()
01699 print message
01700 
01701 ## 1 コネクタープロファイル設定
01702 make_connecter_profile("new", "FIFO", 0)
01703 
01704 ## 3 ポート接続
01705 # データポート1 TimedFloat
01706 ret0 = g_out_ports[g_port1].connect(g_conprof1)
01707 
01708 # データポート2 TimedFloatSeq
01709 ret1 = g_out_ports[g_port2].connect(g_conprof2)
01710 
01711 # サービスポート MyService
01712 ret2 = g_out_ports[g_port3].connect(g_conprof3)
01713 
01714 for i in range(loop_count):
01715 
01716     ## 2 受信データファイル削除
01717     delete_recv_file()
01718 
01719     ## 4 アクティベート
01720     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01721     time.sleep(sleep_recv_act_time)
01722     ec_send[0].activate_component(g_compo_send.rtc_ref)
01723 
01724     time.sleep(sleep_act_time)
01725 
01726     ## 5 ディアクティベート
01727     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01728     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01729 
01730     ## 受信ファイル有無判定
01731     if os.path.isfile(g_diff_recv_file) == False:
01732         fout = open(g_test_result_file, 'a')
01733         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01734         message = message + g_check_message
01735         fout.write(message + '\n')
01736         fout.close()
01737         print message
01738         time.sleep(sleep_for_time)
01739         continue
01740 
01741     ## 7 送受信データ比較
01742     time.sleep(sleep_act_time)
01743     bret = diff_file()
01744 
01745     ## 差分ファイルからテスト結果出力
01746     fout = open(g_test_result_file, 'a')
01747     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01748     # bret==True なら送受信データ一致
01749     if bret == True:
01750         # テスト結果 OK
01751         message = message + g_test_ok
01752         print message
01753         fout.write(message + '\n')
01754     else:
01755         # テスト結果 NG
01756         message = message + g_test_ng
01757         print message
01758         message = message + g_test_ng_message
01759         fout.write(message + '\n')
01760         # 受信データをテスト結果ファイルへコピー
01761         fin2 = open(g_diff_recv_file, 'r')
01762         while(1):
01763             s2 = fin2.readline()
01764             if len(s2) == 0:
01765                 break
01766             fout.write(s2)
01767         fin2.close()
01768     fout.close()
01769 
01770     time.sleep(sleep_for_time)
01771 
01772 ## 6 ポート切断
01773 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01774 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01775 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01776 
01777 ##--------------------------------------------------------------------
01778 ## 接続タイプ：new  方向：out->in  ポリシー：NEW  Activate・Deactivateテスト5
01779 ##--------------------------------------------------------------------
01780 case_no = case_no + 1
01781 fout = open(g_test_result_file, 'a')
01782 message = g_mess_header + g_test_case + str(case_no) + " "
01783 message = message + "Connecting(out->in, new,NEW), Activate -> send/recv -> Deactivate"
01784 message = message + g_mess_footer
01785 fout.write(message + '\n')
01786 fout.close()
01787 print message
01788 
01789 ## 1 コネクタープロファイル設定
01790 make_connecter_profile("new", "NEW", 0)
01791 
01792 ## 3 ポート接続
01793 # データポート1 TimedFloat
01794 ret0 = g_out_ports[g_port1].connect(g_conprof1)
01795 
01796 # データポート2 TimedFloatSeq
01797 ret1 = g_out_ports[g_port2].connect(g_conprof2)
01798 
01799 # サービスポート MyService
01800 ret2 = g_out_ports[g_port3].connect(g_conprof3)
01801 
01802 for i in range(loop_count):
01803 
01804     ## 2 受信データファイル削除
01805     delete_recv_file()
01806 
01807     ## 4 アクティベート
01808     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01809     time.sleep(sleep_recv_act_time)
01810     ec_send[0].activate_component(g_compo_send.rtc_ref)
01811 
01812     time.sleep(sleep_act_time)
01813 
01814     ## 5 ディアクティベート
01815     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01816     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01817 
01818     ## 受信ファイル有無判定
01819     if os.path.isfile(g_diff_recv_file) == False:
01820         fout = open(g_test_result_file, 'a')
01821         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01822         message = message + g_check_message
01823         fout.write(message + '\n')
01824         fout.close()
01825         print message
01826         time.sleep(sleep_for_time)
01827         continue
01828 
01829     ## 7 送受信データ比較
01830     time.sleep(sleep_act_time)
01831     bret = diff_file()
01832 
01833     ## 差分ファイルからテスト結果出力
01834     fout = open(g_test_result_file, 'a')
01835     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01836     # bret==True なら送受信データ一致
01837     if bret == True:
01838         # テスト結果 OK
01839         message = message + g_test_ok
01840         print message
01841         fout.write(message + '\n')
01842     else:
01843         # テスト結果 NG
01844         message = message + g_test_ng
01845         print message
01846         message = message + g_test_ng_message
01847         fout.write(message + '\n')
01848         # 受信データをテスト結果ファイルへコピー
01849         fin2 = open(g_diff_recv_file, 'r')
01850         while(1):
01851             s2 = fin2.readline()
01852             if len(s2) == 0:
01853                 break
01854             fout.write(s2)
01855         fin2.close()
01856     fout.close()
01857 
01858     time.sleep(sleep_for_time)
01859 
01860 ## 6 ポート切断
01861 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01862 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01863 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01864 
01865 ##--------------------------------------------------------------------
01866 ## 接続タイプ：new  方向：out->in  ポリシー：SKIP  Activate・Deactivateテスト4
01867 ##--------------------------------------------------------------------
01868 case_no = case_no + 1
01869 fout = open(g_test_result_file, 'a')
01870 message = g_mess_header + g_test_case + str(case_no) + " "
01871 message = message + "Connecting(out->in, new,SKIP), Activate -> send/recv -> Deactivate"
01872 message = message + g_mess_footer
01873 fout.write(message + '\n')
01874 fout.close()
01875 print message
01876 
01877 ## 1 コネクタープロファイル設定
01878 make_connecter_profile("new", "SKIP", 0)
01879 
01880 ## 3 ポート接続
01881 # データポート1 TimedFloat
01882 ret0 = g_out_ports[g_port1].connect(g_conprof1)
01883 
01884 # データポート2 TimedFloatSeq
01885 ret1 = g_out_ports[g_port2].connect(g_conprof2)
01886 
01887 # サービスポート MyService
01888 ret2 = g_out_ports[g_port3].connect(g_conprof3)
01889 
01890 for i in range(loop_count):
01891 
01892     ## 2 受信データファイル削除
01893     delete_recv_file()
01894 
01895     ## 4 アクティベート
01896     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01897     time.sleep(sleep_recv_act_time)
01898     ec_send[0].activate_component(g_compo_send.rtc_ref)
01899 
01900     time.sleep(sleep_act_time)
01901 
01902     ## 5 ディアクティベート
01903     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01904     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01905 
01906     ## 受信ファイル有無判定
01907     if os.path.isfile(g_diff_recv_file) == False:
01908         fout = open(g_test_result_file, 'a')
01909         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01910         message = message + g_check_message
01911         fout.write(message + '\n')
01912         fout.close()
01913         print message
01914         time.sleep(sleep_for_time)
01915         continue
01916 
01917     ## 7 送受信データ比較
01918     time.sleep(sleep_act_time)
01919     bret = diff_file()
01920 
01921     ## 差分ファイルからテスト結果出力
01922     fout = open(g_test_result_file, 'a')
01923     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01924     # bret==True なら送受信データ一致
01925     if bret == True:
01926         # テスト結果 OK
01927         message = message + g_test_ok
01928         print message
01929         fout.write(message + '\n')
01930     else:
01931         # テスト結果 NG
01932         message = message + g_test_ng
01933         print message
01934         message = message + g_test_ng_message
01935         fout.write(message + '\n')
01936         # 受信データをテスト結果ファイルへコピー
01937         fin2 = open(g_diff_recv_file, 'r')
01938         while(1):
01939             s2 = fin2.readline()
01940             if len(s2) == 0:
01941                 break
01942             fout.write(s2)
01943         fin2.close()
01944     fout.close()
01945 
01946     time.sleep(sleep_for_time)
01947 
01948 ## 6 ポート切断
01949 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
01950 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
01951 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
01952 
01953 ##--------------------------------------------------------------------
01954 ## 接続タイプ：new  方向：in->out  ポリシー：ALL  Activate・Deactivateテスト2
01955 ##--------------------------------------------------------------------
01956 case_no = case_no + 1
01957 fout = open(g_test_result_file, 'a')
01958 message = g_mess_header + g_test_case + str(case_no) + " "
01959 message = message + "Connecting(in->out, new,ALL), Activate -> send/recv -> Deactivate"
01960 message = message + g_mess_footer
01961 fout.write(message + '\n')
01962 fout.close()
01963 print message
01964 
01965 ## 1 コネクタープロファイル設定
01966 make_connecter_profile("new", "ALL", 1)
01967 
01968 ## 3 ポート接続
01969 # データポート1 TimedFloat
01970 ret0 = g_out_ports[g_port1].connect(g_conprof1)
01971 
01972 # データポート2 TimedFloatSeq
01973 ret1 = g_out_ports[g_port2].connect(g_conprof2)
01974 
01975 # サービスポート MyService
01976 ret2 = g_out_ports[g_port3].connect(g_conprof3)
01977 
01978 for i in range(loop_count):
01979 
01980     ## 2 受信データファイル削除
01981     delete_recv_file()
01982 
01983     ## 4 アクティベート
01984     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
01985     time.sleep(sleep_recv_act_time)
01986     ec_send[0].activate_component(g_compo_send.rtc_ref)
01987 
01988     time.sleep(sleep_act_time)
01989 
01990     ## 5 ディアクティベート
01991     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
01992     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
01993 
01994     ## 受信ファイル有無判定
01995     if os.path.isfile(g_diff_recv_file) == False:
01996         fout = open(g_test_result_file, 'a')
01997         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
01998         message = message + g_check_message
01999         fout.write(message + '\n')
02000         fout.close()
02001         print message
02002         time.sleep(sleep_for_time)
02003         continue
02004 
02005     ## 7 送受信データ比較
02006     time.sleep(sleep_act_time)
02007     bret = diff_file()
02008 
02009     ## 差分ファイルからテスト結果出力
02010     fout = open(g_test_result_file, 'a')
02011     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02012     # bret==True なら送受信データ一致
02013     if bret == True:
02014         # テスト結果 OK
02015         message = message + g_test_ok
02016         print message
02017         fout.write(message + '\n')
02018     else:
02019         # テスト結果 NG
02020         message = message + g_test_ng
02021         print message
02022         message = message + g_test_ng_message
02023         fout.write(message + '\n')
02024         # 受信データをテスト結果ファイルへコピー
02025         fin2 = open(g_diff_recv_file, 'r')
02026         while(1):
02027             s2 = fin2.readline()
02028             if len(s2) == 0:
02029                 break
02030             fout.write(s2)
02031         fin2.close()
02032     fout.close()
02033 
02034     time.sleep(sleep_for_time)
02035 
02036 ## 6 ポート切断
02037 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02038 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02039 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02040 
02041 ##--------------------------------------------------------------------
02042 ## 接続タイプ：new  方向：in->out  ポリシー：FIFO  Activate・Deactivateテスト3
02043 ##--------------------------------------------------------------------
02044 case_no = case_no + 1
02045 fout = open(g_test_result_file, 'a')
02046 message = g_mess_header + g_test_case + str(case_no) + " "
02047 message = message + "Connecting(in->out, new,FIFO), Activate -> send/recv -> Deactivate"
02048 message = message + g_mess_footer
02049 fout.write(message + '\n')
02050 fout.close()
02051 print message
02052 
02053 ## 1 コネクタープロファイル設定
02054 make_connecter_profile("new", "FIFO", 1)
02055 
02056 ## 3 ポート接続
02057 # データポート1 TimedFloat
02058 ret0 = g_out_ports[g_port1].connect(g_conprof1)
02059 
02060 # データポート2 TimedFloatSeq
02061 ret1 = g_out_ports[g_port2].connect(g_conprof2)
02062 
02063 # サービスポート MyService
02064 ret2 = g_out_ports[g_port3].connect(g_conprof3)
02065 
02066 for i in range(loop_count):
02067 
02068     ## 2 受信データファイル削除
02069     delete_recv_file()
02070 
02071     ## 4 アクティベート
02072     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02073     time.sleep(sleep_recv_act_time)
02074     ec_send[0].activate_component(g_compo_send.rtc_ref)
02075 
02076     time.sleep(sleep_act_time)
02077 
02078     ## 5 ディアクティベート
02079     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02080     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02081 
02082     ## 受信ファイル有無判定
02083     if os.path.isfile(g_diff_recv_file) == False:
02084         fout = open(g_test_result_file, 'a')
02085         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02086         message = message + g_check_message
02087         fout.write(message + '\n')
02088         fout.close()
02089         print message
02090         time.sleep(sleep_for_time)
02091         continue
02092 
02093     ## 7 送受信データ比較
02094     time.sleep(sleep_act_time)
02095     bret = diff_file()
02096 
02097     ## 差分ファイルからテスト結果出力
02098     fout = open(g_test_result_file, 'a')
02099     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02100     # bret==True なら送受信データ一致
02101     if bret == True:
02102         # テスト結果 OK
02103         message = message + g_test_ok
02104         print message
02105         fout.write(message + '\n')
02106     else:
02107         # テスト結果 NG
02108         message = message + g_test_ng
02109         print message
02110         message = message + g_test_ng_message
02111         fout.write(message + '\n')
02112         # 受信データをテスト結果ファイルへコピー
02113         fin2 = open(g_diff_recv_file, 'r')
02114         while(1):
02115             s2 = fin2.readline()
02116             if len(s2) == 0:
02117                 break
02118             fout.write(s2)
02119         fin2.close()
02120     fout.close()
02121 
02122     time.sleep(sleep_for_time)
02123 
02124 ## 6 ポート切断
02125 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02126 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02127 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02128 
02129 ##--------------------------------------------------------------------
02130 ## 接続タイプ：new  方向：in->out  ポリシー：NEW  Activate・Deactivateテスト5
02131 ##--------------------------------------------------------------------
02132 case_no = case_no + 1
02133 fout = open(g_test_result_file, 'a')
02134 message = g_mess_header + g_test_case + str(case_no) + " "
02135 message = message + "Connecting(in->out, new,NEW), Activate -> send/recv -> Deactivate"
02136 message = message + g_mess_footer
02137 fout.write(message + '\n')
02138 fout.close()
02139 print message
02140 
02141 ## 1 コネクタープロファイル設定
02142 make_connecter_profile("new", "NEW", 1)
02143 
02144 ## 3 ポート接続
02145 # データポート1 TimedFloat
02146 ret0 = g_out_ports[g_port1].connect(g_conprof1)
02147 
02148 # データポート2 TimedFloatSeq
02149 ret1 = g_out_ports[g_port2].connect(g_conprof2)
02150 
02151 # サービスポート MyService
02152 ret2 = g_out_ports[g_port3].connect(g_conprof3)
02153 
02154 for i in range(loop_count):
02155 
02156     ## 2 受信データファイル削除
02157     delete_recv_file()
02158 
02159     ## 4 アクティベート
02160     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02161     time.sleep(sleep_recv_act_time)
02162     ec_send[0].activate_component(g_compo_send.rtc_ref)
02163 
02164     time.sleep(sleep_act_time)
02165 
02166     ## 5 ディアクティベート
02167     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02168     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02169 
02170     ## 受信ファイル有無判定
02171     if os.path.isfile(g_diff_recv_file) == False:
02172         fout = open(g_test_result_file, 'a')
02173         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02174         message = message + g_check_message
02175         fout.write(message + '\n')
02176         fout.close()
02177         print message
02178         time.sleep(sleep_for_time)
02179         continue
02180 
02181     ## 7 送受信データ比較
02182     time.sleep(sleep_act_time)
02183     bret = diff_file()
02184 
02185     ## 差分ファイルからテスト結果出力
02186     fout = open(g_test_result_file, 'a')
02187     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02188     # bret==True なら送受信データ一致
02189     if bret == True:
02190         # テスト結果 OK
02191         message = message + g_test_ok
02192         print message
02193         fout.write(message + '\n')
02194     else:
02195         # テスト結果 NG
02196         message = message + g_test_ng
02197         print message
02198         message = message + g_test_ng_message
02199         fout.write(message + '\n')
02200         # 受信データをテスト結果ファイルへコピー
02201         fin2 = open(g_diff_recv_file, 'r')
02202         while(1):
02203             s2 = fin2.readline()
02204             if len(s2) == 0:
02205                 break
02206             fout.write(s2)
02207         fin2.close()
02208     fout.close()
02209 
02210     time.sleep(sleep_for_time)
02211 
02212 ## 6 ポート切断
02213 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02214 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02215 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02216 
02217 ##--------------------------------------------------------------------
02218 ## 接続タイプ：new  方向：in->out  ポリシー：SKIP  Activate・Deactivateテスト4
02219 ##--------------------------------------------------------------------
02220 case_no = case_no + 1
02221 fout = open(g_test_result_file, 'a')
02222 message = g_mess_header + g_test_case + str(case_no) + " "
02223 message = message + "Connecting(in->out, new,SKIP), Activate -> send/recv -> Deactivate"
02224 message = message + g_mess_footer
02225 fout.write(message + '\n')
02226 fout.close()
02227 print message
02228 
02229 ## 1 コネクタープロファイル設定
02230 make_connecter_profile("new", "SKIP", 1)
02231 
02232 ## 3 ポート接続
02233 # データポート1 TimedFloat
02234 ret0 = g_out_ports[g_port1].connect(g_conprof1)
02235 
02236 # データポート2 TimedFloatSeq
02237 ret1 = g_out_ports[g_port2].connect(g_conprof2)
02238 
02239 # サービスポート MyService
02240 ret2 = g_out_ports[g_port3].connect(g_conprof3)
02241 
02242 for i in range(loop_count):
02243 
02244     ## 2 受信データファイル削除
02245     delete_recv_file()
02246 
02247     ## 4 アクティベート
02248     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02249     time.sleep(sleep_recv_act_time)
02250     ec_send[0].activate_component(g_compo_send.rtc_ref)
02251 
02252     time.sleep(sleep_act_time)
02253 
02254     ## 5 ディアクティベート
02255     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02256     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02257 
02258     ## 受信ファイル有無判定
02259     if os.path.isfile(g_diff_recv_file) == False:
02260         fout = open(g_test_result_file, 'a')
02261         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02262         message = message + g_check_message
02263         fout.write(message + '\n')
02264         fout.close()
02265         print message
02266         time.sleep(sleep_for_time)
02267         continue
02268 
02269     ## 7 送受信データ比較
02270     time.sleep(sleep_act_time)
02271     bret = diff_file()
02272 
02273     ## 差分ファイルからテスト結果出力
02274     fout = open(g_test_result_file, 'a')
02275     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02276     # bret==True なら送受信データ一致
02277     if bret == True:
02278         # テスト結果 OK
02279         message = message + g_test_ok
02280         print message
02281         fout.write(message + '\n')
02282     else:
02283         # テスト結果 NG
02284         message = message + g_test_ng
02285         print message
02286         message = message + g_test_ng_message
02287         fout.write(message + '\n')
02288         # 受信データをテスト結果ファイルへコピー
02289         fin2 = open(g_diff_recv_file, 'r')
02290         while(1):
02291             s2 = fin2.readline()
02292             if len(s2) == 0:
02293                 break
02294             fout.write(s2)
02295         fin2.close()
02296     fout.close()
02297 
02298     time.sleep(sleep_for_time)
02299 
02300 ## 6 ポート切断
02301 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02302 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02303 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02304 
02305 ##--------------------------------------------------------------------
02306 ## 接続タイプ：new  方向：out->in  ポリシー：ALL  接続・切断・Activate・Deactivateテスト1
02307 ##--------------------------------------------------------------------
02308 case_no = case_no + 1
02309 fout = open(g_test_result_file, 'a')
02310 message = g_mess_header + g_test_case + str(case_no) + " "
02311 message = message + "Connect(out->in, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
02312 message = message + g_mess_footer
02313 fout.write(message + '\n')
02314 fout.close()
02315 print message
02316 
02317 for i in range(loop_count):
02318 
02319     ## 2 受信データファイル削除
02320     delete_recv_file()
02321 
02322     ## 1 コネクタープロファイル設定
02323     make_connecter_profile("new", "ALL", 0)
02324 
02325     ## 3 ポート接続
02326     # データポート1 TimedFloat
02327     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02328 
02329     # データポート2 TimedFloatSeq
02330     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02331 
02332     # サービスポート MyService
02333     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02334 
02335     ## 4 アクティベート
02336     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02337     time.sleep(sleep_recv_act_time)
02338     ec_send[0].activate_component(g_compo_send.rtc_ref)
02339 
02340     time.sleep(sleep_act_time)
02341 
02342     ## 5 ディアクティベート
02343     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02344     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02345 
02346     ## 6 ポート切断
02347     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02348     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02349     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02350 
02351     ## 受信ファイル有無判定
02352     if os.path.isfile(g_diff_recv_file) == False:
02353         fout = open(g_test_result_file, 'a')
02354         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02355         message = message + g_check_message
02356         fout.write(message + '\n')
02357         fout.close()
02358         print message
02359         time.sleep(sleep_for_time)
02360         continue
02361 
02362     ## 7 送受信データ比較
02363     time.sleep(sleep_act_time)
02364     bret = diff_file()
02365 
02366     ## 差分ファイルからテスト結果出力
02367     fout = open(g_test_result_file, 'a')
02368     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02369     # bret==True なら送受信データ一致
02370     if bret == True:
02371         # テスト結果 OK
02372         message = message + g_test_ok
02373         print message
02374         fout.write(message + '\n')
02375     else:
02376         # テスト結果 NG
02377         message = message + g_test_ng
02378         print message
02379         message = message + g_test_ng_message
02380         fout.write(message + '\n')
02381         # 受信データをテスト結果ファイルへコピー
02382         fin2 = open(g_diff_recv_file, 'r')
02383         while(1):
02384             s2 = fin2.readline()
02385             if len(s2) == 0:
02386                 break
02387             fout.write(s2)
02388         fin2.close()
02389     fout.close()
02390 
02391     time.sleep(sleep_for_time)
02392 
02393 ##--------------------------------------------------------------------
02394 ## 接続タイプ：new  方向：out->in  ポリシー：FIFO  接続・切断・Activate・Deactivateテスト1
02395 ##--------------------------------------------------------------------
02396 case_no = case_no + 1
02397 fout = open(g_test_result_file, 'a')
02398 message = g_mess_header + g_test_case + str(case_no) + " "
02399 message = message + "Connect(out->in, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
02400 message = message + g_mess_footer
02401 fout.write(message + '\n')
02402 fout.close()
02403 print message
02404 
02405 for i in range(loop_count):
02406 
02407     ## 2 受信データファイル削除
02408     delete_recv_file()
02409 
02410     ## 1 コネクタープロファイル設定
02411     make_connecter_profile("new", "FIFO", 0)
02412 
02413     ## 3 ポート接続
02414     # データポート1 TimedFloat
02415     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02416 
02417     # データポート2 TimedFloatSeq
02418     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02419 
02420     # サービスポート MyService
02421     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02422 
02423     ## 4 アクティベート
02424     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02425     time.sleep(sleep_recv_act_time)
02426     ec_send[0].activate_component(g_compo_send.rtc_ref)
02427 
02428     time.sleep(sleep_act_time)
02429 
02430     ## 5 ディアクティベート
02431     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02432     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02433 
02434     ## 6 ポート切断
02435     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02436     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02437     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02438 
02439     ## 受信ファイル有無判定
02440     if os.path.isfile(g_diff_recv_file) == False:
02441         fout = open(g_test_result_file, 'a')
02442         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02443         message = message + g_check_message
02444         fout.write(message + '\n')
02445         fout.close()
02446         print message
02447         time.sleep(sleep_for_time)
02448         continue
02449 
02450     ## 7 送受信データ比較
02451     time.sleep(sleep_act_time)
02452     bret = diff_file()
02453 
02454     ## 差分ファイルからテスト結果出力
02455     fout = open(g_test_result_file, 'a')
02456     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02457     # bret==True なら送受信データ一致
02458     if bret == True:
02459         # テスト結果 OK
02460         message = message + g_test_ok
02461         print message
02462         fout.write(message + '\n')
02463     else:
02464         # テスト結果 NG
02465         message = message + g_test_ng
02466         print message
02467         message = message + g_test_ng_message
02468         fout.write(message + '\n')
02469         # 受信データをテスト結果ファイルへコピー
02470         fin2 = open(g_diff_recv_file, 'r')
02471         while(1):
02472             s2 = fin2.readline()
02473             if len(s2) == 0:
02474                 break
02475             fout.write(s2)
02476         fin2.close()
02477     fout.close()
02478 
02479     time.sleep(sleep_for_time)
02480 
02481 ##--------------------------------------------------------------------
02482 ## 接続タイプ：new  方向：out->in  ポリシー：NEW  接続・切断・Activate・Deactivateテスト1
02483 ##--------------------------------------------------------------------
02484 case_no = case_no + 1
02485 fout = open(g_test_result_file, 'a')
02486 message = g_mess_header + g_test_case + str(case_no) + " "
02487 message = message + "Connect(out->in, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
02488 message = message + g_mess_footer
02489 fout.write(message + '\n')
02490 fout.close()
02491 print message
02492 
02493 for i in range(loop_count):
02494 
02495     ## 2 受信データファイル削除
02496     delete_recv_file()
02497 
02498     ## 1 コネクタープロファイル設定
02499     make_connecter_profile("new", "NEW", 0)
02500 
02501     ## 3 ポート接続
02502     # データポート1 TimedFloat
02503     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02504 
02505     # データポート2 TimedFloatSeq
02506     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02507 
02508     # サービスポート MyService
02509     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02510 
02511     ## 4 アクティベート
02512     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02513     time.sleep(sleep_recv_act_time)
02514     ec_send[0].activate_component(g_compo_send.rtc_ref)
02515 
02516     time.sleep(sleep_act_time)
02517 
02518     ## 5 ディアクティベート
02519     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02520     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02521 
02522     ## 6 ポート切断
02523     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02524     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02525     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02526 
02527     ## 受信ファイル有無判定
02528     if os.path.isfile(g_diff_recv_file) == False:
02529         fout = open(g_test_result_file, 'a')
02530         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02531         message = message + g_check_message
02532         fout.write(message + '\n')
02533         fout.close()
02534         print message
02535         time.sleep(sleep_for_time)
02536         continue
02537 
02538     ## 7 送受信データ比較
02539     time.sleep(sleep_act_time)
02540     bret = diff_file()
02541 
02542     ## 差分ファイルからテスト結果出力
02543     fout = open(g_test_result_file, 'a')
02544     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02545     # bret==True なら送受信データ一致
02546     if bret == True:
02547         # テスト結果 OK
02548         message = message + g_test_ok
02549         print message
02550         fout.write(message + '\n')
02551     else:
02552         # テスト結果 NG
02553         message = message + g_test_ng
02554         print message
02555         message = message + g_test_ng_message
02556         fout.write(message + '\n')
02557         # 受信データをテスト結果ファイルへコピー
02558         fin2 = open(g_diff_recv_file, 'r')
02559         while(1):
02560             s2 = fin2.readline()
02561             if len(s2) == 0:
02562                 break
02563             fout.write(s2)
02564         fin2.close()
02565     fout.close()
02566 
02567     time.sleep(sleep_for_time)
02568 
02569 ##--------------------------------------------------------------------
02570 ## 接続タイプ：new  方向：out->in  ポリシー：SKIP  接続・切断・Activate・Deactivateテスト1
02571 ##--------------------------------------------------------------------
02572 case_no = case_no + 1
02573 fout = open(g_test_result_file, 'a')
02574 message = g_mess_header + g_test_case + str(case_no) + " "
02575 message = message + "Connect(out->in, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
02576 message = message + g_mess_footer
02577 fout.write(message + '\n')
02578 fout.close()
02579 print message
02580 
02581 for i in range(loop_count):
02582 
02583     ## 2 受信データファイル削除
02584     delete_recv_file()
02585 
02586     ## 1 コネクタープロファイル設定
02587     make_connecter_profile("new", "SKIP", 0)
02588 
02589     ## 3 ポート接続
02590     # データポート1 TimedFloat
02591     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02592 
02593     # データポート2 TimedFloatSeq
02594     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02595 
02596     # サービスポート MyService
02597     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02598 
02599     ## 4 アクティベート
02600     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02601     time.sleep(sleep_recv_act_time)
02602     ec_send[0].activate_component(g_compo_send.rtc_ref)
02603 
02604     time.sleep(sleep_act_time)
02605 
02606     ## 5 ディアクティベート
02607     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02608     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02609 
02610     ## 6 ポート切断
02611     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02612     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02613     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02614 
02615     ## 受信ファイル有無判定
02616     if os.path.isfile(g_diff_recv_file) == False:
02617         fout = open(g_test_result_file, 'a')
02618         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02619         message = message + g_check_message
02620         fout.write(message + '\n')
02621         fout.close()
02622         print message
02623         time.sleep(sleep_for_time)
02624         continue
02625 
02626     ## 7 送受信データ比較
02627     time.sleep(sleep_act_time)
02628     bret = diff_file()
02629 
02630     ## 差分ファイルからテスト結果出力
02631     fout = open(g_test_result_file, 'a')
02632     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02633     # bret==True なら送受信データ一致
02634     if bret == True:
02635         # テスト結果 OK
02636         message = message + g_test_ok
02637         print message
02638         fout.write(message + '\n')
02639     else:
02640         # テスト結果 NG
02641         message = message + g_test_ng
02642         print message
02643         message = message + g_test_ng_message
02644         fout.write(message + '\n')
02645         # 受信データをテスト結果ファイルへコピー
02646         fin2 = open(g_diff_recv_file, 'r')
02647         while(1):
02648             s2 = fin2.readline()
02649             if len(s2) == 0:
02650                 break
02651             fout.write(s2)
02652         fin2.close()
02653     fout.close()
02654 
02655     time.sleep(sleep_for_time)
02656 
02657 ##--------------------------------------------------------------------
02658 ## 接続タイプ：new  方向：in->out  ポリシー：ALL  接続・切断・Activate・Deactivateテスト1
02659 ##--------------------------------------------------------------------
02660 case_no = case_no + 1
02661 fout = open(g_test_result_file, 'a')
02662 message = g_mess_header + g_test_case + str(case_no) + " "
02663 message = message + "Connect(in->out, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
02664 message = message + g_mess_footer
02665 fout.write(message + '\n')
02666 fout.close()
02667 print message
02668 
02669 for i in range(loop_count):
02670 
02671     ## 2 受信データファイル削除
02672     delete_recv_file()
02673 
02674     ## 1 コネクタープロファイル設定
02675     make_connecter_profile("new", "ALL", 1)
02676 
02677     ## 3 ポート接続
02678     # データポート1 TimedFloat
02679     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02680 
02681     # データポート2 TimedFloatSeq
02682     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02683 
02684     # サービスポート MyService
02685     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02686 
02687     ## 4 アクティベート
02688     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02689     time.sleep(sleep_recv_act_time)
02690     ec_send[0].activate_component(g_compo_send.rtc_ref)
02691 
02692     time.sleep(sleep_act_time)
02693 
02694     ## 5 ディアクティベート
02695     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02696     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02697 
02698     ## 6 ポート切断
02699     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02700     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02701     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02702 
02703     ## 受信ファイル有無判定
02704     if os.path.isfile(g_diff_recv_file) == False:
02705         fout = open(g_test_result_file, 'a')
02706         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02707         message = message + g_check_message
02708         fout.write(message + '\n')
02709         fout.close()
02710         print message
02711         time.sleep(sleep_for_time)
02712         continue
02713 
02714     ## 7 送受信データ比較
02715     time.sleep(sleep_act_time)
02716     bret = diff_file()
02717 
02718     ## 差分ファイルからテスト結果出力
02719     fout = open(g_test_result_file, 'a')
02720     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02721     # bret==True なら送受信データ一致
02722     if bret == True:
02723         # テスト結果 OK
02724         message = message + g_test_ok
02725         print message
02726         fout.write(message + '\n')
02727     else:
02728         # テスト結果 NG
02729         message = message + g_test_ng
02730         print message
02731         message = message + g_test_ng_message
02732         fout.write(message + '\n')
02733         # 受信データをテスト結果ファイルへコピー
02734         fin2 = open(g_diff_recv_file, 'r')
02735         while(1):
02736             s2 = fin2.readline()
02737             if len(s2) == 0:
02738                 break
02739             fout.write(s2)
02740         fin2.close()
02741     fout.close()
02742 
02743     time.sleep(sleep_for_time)
02744 
02745 ##--------------------------------------------------------------------
02746 ## 接続タイプ：new  方向：in->out  ポリシー：FIFO  接続・切断・Activate・Deactivateテスト1
02747 ##--------------------------------------------------------------------
02748 case_no = case_no + 1
02749 fout = open(g_test_result_file, 'a')
02750 message = g_mess_header + g_test_case + str(case_no) + " "
02751 message = message + "Connect(in->out, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
02752 message = message + g_mess_footer
02753 fout.write(message + '\n')
02754 fout.close()
02755 print message
02756 
02757 for i in range(loop_count):
02758 
02759     ## 2 受信データファイル削除
02760     delete_recv_file()
02761 
02762     ## 1 コネクタープロファイル設定
02763     make_connecter_profile("new", "FIFO", 1)
02764 
02765     ## 3 ポート接続
02766     # データポート1 TimedFloat
02767     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02768 
02769     # データポート2 TimedFloatSeq
02770     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02771 
02772     # サービスポート MyService
02773     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02774 
02775     ## 4 アクティベート
02776     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02777     time.sleep(sleep_recv_act_time)
02778     ec_send[0].activate_component(g_compo_send.rtc_ref)
02779 
02780     time.sleep(sleep_act_time)
02781 
02782     ## 5 ディアクティベート
02783     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02784     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02785 
02786     ## 6 ポート切断
02787     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02788     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02789     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02790 
02791     ## 受信ファイル有無判定
02792     if os.path.isfile(g_diff_recv_file) == False:
02793         fout = open(g_test_result_file, 'a')
02794         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02795         message = message + g_check_message
02796         fout.write(message + '\n')
02797         fout.close()
02798         print message
02799         time.sleep(sleep_for_time)
02800         continue
02801 
02802     ## 7 送受信データ比較
02803     time.sleep(sleep_act_time)
02804     bret = diff_file()
02805 
02806     ## 差分ファイルからテスト結果出力
02807     fout = open(g_test_result_file, 'a')
02808     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02809     # bret==True なら送受信データ一致
02810     if bret == True:
02811         # テスト結果 OK
02812         message = message + g_test_ok
02813         print message
02814         fout.write(message + '\n')
02815     else:
02816         # テスト結果 NG
02817         message = message + g_test_ng
02818         print message
02819         message = message + g_test_ng_message
02820         fout.write(message + '\n')
02821         # 受信データをテスト結果ファイルへコピー
02822         fin2 = open(g_diff_recv_file, 'r')
02823         while(1):
02824             s2 = fin2.readline()
02825             if len(s2) == 0:
02826                 break
02827             fout.write(s2)
02828         fin2.close()
02829     fout.close()
02830 
02831     time.sleep(sleep_for_time)
02832 
02833 ##--------------------------------------------------------------------
02834 ## 接続タイプ：new  方向：in->out  ポリシー：NEW  接続・切断・Activate・Deactivateテスト1
02835 ##--------------------------------------------------------------------
02836 case_no = case_no + 1
02837 fout = open(g_test_result_file, 'a')
02838 message = g_mess_header + g_test_case + str(case_no) + " "
02839 message = message + "Connect(in->out, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
02840 message = message + g_mess_footer
02841 fout.write(message + '\n')
02842 fout.close()
02843 print message
02844 
02845 for i in range(loop_count):
02846 
02847     ## 2 受信データファイル削除
02848     delete_recv_file()
02849 
02850     ## 1 コネクタープロファイル設定
02851     make_connecter_profile("new", "NEW", 1)
02852 
02853     ## 3 ポート接続
02854     # データポート1 TimedFloat
02855     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02856 
02857     # データポート2 TimedFloatSeq
02858     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02859 
02860     # サービスポート MyService
02861     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02862 
02863     ## 4 アクティベート
02864     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02865     time.sleep(sleep_recv_act_time)
02866     ec_send[0].activate_component(g_compo_send.rtc_ref)
02867 
02868     time.sleep(sleep_act_time)
02869 
02870     ## 5 ディアクティベート
02871     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02872     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02873 
02874     ## 6 ポート切断
02875     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02876     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02877     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02878 
02879     ## 受信ファイル有無判定
02880     if os.path.isfile(g_diff_recv_file) == False:
02881         fout = open(g_test_result_file, 'a')
02882         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02883         message = message + g_check_message
02884         fout.write(message + '\n')
02885         fout.close()
02886         print message
02887         time.sleep(sleep_for_time)
02888         continue
02889 
02890     ## 7 送受信データ比較
02891     time.sleep(sleep_act_time)
02892     bret = diff_file()
02893 
02894     ## 差分ファイルからテスト結果出力
02895     fout = open(g_test_result_file, 'a')
02896     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02897     # bret==True なら送受信データ一致
02898     if bret == True:
02899         # テスト結果 OK
02900         message = message + g_test_ok
02901         print message
02902         fout.write(message + '\n')
02903     else:
02904         # テスト結果 NG
02905         message = message + g_test_ng
02906         print message
02907         message = message + g_test_ng_message
02908         fout.write(message + '\n')
02909         # 受信データをテスト結果ファイルへコピー
02910         fin2 = open(g_diff_recv_file, 'r')
02911         while(1):
02912             s2 = fin2.readline()
02913             if len(s2) == 0:
02914                 break
02915             fout.write(s2)
02916         fin2.close()
02917     fout.close()
02918 
02919     time.sleep(sleep_for_time)
02920 
02921 ##--------------------------------------------------------------------
02922 ## 接続タイプ：new  方向：in->out  ポリシー：SKIP  接続・切断・Activate・Deactivateテスト1
02923 ##--------------------------------------------------------------------
02924 case_no = case_no + 1
02925 fout = open(g_test_result_file, 'a')
02926 message = g_mess_header + g_test_case + str(case_no) + " "
02927 message = message + "Connect(in->out, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
02928 message = message + g_mess_footer
02929 fout.write(message + '\n')
02930 fout.close()
02931 print message
02932 
02933 for i in range(loop_count):
02934 
02935     ## 2 受信データファイル削除
02936     delete_recv_file()
02937 
02938     ## 1 コネクタープロファイル設定
02939     make_connecter_profile("new", "SKIP", 1)
02940 
02941     ## 3 ポート接続
02942     # データポート1 TimedFloat
02943     ret0 = g_out_ports[g_port1].connect(g_conprof1)
02944 
02945     # データポート2 TimedFloatSeq
02946     ret1 = g_out_ports[g_port2].connect(g_conprof2)
02947 
02948     # サービスポート MyService
02949     ret2 = g_out_ports[g_port3].connect(g_conprof3)
02950 
02951     ## 4 アクティベート
02952     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
02953     time.sleep(sleep_recv_act_time)
02954     ec_send[0].activate_component(g_compo_send.rtc_ref)
02955 
02956     time.sleep(sleep_act_time)
02957 
02958     ## 5 ディアクティベート
02959     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
02960     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
02961 
02962     ## 6 ポート切断
02963     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
02964     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
02965     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
02966 
02967     ## 受信ファイル有無判定
02968     if os.path.isfile(g_diff_recv_file) == False:
02969         fout = open(g_test_result_file, 'a')
02970         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02971         message = message + g_check_message
02972         fout.write(message + '\n')
02973         fout.close()
02974         print message
02975         time.sleep(sleep_for_time)
02976         continue
02977 
02978     ## 7 送受信データ比較
02979     time.sleep(sleep_act_time)
02980     bret = diff_file()
02981 
02982     ## 差分ファイルからテスト結果出力
02983     fout = open(g_test_result_file, 'a')
02984     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
02985     # bret==True なら送受信データ一致
02986     if bret == True:
02987         # テスト結果 OK
02988         message = message + g_test_ok
02989         print message
02990         fout.write(message + '\n')
02991     else:
02992         # テスト結果 NG
02993         message = message + g_test_ng
02994         print message
02995         message = message + g_test_ng_message
02996         fout.write(message + '\n')
02997         # 受信データをテスト結果ファイルへコピー
02998         fin2 = open(g_diff_recv_file, 'r')
02999         while(1):
03000             s2 = fin2.readline()
03001             if len(s2) == 0:
03002                 break
03003             fout.write(s2)
03004         fin2.close()
03005     fout.close()
03006 
03007     time.sleep(sleep_for_time)
03008 
03009 ##--------------------------------------------------------------------
03010 ##--------------------------------------------------------------------
03011 ## 接続タイプ：periodic  方向：out->in  ポリシー：ALL  接続・切断テスト7
03012 ##--------------------------------------------------------------------
03013 case_no = case_no + 1
03014 fout = open(g_test_result_file, 'a')
03015 message = g_mess_header + g_test_case + str(case_no) + " "
03016 message = message + "Connect(out->in, periodic,ALL) -> Disconnect"
03017 message = message + g_mess_footer
03018 fout.write(message + '\n')
03019 fout.close()
03020 print message
03021 
03022 for i in range(loop_count):
03023 
03024     ## 1 コネクタープロファイル設定
03025     make_connecter_profile("periodic", "ALL", 0)
03026 
03027     ## 3 ポート接続
03028     # データポート1 TimedFloat
03029     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03030 
03031     # データポート2 TimedFloatSeq
03032     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03033 
03034     # サービスポート MyService
03035     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03036 
03037     time.sleep(sleep_connect_time)
03038 
03039     ## 6 ポート切断
03040     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03041     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03042     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03043 
03044     ## テスト結果出力
03045     fout = open(g_test_result_file, 'a')
03046     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03047     message = message + g_test_ok
03048     print message
03049     fout.write(message + '\n')
03050     fout.close()
03051 
03052     time.sleep(sleep_for_time)
03053 
03054 ##--------------------------------------------------------------------
03055 ## 接続タイプ：periodic  方向：out->in  ポリシー：FIFO  接続・切断テスト8
03056 ##--------------------------------------------------------------------
03057 case_no = case_no + 1
03058 fout = open(g_test_result_file, 'a')
03059 message = g_mess_header + g_test_case + str(case_no) + " "
03060 message = message + "Connect(out->in, periodic,FIFO) -> Disconnect"
03061 message = message + g_mess_footer
03062 fout.write(message + '\n')
03063 fout.close()
03064 print message
03065 
03066 for i in range(loop_count):
03067 
03068     ## 1 コネクタープロファイル設定
03069     make_connecter_profile("periodic", "FIFO", 0)
03070 
03071     ## 3 ポート接続
03072     # データポート1 TimedFloat
03073     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03074 
03075     # データポート2 TimedFloatSeq
03076     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03077 
03078     # サービスポート MyService
03079     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03080 
03081     time.sleep(sleep_connect_time)
03082 
03083     ## 6 ポート切断
03084     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03085     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03086     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03087 
03088     ## テスト結果出力
03089     fout = open(g_test_result_file, 'a')
03090     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03091     message = message + g_test_ok
03092     print message
03093     fout.write(message + '\n')
03094     fout.close()
03095 
03096     time.sleep(sleep_for_time)
03097 
03098 ##--------------------------------------------------------------------
03099 ## 接続タイプ：periodic  方向：out->in  ポリシー：NEW  接続・切断テスト10
03100 ##--------------------------------------------------------------------
03101 case_no = case_no + 1
03102 fout = open(g_test_result_file, 'a')
03103 message = g_mess_header + g_test_case + str(case_no) + " "
03104 message = message + "Connect(out->in, periodic,NEW) -> Disconnect"
03105 message = message + g_mess_footer
03106 fout.write(message + '\n')
03107 fout.close()
03108 print message
03109 
03110 for i in range(loop_count):
03111 
03112     ## 1 コネクタープロファイル設定
03113     make_connecter_profile("periodic", "NEW", 0)
03114 
03115     ## 3 ポート接続
03116     # データポート1 TimedFloat
03117     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03118 
03119     # データポート2 TimedFloatSeq
03120     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03121 
03122     # サービスポート MyService
03123     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03124 
03125     time.sleep(sleep_connect_time)
03126 
03127     ## 6 ポート切断
03128     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03129     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03130     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03131 
03132     ## テスト結果出力
03133     fout = open(g_test_result_file, 'a')
03134     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03135     message = message + g_test_ok
03136     print message
03137     fout.write(message + '\n')
03138     fout.close()
03139 
03140     time.sleep(sleep_for_time)
03141 
03142 ##--------------------------------------------------------------------
03143 ## 接続タイプ：periodic  方向：out->in  ポリシー：SKIP  接続・切断テスト9
03144 ##--------------------------------------------------------------------
03145 case_no = case_no + 1
03146 fout = open(g_test_result_file, 'a')
03147 message = g_mess_header + g_test_case + str(case_no) + " "
03148 message = message + "Connect(out->in, periodic,SKIP) -> Disconnect"
03149 message = message + g_mess_footer
03150 fout.write(message + '\n')
03151 fout.close()
03152 print message
03153 
03154 for i in range(loop_count):
03155 
03156     ## 1 コネクタープロファイル設定
03157     make_connecter_profile("periodic", "SKIP", 0)
03158 
03159     ## 3 ポート接続
03160     # データポート1 TimedFloat
03161     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03162 
03163     # データポート2 TimedFloatSeq
03164     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03165 
03166     # サービスポート MyService
03167     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03168 
03169     time.sleep(sleep_connect_time)
03170 
03171     ## 6 ポート切断
03172     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03173     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03174     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03175 
03176     ## テスト結果出力
03177     fout = open(g_test_result_file, 'a')
03178     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03179     message = message + g_test_ok
03180     print message
03181     fout.write(message + '\n')
03182     fout.close()
03183 
03184     time.sleep(sleep_for_time)
03185 
03186 ##--------------------------------------------------------------------
03187 ## 接続タイプ：periodic  方向：in->out  ポリシー：ALL  接続・切断テスト7
03188 ##--------------------------------------------------------------------
03189 case_no = case_no + 1
03190 fout = open(g_test_result_file, 'a')
03191 message = g_mess_header + g_test_case + str(case_no) + " "
03192 message = message + "Connect(in->out, periodic,ALL) -> Disconnect"
03193 message = message + g_mess_footer
03194 fout.write(message + '\n')
03195 fout.close()
03196 print message
03197 
03198 for i in range(loop_count):
03199 
03200     ## 1 コネクタープロファイル設定
03201     make_connecter_profile("periodic", "ALL", 1)
03202 
03203     ## 3 ポート接続
03204     # データポート1 TimedFloat
03205     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03206 
03207     # データポート2 TimedFloatSeq
03208     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03209 
03210     # サービスポート MyService
03211     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03212 
03213     time.sleep(sleep_connect_time)
03214 
03215     ## 6 ポート切断
03216     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03217     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03218     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03219 
03220     ## テスト結果出力
03221     fout = open(g_test_result_file, 'a')
03222     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03223     message = message + g_test_ok
03224     print message
03225     fout.write(message + '\n')
03226     fout.close()
03227 
03228     time.sleep(sleep_for_time)
03229 
03230 ##--------------------------------------------------------------------
03231 ## 接続タイプ：periodic  方向：in->out  ポリシー：FIFO  接続・切断テスト8
03232 ##--------------------------------------------------------------------
03233 case_no = case_no + 1
03234 fout = open(g_test_result_file, 'a')
03235 message = g_mess_header + g_test_case + str(case_no) + " "
03236 message = message + "Connect(in->out, periodic,FIFO) -> Disconnect"
03237 message = message + g_mess_footer
03238 fout.write(message + '\n')
03239 fout.close()
03240 print message
03241 
03242 for i in range(loop_count):
03243 
03244     ## 1 コネクタープロファイル設定
03245     make_connecter_profile("periodic", "FIFO", 1)
03246 
03247     ## 3 ポート接続
03248     # データポート1 TimedFloat
03249     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03250 
03251     # データポート2 TimedFloatSeq
03252     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03253 
03254     # サービスポート MyService
03255     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03256 
03257     time.sleep(sleep_connect_time)
03258 
03259     ## 6 ポート切断
03260     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03261     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03262     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03263 
03264     ## テスト結果出力
03265     fout = open(g_test_result_file, 'a')
03266     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03267     message = message + g_test_ok
03268     print message
03269     fout.write(message + '\n')
03270     fout.close()
03271 
03272     time.sleep(sleep_for_time)
03273 
03274 ##--------------------------------------------------------------------
03275 ## 接続タイプ：periodic  方向：in->out  ポリシー：NEW  接続・切断テスト10
03276 ##--------------------------------------------------------------------
03277 case_no = case_no + 1
03278 fout = open(g_test_result_file, 'a')
03279 message = g_mess_header + g_test_case + str(case_no) + " "
03280 message = message + "Connect(in->out, periodic,NEW) -> Disconnect"
03281 message = message + g_mess_footer
03282 fout.write(message + '\n')
03283 fout.close()
03284 print message
03285 
03286 for i in range(loop_count):
03287 
03288     ## 1 コネクタープロファイル設定
03289     make_connecter_profile("periodic", "NEW", 1)
03290 
03291     ## 3 ポート接続
03292     # データポート1 TimedFloat
03293     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03294 
03295     # データポート2 TimedFloatSeq
03296     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03297 
03298     # サービスポート MyService
03299     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03300 
03301     time.sleep(sleep_connect_time)
03302 
03303     ## 6 ポート切断
03304     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03305     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03306     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03307 
03308     ## テスト結果出力
03309     fout = open(g_test_result_file, 'a')
03310     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03311     message = message + g_test_ok
03312     print message
03313     fout.write(message + '\n')
03314     fout.close()
03315 
03316     time.sleep(sleep_for_time)
03317 
03318 ##--------------------------------------------------------------------
03319 ## 接続タイプ：periodic  方向：in->out  ポリシー：SKIP  接続・切断テスト9
03320 ##--------------------------------------------------------------------
03321 case_no = case_no + 1
03322 fout = open(g_test_result_file, 'a')
03323 message = g_mess_header + g_test_case + str(case_no) + " "
03324 message = message + "Connect(in->out, periodic,SKIP) -> Disconnect"
03325 message = message + g_mess_footer
03326 fout.write(message + '\n')
03327 fout.close()
03328 print message
03329 
03330 for i in range(loop_count):
03331 
03332     ## 1 コネクタープロファイル設定
03333     make_connecter_profile("periodic", "SKIP", 1)
03334 
03335     ## 3 ポート接続
03336     # データポート1 TimedFloat
03337     ret0 = g_out_ports[g_port1].connect(g_conprof1)
03338 
03339     # データポート2 TimedFloatSeq
03340     ret1 = g_out_ports[g_port2].connect(g_conprof2)
03341 
03342     # サービスポート MyService
03343     ret2 = g_out_ports[g_port3].connect(g_conprof3)
03344 
03345     time.sleep(sleep_connect_time)
03346 
03347     ## 6 ポート切断
03348     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03349     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03350     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03351 
03352     ## テスト結果出力
03353     fout = open(g_test_result_file, 'a')
03354     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03355     message = message + g_test_ok
03356     print message
03357     fout.write(message + '\n')
03358     fout.close()
03359 
03360     time.sleep(sleep_for_time)
03361 
03362 ##--------------------------------------------------------------------
03363 ## 接続タイプ：periodic  方向：out->in  ポリシー：ALL    Activate・Deactivateテスト6
03364 ##--------------------------------------------------------------------
03365 case_no = case_no + 1
03366 fout = open(g_test_result_file, 'a')
03367 message = g_mess_header + g_test_case + str(case_no) + " "
03368 message = message + "Connecting(out->in, periodic,ALL), Activate -> send/recv -> Deactivate"
03369 message = message + g_mess_footer
03370 fout.write(message + '\n')
03371 fout.close()
03372 print message
03373 
03374 ## 1 コネクタープロファイル設定
03375 make_connecter_profile("periodic", "ALL", 0)
03376 
03377 ## 3 ポート接続
03378 # データポート1 TimedFloat
03379 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03380 
03381 # データポート2 TimedFloatSeq
03382 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03383 
03384 # サービスポート MyService
03385 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03386 
03387 for i in range(loop_count):
03388 
03389     ## 2 受信データファイル削除
03390     delete_recv_file()
03391 
03392     ## 4 アクティベート
03393     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03394     time.sleep(sleep_recv_act_time)
03395     ec_send[0].activate_component(g_compo_send.rtc_ref)
03396 
03397     time.sleep(sleep_act_time)
03398 
03399     ## 5 ディアクティベート
03400     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03401     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03402 
03403     ## 受信ファイル有無判定
03404     if os.path.isfile(g_diff_recv_file) == False:
03405         fout = open(g_test_result_file, 'a')
03406         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03407         message = message + g_check_message
03408         fout.write(message + '\n')
03409         fout.close()
03410         print message
03411         time.sleep(sleep_for_time)
03412         continue
03413 
03414     ## 7 送受信データ比較
03415     time.sleep(sleep_act_time)
03416     bret = diff_file()
03417 
03418     ## 差分ファイルからテスト結果出力
03419     fout = open(g_test_result_file, 'a')
03420     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03421     # bret==True なら送受信データ一致
03422     if bret == True:
03423         # テスト結果 OK
03424         message = message + g_test_ok
03425         print message
03426         fout.write(message + '\n')
03427     else:
03428         # テスト結果 NG
03429         message = message + g_test_ng
03430         print message
03431         message = message + g_test_ng_message
03432         fout.write(message + '\n')
03433         # 受信データをテスト結果ファイルへコピー
03434         fin2 = open(g_diff_recv_file, 'r')
03435         while(1):
03436             s2 = fin2.readline()
03437             if len(s2) == 0:
03438                 break
03439             fout.write(s2)
03440         fin2.close()
03441     fout.close()
03442 
03443     time.sleep(sleep_for_time)
03444 
03445 ## 6 ポート切断
03446 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03447 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03448 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03449 
03450 ##--------------------------------------------------------------------
03451 ## 接続タイプ：periodic  方向：out->in  ポリシー：FIFO    Activate・Deactivateテスト7
03452 ##--------------------------------------------------------------------
03453 case_no = case_no + 1
03454 fout = open(g_test_result_file, 'a')
03455 message = g_mess_header + g_test_case + str(case_no) + " "
03456 message = message + "Connecting(out->in, periodic,FIFO), Activate -> send/recv -> Deactivate"
03457 message = message + g_mess_footer
03458 fout.write(message + '\n')
03459 fout.close()
03460 print message
03461 
03462 ## 1 コネクタープロファイル設定
03463 make_connecter_profile("periodic", "FIFO", 0)
03464 
03465 ## 3 ポート接続
03466 # データポート1 TimedFloat
03467 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03468 
03469 # データポート2 TimedFloatSeq
03470 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03471 
03472 # サービスポート MyService
03473 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03474 
03475 for i in range(loop_count):
03476 
03477     ## 2 受信データファイル削除
03478     delete_recv_file()
03479 
03480     ## 4 アクティベート
03481     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03482     time.sleep(sleep_recv_act_time)
03483     ec_send[0].activate_component(g_compo_send.rtc_ref)
03484 
03485     time.sleep(sleep_act_time)
03486 
03487     ## 5 ディアクティベート
03488     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03489     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03490 
03491     ## 受信ファイル有無判定
03492     if os.path.isfile(g_diff_recv_file) == False:
03493         fout = open(g_test_result_file, 'a')
03494         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03495         message = message + g_check_message
03496         fout.write(message + '\n')
03497         fout.close()
03498         print message
03499         time.sleep(sleep_for_time)
03500         continue
03501 
03502     ## 7 送受信データ比較
03503     time.sleep(sleep_act_time)
03504     bret = diff_file()
03505 
03506     ## 差分ファイルからテスト結果出力
03507     fout = open(g_test_result_file, 'a')
03508     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03509     # bret==True なら送受信データ一致
03510     if bret == True:
03511         # テスト結果 OK
03512         message = message + g_test_ok
03513         print message
03514         fout.write(message + '\n')
03515     else:
03516         # テスト結果 NG
03517         message = message + g_test_ng
03518         print message
03519         message = message + g_test_ng_message
03520         fout.write(message + '\n')
03521         # 受信データをテスト結果ファイルへコピー
03522         fin2 = open(g_diff_recv_file, 'r')
03523         while(1):
03524             s2 = fin2.readline()
03525             if len(s2) == 0:
03526                 break
03527             fout.write(s2)
03528         fin2.close()
03529     fout.close()
03530 
03531     time.sleep(sleep_for_time)
03532 
03533 ## 6 ポート切断
03534 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03535 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03536 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03537 
03538 ##--------------------------------------------------------------------
03539 ## 接続タイプ：periodic  方向：out->in  ポリシー：NEW    Activate・Deactivateテスト9
03540 ##--------------------------------------------------------------------
03541 case_no = case_no + 1
03542 fout = open(g_test_result_file, 'a')
03543 message = g_mess_header + g_test_case + str(case_no) + " "
03544 message = message + "Connecting(out->in, periodic,NEW), Activate -> send/recv -> Deactivate"
03545 message = message + g_mess_footer
03546 fout.write(message + '\n')
03547 fout.close()
03548 print message
03549 
03550 ## 1 コネクタープロファイル設定
03551 make_connecter_profile("periodic", "NEW", 0)
03552 
03553 ## 3 ポート接続
03554 # データポート1 TimedFloat
03555 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03556 
03557 # データポート2 TimedFloatSeq
03558 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03559 
03560 # サービスポート MyService
03561 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03562 
03563 for i in range(loop_count):
03564 
03565     ## 2 受信データファイル削除
03566     delete_recv_file()
03567 
03568     ## 4 アクティベート
03569     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03570     time.sleep(sleep_recv_act_time)
03571     ec_send[0].activate_component(g_compo_send.rtc_ref)
03572 
03573     time.sleep(sleep_act_time)
03574 
03575     ## 5 ディアクティベート
03576     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03577     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03578 
03579     ## 受信ファイル有無判定
03580     if os.path.isfile(g_diff_recv_file) == False:
03581         fout = open(g_test_result_file, 'a')
03582         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03583         message = message + g_check_message
03584         fout.write(message + '\n')
03585         fout.close()
03586         print message
03587         time.sleep(sleep_for_time)
03588         continue
03589 
03590     ## 7 送受信データ比較
03591     time.sleep(sleep_act_time)
03592     bret = diff_file()
03593 
03594     ## 差分ファイルからテスト結果出力
03595     fout = open(g_test_result_file, 'a')
03596     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03597     # bret==True なら送受信データ一致
03598     if bret == True:
03599         # テスト結果 OK
03600         message = message + g_test_ok
03601         print message
03602         fout.write(message + '\n')
03603     else:
03604         # テスト結果 NG
03605         message = message + g_test_ng
03606         print message
03607         message = message + g_test_ng_message
03608         fout.write(message + '\n')
03609         # 受信データをテスト結果ファイルへコピー
03610         fin2 = open(g_diff_recv_file, 'r')
03611         while(1):
03612             s2 = fin2.readline()
03613             if len(s2) == 0:
03614                 break
03615             fout.write(s2)
03616         fin2.close()
03617     fout.close()
03618 
03619     time.sleep(sleep_for_time)
03620 
03621 ## 6 ポート切断
03622 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03623 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03624 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03625 
03626 ##--------------------------------------------------------------------
03627 ## 接続タイプ：periodic  方向：out->in  ポリシー：SKIP    Activate・Deactivateテスト8
03628 ##--------------------------------------------------------------------
03629 case_no = case_no + 1
03630 fout = open(g_test_result_file, 'a')
03631 message = g_mess_header + g_test_case + str(case_no) + " "
03632 message = message + "Connecting(out->in, periodic,SKIP), Activate -> send/recv -> Deactivate"
03633 message = message + g_mess_footer
03634 fout.write(message + '\n')
03635 fout.close()
03636 print message
03637 
03638 ## 1 コネクタープロファイル設定
03639 make_connecter_profile("periodic", "SKIP", 0)
03640 
03641 ## 3 ポート接続
03642 # データポート1 TimedFloat
03643 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03644 
03645 # データポート2 TimedFloatSeq
03646 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03647 
03648 # サービスポート MyService
03649 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03650 
03651 for i in range(loop_count):
03652 
03653     ## 2 受信データファイル削除
03654     delete_recv_file()
03655 
03656     ## 4 アクティベート
03657     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03658     time.sleep(sleep_recv_act_time)
03659     ec_send[0].activate_component(g_compo_send.rtc_ref)
03660 
03661     time.sleep(sleep_act_time)
03662 
03663     ## 5 ディアクティベート
03664     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03665     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03666 
03667     ## 受信ファイル有無判定
03668     if os.path.isfile(g_diff_recv_file) == False:
03669         fout = open(g_test_result_file, 'a')
03670         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03671         message = message + g_check_message
03672         fout.write(message + '\n')
03673         fout.close()
03674         print message
03675         time.sleep(sleep_for_time)
03676         continue
03677 
03678     ## 7 送受信データ比較
03679     time.sleep(sleep_act_time)
03680     bret = diff_file()
03681 
03682     ## 差分ファイルからテスト結果出力
03683     fout = open(g_test_result_file, 'a')
03684     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03685     # bret==True なら送受信データ一致
03686     if bret == True:
03687         # テスト結果 OK
03688         message = message + g_test_ok
03689         print message
03690         fout.write(message + '\n')
03691     else:
03692         # テスト結果 NG
03693         message = message + g_test_ng
03694         print message
03695         message = message + g_test_ng_message
03696         fout.write(message + '\n')
03697         # 受信データをテスト結果ファイルへコピー
03698         fin2 = open(g_diff_recv_file, 'r')
03699         while(1):
03700             s2 = fin2.readline()
03701             if len(s2) == 0:
03702                 break
03703             fout.write(s2)
03704         fin2.close()
03705     fout.close()
03706 
03707     time.sleep(sleep_for_time)
03708 
03709 ## 6 ポート切断
03710 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03711 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03712 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03713 
03714 ##--------------------------------------------------------------------
03715 ## 接続タイプ：periodic  方向：in->out  ポリシー：ALL    Activate・Deactivateテスト6
03716 ##--------------------------------------------------------------------
03717 case_no = case_no + 1
03718 fout = open(g_test_result_file, 'a')
03719 message = g_mess_header + g_test_case + str(case_no) + " "
03720 message = message + "Connecting(in->out, periodic,ALL), Activate -> send/recv -> Deactivate"
03721 message = message + g_mess_footer
03722 fout.write(message + '\n')
03723 fout.close()
03724 print message
03725 
03726 ## 1 コネクタープロファイル設定
03727 make_connecter_profile("periodic", "ALL", 1)
03728 
03729 ## 3 ポート接続
03730 # データポート1 TimedFloat
03731 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03732 
03733 # データポート2 TimedFloatSeq
03734 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03735 
03736 # サービスポート MyService
03737 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03738 
03739 for i in range(loop_count):
03740 
03741     ## 2 受信データファイル削除
03742     delete_recv_file()
03743 
03744     ## 4 アクティベート
03745     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03746     time.sleep(sleep_recv_act_time)
03747     ec_send[0].activate_component(g_compo_send.rtc_ref)
03748 
03749     time.sleep(sleep_act_time)
03750 
03751     ## 5 ディアクティベート
03752     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03753     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03754 
03755     ## 受信ファイル有無判定
03756     if os.path.isfile(g_diff_recv_file) == False:
03757         fout = open(g_test_result_file, 'a')
03758         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03759         message = message + g_check_message
03760         fout.write(message + '\n')
03761         fout.close()
03762         print message
03763         time.sleep(sleep_for_time)
03764         continue
03765 
03766     ## 7 送受信データ比較
03767     time.sleep(sleep_act_time)
03768     bret = diff_file()
03769 
03770     ## 差分ファイルからテスト結果出力
03771     fout = open(g_test_result_file, 'a')
03772     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03773     # bret==True なら送受信データ一致
03774     if bret == True:
03775         # テスト結果 OK
03776         message = message + g_test_ok
03777         print message
03778         fout.write(message + '\n')
03779     else:
03780         # テスト結果 NG
03781         message = message + g_test_ng
03782         print message
03783         message = message + g_test_ng_message
03784         fout.write(message + '\n')
03785         # 受信データをテスト結果ファイルへコピー
03786         fin2 = open(g_diff_recv_file, 'r')
03787         while(1):
03788             s2 = fin2.readline()
03789             if len(s2) == 0:
03790                 break
03791             fout.write(s2)
03792         fin2.close()
03793     fout.close()
03794 
03795     time.sleep(sleep_for_time)
03796 
03797 ## 6 ポート切断
03798 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03799 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03800 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03801 
03802 ##--------------------------------------------------------------------
03803 ## 接続タイプ：periodic  方向：in->out  ポリシー：FIFO    Activate・Deactivateテスト7
03804 ##--------------------------------------------------------------------
03805 case_no = case_no + 1
03806 fout = open(g_test_result_file, 'a')
03807 message = g_mess_header + g_test_case + str(case_no) + " "
03808 message = message + "Connecting(in->out, periodic,FIFO), Activate -> send/recv -> Deactivate"
03809 message = message + g_mess_footer
03810 fout.write(message + '\n')
03811 fout.close()
03812 print message
03813 
03814 ## 1 コネクタープロファイル設定
03815 make_connecter_profile("periodic", "FIFO", 1)
03816 
03817 ## 3 ポート接続
03818 # データポート1 TimedFloat
03819 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03820 
03821 # データポート2 TimedFloatSeq
03822 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03823 
03824 # サービスポート MyService
03825 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03826 
03827 for i in range(loop_count):
03828 
03829     ## 2 受信データファイル削除
03830     delete_recv_file()
03831 
03832     ## 4 アクティベート
03833     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03834     time.sleep(sleep_recv_act_time)
03835     ec_send[0].activate_component(g_compo_send.rtc_ref)
03836 
03837     time.sleep(sleep_act_time)
03838 
03839     ## 5 ディアクティベート
03840     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03841     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03842 
03843     ## 受信ファイル有無判定
03844     if os.path.isfile(g_diff_recv_file) == False:
03845         fout = open(g_test_result_file, 'a')
03846         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03847         message = message + g_check_message
03848         fout.write(message + '\n')
03849         fout.close()
03850         print message
03851         time.sleep(sleep_for_time)
03852         continue
03853 
03854     ## 7 送受信データ比較
03855     time.sleep(sleep_act_time)
03856     bret = diff_file()
03857 
03858     ## 差分ファイルからテスト結果出力
03859     fout = open(g_test_result_file, 'a')
03860     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03861     # bret==True なら送受信データ一致
03862     if bret == True:
03863         # テスト結果 OK
03864         message = message + g_test_ok
03865         print message
03866         fout.write(message + '\n')
03867     else:
03868         # テスト結果 NG
03869         message = message + g_test_ng
03870         print message
03871         message = message + g_test_ng_message
03872         fout.write(message + '\n')
03873         # 受信データをテスト結果ファイルへコピー
03874         fin2 = open(g_diff_recv_file, 'r')
03875         while(1):
03876             s2 = fin2.readline()
03877             if len(s2) == 0:
03878                 break
03879             fout.write(s2)
03880         fin2.close()
03881     fout.close()
03882 
03883     time.sleep(sleep_for_time)
03884 
03885 ## 6 ポート切断
03886 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03887 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03888 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03889 
03890 ##--------------------------------------------------------------------
03891 ## 接続タイプ：periodic  方向：in->out  ポリシー：NEW    Activate・Deactivateテスト9
03892 ##--------------------------------------------------------------------
03893 case_no = case_no + 1
03894 fout = open(g_test_result_file, 'a')
03895 message = g_mess_header + g_test_case + str(case_no) + " "
03896 message = message + "Connecting(in->out, periodic,NEW), Activate -> send/recv -> Deactivate"
03897 message = message + g_mess_footer
03898 fout.write(message + '\n')
03899 fout.close()
03900 print message
03901 
03902 ## 1 コネクタープロファイル設定
03903 make_connecter_profile("periodic", "NEW", 1)
03904 
03905 ## 3 ポート接続
03906 # データポート1 TimedFloat
03907 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03908 
03909 # データポート2 TimedFloatSeq
03910 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03911 
03912 # サービスポート MyService
03913 ret2 = g_out_ports[g_port3].connect(g_conprof3)
03914 
03915 for i in range(loop_count):
03916 
03917     ## 2 受信データファイル削除
03918     delete_recv_file()
03919 
03920     ## 4 アクティベート
03921     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
03922     time.sleep(sleep_recv_act_time)
03923     ec_send[0].activate_component(g_compo_send.rtc_ref)
03924 
03925     time.sleep(sleep_act_time)
03926 
03927     ## 5 ディアクティベート
03928     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
03929     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
03930 
03931     ## 受信ファイル有無判定
03932     if os.path.isfile(g_diff_recv_file) == False:
03933         fout = open(g_test_result_file, 'a')
03934         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03935         message = message + g_check_message
03936         fout.write(message + '\n')
03937         fout.close()
03938         print message
03939         time.sleep(sleep_for_time)
03940         continue
03941 
03942     ## 7 送受信データ比較
03943     time.sleep(sleep_act_time)
03944     bret = diff_file()
03945 
03946     ## 差分ファイルからテスト結果出力
03947     fout = open(g_test_result_file, 'a')
03948     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
03949     # bret==True なら送受信データ一致
03950     if bret == True:
03951         # テスト結果 OK
03952         message = message + g_test_ok
03953         print message
03954         fout.write(message + '\n')
03955     else:
03956         # テスト結果 NG
03957         message = message + g_test_ng
03958         print message
03959         message = message + g_test_ng_message
03960         fout.write(message + '\n')
03961         # 受信データをテスト結果ファイルへコピー
03962         fin2 = open(g_diff_recv_file, 'r')
03963         while(1):
03964             s2 = fin2.readline()
03965             if len(s2) == 0:
03966                 break
03967             fout.write(s2)
03968         fin2.close()
03969     fout.close()
03970 
03971     time.sleep(sleep_for_time)
03972 
03973 ## 6 ポート切断
03974 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
03975 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
03976 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
03977 
03978 ##--------------------------------------------------------------------
03979 ## 接続タイプ：periodic  方向：in->out  ポリシー：SKIP    Activate・Deactivateテスト8
03980 ##--------------------------------------------------------------------
03981 case_no = case_no + 1
03982 fout = open(g_test_result_file, 'a')
03983 message = g_mess_header + g_test_case + str(case_no) + " "
03984 message = message + "Connecting(in->out, periodic,SKIP), Activate -> send/recv -> Deactivate"
03985 message = message + g_mess_footer
03986 fout.write(message + '\n')
03987 fout.close()
03988 print message
03989 
03990 ## 1 コネクタープロファイル設定
03991 make_connecter_profile("periodic", "SKIP", 1)
03992 
03993 ## 3 ポート接続
03994 # データポート1 TimedFloat
03995 ret0 = g_out_ports[g_port1].connect(g_conprof1)
03996 
03997 # データポート2 TimedFloatSeq
03998 ret1 = g_out_ports[g_port2].connect(g_conprof2)
03999 
04000 # サービスポート MyService
04001 ret2 = g_out_ports[g_port3].connect(g_conprof3)
04002 
04003 for i in range(loop_count):
04004 
04005     ## 2 受信データファイル削除
04006     delete_recv_file()
04007 
04008     ## 4 アクティベート
04009     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04010     time.sleep(sleep_recv_act_time)
04011     ec_send[0].activate_component(g_compo_send.rtc_ref)
04012 
04013     time.sleep(sleep_act_time)
04014 
04015     ## 5 ディアクティベート
04016     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04017     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04018 
04019     ## 受信ファイル有無判定
04020     if os.path.isfile(g_diff_recv_file) == False:
04021         fout = open(g_test_result_file, 'a')
04022         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04023         message = message + g_check_message
04024         fout.write(message + '\n')
04025         fout.close()
04026         print message
04027         time.sleep(sleep_for_time)
04028         continue
04029 
04030     ## 7 送受信データ比較
04031     time.sleep(sleep_act_time)
04032     bret = diff_file()
04033 
04034     ## 差分ファイルからテスト結果出力
04035     fout = open(g_test_result_file, 'a')
04036     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04037     # bret==True なら送受信データ一致
04038     if bret == True:
04039         # テスト結果 OK
04040         message = message + g_test_ok
04041         print message
04042         fout.write(message + '\n')
04043     else:
04044         # テスト結果 NG
04045         message = message + g_test_ng
04046         print message
04047         message = message + g_test_ng_message
04048         fout.write(message + '\n')
04049         # 受信データをテスト結果ファイルへコピー
04050         fin2 = open(g_diff_recv_file, 'r')
04051         while(1):
04052             s2 = fin2.readline()
04053             if len(s2) == 0:
04054                 break
04055             fout.write(s2)
04056         fin2.close()
04057     fout.close()
04058 
04059     time.sleep(sleep_for_time)
04060 
04061 ## 6 ポート切断
04062 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04063 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04064 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04065 
04066 ##--------------------------------------------------------------------
04067 ## 接続タイプ：periodic  方向：out->in  ポリシー：ALL  接続・切断・Activate・Deactivateテスト1
04068 ##--------------------------------------------------------------------
04069 case_no = case_no + 1
04070 fout = open(g_test_result_file, 'a')
04071 message = g_mess_header + g_test_case + str(case_no) + " "
04072 message = message + "Connect(out->in, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
04073 message = message + g_mess_footer
04074 fout.write(message + '\n')
04075 fout.close()
04076 print message
04077 
04078 for i in range(loop_count):
04079 
04080     ## 2 受信データファイル削除
04081     delete_recv_file()
04082 
04083     ## 1 コネクタープロファイル設定
04084     make_connecter_profile("periodic", "ALL", 0)
04085 
04086     ## 3 ポート接続
04087     # データポート1 TimedFloat
04088     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04089 
04090     # データポート2 TimedFloatSeq
04091     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04092 
04093     # サービスポート MyService
04094     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04095 
04096     ## 4 アクティベート
04097     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04098     time.sleep(sleep_recv_act_time)
04099     ec_send[0].activate_component(g_compo_send.rtc_ref)
04100 
04101     time.sleep(sleep_act_time)
04102 
04103     ## 5 ディアクティベート
04104     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04105     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04106 
04107     ## 6 ポート切断
04108     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04109     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04110     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04111 
04112     ## 受信ファイル有無判定
04113     if os.path.isfile(g_diff_recv_file) == False:
04114         fout = open(g_test_result_file, 'a')
04115         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04116         message = message + g_check_message
04117         fout.write(message + '\n')
04118         fout.close()
04119         print message
04120         time.sleep(sleep_for_time)
04121         continue
04122 
04123     ## 7 送受信データ比較
04124     time.sleep(sleep_act_time)
04125     bret = diff_file()
04126 
04127     ## 差分ファイルからテスト結果出力
04128     fout = open(g_test_result_file, 'a')
04129     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04130     # bret==True なら送受信データ一致
04131     if bret == True:
04132         # テスト結果 OK
04133         message = message + g_test_ok
04134         print message
04135         fout.write(message + '\n')
04136     else:
04137         # テスト結果 NG
04138         message = message + g_test_ng
04139         print message
04140         message = message + g_test_ng_message
04141         fout.write(message + '\n')
04142         # 受信データをテスト結果ファイルへコピー
04143         fin2 = open(g_diff_recv_file, 'r')
04144         while(1):
04145             s2 = fin2.readline()
04146             if len(s2) == 0:
04147                 break
04148             fout.write(s2)
04149         fin2.close()
04150     fout.close()
04151 
04152     time.sleep(sleep_for_time)
04153 
04154 ##--------------------------------------------------------------------
04155 ## 接続タイプ：periodic  方向：out->in  ポリシー：FIFO  接続・切断・Activate・Deactivateテスト1
04156 ##--------------------------------------------------------------------
04157 case_no = case_no + 1
04158 fout = open(g_test_result_file, 'a')
04159 message = g_mess_header + g_test_case + str(case_no) + " "
04160 message = message + "Connect(out->in, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
04161 message = message + g_mess_footer
04162 fout.write(message + '\n')
04163 fout.close()
04164 print message
04165 
04166 for i in range(loop_count):
04167 
04168     ## 2 受信データファイル削除
04169     delete_recv_file()
04170 
04171     ## 1 コネクタープロファイル設定
04172     make_connecter_profile("periodic", "FIFO", 0)
04173 
04174     ## 3 ポート接続
04175     # データポート1 TimedFloat
04176     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04177 
04178     # データポート2 TimedFloatSeq
04179     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04180 
04181     # サービスポート MyService
04182     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04183 
04184     ## 4 アクティベート
04185     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04186     time.sleep(sleep_recv_act_time)
04187     ec_send[0].activate_component(g_compo_send.rtc_ref)
04188 
04189     time.sleep(sleep_act_time)
04190 
04191     ## 5 ディアクティベート
04192     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04193     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04194 
04195     ## 6 ポート切断
04196     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04197     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04198     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04199 
04200     ## 受信ファイル有無判定
04201     if os.path.isfile(g_diff_recv_file) == False:
04202         fout = open(g_test_result_file, 'a')
04203         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04204         message = message + g_check_message
04205         fout.write(message + '\n')
04206         fout.close()
04207         print message
04208         time.sleep(sleep_for_time)
04209         continue
04210 
04211     ## 7 送受信データ比較
04212     time.sleep(sleep_act_time)
04213     bret = diff_file()
04214 
04215     ## 差分ファイルからテスト結果出力
04216     fout = open(g_test_result_file, 'a')
04217     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04218     # bret==True なら送受信データ一致
04219     if bret == True:
04220         # テスト結果 OK
04221         message = message + g_test_ok
04222         print message
04223         fout.write(message + '\n')
04224     else:
04225         # テスト結果 NG
04226         message = message + g_test_ng
04227         print message
04228         message = message + g_test_ng_message
04229         fout.write(message + '\n')
04230         # 受信データをテスト結果ファイルへコピー
04231         fin2 = open(g_diff_recv_file, 'r')
04232         while(1):
04233             s2 = fin2.readline()
04234             if len(s2) == 0:
04235                 break
04236             fout.write(s2)
04237         fin2.close()
04238     fout.close()
04239 
04240     time.sleep(sleep_for_time)
04241 
04242 ##--------------------------------------------------------------------
04243 ## 接続タイプ：periodic  方向：out->in  ポリシー：NEW  接続・切断・Activate・Deactivateテスト1
04244 ##--------------------------------------------------------------------
04245 case_no = case_no + 1
04246 fout = open(g_test_result_file, 'a')
04247 message = g_mess_header + g_test_case + str(case_no) + " "
04248 message = message + "Connect(out->in, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
04249 message = message + g_mess_footer
04250 fout.write(message + '\n')
04251 fout.close()
04252 print message
04253 
04254 for i in range(loop_count):
04255 
04256     ## 2 受信データファイル削除
04257     delete_recv_file()
04258 
04259     ## 1 コネクタープロファイル設定
04260     make_connecter_profile("periodic", "NEW", 0)
04261 
04262     ## 3 ポート接続
04263     # データポート1 TimedFloat
04264     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04265 
04266     # データポート2 TimedFloatSeq
04267     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04268 
04269     # サービスポート MyService
04270     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04271 
04272     ## 4 アクティベート
04273     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04274     time.sleep(sleep_recv_act_time)
04275     ec_send[0].activate_component(g_compo_send.rtc_ref)
04276 
04277     time.sleep(sleep_act_time)
04278 
04279     ## 5 ディアクティベート
04280     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04281     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04282 
04283     ## 6 ポート切断
04284     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04285     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04286     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04287 
04288     ## 受信ファイル有無判定
04289     if os.path.isfile(g_diff_recv_file) == False:
04290         fout = open(g_test_result_file, 'a')
04291         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04292         message = message + g_check_message
04293         fout.write(message + '\n')
04294         fout.close()
04295         print message
04296         time.sleep(sleep_for_time)
04297         continue
04298 
04299     ## 7 送受信データ比較
04300     time.sleep(sleep_act_time)
04301     bret = diff_file()
04302 
04303     ## 差分ファイルからテスト結果出力
04304     fout = open(g_test_result_file, 'a')
04305     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04306     # bret==True なら送受信データ一致
04307     if bret == True:
04308         # テスト結果 OK
04309         message = message + g_test_ok
04310         print message
04311         fout.write(message + '\n')
04312     else:
04313         # テスト結果 NG
04314         message = message + g_test_ng
04315         print message
04316         message = message + g_test_ng_message
04317         fout.write(message + '\n')
04318         # 受信データをテスト結果ファイルへコピー
04319         fin2 = open(g_diff_recv_file, 'r')
04320         while(1):
04321             s2 = fin2.readline()
04322             if len(s2) == 0:
04323                 break
04324             fout.write(s2)
04325         fin2.close()
04326     fout.close()
04327 
04328     time.sleep(sleep_for_time)
04329 
04330 ##--------------------------------------------------------------------
04331 ## 接続タイプ：periodic  方向：out->in  ポリシー：SKIP  接続・切断・Activate・Deactivateテスト1
04332 ##--------------------------------------------------------------------
04333 case_no = case_no + 1
04334 fout = open(g_test_result_file, 'a')
04335 message = g_mess_header + g_test_case + str(case_no) + " "
04336 message = message + "Connect(out->in, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
04337 message = message + g_mess_footer
04338 fout.write(message + '\n')
04339 fout.close()
04340 print message
04341 
04342 for i in range(loop_count):
04343 
04344     ## 2 受信データファイル削除
04345     delete_recv_file()
04346 
04347     ## 1 コネクタープロファイル設定
04348     make_connecter_profile("periodic", "SKIP", 0)
04349 
04350     ## 3 ポート接続
04351     # データポート1 TimedFloat
04352     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04353 
04354     # データポート2 TimedFloatSeq
04355     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04356 
04357     # サービスポート MyService
04358     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04359 
04360     ## 4 アクティベート
04361     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04362     time.sleep(sleep_recv_act_time)
04363     ec_send[0].activate_component(g_compo_send.rtc_ref)
04364 
04365     time.sleep(sleep_act_time)
04366 
04367     ## 5 ディアクティベート
04368     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04369     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04370 
04371     ## 6 ポート切断
04372     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04373     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04374     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04375 
04376     ## 受信ファイル有無判定
04377     if os.path.isfile(g_diff_recv_file) == False:
04378         fout = open(g_test_result_file, 'a')
04379         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04380         message = message + g_check_message
04381         fout.write(message + '\n')
04382         fout.close()
04383         print message
04384         time.sleep(sleep_for_time)
04385         continue
04386 
04387     ## 7 送受信データ比較
04388     time.sleep(sleep_act_time)
04389     bret = diff_file()
04390 
04391     ## 差分ファイルからテスト結果出力
04392     fout = open(g_test_result_file, 'a')
04393     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04394     # bret==True なら送受信データ一致
04395     if bret == True:
04396         # テスト結果 OK
04397         message = message + g_test_ok
04398         print message
04399         fout.write(message + '\n')
04400     else:
04401         # テスト結果 NG
04402         message = message + g_test_ng
04403         print message
04404         message = message + g_test_ng_message
04405         fout.write(message + '\n')
04406         # 受信データをテスト結果ファイルへコピー
04407         fin2 = open(g_diff_recv_file, 'r')
04408         while(1):
04409             s2 = fin2.readline()
04410             if len(s2) == 0:
04411                 break
04412             fout.write(s2)
04413         fin2.close()
04414     fout.close()
04415 
04416     time.sleep(sleep_for_time)
04417 
04418 ##--------------------------------------------------------------------
04419 ## 接続タイプ：periodic  方向：in->out  ポリシー：ALL  接続・切断・Activate・Deactivateテスト1
04420 ##--------------------------------------------------------------------
04421 case_no = case_no + 1
04422 fout = open(g_test_result_file, 'a')
04423 message = g_mess_header + g_test_case + str(case_no) + " "
04424 message = message + "Connect(in->out, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect"
04425 message = message + g_mess_footer
04426 fout.write(message + '\n')
04427 fout.close()
04428 print message
04429 
04430 for i in range(loop_count):
04431 
04432     ## 2 受信データファイル削除
04433     delete_recv_file()
04434 
04435     ## 1 コネクタープロファイル設定
04436     make_connecter_profile("periodic", "ALL", 1)
04437 
04438     ## 3 ポート接続
04439     # データポート1 TimedFloat
04440     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04441 
04442     # データポート2 TimedFloatSeq
04443     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04444 
04445     # サービスポート MyService
04446     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04447 
04448     ## 4 アクティベート
04449     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04450     time.sleep(sleep_recv_act_time)
04451     ec_send[0].activate_component(g_compo_send.rtc_ref)
04452 
04453     time.sleep(sleep_act_time)
04454 
04455     ## 5 ディアクティベート
04456     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04457     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04458 
04459     ## 6 ポート切断
04460     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04461     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04462     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04463 
04464     ## 受信ファイル有無判定
04465     if os.path.isfile(g_diff_recv_file) == False:
04466         fout = open(g_test_result_file, 'a')
04467         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04468         message = message + g_check_message
04469         fout.write(message + '\n')
04470         fout.close()
04471         print message
04472         time.sleep(sleep_for_time)
04473         continue
04474 
04475     ## 7 送受信データ比較
04476     time.sleep(sleep_act_time)
04477     bret = diff_file()
04478 
04479     ## 差分ファイルからテスト結果出力
04480     fout = open(g_test_result_file, 'a')
04481     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04482     # bret==True なら送受信データ一致
04483     if bret == True:
04484         # テスト結果 OK
04485         message = message + g_test_ok
04486         print message
04487         fout.write(message + '\n')
04488     else:
04489         # テスト結果 NG
04490         message = message + g_test_ng
04491         print message
04492         message = message + g_test_ng_message
04493         fout.write(message + '\n')
04494         # 受信データをテスト結果ファイルへコピー
04495         fin2 = open(g_diff_recv_file, 'r')
04496         while(1):
04497             s2 = fin2.readline()
04498             if len(s2) == 0:
04499                 break
04500             fout.write(s2)
04501         fin2.close()
04502     fout.close()
04503 
04504     time.sleep(sleep_for_time)
04505 
04506 ##--------------------------------------------------------------------
04507 ## 接続タイプ：periodic  方向：in->out  ポリシー：FIFO  接続・切断・Activate・Deactivateテスト1
04508 ##--------------------------------------------------------------------
04509 case_no = case_no + 1
04510 fout = open(g_test_result_file, 'a')
04511 message = g_mess_header + g_test_case + str(case_no) + " "
04512 message = message + "Connect(in->out, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect"
04513 message = message + g_mess_footer
04514 fout.write(message + '\n')
04515 fout.close()
04516 print message
04517 
04518 for i in range(loop_count):
04519 
04520     ## 2 受信データファイル削除
04521     delete_recv_file()
04522 
04523     ## 1 コネクタープロファイル設定
04524     make_connecter_profile("periodic", "FIFO", 1)
04525 
04526     ## 3 ポート接続
04527     # データポート1 TimedFloat
04528     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04529 
04530     # データポート2 TimedFloatSeq
04531     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04532 
04533     # サービスポート MyService
04534     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04535 
04536     ## 4 アクティベート
04537     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04538     time.sleep(sleep_recv_act_time)
04539     ec_send[0].activate_component(g_compo_send.rtc_ref)
04540 
04541     time.sleep(sleep_act_time)
04542 
04543     ## 5 ディアクティベート
04544     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04545     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04546 
04547     ## 6 ポート切断
04548     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04549     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04550     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04551 
04552     ## 受信ファイル有無判定
04553     if os.path.isfile(g_diff_recv_file) == False:
04554         fout = open(g_test_result_file, 'a')
04555         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04556         message = message + g_check_message
04557         fout.write(message + '\n')
04558         fout.close()
04559         print message
04560         time.sleep(sleep_for_time)
04561         continue
04562 
04563     ## 7 送受信データ比較
04564     time.sleep(sleep_act_time)
04565     bret = diff_file()
04566 
04567     ## 差分ファイルからテスト結果出力
04568     fout = open(g_test_result_file, 'a')
04569     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04570     # bret==True なら送受信データ一致
04571     if bret == True:
04572         # テスト結果 OK
04573         message = message + g_test_ok
04574         print message
04575         fout.write(message + '\n')
04576     else:
04577         # テスト結果 NG
04578         message = message + g_test_ng
04579         print message
04580         message = message + g_test_ng_message
04581         fout.write(message + '\n')
04582         # 受信データをテスト結果ファイルへコピー
04583         fin2 = open(g_diff_recv_file, 'r')
04584         while(1):
04585             s2 = fin2.readline()
04586             if len(s2) == 0:
04587                 break
04588             fout.write(s2)
04589         fin2.close()
04590     fout.close()
04591 
04592     time.sleep(sleep_for_time)
04593 
04594 ##--------------------------------------------------------------------
04595 ## 接続タイプ：periodic  方向：in->out  ポリシー：NEW  接続・切断・Activate・Deactivateテスト1
04596 ##--------------------------------------------------------------------
04597 case_no = case_no + 1
04598 fout = open(g_test_result_file, 'a')
04599 message = g_mess_header + g_test_case + str(case_no) + " "
04600 message = message + "Connect(in->out, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect"
04601 message = message + g_mess_footer
04602 fout.write(message + '\n')
04603 fout.close()
04604 print message
04605 
04606 for i in range(loop_count):
04607 
04608     ## 2 受信データファイル削除
04609     delete_recv_file()
04610 
04611     ## 1 コネクタープロファイル設定
04612     make_connecter_profile("periodic", "NEW", 1)
04613 
04614     ## 3 ポート接続
04615     # データポート1 TimedFloat
04616     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04617 
04618     # データポート2 TimedFloatSeq
04619     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04620 
04621     # サービスポート MyService
04622     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04623 
04624     ## 4 アクティベート
04625     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04626     time.sleep(sleep_recv_act_time)
04627     ec_send[0].activate_component(g_compo_send.rtc_ref)
04628 
04629     time.sleep(sleep_act_time)
04630 
04631     ## 5 ディアクティベート
04632     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04633     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04634 
04635     ## 6 ポート切断
04636     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04637     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04638     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04639 
04640     ## 受信ファイル有無判定
04641     if os.path.isfile(g_diff_recv_file) == False:
04642         fout = open(g_test_result_file, 'a')
04643         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04644         message = message + g_check_message
04645         fout.write(message + '\n')
04646         fout.close()
04647         print message
04648         time.sleep(sleep_for_time)
04649         continue
04650 
04651     ## 7 送受信データ比較
04652     time.sleep(sleep_act_time)
04653     bret = diff_file()
04654 
04655     ## 差分ファイルからテスト結果出力
04656     fout = open(g_test_result_file, 'a')
04657     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04658     # bret==True なら送受信データ一致
04659     if bret == True:
04660         # テスト結果 OK
04661         message = message + g_test_ok
04662         print message
04663         fout.write(message + '\n')
04664     else:
04665         # テスト結果 NG
04666         message = message + g_test_ng
04667         print message
04668         message = message + g_test_ng_message
04669         fout.write(message + '\n')
04670         # 受信データをテスト結果ファイルへコピー
04671         fin2 = open(g_diff_recv_file, 'r')
04672         while(1):
04673             s2 = fin2.readline()
04674             if len(s2) == 0:
04675                 break
04676             fout.write(s2)
04677         fin2.close()
04678     fout.close()
04679 
04680     time.sleep(sleep_for_time)
04681 
04682 ##--------------------------------------------------------------------
04683 ## 接続タイプ：periodic  方向：in->out  ポリシー：SKIP  接続・切断・Activate・Deactivateテスト1
04684 ##--------------------------------------------------------------------
04685 case_no = case_no + 1
04686 fout = open(g_test_result_file, 'a')
04687 message = g_mess_header + g_test_case + str(case_no) + " "
04688 message = message + "Connect(in->out, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect"
04689 message = message + g_mess_footer
04690 fout.write(message + '\n')
04691 fout.close()
04692 print message
04693 
04694 for i in range(loop_count):
04695 
04696     ## 2 受信データファイル削除
04697     delete_recv_file()
04698 
04699     ## 1 コネクタープロファイル設定
04700     make_connecter_profile("periodic", "SKIP", 1)
04701 
04702     ## 3 ポート接続
04703     # データポート1 TimedFloat
04704     ret0 = g_out_ports[g_port1].connect(g_conprof1)
04705 
04706     # データポート2 TimedFloatSeq
04707     ret1 = g_out_ports[g_port2].connect(g_conprof2)
04708 
04709     # サービスポート MyService
04710     ret2 = g_out_ports[g_port3].connect(g_conprof3)
04711 
04712     ## 4 アクティベート
04713     ec_recv[0].activate_component(g_compo_recv.rtc_ref)
04714     time.sleep(sleep_recv_act_time)
04715     ec_send[0].activate_component(g_compo_send.rtc_ref)
04716 
04717     time.sleep(sleep_act_time)
04718 
04719     ## 5 ディアクティベート
04720     ec_send[0].deactivate_component(g_compo_send.rtc_ref)
04721     ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
04722 
04723     ## 6 ポート切断
04724     g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
04725     g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
04726     g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
04727 
04728     ## 受信ファイル有無判定
04729     if os.path.isfile(g_diff_recv_file) == False:
04730         fout = open(g_test_result_file, 'a')
04731         message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04732         message = message + g_check_message
04733         fout.write(message + '\n')
04734         fout.close()
04735         print message
04736         time.sleep(sleep_for_time)
04737         continue
04738 
04739     ## 7 送受信データ比較
04740     time.sleep(sleep_act_time)
04741     bret = diff_file()
04742 
04743     ## 差分ファイルからテスト結果出力
04744     fout = open(g_test_result_file, 'a')
04745     message = g_mess_header + g_test_case + str(case_no) + " " + g_test_cnt + str(i+1) + g_mess_footer
04746     # bret==True なら送受信データ一致
04747     if bret == True:
04748         # テスト結果 OK
04749         message = message + g_test_ok
04750         print message
04751         fout.write(message + '\n')
04752     else:
04753         # テスト結果 NG
04754         message = message + g_test_ng
04755         print message
04756         message = message + g_test_ng_message
04757         fout.write(message + '\n')
04758         # 受信データをテスト結果ファイルへコピー
04759         fin2 = open(g_diff_recv_file, 'r')
04760         while(1):
04761             s2 = fin2.readline()
04762             if len(s2) == 0:
04763                 break
04764             fout.write(s2)
04765         fin2.close()
04766     fout.close()
04767 
04768     time.sleep(sleep_for_time)
04769 
04770 print "Test Complete."