Method create_sync_module

bmf/builder/bmf_node.py:204–244

(self)

        print('no output stream')

    def create_sync_module(self):
        from bmf.lib._bmf import engine
        node_option = json.dumps(self.option_)

        # convert node option for filter
        if self.module_info_["name"] == "c_ffmpeg_filter":
            node_config = self.get_graph().generate_node_config(self)
            node_option = engine.convert_filter_para(node_config.dump())

        # create module
        mod = engine.Module(self.module_info_["name"], node_option,
                            self.module_info_["type"],
                            self.module_info_["path"],
                            self.module_info_["entry"])

        # input stream list
        input_stream_id = []
        if self.module_info_[
                "name"] == "c_ffmpeg_encoder" and 1 in self.get_input_streams(
                ).keys():
            input_stream_id.append(0)
            input_stream_id.append(1)
        else:
            for id in self.get_input_streams().keys():
                input_stream_id.append(id)

        # output stream list
        output_stream_id = []
        if self.module_info_["name"] == "c_ffmpeg_decoder":
            for key in self.get_output_streams().keys():
                if key == "video":
                    output_stream_id.append(0)
                elif key == "audio":
                    output_stream_id.append(1)
        else:
            for id in self.get_output_streams().keys():
                output_stream_id.append(id)

        # create sync module
        sync_module = SyncModule(mod, input_stream_id, output_stream_id)
        return sync_module