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') 173 f_recv = open(g_diff_recv_file, 'r') 176 str_send = f_send.readline() 177 str_recv = f_recv.readline() 178 if len(str_send) == 0:
187 str_send2 = str_send.rstrip(
'\n')
188 str_send2 = str_send2.rstrip(
'\r')
189 str_recv2 = str_recv.rstrip(
'\n')
190 str_recv2 = str_recv2.rstrip(
'\r')
196 if str_send2 != str_recv2:
216 sleep_recv_act_time = 1
225 sleep_connect_time = 2
228 fout = open(g_test_result_file,
'w')
229 fout.write(g_test_name +
'\n')
238 case_no = case_no + 1
239 fout = open(g_test_result_file,
'a')
240 message = g_mess_header + g_test_case + str(case_no) +
" " 241 message = message +
"Connect(out->in, flush) -> Disconnect" 242 message = message + g_mess_footer
243 fout.write(message +
'\n')
247 for i
in range(loop_count):
254 ret0 = g_out_ports[g_port1].connect(g_conprof1)
257 ret1 = g_out_ports[g_port2].connect(g_conprof2)
260 ret2 = g_out_ports[g_port3].connect(g_conprof3)
262 time.sleep(sleep_connect_time)
265 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
266 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
267 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
270 fout = open(g_test_result_file,
'a')
271 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
272 message = message + g_test_ok
274 fout.write(message +
'\n')
277 time.sleep(sleep_for_time)
282 case_no = case_no + 1
283 fout = open(g_test_result_file,
'a')
284 message = g_mess_header + g_test_case + str(case_no) +
" " 285 message = message +
"Connect(in->out, flush) -> Disconnect" 286 message = message + g_mess_footer
287 fout.write(message +
'\n')
291 for i
in range(loop_count):
298 ret0 = g_out_ports[g_port1].connect(g_conprof1)
301 ret1 = g_out_ports[g_port2].connect(g_conprof2)
304 ret2 = g_out_ports[g_port3].connect(g_conprof3)
306 time.sleep(sleep_connect_time)
309 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
310 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
311 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
314 fout = open(g_test_result_file,
'a')
315 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
316 message = message + g_test_ok
318 fout.write(message +
'\n')
321 time.sleep(sleep_for_time)
326 case_no = case_no + 1
327 fout = open(g_test_result_file,
'a')
328 message = g_mess_header + g_test_case + str(case_no) +
" " 329 message = message +
"Connecting(out->in, flush), Activate -> send/recv -> Deactivate" 330 message = message + g_mess_footer
331 fout.write(message +
'\n')
340 ret0 = g_out_ports[g_port1].connect(g_conprof1)
343 ret1 = g_out_ports[g_port2].connect(g_conprof2)
346 ret2 = g_out_ports[g_port3].connect(g_conprof3)
348 for i
in range(loop_count):
354 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
355 time.sleep(sleep_recv_act_time)
356 ec_send[0].activate_component(g_compo_send.rtc_ref)
358 time.sleep(sleep_act_time)
361 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
362 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
365 if os.path.isfile(g_diff_recv_file) ==
False:
366 fout = open(g_test_result_file,
'a')
367 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
368 message = message + g_check_message
369 fout.write(message +
'\n')
372 time.sleep(sleep_for_time)
376 time.sleep(sleep_act_time)
380 fout = open(g_test_result_file,
'a')
381 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
385 message = message + g_test_ok
387 fout.write(message +
'\n')
390 message = message + g_test_ng
392 message = message + g_test_ng_message
393 fout.write(message +
'\n')
395 fin2 = open(g_diff_recv_file,
'r') 404 time.sleep(sleep_for_time)
407 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
408 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
409 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
414 case_no = case_no + 1
415 fout = open(g_test_result_file,
'a')
416 message = g_mess_header + g_test_case + str(case_no) +
" " 417 message = message +
"Connecting(in->out, flush), Activate -> send/recv -> Deactivate" 418 message = message + g_mess_footer
419 fout.write(message +
'\n')
428 ret0 = g_out_ports[g_port1].connect(g_conprof1)
431 ret1 = g_out_ports[g_port2].connect(g_conprof2)
434 ret2 = g_out_ports[g_port3].connect(g_conprof3)
436 for i
in range(loop_count):
442 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
443 time.sleep(sleep_recv_act_time)
444 ec_send[0].activate_component(g_compo_send.rtc_ref)
446 time.sleep(sleep_act_time)
449 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
450 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
453 if os.path.isfile(g_diff_recv_file) ==
False:
454 fout = open(g_test_result_file,
'a')
455 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
456 message = message + g_check_message
457 fout.write(message +
'\n')
460 time.sleep(sleep_for_time)
464 time.sleep(sleep_act_time)
468 fout = open(g_test_result_file,
'a')
469 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
473 message = message + g_test_ok
475 fout.write(message +
'\n')
478 message = message + g_test_ng
480 message = message + g_test_ng_message
481 fout.write(message +
'\n')
483 fin2 = open(g_diff_recv_file,
'r') 492 time.sleep(sleep_for_time)
495 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
496 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
497 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
502 case_no = case_no + 1
503 fout = open(g_test_result_file,
'a')
504 message = g_mess_header + g_test_case + str(case_no) +
" " 505 message = message +
"Not Connect(out->in, flush), Activate -> Deactivate" 506 message = message + g_mess_footer
507 fout.write(message +
'\n')
511 for i
in range(loop_count):
517 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
518 time.sleep(sleep_recv_act_time)
519 ec_send[0].activate_component(g_compo_send.rtc_ref)
521 time.sleep(sleep_act_time)
524 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
525 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
528 fout = open(g_test_result_file,
'a')
529 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
530 message = message + g_test_ok
532 fout.write(message +
'\n')
535 time.sleep(sleep_for_time)
540 case_no = case_no + 1
541 fout = open(g_test_result_file,
'a')
542 message = g_mess_header + g_test_case + str(case_no) +
" " 543 message = message +
"Connect(out->in, flush) -> Activate -> send/recv -> Deactivate -> Disconnect" 544 message = message + g_mess_footer
545 fout.write(message +
'\n')
549 for i
in range(loop_count):
559 ret0 = g_out_ports[g_port1].connect(g_conprof1)
562 ret1 = g_out_ports[g_port2].connect(g_conprof2)
565 ret2 = g_out_ports[g_port3].connect(g_conprof3)
568 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
569 time.sleep(sleep_recv_act_time)
570 ec_send[0].activate_component(g_compo_send.rtc_ref)
572 time.sleep(sleep_act_time)
575 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
576 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
579 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
580 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
581 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
584 if os.path.isfile(g_diff_recv_file) ==
False:
585 fout = open(g_test_result_file,
'a')
586 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
587 message = message + g_check_message
588 fout.write(message +
'\n')
591 time.sleep(sleep_for_time)
595 time.sleep(sleep_act_time)
599 fout = open(g_test_result_file,
'a')
600 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
604 message = message + g_test_ok
606 fout.write(message +
'\n')
609 message = message + g_test_ng
611 message = message + g_test_ng_message
612 fout.write(message +
'\n')
614 fin2 = open(g_diff_recv_file,
'r') 623 time.sleep(sleep_for_time)
628 case_no = case_no + 1
629 fout = open(g_test_result_file,
'a')
630 message = g_mess_header + g_test_case + str(case_no) +
" " 631 message = message +
"Connect(in->out, flush) -> Activate -> send/recv -> Deactivate -> Disconnect" 632 message = message + g_mess_footer
633 fout.write(message +
'\n')
637 for i
in range(loop_count):
647 ret0 = g_out_ports[g_port1].connect(g_conprof1)
650 ret1 = g_out_ports[g_port2].connect(g_conprof2)
653 ret2 = g_out_ports[g_port3].connect(g_conprof3)
656 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
657 time.sleep(sleep_recv_act_time)
658 ec_send[0].activate_component(g_compo_send.rtc_ref)
660 time.sleep(sleep_act_time)
663 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
664 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
667 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
668 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
669 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
672 if os.path.isfile(g_diff_recv_file) ==
False:
673 fout = open(g_test_result_file,
'a')
674 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
675 message = message + g_check_message
676 fout.write(message +
'\n')
679 time.sleep(sleep_for_time)
683 time.sleep(sleep_act_time)
687 fout = open(g_test_result_file,
'a')
688 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
692 message = message + g_test_ok
694 fout.write(message +
'\n')
697 message = message + g_test_ng
699 message = message + g_test_ng_message
700 fout.write(message +
'\n')
702 fin2 = open(g_diff_recv_file,
'r') 711 time.sleep(sleep_for_time)
716 case_no = case_no + 1
717 fout = open(g_test_result_file,
'a')
718 message = g_mess_header + g_test_case + str(case_no) +
" " 719 message = message +
"Connect(out->in, flush) -> Activate -> send/recv -> Disconnect -> Deactivate" 720 message = message + g_mess_footer
721 fout.write(message +
'\n')
725 for i
in range(loop_count):
735 ret0 = g_out_ports[g_port1].connect(g_conprof1)
738 ret1 = g_out_ports[g_port2].connect(g_conprof2)
741 ret2 = g_out_ports[g_port3].connect(g_conprof3)
744 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
745 time.sleep(sleep_recv_act_time)
746 ec_send[0].activate_component(g_compo_send.rtc_ref)
748 time.sleep(sleep_act_time)
751 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
752 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
753 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
756 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
757 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
760 if os.path.isfile(g_diff_recv_file) ==
False:
761 fout = open(g_test_result_file,
'a')
762 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
763 message = message + g_check_message
764 fout.write(message +
'\n')
767 time.sleep(sleep_for_time)
771 time.sleep(sleep_act_time)
775 fout = open(g_test_result_file,
'a')
776 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
780 message = message + g_test_ok
782 fout.write(message +
'\n')
785 message = message + g_test_ng
787 message = message + g_test_ng_message
788 fout.write(message +
'\n')
790 fin2 = open(g_diff_recv_file,
'r') 799 time.sleep(sleep_for_time)
804 case_no = case_no + 1
805 fout = open(g_test_result_file,
'a')
806 message = g_mess_header + g_test_case + str(case_no) +
" " 807 message = message +
"Connect(in->out, flush) -> Activate -> send/recv -> Disconnect -> Deactivate" 808 message = message + g_mess_footer
809 fout.write(message +
'\n')
813 for i
in range(loop_count):
823 ret0 = g_out_ports[g_port1].connect(g_conprof1)
826 ret1 = g_out_ports[g_port2].connect(g_conprof2)
829 ret2 = g_out_ports[g_port3].connect(g_conprof3)
832 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
833 time.sleep(sleep_recv_act_time)
834 ec_send[0].activate_component(g_compo_send.rtc_ref)
836 time.sleep(sleep_act_time)
839 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
840 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
841 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
844 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
845 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
848 if os.path.isfile(g_diff_recv_file) ==
False:
849 fout = open(g_test_result_file,
'a')
850 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
851 message = message + g_check_message
852 fout.write(message +
'\n')
855 time.sleep(sleep_for_time)
859 time.sleep(sleep_act_time)
863 fout = open(g_test_result_file,
'a')
864 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
868 message = message + g_test_ok
870 fout.write(message +
'\n')
873 message = message + g_test_ng
875 message = message + g_test_ng_message
876 fout.write(message +
'\n')
878 fin2 = open(g_diff_recv_file,
'r') 887 time.sleep(sleep_for_time)
894 case_no = case_no + 1
895 fout = open(g_test_result_file,
'a')
896 message = g_mess_header + g_test_case + str(case_no) +
" " 897 message = message +
"Activate -> Connect(out->in, flush) -> send/recv -> Deactivate -> Disconnect" 898 message = message + g_mess_footer
899 fout.write(message +
'\n')
903 for i
in range(loop_count):
912 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
913 time.sleep(sleep_recv_act_time)
914 ec_send[0].activate_component(g_compo_send.rtc_ref)
918 ret0 = g_out_ports[g_port1].connect(g_conprof1)
921 ret1 = g_out_ports[g_port2].connect(g_conprof2)
924 ret2 = g_out_ports[g_port3].connect(g_conprof3)
926 time.sleep(sleep_act_time)
929 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
930 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
933 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
934 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
935 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
938 if os.path.isfile(g_diff_recv_file) ==
False:
939 fout = open(g_test_result_file,
'a')
940 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
941 message = message + g_check_message
942 fout.write(message +
'\n')
945 time.sleep(sleep_for_time)
949 time.sleep(sleep_act_time)
953 fout = open(g_test_result_file,
'a')
954 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
958 message = message + g_test_ok
960 fout.write(message +
'\n')
963 message = message + g_test_ng
965 message = message + g_test_ng_message
966 fout.write(message +
'\n')
968 fin2 = open(g_diff_recv_file,
'r') 977 time.sleep(sleep_for_time)
983 case_no = case_no + 1
984 fout = open(g_test_result_file,
'a')
985 message = g_mess_header + g_test_case + str(case_no) +
" " 986 message = message +
"Activate -> Connect(in->out, flush) -> send/recv -> Deactivate -> Disconnect" 987 message = message + g_mess_footer
988 fout.write(message +
'\n')
992 for i
in range(loop_count):
1001 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1002 time.sleep(sleep_recv_act_time)
1003 ec_send[0].activate_component(g_compo_send.rtc_ref)
1007 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1010 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1013 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1015 time.sleep(sleep_act_time)
1018 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1019 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1022 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1023 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1024 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1027 if os.path.isfile(g_diff_recv_file) ==
False:
1028 fout = open(g_test_result_file,
'a')
1029 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1030 message = message + g_check_message
1031 fout.write(message +
'\n')
1034 time.sleep(sleep_for_time)
1038 time.sleep(sleep_act_time)
1042 fout = open(g_test_result_file,
'a')
1043 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1047 message = message + g_test_ok
1049 fout.write(message +
'\n')
1052 message = message + g_test_ng
1054 message = message + g_test_ng_message
1055 fout.write(message +
'\n')
1057 fin2 = open(g_diff_recv_file,
'r') 1059 s2 = fin2.readline() 1066 time.sleep(sleep_for_time)
1072 case_no = case_no + 1
1073 fout = open(g_test_result_file,
'a')
1074 message = g_mess_header + g_test_case + str(case_no) +
" " 1075 message = message +
"Activate -> Connect(out->in, flush) -> send/recv -> Disconnect -> Deactivate" 1076 message = message + g_mess_footer
1077 fout.write(message +
'\n')
1081 for i
in range(loop_count):
1090 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1091 time.sleep(sleep_recv_act_time)
1092 ec_send[0].activate_component(g_compo_send.rtc_ref)
1096 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1099 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1102 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1104 time.sleep(sleep_act_time)
1107 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1108 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1109 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1112 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1113 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1116 if os.path.isfile(g_diff_recv_file) ==
False:
1117 fout = open(g_test_result_file,
'a')
1118 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1119 message = message + g_check_message
1120 fout.write(message +
'\n')
1123 time.sleep(sleep_for_time)
1127 time.sleep(sleep_act_time)
1131 fout = open(g_test_result_file,
'a')
1132 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1136 message = message + g_test_ok
1138 fout.write(message +
'\n')
1141 message = message + g_test_ng
1143 message = message + g_test_ng_message
1144 fout.write(message +
'\n')
1146 fin2 = open(g_diff_recv_file,
'r') 1148 s2 = fin2.readline() 1155 time.sleep(sleep_for_time)
1161 case_no = case_no + 1
1162 fout = open(g_test_result_file,
'a')
1163 message = g_mess_header + g_test_case + str(case_no) +
" " 1164 message = message +
"Activate -> Connect(in->out, flush) -> send/recv -> Disconnect -> Deactivate" 1165 message = message + g_mess_footer
1166 fout.write(message +
'\n')
1170 for i
in range(loop_count):
1179 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1180 time.sleep(sleep_recv_act_time)
1181 ec_send[0].activate_component(g_compo_send.rtc_ref)
1185 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1188 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1191 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1193 time.sleep(sleep_act_time)
1196 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1197 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1198 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1201 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1202 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1205 if os.path.isfile(g_diff_recv_file) ==
False:
1206 fout = open(g_test_result_file,
'a')
1207 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1208 message = message + g_check_message
1209 fout.write(message +
'\n')
1212 time.sleep(sleep_for_time)
1216 time.sleep(sleep_act_time)
1220 fout = open(g_test_result_file,
'a')
1221 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1225 message = message + g_test_ok
1227 fout.write(message +
'\n')
1230 message = message + g_test_ng
1232 message = message + g_test_ng_message
1233 fout.write(message +
'\n')
1235 fin2 = open(g_diff_recv_file,
'r') 1237 s2 = fin2.readline() 1244 time.sleep(sleep_for_time)
1250 case_no = case_no + 1
1251 fout = open(g_test_result_file,
'a')
1252 message = g_mess_header + g_test_case + str(case_no) +
" " 1253 message = message +
"Connect(out->in, new,ALL) -> Disconnect" 1254 message = message + g_mess_footer
1255 fout.write(message +
'\n')
1259 for i
in range(loop_count):
1266 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1269 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1272 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1274 time.sleep(sleep_connect_time)
1277 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1278 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1279 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1282 fout = open(g_test_result_file,
'a')
1283 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1284 message = message + g_test_ok
1286 fout.write(message +
'\n')
1289 time.sleep(sleep_for_time)
1294 case_no = case_no + 1
1295 fout = open(g_test_result_file,
'a')
1296 message = g_mess_header + g_test_case + str(case_no) +
" " 1297 message = message +
"Connect(out->in, new,FIFO) -> Disconnect" 1298 message = message + g_mess_footer
1299 fout.write(message +
'\n')
1303 for i
in range(loop_count):
1310 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1313 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1316 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1318 time.sleep(sleep_connect_time)
1321 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1322 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1323 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1326 fout = open(g_test_result_file,
'a')
1327 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1328 message = message + g_test_ok
1330 fout.write(message +
'\n')
1333 time.sleep(sleep_for_time)
1338 case_no = case_no + 1
1339 fout = open(g_test_result_file,
'a')
1340 message = g_mess_header + g_test_case + str(case_no) +
" " 1341 message = message +
"Connect(out->in, new,NEW) -> Disconnect" 1342 message = message + g_mess_footer
1343 fout.write(message +
'\n')
1347 for i
in range(loop_count):
1354 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1357 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1360 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1362 time.sleep(sleep_connect_time)
1365 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1366 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1367 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1370 fout = open(g_test_result_file,
'a')
1371 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1372 message = message + g_test_ok
1374 fout.write(message +
'\n')
1377 time.sleep(sleep_for_time)
1382 case_no = case_no + 1
1383 fout = open(g_test_result_file,
'a')
1384 message = g_mess_header + g_test_case + str(case_no) +
" " 1385 message = message +
"Connect(out->in, new,SKIP) -> Disconnect" 1386 message = message + g_mess_footer
1387 fout.write(message +
'\n')
1391 for i
in range(loop_count):
1398 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1401 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1404 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1406 time.sleep(sleep_connect_time)
1409 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1410 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1411 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1414 fout = open(g_test_result_file,
'a')
1415 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1416 message = message + g_test_ok
1418 fout.write(message +
'\n')
1421 time.sleep(sleep_for_time)
1426 case_no = case_no + 1
1427 fout = open(g_test_result_file,
'a')
1428 message = g_mess_header + g_test_case + str(case_no) +
" " 1429 message = message +
"Connect(in->out, new,ALL) -> Disconnect" 1430 message = message + g_mess_footer
1431 fout.write(message +
'\n')
1435 for i
in range(loop_count):
1442 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1445 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1448 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1450 time.sleep(sleep_connect_time)
1453 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1454 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1455 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1458 fout = open(g_test_result_file,
'a')
1459 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1460 message = message + g_test_ok
1462 fout.write(message +
'\n')
1465 time.sleep(sleep_for_time)
1470 case_no = case_no + 1
1471 fout = open(g_test_result_file,
'a')
1472 message = g_mess_header + g_test_case + str(case_no) +
" " 1473 message = message +
"Connect(in->out, new,FIFO) -> Disconnect" 1474 message = message + g_mess_footer
1475 fout.write(message +
'\n')
1479 for i
in range(loop_count):
1486 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1489 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1492 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1494 time.sleep(sleep_connect_time)
1497 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1498 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1499 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1502 fout = open(g_test_result_file,
'a')
1503 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1504 message = message + g_test_ok
1506 fout.write(message +
'\n')
1509 time.sleep(sleep_for_time)
1514 case_no = case_no + 1
1515 fout = open(g_test_result_file,
'a')
1516 message = g_mess_header + g_test_case + str(case_no) +
" " 1517 message = message +
"Connect(in->out, new,NEW) -> Disconnect" 1518 message = message + g_mess_footer
1519 fout.write(message +
'\n')
1523 for i
in range(loop_count):
1530 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1533 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1536 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1538 time.sleep(sleep_connect_time)
1541 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1542 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1543 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1546 fout = open(g_test_result_file,
'a')
1547 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1548 message = message + g_test_ok
1550 fout.write(message +
'\n')
1553 time.sleep(sleep_for_time)
1558 case_no = case_no + 1
1559 fout = open(g_test_result_file,
'a')
1560 message = g_mess_header + g_test_case + str(case_no) +
" " 1561 message = message +
"Connect(in->out, new,SKIP) -> Disconnect" 1562 message = message + g_mess_footer
1563 fout.write(message +
'\n')
1567 for i
in range(loop_count):
1574 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1577 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1580 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1582 time.sleep(sleep_connect_time)
1585 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1586 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1587 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1590 fout = open(g_test_result_file,
'a')
1591 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1592 message = message + g_test_ok
1594 fout.write(message +
'\n')
1597 time.sleep(sleep_for_time)
1602 case_no = case_no + 1
1603 fout = open(g_test_result_file,
'a')
1604 message = g_mess_header + g_test_case + str(case_no) +
" " 1605 message = message +
"Connecting(out->in, new,ALL), Activate -> send/recv -> Deactivate" 1606 message = message + g_mess_footer
1607 fout.write(message +
'\n')
1616 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1619 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1622 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1624 for i
in range(loop_count):
1630 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1631 time.sleep(sleep_recv_act_time)
1632 ec_send[0].activate_component(g_compo_send.rtc_ref)
1634 time.sleep(sleep_act_time)
1637 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1638 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1641 if os.path.isfile(g_diff_recv_file) ==
False:
1642 fout = open(g_test_result_file,
'a')
1643 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1644 message = message + g_check_message
1645 fout.write(message +
'\n')
1648 time.sleep(sleep_for_time)
1652 time.sleep(sleep_act_time)
1656 fout = open(g_test_result_file,
'a')
1657 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1661 message = message + g_test_ok
1663 fout.write(message +
'\n')
1666 message = message + g_test_ng
1668 message = message + g_test_ng_message
1669 fout.write(message +
'\n')
1671 fin2 = open(g_diff_recv_file,
'r') 1673 s2 = fin2.readline() 1680 time.sleep(sleep_for_time)
1683 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1684 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1685 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1690 case_no = case_no + 1
1691 fout = open(g_test_result_file,
'a')
1692 message = g_mess_header + g_test_case + str(case_no) +
" " 1693 message = message +
"Connecting(out->in, new,FIFO), Activate -> send/recv -> Deactivate" 1694 message = message + g_mess_footer
1695 fout.write(message +
'\n')
1704 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1707 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1710 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1712 for i
in range(loop_count):
1718 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1719 time.sleep(sleep_recv_act_time)
1720 ec_send[0].activate_component(g_compo_send.rtc_ref)
1722 time.sleep(sleep_act_time)
1725 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1726 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1729 if os.path.isfile(g_diff_recv_file) ==
False:
1730 fout = open(g_test_result_file,
'a')
1731 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1732 message = message + g_check_message
1733 fout.write(message +
'\n')
1736 time.sleep(sleep_for_time)
1740 time.sleep(sleep_act_time)
1744 fout = open(g_test_result_file,
'a')
1745 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1749 message = message + g_test_ok
1751 fout.write(message +
'\n')
1754 message = message + g_test_ng
1756 message = message + g_test_ng_message
1757 fout.write(message +
'\n')
1759 fin2 = open(g_diff_recv_file,
'r') 1761 s2 = fin2.readline() 1768 time.sleep(sleep_for_time)
1771 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1772 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1773 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1778 case_no = case_no + 1
1779 fout = open(g_test_result_file,
'a')
1780 message = g_mess_header + g_test_case + str(case_no) +
" " 1781 message = message +
"Connecting(out->in, new,NEW), Activate -> send/recv -> Deactivate" 1782 message = message + g_mess_footer
1783 fout.write(message +
'\n')
1792 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1795 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1798 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1800 for i
in range(loop_count):
1806 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1807 time.sleep(sleep_recv_act_time)
1808 ec_send[0].activate_component(g_compo_send.rtc_ref)
1810 time.sleep(sleep_act_time)
1813 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1814 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1817 if os.path.isfile(g_diff_recv_file) ==
False:
1818 fout = open(g_test_result_file,
'a')
1819 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1820 message = message + g_check_message
1821 fout.write(message +
'\n')
1824 time.sleep(sleep_for_time)
1828 time.sleep(sleep_act_time)
1832 fout = open(g_test_result_file,
'a')
1833 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1837 message = message + g_test_ok
1839 fout.write(message +
'\n')
1842 message = message + g_test_ng
1844 message = message + g_test_ng_message
1845 fout.write(message +
'\n')
1847 fin2 = open(g_diff_recv_file,
'r') 1849 s2 = fin2.readline() 1856 time.sleep(sleep_for_time)
1859 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1860 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1861 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1866 case_no = case_no + 1
1867 fout = open(g_test_result_file,
'a')
1868 message = g_mess_header + g_test_case + str(case_no) +
" " 1869 message = message +
"Connecting(out->in, new,SKIP), Activate -> send/recv -> Deactivate" 1870 message = message + g_mess_footer
1871 fout.write(message +
'\n')
1880 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1883 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1886 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1888 for i
in range(loop_count):
1894 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1895 time.sleep(sleep_recv_act_time)
1896 ec_send[0].activate_component(g_compo_send.rtc_ref)
1898 time.sleep(sleep_act_time)
1901 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1902 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1905 if os.path.isfile(g_diff_recv_file) ==
False:
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
1908 message = message + g_check_message
1909 fout.write(message +
'\n')
1912 time.sleep(sleep_for_time)
1916 time.sleep(sleep_act_time)
1920 fout = open(g_test_result_file,
'a')
1921 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1925 message = message + g_test_ok
1927 fout.write(message +
'\n')
1930 message = message + g_test_ng
1932 message = message + g_test_ng_message
1933 fout.write(message +
'\n')
1935 fin2 = open(g_diff_recv_file,
'r') 1937 s2 = fin2.readline() 1944 time.sleep(sleep_for_time)
1947 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
1948 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
1949 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
1954 case_no = case_no + 1
1955 fout = open(g_test_result_file,
'a')
1956 message = g_mess_header + g_test_case + str(case_no) +
" " 1957 message = message +
"Connecting(in->out, new,ALL), Activate -> send/recv -> Deactivate" 1958 message = message + g_mess_footer
1959 fout.write(message +
'\n')
1968 ret0 = g_out_ports[g_port1].connect(g_conprof1)
1971 ret1 = g_out_ports[g_port2].connect(g_conprof2)
1974 ret2 = g_out_ports[g_port3].connect(g_conprof3)
1976 for i
in range(loop_count):
1982 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
1983 time.sleep(sleep_recv_act_time)
1984 ec_send[0].activate_component(g_compo_send.rtc_ref)
1986 time.sleep(sleep_act_time)
1989 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
1990 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
1993 if os.path.isfile(g_diff_recv_file) ==
False:
1994 fout = open(g_test_result_file,
'a')
1995 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
1996 message = message + g_check_message
1997 fout.write(message +
'\n')
2000 time.sleep(sleep_for_time)
2004 time.sleep(sleep_act_time)
2008 fout = open(g_test_result_file,
'a')
2009 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2013 message = message + g_test_ok
2015 fout.write(message +
'\n')
2018 message = message + g_test_ng
2020 message = message + g_test_ng_message
2021 fout.write(message +
'\n')
2023 fin2 = open(g_diff_recv_file,
'r') 2025 s2 = fin2.readline() 2032 time.sleep(sleep_for_time)
2035 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2036 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2037 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2042 case_no = case_no + 1
2043 fout = open(g_test_result_file,
'a')
2044 message = g_mess_header + g_test_case + str(case_no) +
" " 2045 message = message +
"Connecting(in->out, new,FIFO), Activate -> send/recv -> Deactivate" 2046 message = message + g_mess_footer
2047 fout.write(message +
'\n')
2056 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2059 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2062 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2064 for i
in range(loop_count):
2070 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2071 time.sleep(sleep_recv_act_time)
2072 ec_send[0].activate_component(g_compo_send.rtc_ref)
2074 time.sleep(sleep_act_time)
2077 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2078 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2081 if os.path.isfile(g_diff_recv_file) ==
False:
2082 fout = open(g_test_result_file,
'a')
2083 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2084 message = message + g_check_message
2085 fout.write(message +
'\n')
2088 time.sleep(sleep_for_time)
2092 time.sleep(sleep_act_time)
2096 fout = open(g_test_result_file,
'a')
2097 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2101 message = message + g_test_ok
2103 fout.write(message +
'\n')
2106 message = message + g_test_ng
2108 message = message + g_test_ng_message
2109 fout.write(message +
'\n')
2111 fin2 = open(g_diff_recv_file,
'r') 2113 s2 = fin2.readline() 2120 time.sleep(sleep_for_time)
2123 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2124 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2125 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2130 case_no = case_no + 1
2131 fout = open(g_test_result_file,
'a')
2132 message = g_mess_header + g_test_case + str(case_no) +
" " 2133 message = message +
"Connecting(in->out, new,NEW), Activate -> send/recv -> Deactivate" 2134 message = message + g_mess_footer
2135 fout.write(message +
'\n')
2144 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2147 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2150 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2152 for i
in range(loop_count):
2158 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2159 time.sleep(sleep_recv_act_time)
2160 ec_send[0].activate_component(g_compo_send.rtc_ref)
2162 time.sleep(sleep_act_time)
2165 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2166 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2169 if os.path.isfile(g_diff_recv_file) ==
False:
2170 fout = open(g_test_result_file,
'a')
2171 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2172 message = message + g_check_message
2173 fout.write(message +
'\n')
2176 time.sleep(sleep_for_time)
2180 time.sleep(sleep_act_time)
2184 fout = open(g_test_result_file,
'a')
2185 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2189 message = message + g_test_ok
2191 fout.write(message +
'\n')
2194 message = message + g_test_ng
2196 message = message + g_test_ng_message
2197 fout.write(message +
'\n')
2199 fin2 = open(g_diff_recv_file,
'r') 2201 s2 = fin2.readline() 2208 time.sleep(sleep_for_time)
2211 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2212 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2213 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2218 case_no = case_no + 1
2219 fout = open(g_test_result_file,
'a')
2220 message = g_mess_header + g_test_case + str(case_no) +
" " 2221 message = message +
"Connecting(in->out, new,SKIP), Activate -> send/recv -> Deactivate" 2222 message = message + g_mess_footer
2223 fout.write(message +
'\n')
2232 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2235 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2238 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2240 for i
in range(loop_count):
2246 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2247 time.sleep(sleep_recv_act_time)
2248 ec_send[0].activate_component(g_compo_send.rtc_ref)
2250 time.sleep(sleep_act_time)
2253 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2254 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2257 if os.path.isfile(g_diff_recv_file) ==
False:
2258 fout = open(g_test_result_file,
'a')
2259 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2260 message = message + g_check_message
2261 fout.write(message +
'\n')
2264 time.sleep(sleep_for_time)
2268 time.sleep(sleep_act_time)
2272 fout = open(g_test_result_file,
'a')
2273 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2277 message = message + g_test_ok
2279 fout.write(message +
'\n')
2282 message = message + g_test_ng
2284 message = message + g_test_ng_message
2285 fout.write(message +
'\n')
2287 fin2 = open(g_diff_recv_file,
'r') 2289 s2 = fin2.readline() 2296 time.sleep(sleep_for_time)
2299 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2300 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2301 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2306 case_no = case_no + 1
2307 fout = open(g_test_result_file,
'a')
2308 message = g_mess_header + g_test_case + str(case_no) +
" " 2309 message = message +
"Connect(out->in, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 2310 message = message + g_mess_footer
2311 fout.write(message +
'\n')
2315 for i
in range(loop_count):
2325 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2328 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2331 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2334 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2335 time.sleep(sleep_recv_act_time)
2336 ec_send[0].activate_component(g_compo_send.rtc_ref)
2338 time.sleep(sleep_act_time)
2341 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2342 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2345 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2346 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2347 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2350 if os.path.isfile(g_diff_recv_file) ==
False:
2351 fout = open(g_test_result_file,
'a')
2352 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2353 message = message + g_check_message
2354 fout.write(message +
'\n')
2357 time.sleep(sleep_for_time)
2361 time.sleep(sleep_act_time)
2365 fout = open(g_test_result_file,
'a')
2366 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2370 message = message + g_test_ok
2372 fout.write(message +
'\n')
2375 message = message + g_test_ng
2377 message = message + g_test_ng_message
2378 fout.write(message +
'\n')
2380 fin2 = open(g_diff_recv_file,
'r') 2382 s2 = fin2.readline() 2389 time.sleep(sleep_for_time)
2394 case_no = case_no + 1
2395 fout = open(g_test_result_file,
'a')
2396 message = g_mess_header + g_test_case + str(case_no) +
" " 2397 message = message +
"Connect(out->in, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 2398 message = message + g_mess_footer
2399 fout.write(message +
'\n')
2403 for i
in range(loop_count):
2413 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2416 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2419 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2422 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2423 time.sleep(sleep_recv_act_time)
2424 ec_send[0].activate_component(g_compo_send.rtc_ref)
2426 time.sleep(sleep_act_time)
2429 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2430 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2433 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2434 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2435 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2438 if os.path.isfile(g_diff_recv_file) ==
False:
2439 fout = open(g_test_result_file,
'a')
2440 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2441 message = message + g_check_message
2442 fout.write(message +
'\n')
2445 time.sleep(sleep_for_time)
2449 time.sleep(sleep_act_time)
2453 fout = open(g_test_result_file,
'a')
2454 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2458 message = message + g_test_ok
2460 fout.write(message +
'\n')
2463 message = message + g_test_ng
2465 message = message + g_test_ng_message
2466 fout.write(message +
'\n')
2468 fin2 = open(g_diff_recv_file,
'r') 2470 s2 = fin2.readline() 2477 time.sleep(sleep_for_time)
2482 case_no = case_no + 1
2483 fout = open(g_test_result_file,
'a')
2484 message = g_mess_header + g_test_case + str(case_no) +
" " 2485 message = message +
"Connect(out->in, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 2486 message = message + g_mess_footer
2487 fout.write(message +
'\n')
2491 for i
in range(loop_count):
2501 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2504 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2507 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2510 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2511 time.sleep(sleep_recv_act_time)
2512 ec_send[0].activate_component(g_compo_send.rtc_ref)
2514 time.sleep(sleep_act_time)
2517 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2518 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2521 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2522 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2523 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2526 if os.path.isfile(g_diff_recv_file) ==
False:
2527 fout = open(g_test_result_file,
'a')
2528 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2529 message = message + g_check_message
2530 fout.write(message +
'\n')
2533 time.sleep(sleep_for_time)
2537 time.sleep(sleep_act_time)
2541 fout = open(g_test_result_file,
'a')
2542 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2546 message = message + g_test_ok
2548 fout.write(message +
'\n')
2551 message = message + g_test_ng
2553 message = message + g_test_ng_message
2554 fout.write(message +
'\n')
2556 fin2 = open(g_diff_recv_file,
'r') 2558 s2 = fin2.readline() 2565 time.sleep(sleep_for_time)
2570 case_no = case_no + 1
2571 fout = open(g_test_result_file,
'a')
2572 message = g_mess_header + g_test_case + str(case_no) +
" " 2573 message = message +
"Connect(out->in, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 2574 message = message + g_mess_footer
2575 fout.write(message +
'\n')
2579 for i
in range(loop_count):
2589 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2592 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2595 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2598 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2599 time.sleep(sleep_recv_act_time)
2600 ec_send[0].activate_component(g_compo_send.rtc_ref)
2602 time.sleep(sleep_act_time)
2605 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2606 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2609 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2610 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2611 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2614 if os.path.isfile(g_diff_recv_file) ==
False:
2615 fout = open(g_test_result_file,
'a')
2616 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2617 message = message + g_check_message
2618 fout.write(message +
'\n')
2621 time.sleep(sleep_for_time)
2625 time.sleep(sleep_act_time)
2629 fout = open(g_test_result_file,
'a')
2630 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2634 message = message + g_test_ok
2636 fout.write(message +
'\n')
2639 message = message + g_test_ng
2641 message = message + g_test_ng_message
2642 fout.write(message +
'\n')
2644 fin2 = open(g_diff_recv_file,
'r') 2646 s2 = fin2.readline() 2653 time.sleep(sleep_for_time)
2658 case_no = case_no + 1
2659 fout = open(g_test_result_file,
'a')
2660 message = g_mess_header + g_test_case + str(case_no) +
" " 2661 message = message +
"Connect(in->out, new,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 2662 message = message + g_mess_footer
2663 fout.write(message +
'\n')
2667 for i
in range(loop_count):
2677 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2680 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2683 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2686 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2687 time.sleep(sleep_recv_act_time)
2688 ec_send[0].activate_component(g_compo_send.rtc_ref)
2690 time.sleep(sleep_act_time)
2693 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2694 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2697 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2698 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2699 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2702 if os.path.isfile(g_diff_recv_file) ==
False:
2703 fout = open(g_test_result_file,
'a')
2704 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2705 message = message + g_check_message
2706 fout.write(message +
'\n')
2709 time.sleep(sleep_for_time)
2713 time.sleep(sleep_act_time)
2717 fout = open(g_test_result_file,
'a')
2718 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2722 message = message + g_test_ok
2724 fout.write(message +
'\n')
2727 message = message + g_test_ng
2729 message = message + g_test_ng_message
2730 fout.write(message +
'\n')
2732 fin2 = open(g_diff_recv_file,
'r') 2734 s2 = fin2.readline() 2741 time.sleep(sleep_for_time)
2746 case_no = case_no + 1
2747 fout = open(g_test_result_file,
'a')
2748 message = g_mess_header + g_test_case + str(case_no) +
" " 2749 message = message +
"Connect(in->out, new,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 2750 message = message + g_mess_footer
2751 fout.write(message +
'\n')
2755 for i
in range(loop_count):
2765 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2768 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2771 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2774 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2775 time.sleep(sleep_recv_act_time)
2776 ec_send[0].activate_component(g_compo_send.rtc_ref)
2778 time.sleep(sleep_act_time)
2781 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2782 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2785 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2786 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2787 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2790 if os.path.isfile(g_diff_recv_file) ==
False:
2791 fout = open(g_test_result_file,
'a')
2792 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2793 message = message + g_check_message
2794 fout.write(message +
'\n')
2797 time.sleep(sleep_for_time)
2801 time.sleep(sleep_act_time)
2805 fout = open(g_test_result_file,
'a')
2806 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2810 message = message + g_test_ok
2812 fout.write(message +
'\n')
2815 message = message + g_test_ng
2817 message = message + g_test_ng_message
2818 fout.write(message +
'\n')
2820 fin2 = open(g_diff_recv_file,
'r') 2822 s2 = fin2.readline() 2829 time.sleep(sleep_for_time)
2834 case_no = case_no + 1
2835 fout = open(g_test_result_file,
'a')
2836 message = g_mess_header + g_test_case + str(case_no) +
" " 2837 message = message +
"Connect(in->out, new,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 2838 message = message + g_mess_footer
2839 fout.write(message +
'\n')
2843 for i
in range(loop_count):
2853 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2856 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2859 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2862 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2863 time.sleep(sleep_recv_act_time)
2864 ec_send[0].activate_component(g_compo_send.rtc_ref)
2866 time.sleep(sleep_act_time)
2869 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2870 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2873 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2874 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2875 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2878 if os.path.isfile(g_diff_recv_file) ==
False:
2879 fout = open(g_test_result_file,
'a')
2880 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2881 message = message + g_check_message
2882 fout.write(message +
'\n')
2885 time.sleep(sleep_for_time)
2889 time.sleep(sleep_act_time)
2893 fout = open(g_test_result_file,
'a')
2894 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2898 message = message + g_test_ok
2900 fout.write(message +
'\n')
2903 message = message + g_test_ng
2905 message = message + g_test_ng_message
2906 fout.write(message +
'\n')
2908 fin2 = open(g_diff_recv_file,
'r') 2910 s2 = fin2.readline() 2917 time.sleep(sleep_for_time)
2922 case_no = case_no + 1
2923 fout = open(g_test_result_file,
'a')
2924 message = g_mess_header + g_test_case + str(case_no) +
" " 2925 message = message +
"Connect(in->out, new,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 2926 message = message + g_mess_footer
2927 fout.write(message +
'\n')
2931 for i
in range(loop_count):
2941 ret0 = g_out_ports[g_port1].connect(g_conprof1)
2944 ret1 = g_out_ports[g_port2].connect(g_conprof2)
2947 ret2 = g_out_ports[g_port3].connect(g_conprof3)
2950 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
2951 time.sleep(sleep_recv_act_time)
2952 ec_send[0].activate_component(g_compo_send.rtc_ref)
2954 time.sleep(sleep_act_time)
2957 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
2958 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
2961 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
2962 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
2963 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
2966 if os.path.isfile(g_diff_recv_file) ==
False:
2967 fout = open(g_test_result_file,
'a')
2968 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2969 message = message + g_check_message
2970 fout.write(message +
'\n')
2973 time.sleep(sleep_for_time)
2977 time.sleep(sleep_act_time)
2981 fout = open(g_test_result_file,
'a')
2982 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
2986 message = message + g_test_ok
2988 fout.write(message +
'\n')
2991 message = message + g_test_ng
2993 message = message + g_test_ng_message
2994 fout.write(message +
'\n')
2996 fin2 = open(g_diff_recv_file,
'r') 2998 s2 = fin2.readline() 3005 time.sleep(sleep_for_time)
3011 case_no = case_no + 1
3012 fout = open(g_test_result_file,
'a')
3013 message = g_mess_header + g_test_case + str(case_no) +
" " 3014 message = message +
"Connect(out->in, periodic,ALL) -> Disconnect" 3015 message = message + g_mess_footer
3016 fout.write(message +
'\n')
3020 for i
in range(loop_count):
3027 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3030 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3033 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3035 time.sleep(sleep_connect_time)
3038 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3039 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3040 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3043 fout = open(g_test_result_file,
'a')
3044 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3045 message = message + g_test_ok
3047 fout.write(message +
'\n')
3050 time.sleep(sleep_for_time)
3055 case_no = case_no + 1
3056 fout = open(g_test_result_file,
'a')
3057 message = g_mess_header + g_test_case + str(case_no) +
" " 3058 message = message +
"Connect(out->in, periodic,FIFO) -> Disconnect" 3059 message = message + g_mess_footer
3060 fout.write(message +
'\n')
3064 for i
in range(loop_count):
3071 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3074 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3077 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3079 time.sleep(sleep_connect_time)
3082 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3083 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3084 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3087 fout = open(g_test_result_file,
'a')
3088 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3089 message = message + g_test_ok
3091 fout.write(message +
'\n')
3094 time.sleep(sleep_for_time)
3099 case_no = case_no + 1
3100 fout = open(g_test_result_file,
'a')
3101 message = g_mess_header + g_test_case + str(case_no) +
" " 3102 message = message +
"Connect(out->in, periodic,NEW) -> Disconnect" 3103 message = message + g_mess_footer
3104 fout.write(message +
'\n')
3108 for i
in range(loop_count):
3115 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3118 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3121 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3123 time.sleep(sleep_connect_time)
3126 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3127 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3128 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3131 fout = open(g_test_result_file,
'a')
3132 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3133 message = message + g_test_ok
3135 fout.write(message +
'\n')
3138 time.sleep(sleep_for_time)
3143 case_no = case_no + 1
3144 fout = open(g_test_result_file,
'a')
3145 message = g_mess_header + g_test_case + str(case_no) +
" " 3146 message = message +
"Connect(out->in, periodic,SKIP) -> Disconnect" 3147 message = message + g_mess_footer
3148 fout.write(message +
'\n')
3152 for i
in range(loop_count):
3159 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3162 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3165 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3167 time.sleep(sleep_connect_time)
3170 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3171 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3172 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3175 fout = open(g_test_result_file,
'a')
3176 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3177 message = message + g_test_ok
3179 fout.write(message +
'\n')
3182 time.sleep(sleep_for_time)
3187 case_no = case_no + 1
3188 fout = open(g_test_result_file,
'a')
3189 message = g_mess_header + g_test_case + str(case_no) +
" " 3190 message = message +
"Connect(in->out, periodic,ALL) -> Disconnect" 3191 message = message + g_mess_footer
3192 fout.write(message +
'\n')
3196 for i
in range(loop_count):
3203 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3206 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3209 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3211 time.sleep(sleep_connect_time)
3214 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3215 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3216 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3219 fout = open(g_test_result_file,
'a')
3220 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3221 message = message + g_test_ok
3223 fout.write(message +
'\n')
3226 time.sleep(sleep_for_time)
3231 case_no = case_no + 1
3232 fout = open(g_test_result_file,
'a')
3233 message = g_mess_header + g_test_case + str(case_no) +
" " 3234 message = message +
"Connect(in->out, periodic,FIFO) -> Disconnect" 3235 message = message + g_mess_footer
3236 fout.write(message +
'\n')
3240 for i
in range(loop_count):
3247 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3250 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3253 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3255 time.sleep(sleep_connect_time)
3258 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3259 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3260 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3263 fout = open(g_test_result_file,
'a')
3264 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3265 message = message + g_test_ok
3267 fout.write(message +
'\n')
3270 time.sleep(sleep_for_time)
3275 case_no = case_no + 1
3276 fout = open(g_test_result_file,
'a')
3277 message = g_mess_header + g_test_case + str(case_no) +
" " 3278 message = message +
"Connect(in->out, periodic,NEW) -> Disconnect" 3279 message = message + g_mess_footer
3280 fout.write(message +
'\n')
3284 for i
in range(loop_count):
3291 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3294 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3297 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3299 time.sleep(sleep_connect_time)
3302 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3303 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3304 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3307 fout = open(g_test_result_file,
'a')
3308 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3309 message = message + g_test_ok
3311 fout.write(message +
'\n')
3314 time.sleep(sleep_for_time)
3319 case_no = case_no + 1
3320 fout = open(g_test_result_file,
'a')
3321 message = g_mess_header + g_test_case + str(case_no) +
" " 3322 message = message +
"Connect(in->out, periodic,SKIP) -> Disconnect" 3323 message = message + g_mess_footer
3324 fout.write(message +
'\n')
3328 for i
in range(loop_count):
3335 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3338 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3341 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3343 time.sleep(sleep_connect_time)
3346 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3347 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3348 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3351 fout = open(g_test_result_file,
'a')
3352 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3353 message = message + g_test_ok
3355 fout.write(message +
'\n')
3358 time.sleep(sleep_for_time)
3363 case_no = case_no + 1
3364 fout = open(g_test_result_file,
'a')
3365 message = g_mess_header + g_test_case + str(case_no) +
" " 3366 message = message +
"Connecting(out->in, periodic,ALL), Activate -> send/recv -> Deactivate" 3367 message = message + g_mess_footer
3368 fout.write(message +
'\n')
3377 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3380 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3383 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3385 for i
in range(loop_count):
3391 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3392 time.sleep(sleep_recv_act_time)
3393 ec_send[0].activate_component(g_compo_send.rtc_ref)
3395 time.sleep(sleep_act_time)
3398 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3399 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3402 if os.path.isfile(g_diff_recv_file) ==
False:
3403 fout = open(g_test_result_file,
'a')
3404 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3405 message = message + g_check_message
3406 fout.write(message +
'\n')
3409 time.sleep(sleep_for_time)
3413 time.sleep(sleep_act_time)
3417 fout = open(g_test_result_file,
'a')
3418 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3422 message = message + g_test_ok
3424 fout.write(message +
'\n')
3427 message = message + g_test_ng
3429 message = message + g_test_ng_message
3430 fout.write(message +
'\n')
3432 fin2 = open(g_diff_recv_file,
'r') 3434 s2 = fin2.readline() 3441 time.sleep(sleep_for_time)
3444 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3445 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3446 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3451 case_no = case_no + 1
3452 fout = open(g_test_result_file,
'a')
3453 message = g_mess_header + g_test_case + str(case_no) +
" " 3454 message = message +
"Connecting(out->in, periodic,FIFO), Activate -> send/recv -> Deactivate" 3455 message = message + g_mess_footer
3456 fout.write(message +
'\n')
3465 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3468 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3471 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3473 for i
in range(loop_count):
3479 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3480 time.sleep(sleep_recv_act_time)
3481 ec_send[0].activate_component(g_compo_send.rtc_ref)
3483 time.sleep(sleep_act_time)
3486 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3487 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3490 if os.path.isfile(g_diff_recv_file) ==
False:
3491 fout = open(g_test_result_file,
'a')
3492 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3493 message = message + g_check_message
3494 fout.write(message +
'\n')
3497 time.sleep(sleep_for_time)
3501 time.sleep(sleep_act_time)
3505 fout = open(g_test_result_file,
'a')
3506 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3510 message = message + g_test_ok
3512 fout.write(message +
'\n')
3515 message = message + g_test_ng
3517 message = message + g_test_ng_message
3518 fout.write(message +
'\n')
3520 fin2 = open(g_diff_recv_file,
'r') 3522 s2 = fin2.readline() 3529 time.sleep(sleep_for_time)
3532 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3533 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3534 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3539 case_no = case_no + 1
3540 fout = open(g_test_result_file,
'a')
3541 message = g_mess_header + g_test_case + str(case_no) +
" " 3542 message = message +
"Connecting(out->in, periodic,NEW), Activate -> send/recv -> Deactivate" 3543 message = message + g_mess_footer
3544 fout.write(message +
'\n')
3553 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3556 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3559 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3561 for i
in range(loop_count):
3567 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3568 time.sleep(sleep_recv_act_time)
3569 ec_send[0].activate_component(g_compo_send.rtc_ref)
3571 time.sleep(sleep_act_time)
3574 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3575 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3578 if os.path.isfile(g_diff_recv_file) ==
False:
3579 fout = open(g_test_result_file,
'a')
3580 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3581 message = message + g_check_message
3582 fout.write(message +
'\n')
3585 time.sleep(sleep_for_time)
3589 time.sleep(sleep_act_time)
3593 fout = open(g_test_result_file,
'a')
3594 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3598 message = message + g_test_ok
3600 fout.write(message +
'\n')
3603 message = message + g_test_ng
3605 message = message + g_test_ng_message
3606 fout.write(message +
'\n')
3608 fin2 = open(g_diff_recv_file,
'r') 3610 s2 = fin2.readline() 3617 time.sleep(sleep_for_time)
3620 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3621 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3622 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3627 case_no = case_no + 1
3628 fout = open(g_test_result_file,
'a')
3629 message = g_mess_header + g_test_case + str(case_no) +
" " 3630 message = message +
"Connecting(out->in, periodic,SKIP), Activate -> send/recv -> Deactivate" 3631 message = message + g_mess_footer
3632 fout.write(message +
'\n')
3641 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3644 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3647 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3649 for i
in range(loop_count):
3655 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3656 time.sleep(sleep_recv_act_time)
3657 ec_send[0].activate_component(g_compo_send.rtc_ref)
3659 time.sleep(sleep_act_time)
3662 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3663 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3666 if os.path.isfile(g_diff_recv_file) ==
False:
3667 fout = open(g_test_result_file,
'a')
3668 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3669 message = message + g_check_message
3670 fout.write(message +
'\n')
3673 time.sleep(sleep_for_time)
3677 time.sleep(sleep_act_time)
3681 fout = open(g_test_result_file,
'a')
3682 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3686 message = message + g_test_ok
3688 fout.write(message +
'\n')
3691 message = message + g_test_ng
3693 message = message + g_test_ng_message
3694 fout.write(message +
'\n')
3696 fin2 = open(g_diff_recv_file,
'r') 3698 s2 = fin2.readline() 3705 time.sleep(sleep_for_time)
3708 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3709 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3710 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3715 case_no = case_no + 1
3716 fout = open(g_test_result_file,
'a')
3717 message = g_mess_header + g_test_case + str(case_no) +
" " 3718 message = message +
"Connecting(in->out, periodic,ALL), Activate -> send/recv -> Deactivate" 3719 message = message + g_mess_footer
3720 fout.write(message +
'\n')
3729 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3732 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3735 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3737 for i
in range(loop_count):
3743 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3744 time.sleep(sleep_recv_act_time)
3745 ec_send[0].activate_component(g_compo_send.rtc_ref)
3747 time.sleep(sleep_act_time)
3750 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3751 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3754 if os.path.isfile(g_diff_recv_file) ==
False:
3755 fout = open(g_test_result_file,
'a')
3756 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3757 message = message + g_check_message
3758 fout.write(message +
'\n')
3761 time.sleep(sleep_for_time)
3765 time.sleep(sleep_act_time)
3769 fout = open(g_test_result_file,
'a')
3770 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3774 message = message + g_test_ok
3776 fout.write(message +
'\n')
3779 message = message + g_test_ng
3781 message = message + g_test_ng_message
3782 fout.write(message +
'\n')
3784 fin2 = open(g_diff_recv_file,
'r') 3786 s2 = fin2.readline() 3793 time.sleep(sleep_for_time)
3796 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3797 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3798 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3803 case_no = case_no + 1
3804 fout = open(g_test_result_file,
'a')
3805 message = g_mess_header + g_test_case + str(case_no) +
" " 3806 message = message +
"Connecting(in->out, periodic,FIFO), Activate -> send/recv -> Deactivate" 3807 message = message + g_mess_footer
3808 fout.write(message +
'\n')
3817 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3820 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3823 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3825 for i
in range(loop_count):
3831 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3832 time.sleep(sleep_recv_act_time)
3833 ec_send[0].activate_component(g_compo_send.rtc_ref)
3835 time.sleep(sleep_act_time)
3838 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3839 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3842 if os.path.isfile(g_diff_recv_file) ==
False:
3843 fout = open(g_test_result_file,
'a')
3844 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3845 message = message + g_check_message
3846 fout.write(message +
'\n')
3849 time.sleep(sleep_for_time)
3853 time.sleep(sleep_act_time)
3857 fout = open(g_test_result_file,
'a')
3858 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3862 message = message + g_test_ok
3864 fout.write(message +
'\n')
3867 message = message + g_test_ng
3869 message = message + g_test_ng_message
3870 fout.write(message +
'\n')
3872 fin2 = open(g_diff_recv_file,
'r') 3874 s2 = fin2.readline() 3881 time.sleep(sleep_for_time)
3884 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3885 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3886 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3891 case_no = case_no + 1
3892 fout = open(g_test_result_file,
'a')
3893 message = g_mess_header + g_test_case + str(case_no) +
" " 3894 message = message +
"Connecting(in->out, periodic,NEW), Activate -> send/recv -> Deactivate" 3895 message = message + g_mess_footer
3896 fout.write(message +
'\n')
3905 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3908 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3911 ret2 = g_out_ports[g_port3].connect(g_conprof3)
3913 for i
in range(loop_count):
3919 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
3920 time.sleep(sleep_recv_act_time)
3921 ec_send[0].activate_component(g_compo_send.rtc_ref)
3923 time.sleep(sleep_act_time)
3926 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
3927 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
3930 if os.path.isfile(g_diff_recv_file) ==
False:
3931 fout = open(g_test_result_file,
'a')
3932 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3933 message = message + g_check_message
3934 fout.write(message +
'\n')
3937 time.sleep(sleep_for_time)
3941 time.sleep(sleep_act_time)
3945 fout = open(g_test_result_file,
'a')
3946 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
3950 message = message + g_test_ok
3952 fout.write(message +
'\n')
3955 message = message + g_test_ng
3957 message = message + g_test_ng_message
3958 fout.write(message +
'\n')
3960 fin2 = open(g_diff_recv_file,
'r') 3962 s2 = fin2.readline() 3969 time.sleep(sleep_for_time)
3972 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
3973 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
3974 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
3979 case_no = case_no + 1
3980 fout = open(g_test_result_file,
'a')
3981 message = g_mess_header + g_test_case + str(case_no) +
" " 3982 message = message +
"Connecting(in->out, periodic,SKIP), Activate -> send/recv -> Deactivate" 3983 message = message + g_mess_footer
3984 fout.write(message +
'\n')
3993 ret0 = g_out_ports[g_port1].connect(g_conprof1)
3996 ret1 = g_out_ports[g_port2].connect(g_conprof2)
3999 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4001 for i
in range(loop_count):
4007 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4008 time.sleep(sleep_recv_act_time)
4009 ec_send[0].activate_component(g_compo_send.rtc_ref)
4011 time.sleep(sleep_act_time)
4014 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4015 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4018 if os.path.isfile(g_diff_recv_file) ==
False:
4019 fout = open(g_test_result_file,
'a')
4020 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4021 message = message + g_check_message
4022 fout.write(message +
'\n')
4025 time.sleep(sleep_for_time)
4029 time.sleep(sleep_act_time)
4033 fout = open(g_test_result_file,
'a')
4034 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4038 message = message + g_test_ok
4040 fout.write(message +
'\n')
4043 message = message + g_test_ng
4045 message = message + g_test_ng_message
4046 fout.write(message +
'\n')
4048 fin2 = open(g_diff_recv_file,
'r') 4050 s2 = fin2.readline() 4057 time.sleep(sleep_for_time)
4060 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4061 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4062 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4067 case_no = case_no + 1
4068 fout = open(g_test_result_file,
'a')
4069 message = g_mess_header + g_test_case + str(case_no) +
" " 4070 message = message +
"Connect(out->in, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 4071 message = message + g_mess_footer
4072 fout.write(message +
'\n')
4076 for i
in range(loop_count):
4086 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4089 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4092 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4095 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4096 time.sleep(sleep_recv_act_time)
4097 ec_send[0].activate_component(g_compo_send.rtc_ref)
4099 time.sleep(sleep_act_time)
4102 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4103 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4106 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4107 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4108 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4111 if os.path.isfile(g_diff_recv_file) ==
False:
4112 fout = open(g_test_result_file,
'a')
4113 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4114 message = message + g_check_message
4115 fout.write(message +
'\n')
4118 time.sleep(sleep_for_time)
4122 time.sleep(sleep_act_time)
4126 fout = open(g_test_result_file,
'a')
4127 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4131 message = message + g_test_ok
4133 fout.write(message +
'\n')
4136 message = message + g_test_ng
4138 message = message + g_test_ng_message
4139 fout.write(message +
'\n')
4141 fin2 = open(g_diff_recv_file,
'r') 4143 s2 = fin2.readline() 4150 time.sleep(sleep_for_time)
4155 case_no = case_no + 1
4156 fout = open(g_test_result_file,
'a')
4157 message = g_mess_header + g_test_case + str(case_no) +
" " 4158 message = message +
"Connect(out->in, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 4159 message = message + g_mess_footer
4160 fout.write(message +
'\n')
4164 for i
in range(loop_count):
4174 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4177 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4180 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4183 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4184 time.sleep(sleep_recv_act_time)
4185 ec_send[0].activate_component(g_compo_send.rtc_ref)
4187 time.sleep(sleep_act_time)
4190 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4191 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4194 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4195 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4196 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4199 if os.path.isfile(g_diff_recv_file) ==
False:
4200 fout = open(g_test_result_file,
'a')
4201 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4202 message = message + g_check_message
4203 fout.write(message +
'\n')
4206 time.sleep(sleep_for_time)
4210 time.sleep(sleep_act_time)
4214 fout = open(g_test_result_file,
'a')
4215 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4219 message = message + g_test_ok
4221 fout.write(message +
'\n')
4224 message = message + g_test_ng
4226 message = message + g_test_ng_message
4227 fout.write(message +
'\n')
4229 fin2 = open(g_diff_recv_file,
'r') 4231 s2 = fin2.readline() 4238 time.sleep(sleep_for_time)
4243 case_no = case_no + 1
4244 fout = open(g_test_result_file,
'a')
4245 message = g_mess_header + g_test_case + str(case_no) +
" " 4246 message = message +
"Connect(out->in, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 4247 message = message + g_mess_footer
4248 fout.write(message +
'\n')
4252 for i
in range(loop_count):
4262 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4265 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4268 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4271 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4272 time.sleep(sleep_recv_act_time)
4273 ec_send[0].activate_component(g_compo_send.rtc_ref)
4275 time.sleep(sleep_act_time)
4278 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4279 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4282 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4283 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4284 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4287 if os.path.isfile(g_diff_recv_file) ==
False:
4288 fout = open(g_test_result_file,
'a')
4289 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4290 message = message + g_check_message
4291 fout.write(message +
'\n')
4294 time.sleep(sleep_for_time)
4298 time.sleep(sleep_act_time)
4302 fout = open(g_test_result_file,
'a')
4303 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4307 message = message + g_test_ok
4309 fout.write(message +
'\n')
4312 message = message + g_test_ng
4314 message = message + g_test_ng_message
4315 fout.write(message +
'\n')
4317 fin2 = open(g_diff_recv_file,
'r') 4319 s2 = fin2.readline() 4326 time.sleep(sleep_for_time)
4331 case_no = case_no + 1
4332 fout = open(g_test_result_file,
'a')
4333 message = g_mess_header + g_test_case + str(case_no) +
" " 4334 message = message +
"Connect(out->in, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 4335 message = message + g_mess_footer
4336 fout.write(message +
'\n')
4340 for i
in range(loop_count):
4350 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4353 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4356 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4359 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4360 time.sleep(sleep_recv_act_time)
4361 ec_send[0].activate_component(g_compo_send.rtc_ref)
4363 time.sleep(sleep_act_time)
4366 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4367 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4370 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4371 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4372 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4375 if os.path.isfile(g_diff_recv_file) ==
False:
4376 fout = open(g_test_result_file,
'a')
4377 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4378 message = message + g_check_message
4379 fout.write(message +
'\n')
4382 time.sleep(sleep_for_time)
4386 time.sleep(sleep_act_time)
4390 fout = open(g_test_result_file,
'a')
4391 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4395 message = message + g_test_ok
4397 fout.write(message +
'\n')
4400 message = message + g_test_ng
4402 message = message + g_test_ng_message
4403 fout.write(message +
'\n')
4405 fin2 = open(g_diff_recv_file,
'r') 4407 s2 = fin2.readline() 4414 time.sleep(sleep_for_time)
4419 case_no = case_no + 1
4420 fout = open(g_test_result_file,
'a')
4421 message = g_mess_header + g_test_case + str(case_no) +
" " 4422 message = message +
"Connect(in->out, periodic,ALL) -> Activate -> send/recv -> Deactivate -> Disconnect" 4423 message = message + g_mess_footer
4424 fout.write(message +
'\n')
4428 for i
in range(loop_count):
4438 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4441 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4444 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4447 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4448 time.sleep(sleep_recv_act_time)
4449 ec_send[0].activate_component(g_compo_send.rtc_ref)
4451 time.sleep(sleep_act_time)
4454 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4455 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4458 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4459 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4460 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4463 if os.path.isfile(g_diff_recv_file) ==
False:
4464 fout = open(g_test_result_file,
'a')
4465 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4466 message = message + g_check_message
4467 fout.write(message +
'\n')
4470 time.sleep(sleep_for_time)
4474 time.sleep(sleep_act_time)
4478 fout = open(g_test_result_file,
'a')
4479 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4483 message = message + g_test_ok
4485 fout.write(message +
'\n')
4488 message = message + g_test_ng
4490 message = message + g_test_ng_message
4491 fout.write(message +
'\n')
4493 fin2 = open(g_diff_recv_file,
'r') 4495 s2 = fin2.readline() 4502 time.sleep(sleep_for_time)
4507 case_no = case_no + 1
4508 fout = open(g_test_result_file,
'a')
4509 message = g_mess_header + g_test_case + str(case_no) +
" " 4510 message = message +
"Connect(in->out, periodic,FIFO) -> Activate -> send/recv -> Deactivate -> Disconnect" 4511 message = message + g_mess_footer
4512 fout.write(message +
'\n')
4516 for i
in range(loop_count):
4526 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4529 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4532 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4535 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4536 time.sleep(sleep_recv_act_time)
4537 ec_send[0].activate_component(g_compo_send.rtc_ref)
4539 time.sleep(sleep_act_time)
4542 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4543 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4546 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4547 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4548 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4551 if os.path.isfile(g_diff_recv_file) ==
False:
4552 fout = open(g_test_result_file,
'a')
4553 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4554 message = message + g_check_message
4555 fout.write(message +
'\n')
4558 time.sleep(sleep_for_time)
4562 time.sleep(sleep_act_time)
4566 fout = open(g_test_result_file,
'a')
4567 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4571 message = message + g_test_ok
4573 fout.write(message +
'\n')
4576 message = message + g_test_ng
4578 message = message + g_test_ng_message
4579 fout.write(message +
'\n')
4581 fin2 = open(g_diff_recv_file,
'r') 4583 s2 = fin2.readline() 4590 time.sleep(sleep_for_time)
4595 case_no = case_no + 1
4596 fout = open(g_test_result_file,
'a')
4597 message = g_mess_header + g_test_case + str(case_no) +
" " 4598 message = message +
"Connect(in->out, periodic,NEW) -> Activate -> send/recv -> Deactivate -> Disconnect" 4599 message = message + g_mess_footer
4600 fout.write(message +
'\n')
4604 for i
in range(loop_count):
4614 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4617 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4620 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4623 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4624 time.sleep(sleep_recv_act_time)
4625 ec_send[0].activate_component(g_compo_send.rtc_ref)
4627 time.sleep(sleep_act_time)
4630 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4631 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4634 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4635 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4636 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4639 if os.path.isfile(g_diff_recv_file) ==
False:
4640 fout = open(g_test_result_file,
'a')
4641 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4642 message = message + g_check_message
4643 fout.write(message +
'\n')
4646 time.sleep(sleep_for_time)
4650 time.sleep(sleep_act_time)
4654 fout = open(g_test_result_file,
'a')
4655 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4659 message = message + g_test_ok
4661 fout.write(message +
'\n')
4664 message = message + g_test_ng
4666 message = message + g_test_ng_message
4667 fout.write(message +
'\n')
4669 fin2 = open(g_diff_recv_file,
'r') 4671 s2 = fin2.readline() 4678 time.sleep(sleep_for_time)
4683 case_no = case_no + 1
4684 fout = open(g_test_result_file,
'a')
4685 message = g_mess_header + g_test_case + str(case_no) +
" " 4686 message = message +
"Connect(in->out, periodic,SKIP) -> Activate -> send/recv -> Deactivate -> Disconnect" 4687 message = message + g_mess_footer
4688 fout.write(message +
'\n')
4692 for i
in range(loop_count):
4702 ret0 = g_out_ports[g_port1].connect(g_conprof1)
4705 ret1 = g_out_ports[g_port2].connect(g_conprof2)
4708 ret2 = g_out_ports[g_port3].connect(g_conprof3)
4711 ec_recv[0].activate_component(g_compo_recv.rtc_ref)
4712 time.sleep(sleep_recv_act_time)
4713 ec_send[0].activate_component(g_compo_send.rtc_ref)
4715 time.sleep(sleep_act_time)
4718 ec_send[0].deactivate_component(g_compo_send.rtc_ref)
4719 ec_recv[0].deactivate_component(g_compo_recv.rtc_ref)
4722 g_in_ports[g_port3].disconnect(g_conprof3.connector_id)
4723 g_in_ports[g_port2].disconnect(g_conprof2.connector_id)
4724 g_in_ports[g_port1].disconnect(g_conprof1.connector_id)
4727 if os.path.isfile(g_diff_recv_file) ==
False:
4728 fout = open(g_test_result_file,
'a')
4729 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4730 message = message + g_check_message
4731 fout.write(message +
'\n')
4734 time.sleep(sleep_for_time)
4738 time.sleep(sleep_act_time)
4742 fout = open(g_test_result_file,
'a')
4743 message = g_mess_header + g_test_case + str(case_no) +
" " + g_test_cnt + str(i+1) + g_mess_footer
4747 message = message + g_test_ok
4749 fout.write(message +
'\n')
4752 message = message + g_test_ng
4754 message = message + g_test_ng_message
4755 fout.write(message +
'\n')
4757 fin2 = open(g_diff_recv_file,
'r') 4759 s2 = fin2.readline() 4766 time.sleep(sleep_for_time)
4768 print "Test Complete."
def make_connecter_profile(subscription_type, push_policy, connect_direction)
内部関数:コネクタープロファイル設定(データポート)
def delete_recv_file()
内部関数:受信ファイル削除
def diff_file()
内部関数:送受信ファイルのデータ比較