test_python_multiout.py 文件源码

def setUp(self):
        self.setContext()
        if self.srcData:
            self.seq = self.srcData
        else:
            self.seq = range(100)

        self.orb = CORBA.ORB_init();
        self.rootPOA = self.orb.resolve_initial_references("RootPOA")
        self.logger = logging.getLogger(self.ptype[0])
        self.logger.setLevel(logging.NOTSET)
        self.logger.info( "Setup - Multiout Create Ports Table " );

        self.ip1 = bulkio.InFloatPort("sink_1", self.logger );
        self.ip1_oid = self.rootPOA.activate_object(self.ip1);
        self.ip2 = bulkio.InFloatPort("sink_2", self.logger );
        self.ip2_oid = self.rootPOA.activate_object(self.ip2);
        self.ip3 = bulkio.InFloatPort("sink_3", self.logger );
        self.ip3_oid = self.rootPOA.activate_object(self.ip3);
        self.ip4 = bulkio.InFloatPort("sink_4", self.logger );
        self.ip4_oid = self.rootPOA.activate_object(self.ip4);
        self.port = bulkio.OutFloatPort("multiout_source", self.logger );
        self.port_oid = self.rootPOA.activate_object(self.port);

        self.desc_list=[];
        self.logger.info( "Setup - Multiout Connection Table " );
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_1", stream_id="stream-1-1" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_1", stream_id="stream-1-2" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_1", stream_id="stream-1-3" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_2", stream_id="stream-2-1" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_2", stream_id="stream-2-2" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_2", stream_id="stream-2-3" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_3", stream_id="stream-3-1" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_3", stream_id="stream-3-2" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_3", stream_id="stream-3-3" ) )
        self.desc_list.append( bulkio.connection_descriptor_struct( port_name="multiout_source", connection_id="connection_4", stream_id="stream-4-1" ) )