9 from rtc_handle
import *
10 from BasicDataType_idl
import *
17 g_test_name =
"<< component connection test >>" 25 env =
RtmEnv(sys.argv, [
"localhost:2809"])
26 list0 = env.name_space[
"localhost:2809"].list_obj()
27 env.name_space[
'localhost:2809'].rtc_handles.keys()
28 ns = env.name_space[
'localhost:2809']
30 g_compo_send = ns.rtc_handles[
"AutoTestOut0.rtc"]
31 g_compo_recv = ns.rtc_handles[
"AutoTestIn0.rtc"]
33 ec_send = g_compo_send.rtc_ref.get_owned_contexts()
34 ec_recv = g_compo_recv.rtc_ref.get_owned_contexts()
36 g_out_ports = g_compo_send.rtc_ref.get_ports()
37 g_in_ports = g_compo_recv.rtc_ref.get_ports()
47 g_interface_type1 =
"corba_cdr" 48 g_dataflow_type =
"push" 49 g_subscription_type =
"flush" 68 g_connector_id1 =
"001" 69 g_data_type1 =
"TimedFloat" 71 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))])
75 g_connector_id2 =
"002" 76 g_data_type2 =
"TimedFloatSeq" 78 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))])
82 g_connector_id3 =
"003" 83 g_interface_type3 =
"MyService" 85 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))])
89 g_diff_send_file =
"./original-data" 90 g_diff_recv_file =
"./received-data" 91 g_check_message = g_diff_recv_file +
" file not found." 92 g_test_result_file =
"./ResultTest.log" 96 g_test_ng =
"NG detected." 97 g_test_ng_message =
" < received-data >" 113 global g_conprof1, g_conprof2, g_conprof3
115 if connect_direction == 0:
117 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))])
119 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))])
126 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))])
128 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))])
144 if os.path.isfile(g_diff_recv_file) ==
True:
145 os.remove(g_diff_recv_file)
162 if os.path.isfile(g_diff_send_file) ==
False:
163 print "send_file (%s) not found." % send_file
167 if os.path.isfile(g_diff_recv_file) ==
False:
168 print "recv_file (%s) not found." % recv_file
172 f_send = open(g_diff_send_file,
'r') f_recv = open(g_diff_recv_file, 'r') 175 str_send = f_send.readline() 176 str_recv = f_recv.readline() 177 if len(str_send) == 0:
186 str_send2 = str_send.rstrip(
'\n')
187 str_send2 = str_send2.rstrip(
'\r')
188 str_recv2 = str_recv.rstrip(
'\n')
189 str_recv2 = str_recv2.rstrip(
'\r')
195 if str_send2 != str_recv2:
215 sleep_recv_act_time = 1
224 sleep_connect_time = 2
227 fout = open(g_test_result_file,
'w')
228 fout.write(g_test_name +
'\n')
237 case_no = case_no + 1
238 fout = open(g_test_result_file,
'a')
239 message = g_mess_header + g_test_case + str(case_no) +
" " 240 message = message +
"Connect(out->in, flush) -> Disconnect" 241 message = message + g_mess_footer
242 fout.write(message +
'\n')
246 for i
in range(loop_count):
253 ret0 = g_out_ports[g_port1].connect(g_conprof1)
256 ret1 = g_out_ports[g_port2].connect(g_conprof2)
259 ret2 = g_out_ports[g_port3].connect(g_conprof3)
261 time.sleep(sleep_connect_time)
264 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
265 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
266 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
269 fout = open(g_test_result_file,
'a')
270 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
271 message = message + g_test_ok
273 fout.write(message +
'\n')
276 time.sleep(sleep_for_time)
281 case_no = case_no + 1
282 fout = open(g_test_result_file,
'a')
283 message = g_mess_header + g_test_case + str(case_no) +
" " 284 message = message +
"Connect(in->out, flush) -> Disconnect" 285 message = message + g_mess_footer
286 fout.write(message +
'\n')
290 for i
in range(loop_count):
297 ret0 = g_out_ports[g_port1].connect(g_conprof1)
300 ret1 = g_out_ports[g_port2].connect(g_conprof2)
303 ret2 = g_out_ports[g_port3].connect(g_conprof3)
305 time.sleep(sleep_connect_time)
308 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
309 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
310 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
313 fout = open(g_test_result_file,
'a')
314 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
315 message = message + g_test_ok
317 fout.write(message +
'\n')
320 time.sleep(sleep_for_time)
325 case_no = case_no + 1
326 fout = open(g_test_result_file,
'a')
327 message = g_mess_header + g_test_case + str(case_no) +
" " 328 message = message +
"Connecting(out->in, flush), Activate -> send/recv -> Deactivate" 329 message = message + g_mess_footer
330 fout.write(message +
'\n')
339 ret0 = g_out_ports[g_port1].connect(g_conprof1)
342 ret1 = g_out_ports[g_port2].connect(g_conprof2)
345 ret2 = g_out_ports[g_port3].connect(g_conprof3)
347 for i
in range(loop_count):
353 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
354 time.sleep(sleep_recv_act_time)
355 ec_send[0].activate_component(g_compo_send.rtc_ref)
357 time.sleep(sleep_act_time)
360 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
361 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
364 if os.path.isfile(g_diff_recv_file) ==
False:
365 fout = open(g_test_result_file,
'a')
366 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
367 message = message + g_check_message
368 fout.write(message +
'\n')
371 time.sleep(sleep_for_time)
375 time.sleep(sleep_act_time)
379 fout = open(g_test_result_file,
'a')
380 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
384 message = message + g_test_ok
386 fout.write(message +
'\n')
389 message = message + g_test_ng
391 message = message + g_test_ng_message
392 fout.write(message +
'\n')
394 fin2 = open(g_diff_recv_file,
'r') while(1): 402 time.sleep(sleep_for_time)
405 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
406 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
407 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
412 case_no = case_no + 1
413 fout = open(g_test_result_file,
'a')
414 message = g_mess_header + g_test_case + str(case_no) +
" " 415 message = message +
"Connecting(in->out, flush), Activate -> send/recv -> Deactivate" 416 message = message + g_mess_footer
417 fout.write(message +
'\n')
426 ret0 = g_out_ports[g_port1].connect(g_conprof1)
429 ret1 = g_out_ports[g_port2].connect(g_conprof2)
432 ret2 = g_out_ports[g_port3].connect(g_conprof3)
434 for i
in range(loop_count):
440 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
441 time.sleep(sleep_recv_act_time)
442 ec_send[0].activate_component(g_compo_send.rtc_ref)
444 time.sleep(sleep_act_time)
447 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
448 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
451 if os.path.isfile(g_diff_recv_file) ==
False:
452 fout = open(g_test_result_file,
'a')
453 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
454 message = message + g_check_message
455 fout.write(message +
'\n')
458 time.sleep(sleep_for_time)
462 time.sleep(sleep_act_time)
466 fout = open(g_test_result_file,
'a')
467 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
471 message = message + g_test_ok
473 fout.write(message +
'\n')
476 message = message + g_test_ng
478 message = message + g_test_ng_message
479 fout.write(message +
'\n')
481 fin2 = open(g_diff_recv_file,
'r') while(1): 489 time.sleep(sleep_for_time)
492 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
493 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
494 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
499 case_no = case_no + 1
500 fout = open(g_test_result_file,
'a')
501 message = g_mess_header + g_test_case + str(case_no) +
" " 502 message = message +
"Not Connect(out->in, flush), Activate -> Deactivate" 503 message = message + g_mess_footer
504 fout.write(message +
'\n')
508 for i
in range(loop_count):
514 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
515 time.sleep(sleep_recv_act_time)
516 ec_send[0].activate_component(g_compo_send.rtc_ref)
518 time.sleep(sleep_act_time)
521 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
522 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
525 fout = open(g_test_result_file,
'a')
526 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
527 message = message + g_test_ok
529 fout.write(message +
'\n')
532 time.sleep(sleep_for_time)
537 case_no = case_no + 1
538 fout = open(g_test_result_file,
'a')
539 message = g_mess_header + g_test_case + str(case_no) +
" " 540 message = message +
"Connect(out->in, flush) -> Activate -> send/recv -> Deactivate -> Disconnect" 541 message = message + g_mess_footer
542 fout.write(message +
'\n')
546 for i
in range(loop_count):
556 ret0 = g_out_ports[g_port1].connect(g_conprof1)
559 ret1 = g_out_ports[g_port2].connect(g_conprof2)
562 ret2 = g_out_ports[g_port3].connect(g_conprof3)
565 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
566 time.sleep(sleep_recv_act_time)
567 ec_send[0].activate_component(g_compo_send.rtc_ref)
569 time.sleep(sleep_act_time)
572 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
573 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
576 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
577 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
578 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
581 if os.path.isfile(g_diff_recv_file) ==
False:
582 fout = open(g_test_result_file,
'a')
583 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
584 message = message + g_check_message
585 fout.write(message +
'\n')
588 time.sleep(sleep_for_time)
592 time.sleep(sleep_act_time)
596 fout = open(g_test_result_file,
'a')
597 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
601 message = message + g_test_ok
603 fout.write(message +
'\n')
606 message = message + g_test_ng
608 message = message + g_test_ng_message
609 fout.write(message +
'\n')
611 fin2 = open(g_diff_recv_file,
'r') while(1): 619 time.sleep(sleep_for_time)
624 case_no = case_no + 1
625 fout = open(g_test_result_file,
'a')
626 message = g_mess_header + g_test_case + str(case_no) +
" " 627 message = message +
"Connect(in->out, flush) -> Activate -> send/recv -> Deactivate -> Disconnect" 628 message = message + g_mess_footer
629 fout.write(message +
'\n')
633 for i
in range(loop_count):
643 ret0 = g_out_ports[g_port1].connect(g_conprof1)
646 ret1 = g_out_ports[g_port2].connect(g_conprof2)
649 ret2 = g_out_ports[g_port3].connect(g_conprof3)
652 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
653 time.sleep(sleep_recv_act_time)
654 ec_send[0].activate_component(g_compo_send.rtc_ref)
656 time.sleep(sleep_act_time)
659 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
660 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
663 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
664 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
665 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
668 if os.path.isfile(g_diff_recv_file) ==
False:
669 fout = open(g_test_result_file,
'a')
670 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
671 message = message + g_check_message
672 fout.write(message +
'\n')
675 time.sleep(sleep_for_time)
679 time.sleep(sleep_act_time)
683 fout = open(g_test_result_file,
'a')
684 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
688 message = message + g_test_ok
690 fout.write(message +
'\n')
693 message = message + g_test_ng
695 message = message + g_test_ng_message
696 fout.write(message +
'\n')
698 fin2 = open(g_diff_recv_file,
'r') while(1): 706 time.sleep(sleep_for_time)
711 case_no = case_no + 1
712 fout = open(g_test_result_file,
'a')
713 message = g_mess_header + g_test_case + str(case_no) +
" " 714 message = message +
"Connect(out->in, flush) -> Activate -> send/recv -> Disconnect -> Deactivate" 715 message = message + g_mess_footer
716 fout.write(message +
'\n')
720 for i
in range(loop_count):
730 ret0 = g_out_ports[g_port1].connect(g_conprof1)
733 ret1 = g_out_ports[g_port2].connect(g_conprof2)
736 ret2 = g_out_ports[g_port3].connect(g_conprof3)
739 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
740 time.sleep(sleep_recv_act_time)
741 ec_send[0].activate_component(g_compo_send.rtc_ref)
743 time.sleep(sleep_act_time)
746 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
747 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
748 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
751 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
752 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
755 if os.path.isfile(g_diff_recv_file) ==
False:
756 fout = open(g_test_result_file,
'a')
757 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
758 message = message + g_check_message
759 fout.write(message +
'\n')
762 time.sleep(sleep_for_time)
766 time.sleep(sleep_act_time)
770 fout = open(g_test_result_file,
'a')
771 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
775 message = message + g_test_ok
777 fout.write(message +
'\n')
780 message = message + g_test_ng
782 message = message + g_test_ng_message
783 fout.write(message +
'\n')
785 fin2 = open(g_diff_recv_file,
'r') while(1): 793 time.sleep(sleep_for_time)
798 case_no = case_no + 1
799 fout = open(g_test_result_file,
'a')
800 message = g_mess_header + g_test_case + str(case_no) +
" " 801 message = message +
"Connect(in->out, flush) -> Activate -> send/recv -> Disconnect -> Deactivate" 802 message = message + g_mess_footer
803 fout.write(message +
'\n')
807 for i
in range(loop_count):
817 ret0 = g_out_ports[g_port1].connect(g_conprof1)
820 ret1 = g_out_ports[g_port2].connect(g_conprof2)
823 ret2 = g_out_ports[g_port3].connect(g_conprof3)
826 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
827 time.sleep(sleep_recv_act_time)
828 ec_send[0].activate_component(g_compo_send.rtc_ref)
830 time.sleep(sleep_act_time)
833 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
834 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
835 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
838 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
839 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
842 if os.path.isfile(g_diff_recv_file) ==
False:
843 fout = open(g_test_result_file,
'a')
844 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
845 message = message + g_check_message
846 fout.write(message +
'\n')
849 time.sleep(sleep_for_time)
853 time.sleep(sleep_act_time)
857 fout = open(g_test_result_file,
'a')
858 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
862 message = message + g_test_ok
864 fout.write(message +
'\n')
867 message = message + g_test_ng
869 message = message + g_test_ng_message
870 fout.write(message +
'\n')
872 fin2 = open(g_diff_recv_file,
'r') while(1): 880 time.sleep(sleep_for_time)
887 case_no = case_no + 1
888 fout = open(g_test_result_file,
'a')
889 message = g_mess_header + g_test_case + str(case_no) +
" " 890 message = message +
"Activate -> Connect(out->in, flush) -> send/recv -> Deactivate -> Disconnect" 891 message = message + g_mess_footer
892 fout.write(message +
'\n')
896 for i
in range(loop_count):
905 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
906 time.sleep(sleep_recv_act_time)
907 ec_send[0].activate_component(g_compo_send.rtc_ref)
911 ret0 = g_out_ports[g_port1].connect(g_conprof1)
914 ret1 = g_out_ports[g_port2].connect(g_conprof2)
917 ret2 = g_out_ports[g_port3].connect(g_conprof3)
919 time.sleep(sleep_act_time)
922 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
923 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
926 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
927 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
928 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
931 if os.path.isfile(g_diff_recv_file) ==
False:
932 fout = open(g_test_result_file,
'a')
933 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
934 message = message + g_check_message
935 fout.write(message +
'\n')
938 time.sleep(sleep_for_time)
942 time.sleep(sleep_act_time)
946 fout = open(g_test_result_file,
'a')
947 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
951 message = message + g_test_ok
953 fout.write(message +
'\n')
956 message = message + g_test_ng
958 message = message + g_test_ng_message
959 fout.write(message +
'\n')
961 fin2 = open(g_diff_recv_file,
'r') while(1): 969 time.sleep(sleep_for_time)
975 case_no = case_no + 1
976 fout = open(g_test_result_file,
'a')
977 message = g_mess_header + g_test_case + str(case_no) +
" " 978 message = message +
"Activate -> Connect(in->out, flush) -> send/recv -> Deactivate -> Disconnect" 979 message = message + g_mess_footer
980 fout.write(message +
'\n')
984 for i
in range(loop_count):
993 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
994 time.sleep(sleep_recv_act_time)
995 ec_send[0].activate_component(g_compo_send.rtc_ref)
999 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1002 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1005 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1007 time.sleep(sleep_act_time)
1010 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1011 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1014 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1015 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1016 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1019 if os.path.isfile(g_diff_recv_file) ==
False:
1020 fout = open(g_test_result_file,
'a')
1021 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1022 message = message + g_check_message
1023 fout.write(message +
'\n')
1026 time.sleep(sleep_for_time)
1030 time.sleep(sleep_act_time)
1034 fout = open(g_test_result_file,
'a')
1035 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1039 message = message + g_test_ok
1041 fout.write(message +
'\n')
1044 message = message + g_test_ng
1046 message = message + g_test_ng_message
1047 fout.write(message +
'\n')
1049 fin2 = open(g_diff_recv_file,
'r') while(1): 1050 s2 = fin2.readline() 1057 time.sleep(sleep_for_time)
1063 case_no = case_no + 1
1064 fout = open(g_test_result_file,
'a')
1065 message = g_mess_header + g_test_case + str(case_no) +
" " 1066 message = message +
"Activate -> Connect(out->in, flush) -> send/recv -> Disconnect -> Deactivate" 1067 message = message + g_mess_footer
1068 fout.write(message +
'\n')
1072 for i
in range(loop_count):
1081 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1082 time.sleep(sleep_recv_act_time)
1083 ec_send[0].activate_component(g_compo_send.rtc_ref)
1087 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1090 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1093 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1095 time.sleep(sleep_act_time)
1098 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1099 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1100 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1103 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1104 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1107 if os.path.isfile(g_diff_recv_file) ==
False:
1108 fout = open(g_test_result_file,
'a')
1109 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1110 message = message + g_check_message
1111 fout.write(message +
'\n')
1114 time.sleep(sleep_for_time)
1118 time.sleep(sleep_act_time)
1122 fout = open(g_test_result_file,
'a')
1123 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1127 message = message + g_test_ok
1129 fout.write(message +
'\n')
1132 message = message + g_test_ng
1134 message = message + g_test_ng_message
1135 fout.write(message +
'\n')
1137 fin2 = open(g_diff_recv_file,
'r') while(1): 1138 s2 = fin2.readline() 1145 time.sleep(sleep_for_time)
1151 case_no = case_no + 1
1152 fout = open(g_test_result_file,
'a')
1153 message = g_mess_header + g_test_case + str(case_no) +
" " 1154 message = message +
"Activate -> Connect(in->out, flush) -> send/recv -> Disconnect -> Deactivate" 1155 message = message + g_mess_footer
1156 fout.write(message +
'\n')
1160 for i
in range(loop_count):
1169 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1170 time.sleep(sleep_recv_act_time)
1171 ec_send[0].activate_component(g_compo_send.rtc_ref)
1175 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1178 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1181 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1183 time.sleep(sleep_act_time)
1186 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1187 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1188 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1191 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1192 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1195 if os.path.isfile(g_diff_recv_file) ==
False:
1196 fout = open(g_test_result_file,
'a')
1197 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1198 message = message + g_check_message
1199 fout.write(message +
'\n')
1202 time.sleep(sleep_for_time)
1206 time.sleep(sleep_act_time)
1210 fout = open(g_test_result_file,
'a')
1211 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1215 message = message + g_test_ok
1217 fout.write(message +
'\n')
1220 message = message + g_test_ng
1222 message = message + g_test_ng_message
1223 fout.write(message +
'\n')
1225 fin2 = open(g_diff_recv_file,
'r') while(1): 1226 s2 = fin2.readline() 1233 time.sleep(sleep_for_time)
1239 case_no = case_no + 1
1240 fout = open(g_test_result_file,
'a')
1241 message = g_mess_header + g_test_case + str(case_no) +
" " 1242 message = message +
"Connect(out->in, new,ALL) -> Disconnect" 1243 message = message + g_mess_footer
1244 fout.write(message +
'\n')
1248 for i
in range(loop_count):
1255 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1258 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1261 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1263 time.sleep(sleep_connect_time)
1266 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1267 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1268 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1271 fout = open(g_test_result_file,
'a')
1272 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1273 message = message + g_test_ok
1275 fout.write(message +
'\n')
1278 time.sleep(sleep_for_time)
1283 case_no = case_no + 1
1284 fout = open(g_test_result_file,
'a')
1285 message = g_mess_header + g_test_case + str(case_no) +
" " 1286 message = message +
"Connect(out->in, new,FIFO) -> Disconnect" 1287 message = message + g_mess_footer
1288 fout.write(message +
'\n')
1292 for i
in range(loop_count):
1299 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1302 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1305 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1307 time.sleep(sleep_connect_time)
1310 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1311 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1312 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1315 fout = open(g_test_result_file,
'a')
1316 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1317 message = message + g_test_ok
1319 fout.write(message +
'\n')
1322 time.sleep(sleep_for_time)
1327 case_no = case_no + 1
1328 fout = open(g_test_result_file,
'a')
1329 message = g_mess_header + g_test_case + str(case_no) +
" " 1330 message = message +
"Connect(out->in, new,NEW) -> Disconnect" 1331 message = message + g_mess_footer
1332 fout.write(message +
'\n')
1336 for i
in range(loop_count):
1343 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1346 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1349 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1351 time.sleep(sleep_connect_time)
1354 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1355 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1356 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1359 fout = open(g_test_result_file,
'a')
1360 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1361 message = message + g_test_ok
1363 fout.write(message +
'\n')
1366 time.sleep(sleep_for_time)
1371 case_no = case_no + 1
1372 fout = open(g_test_result_file,
'a')
1373 message = g_mess_header + g_test_case + str(case_no) +
" " 1374 message = message +
"Connect(out->in, new,SKIP) -> Disconnect" 1375 message = message + g_mess_footer
1376 fout.write(message +
'\n')
1380 for i
in range(loop_count):
1387 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1390 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1393 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1395 time.sleep(sleep_connect_time)
1398 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1399 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1400 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1403 fout = open(g_test_result_file,
'a')
1404 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1405 message = message + g_test_ok
1407 fout.write(message +
'\n')
1410 time.sleep(sleep_for_time)
1415 case_no = case_no + 1
1416 fout = open(g_test_result_file,
'a')
1417 message = g_mess_header + g_test_case + str(case_no) +
" " 1418 message = message +
"Connect(in->out, new,ALL) -> Disconnect" 1419 message = message + g_mess_footer
1420 fout.write(message +
'\n')
1424 for i
in range(loop_count):
1431 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1434 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1437 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1439 time.sleep(sleep_connect_time)
1442 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1443 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1444 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1447 fout = open(g_test_result_file,
'a')
1448 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1449 message = message + g_test_ok
1451 fout.write(message +
'\n')
1454 time.sleep(sleep_for_time)
1459 case_no = case_no + 1
1460 fout = open(g_test_result_file,
'a')
1461 message = g_mess_header + g_test_case + str(case_no) +
" " 1462 message = message +
"Connect(in->out, new,FIFO) -> Disconnect" 1463 message = message + g_mess_footer
1464 fout.write(message +
'\n')
1468 for i
in range(loop_count):
1475 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1478 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1481 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1483 time.sleep(sleep_connect_time)
1486 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1487 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1488 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1491 fout = open(g_test_result_file,
'a')
1492 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1493 message = message + g_test_ok
1495 fout.write(message +
'\n')
1498 time.sleep(sleep_for_time)
1503 case_no = case_no + 1
1504 fout = open(g_test_result_file,
'a')
1505 message = g_mess_header + g_test_case + str(case_no) +
" " 1506 message = message +
"Connect(in->out, new,NEW) -> Disconnect" 1507 message = message + g_mess_footer
1508 fout.write(message +
'\n')
1512 for i
in range(loop_count):
1519 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1522 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1525 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1527 time.sleep(sleep_connect_time)
1530 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1531 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1532 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1535 fout = open(g_test_result_file,
'a')
1536 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1537 message = message + g_test_ok
1539 fout.write(message +
'\n')
1542 time.sleep(sleep_for_time)
1547 case_no = case_no + 1
1548 fout = open(g_test_result_file,
'a')
1549 message = g_mess_header + g_test_case + str(case_no) +
" " 1550 message = message +
"Connect(in->out, new,SKIP) -> Disconnect" 1551 message = message + g_mess_footer
1552 fout.write(message +
'\n')
1556 for i
in range(loop_count):
1563 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1566 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1569 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1571 time.sleep(sleep_connect_time)
1574 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1575 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1576 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1579 fout = open(g_test_result_file,
'a')
1580 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1581 message = message + g_test_ok
1583 fout.write(message +
'\n')
1586 time.sleep(sleep_for_time)
1591 case_no = case_no + 1
1592 fout = open(g_test_result_file,
'a')
1593 message = g_mess_header + g_test_case + str(case_no) +
" " 1594 message = message +
"Connecting(out->in, new,ALL), Activate -> send/recv -> Deactivate" 1595 message = message + g_mess_footer
1596 fout.write(message +
'\n')
1605 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1608 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1611 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1613 for i
in range(loop_count):
1619 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1620 time.sleep(sleep_recv_act_time)
1621 ec_send[0].activate_component(g_compo_send.rtc_ref)
1623 time.sleep(sleep_act_time)
1626 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1627 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1630 if os.path.isfile(g_diff_recv_file) ==
False:
1631 fout = open(g_test_result_file,
'a')
1632 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1633 message = message + g_check_message
1634 fout.write(message +
'\n')
1637 time.sleep(sleep_for_time)
1641 time.sleep(sleep_act_time)
1645 fout = open(g_test_result_file,
'a')
1646 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1650 message = message + g_test_ok
1652 fout.write(message +
'\n')
1655 message = message + g_test_ng
1657 message = message + g_test_ng_message
1658 fout.write(message +
'\n')
1660 fin2 = open(g_diff_recv_file,
'r') while(1): 1661 s2 = fin2.readline() 1668 time.sleep(sleep_for_time)
1671 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1672 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1673 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1678 case_no = case_no + 1
1679 fout = open(g_test_result_file,
'a')
1680 message = g_mess_header + g_test_case + str(case_no) +
" " 1681 message = message +
"Connecting(out->in, new,FIFO), Activate -> send/recv -> Deactivate" 1682 message = message + g_mess_footer
1683 fout.write(message +
'\n')
1692 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1695 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1698 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1700 for i
in range(loop_count):
1706 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1707 time.sleep(sleep_recv_act_time)
1708 ec_send[0].activate_component(g_compo_send.rtc_ref)
1710 time.sleep(sleep_act_time)
1713 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1714 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1717 if os.path.isfile(g_diff_recv_file) ==
False:
1718 fout = open(g_test_result_file,
'a')
1719 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1720 message = message + g_check_message
1721 fout.write(message +
'\n')
1724 time.sleep(sleep_for_time)
1728 time.sleep(sleep_act_time)
1732 fout = open(g_test_result_file,
'a')
1733 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1737 message = message + g_test_ok
1739 fout.write(message +
'\n')
1742 message = message + g_test_ng
1744 message = message + g_test_ng_message
1745 fout.write(message +
'\n')
1747 fin2 = open(g_diff_recv_file,
'r') while(1): 1748 s2 = fin2.readline() 1755 time.sleep(sleep_for_time)
1758 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1759 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1760 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1765 case_no = case_no + 1
1766 fout = open(g_test_result_file,
'a')
1767 message = g_mess_header + g_test_case + str(case_no) +
" " 1768 message = message +
"Connecting(out->in, new,NEW), Activate -> send/recv -> Deactivate" 1769 message = message + g_mess_footer
1770 fout.write(message +
'\n')
1779 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1782 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1785 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1787 for i
in range(loop_count):
1793 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1794 time.sleep(sleep_recv_act_time)
1795 ec_send[0].activate_component(g_compo_send.rtc_ref)
1797 time.sleep(sleep_act_time)
1800 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1801 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1804 if os.path.isfile(g_diff_recv_file) ==
False:
1805 fout = open(g_test_result_file,
'a')
1806 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1807 message = message + g_check_message
1808 fout.write(message +
'\n')
1811 time.sleep(sleep_for_time)
1815 time.sleep(sleep_act_time)
1819 fout = open(g_test_result_file,
'a')
1820 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1824 message = message + g_test_ok
1826 fout.write(message +
'\n')
1829 message = message + g_test_ng
1831 message = message + g_test_ng_message
1832 fout.write(message +
'\n')
1834 fin2 = open(g_diff_recv_file,
'r') while(1): 1835 s2 = fin2.readline() 1842 time.sleep(sleep_for_time)
1845 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1846 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1847 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1852 case_no = case_no + 1
1853 fout = open(g_test_result_file,
'a')
1854 message = g_mess_header + g_test_case + str(case_no) +
" " 1855 message = message +
"Connecting(out->in, new,SKIP), Activate -> send/recv -> Deactivate" 1856 message = message + g_mess_footer
1857 fout.write(message +
'\n')
1866 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1869 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1872 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1874 for i
in range(loop_count):
1880 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1881 time.sleep(sleep_recv_act_time)
1882 ec_send[0].activate_component(g_compo_send.rtc_ref)
1884 time.sleep(sleep_act_time)
1887 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1888 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1891 if os.path.isfile(g_diff_recv_file) ==
False:
1892 fout = open(g_test_result_file,
'a')
1893 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1894 message = message + g_check_message
1895 fout.write(message +
'\n')
1898 time.sleep(sleep_for_time)
1902 time.sleep(sleep_act_time)
1906 fout = open(g_test_result_file,
'a')
1907 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1911 message = message + g_test_ok
1913 fout.write(message +
'\n')
1916 message = message + g_test_ng
1918 message = message + g_test_ng_message
1919 fout.write(message +
'\n')
1921 fin2 = open(g_diff_recv_file,
'r') while(1): 1922 s2 = fin2.readline() 1929 time.sleep(sleep_for_time)
1932 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1933 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1934 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1939 case_no = case_no + 1
1940 fout = open(g_test_result_file,
'a')
1941 message = g_mess_header + g_test_case + str(case_no) +
" " 1942 message = message +
"Connecting(in->out, new,ALL), Activate -> send/recv -> Deactivate" 1943 message = message + g_mess_footer
1944 fout.write(message +
'\n')
1953 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1956 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1959 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1961 for i
in range(loop_count):
1967 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1968 time.sleep(sleep_recv_act_time)
1969 ec_send[0].activate_component(g_compo_send.rtc_ref)
1971 time.sleep(sleep_act_time)
1974 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1975 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1978 if os.path.isfile(g_diff_recv_file) ==
False:
1979 fout = open(g_test_result_file,
'a')
1980 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1981 message = message + g_check_message
1982 fout.write(message +
'\n')
1985 time.sleep(sleep_for_time)
1989 time.sleep(sleep_act_time)
1993 fout = open(g_test_result_file,
'a')
1994 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1998 message = message + g_test_ok
2000 fout.write(message +
'\n')
2003 message = message + g_test_ng
2005 message = message + g_test_ng_message
2006 fout.write(message +
'\n')
2008 fin2 = open(g_diff_recv_file,
'r') while(1): 2009 s2 = fin2.readline() 2016 time.sleep(sleep_for_time)
2019 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2020 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2021 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2026 case_no = case_no + 1
2027 fout = open(g_test_result_file,
'a')
2028 message = g_mess_header + g_test_case + str(case_no) +
" " 2029 message = message +
"Connecting(in->out, new,FIFO), Activate -> send/recv -> Deactivate" 2030 message = message + g_mess_footer
2031 fout.write(message +
'\n')
2040 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2043 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2046 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2048 for i
in range(loop_count):
2054 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2055 time.sleep(sleep_recv_act_time)
2056 ec_send[0].activate_component(g_compo_send.rtc_ref)
2058 time.sleep(sleep_act_time)
2061 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2062 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2065 if os.path.isfile(g_diff_recv_file) ==
False:
2066 fout = open(g_test_result_file,
'a')
2067 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2068 message = message + g_check_message
2069 fout.write(message +
'\n')
2072 time.sleep(sleep_for_time)
2076 time.sleep(sleep_act_time)
2080 fout = open(g_test_result_file,
'a')
2081 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2085 message = message + g_test_ok
2087 fout.write(message +
'\n')
2090 message = message + g_test_ng
2092 message = message + g_test_ng_message
2093 fout.write(message +
'\n')
2095 fin2 = open(g_diff_recv_file,
'r') while(1): 2096 s2 = fin2.readline() 2103 time.sleep(sleep_for_time)
2106 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2107 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2108 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2113 case_no = case_no + 1
2114 fout = open(g_test_result_file,
'a')
2115 message = g_mess_header + g_test_case + str(case_no) +
" " 2116 message = message +
"Connecting(in->out, new,NEW), Activate -> send/recv -> Deactivate" 2117 message = message + g_mess_footer
2118 fout.write(message +
'\n')
2127 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2130 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2133 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2135 for i
in range(loop_count):
2141 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2142 time.sleep(sleep_recv_act_time)
2143 ec_send[0].activate_component(g_compo_send.rtc_ref)
2145 time.sleep(sleep_act_time)
2148 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2149 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2152 if os.path.isfile(g_diff_recv_file) ==
False:
2153 fout = open(g_test_result_file,
'a')
2154 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2155 message = message + g_check_message
2156 fout.write(message +
'\n')
2159 time.sleep(sleep_for_time)
2163 time.sleep(sleep_act_time)
2167 fout = open(g_test_result_file,
'a')
2168 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2172 message = message + g_test_ok
2174 fout.write(message +
'\n')
2177 message = message + g_test_ng
2179 message = message + g_test_ng_message
2180 fout.write(message +
'\n')
2182 fin2 = open(g_diff_recv_file,
'r') while(1): 2183 s2 = fin2.readline() 2190 time.sleep(sleep_for_time)
2193 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2194 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2195 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2200 case_no = case_no + 1
2201 fout = open(g_test_result_file,
'a')
2202 message = g_mess_header + g_test_case + str(case_no) +
" " 2203 message = message +
"Connecting(in->out, new,SKIP), Activate -> send/recv -> Deactivate" 2204 message = message + g_mess_footer
2205 fout.write(message +
'\n')
2214 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2217 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2220 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2222 for i
in range(loop_count):
2228 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2229 time.sleep(sleep_recv_act_time)
2230 ec_send[0].activate_component(g_compo_send.rtc_ref)
2232 time.sleep(sleep_act_time)
2235 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2236 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2239 if os.path.isfile(g_diff_recv_file) ==
False:
2240 fout = open(g_test_result_file,
'a')
2241 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2242 message = message + g_check_message
2243 fout.write(message +
'\n')
2246 time.sleep(sleep_for_time)
2250 time.sleep(sleep_act_time)
2254 fout = open(g_test_result_file,
'a')
2255 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2259 message = message + g_test_ok
2261 fout.write(message +
'\n')
2264 message = message + g_test_ng
2266 message = message + g_test_ng_message
2267 fout.write(message +
'\n')
2269 fin2 = open(g_diff_recv_file,
'r') while(1): 2270 s2 = fin2.readline() 2277 time.sleep(sleep_for_time)
2280 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2281 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2282 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2287 case_no = case_no + 1
2288 fout = open(g_test_result_file,
'a')
2289 message = g_mess_header + g_test_case + str(case_no) +
" " 2290 message = message +
"Connect(out->in, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 2291 message = message + g_mess_footer
2292 fout.write(message +
'\n')
2296 for i
in range(loop_count):
2306 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2309 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2312 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2315 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2316 time.sleep(sleep_recv_act_time)
2317 ec_send[0].activate_component(g_compo_send.rtc_ref)
2319 time.sleep(sleep_act_time)
2322 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2323 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2326 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2327 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2328 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2331 if os.path.isfile(g_diff_recv_file) ==
False:
2332 fout = open(g_test_result_file,
'a')
2333 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2334 message = message + g_check_message
2335 fout.write(message +
'\n')
2338 time.sleep(sleep_for_time)
2342 time.sleep(sleep_act_time)
2346 fout = open(g_test_result_file,
'a')
2347 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2351 message = message + g_test_ok
2353 fout.write(message +
'\n')
2356 message = message + g_test_ng
2358 message = message + g_test_ng_message
2359 fout.write(message +
'\n')
2361 fin2 = open(g_diff_recv_file,
'r') while(1): 2362 s2 = fin2.readline() 2369 time.sleep(sleep_for_time)
2374 case_no = case_no + 1
2375 fout = open(g_test_result_file,
'a')
2376 message = g_mess_header + g_test_case + str(case_no) +
" " 2377 message = message +
"Connect(out->in, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 2378 message = message + g_mess_footer
2379 fout.write(message +
'\n')
2383 for i
in range(loop_count):
2393 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2396 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2399 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2402 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2403 time.sleep(sleep_recv_act_time)
2404 ec_send[0].activate_component(g_compo_send.rtc_ref)
2406 time.sleep(sleep_act_time)
2409 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2410 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2413 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2414 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2415 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2418 if os.path.isfile(g_diff_recv_file) ==
False:
2419 fout = open(g_test_result_file,
'a')
2420 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2421 message = message + g_check_message
2422 fout.write(message +
'\n')
2425 time.sleep(sleep_for_time)
2429 time.sleep(sleep_act_time)
2433 fout = open(g_test_result_file,
'a')
2434 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2438 message = message + g_test_ok
2440 fout.write(message +
'\n')
2443 message = message + g_test_ng
2445 message = message + g_test_ng_message
2446 fout.write(message +
'\n')
2448 fin2 = open(g_diff_recv_file,
'r') while(1): 2449 s2 = fin2.readline() 2456 time.sleep(sleep_for_time)
2461 case_no = case_no + 1
2462 fout = open(g_test_result_file,
'a')
2463 message = g_mess_header + g_test_case + str(case_no) +
" " 2464 message = message +
"Connect(out->in, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 2465 message = message + g_mess_footer
2466 fout.write(message +
'\n')
2470 for i
in range(loop_count):
2480 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2483 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2486 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2489 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2490 time.sleep(sleep_recv_act_time)
2491 ec_send[0].activate_component(g_compo_send.rtc_ref)
2493 time.sleep(sleep_act_time)
2496 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2497 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2500 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2501 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2502 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2505 if os.path.isfile(g_diff_recv_file) ==
False:
2506 fout = open(g_test_result_file,
'a')
2507 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2508 message = message + g_check_message
2509 fout.write(message +
'\n')
2512 time.sleep(sleep_for_time)
2516 time.sleep(sleep_act_time)
2520 fout = open(g_test_result_file,
'a')
2521 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2525 message = message + g_test_ok
2527 fout.write(message +
'\n')
2530 message = message + g_test_ng
2532 message = message + g_test_ng_message
2533 fout.write(message +
'\n')
2535 fin2 = open(g_diff_recv_file,
'r') while(1): 2536 s2 = fin2.readline() 2543 time.sleep(sleep_for_time)
2548 case_no = case_no + 1
2549 fout = open(g_test_result_file,
'a')
2550 message = g_mess_header + g_test_case + str(case_no) +
" " 2551 message = message +
"Connect(out->in, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 2552 message = message + g_mess_footer
2553 fout.write(message +
'\n')
2557 for i
in range(loop_count):
2567 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2570 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2573 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2576 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2577 time.sleep(sleep_recv_act_time)
2578 ec_send[0].activate_component(g_compo_send.rtc_ref)
2580 time.sleep(sleep_act_time)
2583 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2584 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2587 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2588 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2589 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2592 if os.path.isfile(g_diff_recv_file) ==
False:
2593 fout = open(g_test_result_file,
'a')
2594 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2595 message = message + g_check_message
2596 fout.write(message +
'\n')
2599 time.sleep(sleep_for_time)
2603 time.sleep(sleep_act_time)
2607 fout = open(g_test_result_file,
'a')
2608 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2612 message = message + g_test_ok
2614 fout.write(message +
'\n')
2617 message = message + g_test_ng
2619 message = message + g_test_ng_message
2620 fout.write(message +
'\n')
2622 fin2 = open(g_diff_recv_file,
'r') while(1): 2623 s2 = fin2.readline() 2630 time.sleep(sleep_for_time)
2635 case_no = case_no + 1
2636 fout = open(g_test_result_file,
'a')
2637 message = g_mess_header + g_test_case + str(case_no) +
" " 2638 message = message +
"Connect(in->out, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 2639 message = message + g_mess_footer
2640 fout.write(message +
'\n')
2644 for i
in range(loop_count):
2654 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2657 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2660 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2663 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2664 time.sleep(sleep_recv_act_time)
2665 ec_send[0].activate_component(g_compo_send.rtc_ref)
2667 time.sleep(sleep_act_time)
2670 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2671 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2674 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2675 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2676 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2679 if os.path.isfile(g_diff_recv_file) ==
False:
2680 fout = open(g_test_result_file,
'a')
2681 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2682 message = message + g_check_message
2683 fout.write(message +
'\n')
2686 time.sleep(sleep_for_time)
2690 time.sleep(sleep_act_time)
2694 fout = open(g_test_result_file,
'a')
2695 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2699 message = message + g_test_ok
2701 fout.write(message +
'\n')
2704 message = message + g_test_ng
2706 message = message + g_test_ng_message
2707 fout.write(message +
'\n')
2709 fin2 = open(g_diff_recv_file,
'r') while(1): 2710 s2 = fin2.readline() 2717 time.sleep(sleep_for_time)
2722 case_no = case_no + 1
2723 fout = open(g_test_result_file,
'a')
2724 message = g_mess_header + g_test_case + str(case_no) +
" " 2725 message = message +
"Connect(in->out, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 2726 message = message + g_mess_footer
2727 fout.write(message +
'\n')
2731 for i
in range(loop_count):
2741 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2744 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2747 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2750 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2751 time.sleep(sleep_recv_act_time)
2752 ec_send[0].activate_component(g_compo_send.rtc_ref)
2754 time.sleep(sleep_act_time)
2757 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2758 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2761 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2762 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2763 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2766 if os.path.isfile(g_diff_recv_file) ==
False:
2767 fout = open(g_test_result_file,
'a')
2768 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2769 message = message + g_check_message
2770 fout.write(message +
'\n')
2773 time.sleep(sleep_for_time)
2777 time.sleep(sleep_act_time)
2781 fout = open(g_test_result_file,
'a')
2782 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2786 message = message + g_test_ok
2788 fout.write(message +
'\n')
2791 message = message + g_test_ng
2793 message = message + g_test_ng_message
2794 fout.write(message +
'\n')
2796 fin2 = open(g_diff_recv_file,
'r') while(1): 2797 s2 = fin2.readline() 2804 time.sleep(sleep_for_time)
2809 case_no = case_no + 1
2810 fout = open(g_test_result_file,
'a')
2811 message = g_mess_header + g_test_case + str(case_no) +
" " 2812 message = message +
"Connect(in->out, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 2813 message = message + g_mess_footer
2814 fout.write(message +
'\n')
2818 for i
in range(loop_count):
2828 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2831 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2834 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2837 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2838 time.sleep(sleep_recv_act_time)
2839 ec_send[0].activate_component(g_compo_send.rtc_ref)
2841 time.sleep(sleep_act_time)
2844 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2845 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2848 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2849 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2850 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2853 if os.path.isfile(g_diff_recv_file) ==
False:
2854 fout = open(g_test_result_file,
'a')
2855 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2856 message = message + g_check_message
2857 fout.write(message +
'\n')
2860 time.sleep(sleep_for_time)
2864 time.sleep(sleep_act_time)
2868 fout = open(g_test_result_file,
'a')
2869 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2873 message = message + g_test_ok
2875 fout.write(message +
'\n')
2878 message = message + g_test_ng
2880 message = message + g_test_ng_message
2881 fout.write(message +
'\n')
2883 fin2 = open(g_diff_recv_file,
'r') while(1): 2884 s2 = fin2.readline() 2891 time.sleep(sleep_for_time)
2896 case_no = case_no + 1
2897 fout = open(g_test_result_file,
'a')
2898 message = g_mess_header + g_test_case + str(case_no) +
" " 2899 message = message +
"Connect(in->out, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 2900 message = message + g_mess_footer
2901 fout.write(message +
'\n')
2905 for i
in range(loop_count):
2915 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2918 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2921 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2924 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2925 time.sleep(sleep_recv_act_time)
2926 ec_send[0].activate_component(g_compo_send.rtc_ref)
2928 time.sleep(sleep_act_time)
2931 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2932 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2935 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2936 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2937 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2940 if os.path.isfile(g_diff_recv_file) ==
False:
2941 fout = open(g_test_result_file,
'a')
2942 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2943 message = message + g_check_message
2944 fout.write(message +
'\n')
2947 time.sleep(sleep_for_time)
2951 time.sleep(sleep_act_time)
2955 fout = open(g_test_result_file,
'a')
2956 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2960 message = message + g_test_ok
2962 fout.write(message +
'\n')
2965 message = message + g_test_ng
2967 message = message + g_test_ng_message
2968 fout.write(message +
'\n')
2970 fin2 = open(g_diff_recv_file,
'r') while(1): 2971 s2 = fin2.readline() 2978 time.sleep(sleep_for_time)
2984 case_no = case_no + 1
2985 fout = open(g_test_result_file,
'a')
2986 message = g_mess_header + g_test_case + str(case_no) +
" " 2987 message = message +
"Connect(out->in, periodic,ALL) -> Disconnect" 2988 message = message + g_mess_footer
2989 fout.write(message +
'\n')
2993 for i
in range(loop_count):
3000 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3003 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3006 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3008 time.sleep(sleep_connect_time)
3011 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3012 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3013 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3016 fout = open(g_test_result_file,
'a')
3017 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3018 message = message + g_test_ok
3020 fout.write(message +
'\n')
3023 time.sleep(sleep_for_time)
3028 case_no = case_no + 1
3029 fout = open(g_test_result_file,
'a')
3030 message = g_mess_header + g_test_case + str(case_no) +
" " 3031 message = message +
"Connect(out->in, periodic,FIFO) -> Disconnect" 3032 message = message + g_mess_footer
3033 fout.write(message +
'\n')
3037 for i
in range(loop_count):
3044 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3047 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3050 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3052 time.sleep(sleep_connect_time)
3055 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3056 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3057 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3060 fout = open(g_test_result_file,
'a')
3061 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3062 message = message + g_test_ok
3064 fout.write(message +
'\n')
3067 time.sleep(sleep_for_time)
3072 case_no = case_no + 1
3073 fout = open(g_test_result_file,
'a')
3074 message = g_mess_header + g_test_case + str(case_no) +
" " 3075 message = message +
"Connect(out->in, periodic,NEW) -> Disconnect" 3076 message = message + g_mess_footer
3077 fout.write(message +
'\n')
3081 for i
in range(loop_count):
3088 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3091 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3094 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3096 time.sleep(sleep_connect_time)
3099 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3100 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3101 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3104 fout = open(g_test_result_file,
'a')
3105 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3106 message = message + g_test_ok
3108 fout.write(message +
'\n')
3111 time.sleep(sleep_for_time)
3116 case_no = case_no + 1
3117 fout = open(g_test_result_file,
'a')
3118 message = g_mess_header + g_test_case + str(case_no) +
" " 3119 message = message +
"Connect(out->in, periodic,SKIP) -> Disconnect" 3120 message = message + g_mess_footer
3121 fout.write(message +
'\n')
3125 for i
in range(loop_count):
3132 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3135 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3138 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3140 time.sleep(sleep_connect_time)
3143 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3144 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3145 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3148 fout = open(g_test_result_file,
'a')
3149 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3150 message = message + g_test_ok
3152 fout.write(message +
'\n')
3155 time.sleep(sleep_for_time)
3160 case_no = case_no + 1
3161 fout = open(g_test_result_file,
'a')
3162 message = g_mess_header + g_test_case + str(case_no) +
" " 3163 message = message +
"Connect(in->out, periodic,ALL) -> Disconnect" 3164 message = message + g_mess_footer
3165 fout.write(message +
'\n')
3169 for i
in range(loop_count):
3176 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3179 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3182 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3184 time.sleep(sleep_connect_time)
3187 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3188 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3189 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3192 fout = open(g_test_result_file,
'a')
3193 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3194 message = message + g_test_ok
3196 fout.write(message +
'\n')
3199 time.sleep(sleep_for_time)
3204 case_no = case_no + 1
3205 fout = open(g_test_result_file,
'a')
3206 message = g_mess_header + g_test_case + str(case_no) +
" " 3207 message = message +
"Connect(in->out, periodic,FIFO) -> Disconnect" 3208 message = message + g_mess_footer
3209 fout.write(message +
'\n')
3213 for i
in range(loop_count):
3220 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3223 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3226 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3228 time.sleep(sleep_connect_time)
3231 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3232 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3233 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3236 fout = open(g_test_result_file,
'a')
3237 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3238 message = message + g_test_ok
3240 fout.write(message +
'\n')
3243 time.sleep(sleep_for_time)
3248 case_no = case_no + 1
3249 fout = open(g_test_result_file,
'a')
3250 message = g_mess_header + g_test_case + str(case_no) +
" " 3251 message = message +
"Connect(in->out, periodic,NEW) -> Disconnect" 3252 message = message + g_mess_footer
3253 fout.write(message +
'\n')
3257 for i
in range(loop_count):
3264 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3267 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3270 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3272 time.sleep(sleep_connect_time)
3275 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3276 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3277 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3280 fout = open(g_test_result_file,
'a')
3281 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3282 message = message + g_test_ok
3284 fout.write(message +
'\n')
3287 time.sleep(sleep_for_time)
3292 case_no = case_no + 1
3293 fout = open(g_test_result_file,
'a')
3294 message = g_mess_header + g_test_case + str(case_no) +
" " 3295 message = message +
"Connect(in->out, periodic,SKIP) -> Disconnect" 3296 message = message + g_mess_footer
3297 fout.write(message +
'\n')
3301 for i
in range(loop_count):
3308 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3311 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3314 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3316 time.sleep(sleep_connect_time)
3319 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3320 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3321 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3324 fout = open(g_test_result_file,
'a')
3325 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3326 message = message + g_test_ok
3328 fout.write(message +
'\n')
3331 time.sleep(sleep_for_time)
3336 case_no = case_no + 1
3337 fout = open(g_test_result_file,
'a')
3338 message = g_mess_header + g_test_case + str(case_no) +
" " 3339 message = message +
"Connecting(out->in, periodic,ALL), Activate -> send/recv -> Deactivate" 3340 message = message + g_mess_footer
3341 fout.write(message +
'\n')
3350 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3353 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3356 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3358 for i
in range(loop_count):
3364 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3365 time.sleep(sleep_recv_act_time)
3366 ec_send[0].activate_component(g_compo_send.rtc_ref)
3368 time.sleep(sleep_act_time)
3371 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3372 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3375 if os.path.isfile(g_diff_recv_file) ==
False:
3376 fout = open(g_test_result_file,
'a')
3377 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3378 message = message + g_check_message
3379 fout.write(message +
'\n')
3382 time.sleep(sleep_for_time)
3386 time.sleep(sleep_act_time)
3390 fout = open(g_test_result_file,
'a')
3391 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3395 message = message + g_test_ok
3397 fout.write(message +
'\n')
3400 message = message + g_test_ng
3402 message = message + g_test_ng_message
3403 fout.write(message +
'\n')
3405 fin2 = open(g_diff_recv_file,
'r') while(1): 3406 s2 = fin2.readline() 3413 time.sleep(sleep_for_time)
3416 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3417 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3418 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3423 case_no = case_no + 1
3424 fout = open(g_test_result_file,
'a')
3425 message = g_mess_header + g_test_case + str(case_no) +
" " 3426 message = message +
"Connecting(out->in, periodic,FIFO), Activate -> send/recv -> Deactivate" 3427 message = message + g_mess_footer
3428 fout.write(message +
'\n')
3437 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3440 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3443 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3445 for i
in range(loop_count):
3451 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3452 time.sleep(sleep_recv_act_time)
3453 ec_send[0].activate_component(g_compo_send.rtc_ref)
3455 time.sleep(sleep_act_time)
3458 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3459 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3462 if os.path.isfile(g_diff_recv_file) ==
False:
3463 fout = open(g_test_result_file,
'a')
3464 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3465 message = message + g_check_message
3466 fout.write(message +
'\n')
3469 time.sleep(sleep_for_time)
3473 time.sleep(sleep_act_time)
3477 fout = open(g_test_result_file,
'a')
3478 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3482 message = message + g_test_ok
3484 fout.write(message +
'\n')
3487 message = message + g_test_ng
3489 message = message + g_test_ng_message
3490 fout.write(message +
'\n')
3492 fin2 = open(g_diff_recv_file,
'r') while(1): 3493 s2 = fin2.readline() 3500 time.sleep(sleep_for_time)
3503 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3504 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3505 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3510 case_no = case_no + 1
3511 fout = open(g_test_result_file,
'a')
3512 message = g_mess_header + g_test_case + str(case_no) +
" " 3513 message = message +
"Connecting(out->in, periodic,NEW), Activate -> send/recv -> Deactivate" 3514 message = message + g_mess_footer
3515 fout.write(message +
'\n')
3524 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3527 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3530 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3532 for i
in range(loop_count):
3538 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3539 time.sleep(sleep_recv_act_time)
3540 ec_send[0].activate_component(g_compo_send.rtc_ref)
3542 time.sleep(sleep_act_time)
3545 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3546 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3549 if os.path.isfile(g_diff_recv_file) ==
False:
3550 fout = open(g_test_result_file,
'a')
3551 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3552 message = message + g_check_message
3553 fout.write(message +
'\n')
3556 time.sleep(sleep_for_time)
3560 time.sleep(sleep_act_time)
3564 fout = open(g_test_result_file,
'a')
3565 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3569 message = message + g_test_ok
3571 fout.write(message +
'\n')
3574 message = message + g_test_ng
3576 message = message + g_test_ng_message
3577 fout.write(message +
'\n')
3579 fin2 = open(g_diff_recv_file,
'r') while(1): 3580 s2 = fin2.readline() 3587 time.sleep(sleep_for_time)
3590 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3591 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3592 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3597 case_no = case_no + 1
3598 fout = open(g_test_result_file,
'a')
3599 message = g_mess_header + g_test_case + str(case_no) +
" " 3600 message = message +
"Connecting(out->in, periodic,SKIP), Activate -> send/recv -> Deactivate" 3601 message = message + g_mess_footer
3602 fout.write(message +
'\n')
3611 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3614 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3617 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3619 for i
in range(loop_count):
3625 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3626 time.sleep(sleep_recv_act_time)
3627 ec_send[0].activate_component(g_compo_send.rtc_ref)
3629 time.sleep(sleep_act_time)
3632 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3633 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3636 if os.path.isfile(g_diff_recv_file) ==
False:
3637 fout = open(g_test_result_file,
'a')
3638 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3639 message = message + g_check_message
3640 fout.write(message +
'\n')
3643 time.sleep(sleep_for_time)
3647 time.sleep(sleep_act_time)
3651 fout = open(g_test_result_file,
'a')
3652 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3656 message = message + g_test_ok
3658 fout.write(message +
'\n')
3661 message = message + g_test_ng
3663 message = message + g_test_ng_message
3664 fout.write(message +
'\n')
3666 fin2 = open(g_diff_recv_file,
'r') while(1): 3667 s2 = fin2.readline() 3674 time.sleep(sleep_for_time)
3677 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3678 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3679 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3684 case_no = case_no + 1
3685 fout = open(g_test_result_file,
'a')
3686 message = g_mess_header + g_test_case + str(case_no) +
" " 3687 message = message +
"Connecting(in->out, periodic,ALL), Activate -> send/recv -> Deactivate" 3688 message = message + g_mess_footer
3689 fout.write(message +
'\n')
3698 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3701 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3704 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3706 for i
in range(loop_count):
3712 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3713 time.sleep(sleep_recv_act_time)
3714 ec_send[0].activate_component(g_compo_send.rtc_ref)
3716 time.sleep(sleep_act_time)
3719 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3720 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3723 if os.path.isfile(g_diff_recv_file) ==
False:
3724 fout = open(g_test_result_file,
'a')
3725 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3726 message = message + g_check_message
3727 fout.write(message +
'\n')
3730 time.sleep(sleep_for_time)
3734 time.sleep(sleep_act_time)
3738 fout = open(g_test_result_file,
'a')
3739 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3743 message = message + g_test_ok
3745 fout.write(message +
'\n')
3748 message = message + g_test_ng
3750 message = message + g_test_ng_message
3751 fout.write(message +
'\n')
3753 fin2 = open(g_diff_recv_file,
'r') while(1): 3754 s2 = fin2.readline() 3761 time.sleep(sleep_for_time)
3764 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3765 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3766 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3771 case_no = case_no + 1
3772 fout = open(g_test_result_file,
'a')
3773 message = g_mess_header + g_test_case + str(case_no) +
" " 3774 message = message +
"Connecting(in->out, periodic,FIFO), Activate -> send/recv -> Deactivate" 3775 message = message + g_mess_footer
3776 fout.write(message +
'\n')
3785 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3788 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3791 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3793 for i
in range(loop_count):
3799 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3800 time.sleep(sleep_recv_act_time)
3801 ec_send[0].activate_component(g_compo_send.rtc_ref)
3803 time.sleep(sleep_act_time)
3806 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3807 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3810 if os.path.isfile(g_diff_recv_file) ==
False:
3811 fout = open(g_test_result_file,
'a')
3812 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3813 message = message + g_check_message
3814 fout.write(message +
'\n')
3817 time.sleep(sleep_for_time)
3821 time.sleep(sleep_act_time)
3825 fout = open(g_test_result_file,
'a')
3826 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3830 message = message + g_test_ok
3832 fout.write(message +
'\n')
3835 message = message + g_test_ng
3837 message = message + g_test_ng_message
3838 fout.write(message +
'\n')
3840 fin2 = open(g_diff_recv_file,
'r') while(1): 3841 s2 = fin2.readline() 3848 time.sleep(sleep_for_time)
3851 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3852 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3853 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3858 case_no = case_no + 1
3859 fout = open(g_test_result_file,
'a')
3860 message = g_mess_header + g_test_case + str(case_no) +
" " 3861 message = message +
"Connecting(in->out, periodic,NEW), Activate -> send/recv -> Deactivate" 3862 message = message + g_mess_footer
3863 fout.write(message +
'\n')
3872 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3875 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3878 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3880 for i
in range(loop_count):
3886 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3887 time.sleep(sleep_recv_act_time)
3888 ec_send[0].activate_component(g_compo_send.rtc_ref)
3890 time.sleep(sleep_act_time)
3893 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3894 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3897 if os.path.isfile(g_diff_recv_file) ==
False:
3898 fout = open(g_test_result_file,
'a')
3899 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3900 message = message + g_check_message
3901 fout.write(message +
'\n')
3904 time.sleep(sleep_for_time)
3908 time.sleep(sleep_act_time)
3912 fout = open(g_test_result_file,
'a')
3913 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3917 message = message + g_test_ok
3919 fout.write(message +
'\n')
3922 message = message + g_test_ng
3924 message = message + g_test_ng_message
3925 fout.write(message +
'\n')
3927 fin2 = open(g_diff_recv_file,
'r') while(1): 3928 s2 = fin2.readline() 3935 time.sleep(sleep_for_time)
3938 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3939 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3940 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3945 case_no = case_no + 1
3946 fout = open(g_test_result_file,
'a')
3947 message = g_mess_header + g_test_case + str(case_no) +
" " 3948 message = message +
"Connecting(in->out, periodic,SKIP), Activate -> send/recv -> Deactivate" 3949 message = message + g_mess_footer
3950 fout.write(message +
'\n')
3959 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3962 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3965 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3967 for i
in range(loop_count):
3973 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3974 time.sleep(sleep_recv_act_time)
3975 ec_send[0].activate_component(g_compo_send.rtc_ref)
3977 time.sleep(sleep_act_time)
3980 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3981 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3984 if os.path.isfile(g_diff_recv_file) ==
False:
3985 fout = open(g_test_result_file,
'a')
3986 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3987 message = message + g_check_message
3988 fout.write(message +
'\n')
3991 time.sleep(sleep_for_time)
3995 time.sleep(sleep_act_time)
3999 fout = open(g_test_result_file,
'a')
4000 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4004 message = message + g_test_ok
4006 fout.write(message +
'\n')
4009 message = message + g_test_ng
4011 message = message + g_test_ng_message
4012 fout.write(message +
'\n')
4014 fin2 = open(g_diff_recv_file,
'r') while(1): 4015 s2 = fin2.readline() 4022 time.sleep(sleep_for_time)
4025 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4026 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4027 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4032 case_no = case_no + 1
4033 fout = open(g_test_result_file,
'a')
4034 message = g_mess_header + g_test_case + str(case_no) +
" " 4035 message = message +
"Connect(out->in, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 4036 message = message + g_mess_footer
4037 fout.write(message +
'\n')
4041 for i
in range(loop_count):
4051 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4054 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4057 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4060 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4061 time.sleep(sleep_recv_act_time)
4062 ec_send[0].activate_component(g_compo_send.rtc_ref)
4064 time.sleep(sleep_act_time)
4067 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4068 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4071 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4072 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4073 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4076 if os.path.isfile(g_diff_recv_file) ==
False:
4077 fout = open(g_test_result_file,
'a')
4078 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4079 message = message + g_check_message
4080 fout.write(message +
'\n')
4083 time.sleep(sleep_for_time)
4087 time.sleep(sleep_act_time)
4091 fout = open(g_test_result_file,
'a')
4092 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4096 message = message + g_test_ok
4098 fout.write(message +
'\n')
4101 message = message + g_test_ng
4103 message = message + g_test_ng_message
4104 fout.write(message +
'\n')
4106 fin2 = open(g_diff_recv_file,
'r') while(1): 4107 s2 = fin2.readline() 4114 time.sleep(sleep_for_time)
4119 case_no = case_no + 1
4120 fout = open(g_test_result_file,
'a')
4121 message = g_mess_header + g_test_case + str(case_no) +
" " 4122 message = message +
"Connect(out->in, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 4123 message = message + g_mess_footer
4124 fout.write(message +
'\n')
4128 for i
in range(loop_count):
4138 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4141 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4144 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4147 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4148 time.sleep(sleep_recv_act_time)
4149 ec_send[0].activate_component(g_compo_send.rtc_ref)
4151 time.sleep(sleep_act_time)
4154 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4155 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4158 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4159 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4160 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4163 if os.path.isfile(g_diff_recv_file) ==
False:
4164 fout = open(g_test_result_file,
'a')
4165 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4166 message = message + g_check_message
4167 fout.write(message +
'\n')
4170 time.sleep(sleep_for_time)
4174 time.sleep(sleep_act_time)
4178 fout = open(g_test_result_file,
'a')
4179 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4183 message = message + g_test_ok
4185 fout.write(message +
'\n')
4188 message = message + g_test_ng
4190 message = message + g_test_ng_message
4191 fout.write(message +
'\n')
4193 fin2 = open(g_diff_recv_file,
'r') while(1): 4194 s2 = fin2.readline() 4201 time.sleep(sleep_for_time)
4206 case_no = case_no + 1
4207 fout = open(g_test_result_file,
'a')
4208 message = g_mess_header + g_test_case + str(case_no) +
" " 4209 message = message +
"Connect(out->in, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 4210 message = message + g_mess_footer
4211 fout.write(message +
'\n')
4215 for i
in range(loop_count):
4225 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4228 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4231 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4234 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4235 time.sleep(sleep_recv_act_time)
4236 ec_send[0].activate_component(g_compo_send.rtc_ref)
4238 time.sleep(sleep_act_time)
4241 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4242 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4245 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4246 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4247 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4250 if os.path.isfile(g_diff_recv_file) ==
False:
4251 fout = open(g_test_result_file,
'a')
4252 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4253 message = message + g_check_message
4254 fout.write(message +
'\n')
4257 time.sleep(sleep_for_time)
4261 time.sleep(sleep_act_time)
4265 fout = open(g_test_result_file,
'a')
4266 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4270 message = message + g_test_ok
4272 fout.write(message +
'\n')
4275 message = message + g_test_ng
4277 message = message + g_test_ng_message
4278 fout.write(message +
'\n')
4280 fin2 = open(g_diff_recv_file,
'r') while(1): 4281 s2 = fin2.readline() 4288 time.sleep(sleep_for_time)
4293 case_no = case_no + 1
4294 fout = open(g_test_result_file,
'a')
4295 message = g_mess_header + g_test_case + str(case_no) +
" " 4296 message = message +
"Connect(out->in, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 4297 message = message + g_mess_footer
4298 fout.write(message +
'\n')
4302 for i
in range(loop_count):
4312 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4315 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4318 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4321 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4322 time.sleep(sleep_recv_act_time)
4323 ec_send[0].activate_component(g_compo_send.rtc_ref)
4325 time.sleep(sleep_act_time)
4328 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4329 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4332 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4333 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4334 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4337 if os.path.isfile(g_diff_recv_file) ==
False:
4338 fout = open(g_test_result_file,
'a')
4339 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4340 message = message + g_check_message
4341 fout.write(message +
'\n')
4344 time.sleep(sleep_for_time)
4348 time.sleep(sleep_act_time)
4352 fout = open(g_test_result_file,
'a')
4353 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4357 message = message + g_test_ok
4359 fout.write(message +
'\n')
4362 message = message + g_test_ng
4364 message = message + g_test_ng_message
4365 fout.write(message +
'\n')
4367 fin2 = open(g_diff_recv_file,
'r') while(1): 4368 s2 = fin2.readline() 4375 time.sleep(sleep_for_time)
4380 case_no = case_no + 1
4381 fout = open(g_test_result_file,
'a')
4382 message = g_mess_header + g_test_case + str(case_no) +
" " 4383 message = message +
"Connect(in->out, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 4384 message = message + g_mess_footer
4385 fout.write(message +
'\n')
4389 for i
in range(loop_count):
4399 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4402 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4405 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4408 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4409 time.sleep(sleep_recv_act_time)
4410 ec_send[0].activate_component(g_compo_send.rtc_ref)
4412 time.sleep(sleep_act_time)
4415 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4416 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4419 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4420 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4421 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4424 if os.path.isfile(g_diff_recv_file) ==
False:
4425 fout = open(g_test_result_file,
'a')
4426 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4427 message = message + g_check_message
4428 fout.write(message +
'\n')
4431 time.sleep(sleep_for_time)
4435 time.sleep(sleep_act_time)
4439 fout = open(g_test_result_file,
'a')
4440 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4444 message = message + g_test_ok
4446 fout.write(message +
'\n')
4449 message = message + g_test_ng
4451 message = message + g_test_ng_message
4452 fout.write(message +
'\n')
4454 fin2 = open(g_diff_recv_file,
'r') while(1): 4455 s2 = fin2.readline() 4462 time.sleep(sleep_for_time)
4467 case_no = case_no + 1
4468 fout = open(g_test_result_file,
'a')
4469 message = g_mess_header + g_test_case + str(case_no) +
" " 4470 message = message +
"Connect(in->out, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 4471 message = message + g_mess_footer
4472 fout.write(message +
'\n')
4476 for i
in range(loop_count):
4486 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4489 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4492 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4495 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4496 time.sleep(sleep_recv_act_time)
4497 ec_send[0].activate_component(g_compo_send.rtc_ref)
4499 time.sleep(sleep_act_time)
4502 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4503 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4506 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4507 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4508 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4511 if os.path.isfile(g_diff_recv_file) ==
False:
4512 fout = open(g_test_result_file,
'a')
4513 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4514 message = message + g_check_message
4515 fout.write(message +
'\n')
4518 time.sleep(sleep_for_time)
4522 time.sleep(sleep_act_time)
4526 fout = open(g_test_result_file,
'a')
4527 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4531 message = message + g_test_ok
4533 fout.write(message +
'\n')
4536 message = message + g_test_ng
4538 message = message + g_test_ng_message
4539 fout.write(message +
'\n')
4541 fin2 = open(g_diff_recv_file,
'r') while(1): 4542 s2 = fin2.readline() 4549 time.sleep(sleep_for_time)
4554 case_no = case_no + 1
4555 fout = open(g_test_result_file,
'a')
4556 message = g_mess_header + g_test_case + str(case_no) +
" " 4557 message = message +
"Connect(in->out, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 4558 message = message + g_mess_footer
4559 fout.write(message +
'\n')
4563 for i
in range(loop_count):
4573 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4576 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4579 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4582 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4583 time.sleep(sleep_recv_act_time)
4584 ec_send[0].activate_component(g_compo_send.rtc_ref)
4586 time.sleep(sleep_act_time)
4589 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4590 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4593 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4594 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4595 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4598 if os.path.isfile(g_diff_recv_file) ==
False:
4599 fout = open(g_test_result_file,
'a')
4600 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4601 message = message + g_check_message
4602 fout.write(message +
'\n')
4605 time.sleep(sleep_for_time)
4609 time.sleep(sleep_act_time)
4613 fout = open(g_test_result_file,
'a')
4614 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4618 message = message + g_test_ok
4620 fout.write(message +
'\n')
4623 message = message + g_test_ng
4625 message = message + g_test_ng_message
4626 fout.write(message +
'\n')
4628 fin2 = open(g_diff_recv_file,
'r') while(1): 4629 s2 = fin2.readline() 4636 time.sleep(sleep_for_time)
4641 case_no = case_no + 1
4642 fout = open(g_test_result_file,
'a')
4643 message = g_mess_header + g_test_case + str(case_no) +
" " 4644 message = message +
"Connect(in->out, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 4645 message = message + g_mess_footer
4646 fout.write(message +
'\n')
4650 for i
in range(loop_count):
4660 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4663 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4666 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4669 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4670 time.sleep(sleep_recv_act_time)
4671 ec_send[0].activate_component(g_compo_send.rtc_ref)
4673 time.sleep(sleep_act_time)
4676 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4677 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4680 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4681 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4682 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4685 if os.path.isfile(g_diff_recv_file) ==
False:
4686 fout = open(g_test_result_file,
'a')
4687 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4688 message = message + g_check_message
4689 fout.write(message +
'\n')
4692 time.sleep(sleep_for_time)
4696 time.sleep(sleep_act_time)
4700 fout = open(g_test_result_file,
'a')
4701 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4705 message = message + g_test_ok
4707 fout.write(message +
'\n')
4710 message = message + g_test_ng
4712 message = message + g_test_ng_message
4713 fout.write(message +
'\n')
4715 fin2 = open(g_diff_recv_file,
'r') while(1): 4716 s2 = fin2.readline() 4723 time.sleep(sleep_for_time)
4725 print "Test Complete." 4726
def make_connecter_profile(subscription_type, push_policy, connect_direction)
�����ؿ������ͥ������ץ��ե���������(�ǡ����ݡ���)
def delete_recv_file()
�����ؿ��������ե�������
def diff_file()
�����ؿ����������ե�����Υǡ������