System for emulating multi-tasking pipelines in a single tasking environment

A control system for operating a single application processing computer to simulate a multi-application processing computer, comprising:

• a single application processing processor;
• a memory;
• a host application comprising a first control means for operating the processor;
• and
• a data processing pipeline comprising a plurality of linked pipeline sections stored in the memory, each pipeline section comprising second control means for operating the processor, each pipeline section further comprising a plurality of data buffers, data defining a current state of the pipeline section, a process pointer for linking the pipeline section to another pipeline section, and data defining a processing operation;
• wherein, when the host application requests data from the data processing pipeline, the data request is passed up the pipeline from section to section until the data request is passed to a first pipeline section, the first pipeline section receiving data from a data source, processing the data, and providing the processed data to an adjacent downstream pipeline section, and wherein each of the intermediate pipeline sections processes the provided data and provides the processed data to the adjacent downstream pipeline section until the processed data is provided to the host application;
• wherein each pipeline section controls the processor to accomplish its data processing so that the single application processing computer simulates a multi-application processing computer;
• and
• wherein the host application creates the data processing pipeline before requesting data from the pipeline by instantiating data processing functions to form the plurality of linked pipeline sections.

A control means for pipeline data processing in a single application processing environment, comprising:

• a memory;
• a single application processing processor;
• function library means for storing data processing functions;
• and
• a controller for controlling the processor, the controller comprising:
• memory management means for allocating and deallocating memory blocks of the memory;
• host application means for operating the processor in a single application environment;
• and
• a data processing pipeline, the pipeline comprising a first task means and at least one additional task means for operating the processor to process data, the pipeline obtaining data from a data source, processing the obtained data, and providing processed data to the host application means, one end of the pipeline being linked to the host application means;
• wherein the host application means comprises:
• instantiating means for creating the data processing pipeline by instantiating the data processing functions stored in the function library means to form the plurality of task means, each task means of the pipeline being stored in a memory block of the memory, and
• invoking means for invoking the data processing pipeline after the instantiating means has created the pipeline by requesting data from the task means of the pipeline linked to the host application means, each of the additional task means requesting data from an immediately upstream task of the pipeline until the request for data reaches the first task means of the pipeline, the first task means obtaining or generating data and passing the data to the immediately downstream task means, each of the additional task means processing the data and passing the processed data to an immediately downstream task means until the last task means processes the data and passes it to the host application means;
• and
• wherein each of the plurality of linked task means of the pipeline controls the processor to accomplish data processing and comprises:
• link means for linking at least two task means together,
• at least one channel means for passing data between linked task means,
• data processing means for processing data received via each at least one channel means, and
• task state means for controlling the task means;
• and
• wherein the data processing pipeline is created by the host application means before the invoking means of the host application means invokes the data processing pipeline.

A control system for pipelined data processing in a single application environment, comprising:

• a memory;
• a single application processor;
• function library means for storing data processing functions;
• and
• a controller, comprising:
• memory management means for allocating and deallocating memory blocks of the memory,
• a data processing pipeline comprising a most downstream task means, a most upstream task means, and at least one intermediate task means, each of the task means operating the processor to process data, each of the task means being stored in the memory, and
• host application means for operating the processor and comprising:
• instantiating means for instantiating data processing functions stored in the function library means to form the data processing pipeline of task means, and
• invoking means for invoking the data processing pipeline, the invoking means requesting data from the most downstream task means in the pipeline, each intermediate task means requesting data from an immediately upstream task means until the data request reaches the most upstream task means, the most upstream task means responding to the data request by obtaining or generating data and passing it to an immediately downstream task means, each intermediate task means processing data passed to it and passing the processed data to an immediately downstream task means until the most downstream task means passes the processed data to the host application;
• and
• wherein each task means comprises:
• at least one channel means for passing data between linked task means,
• link means for linking corresponding channel means of the at least one channel means of a pair of task means,
• data processing means for processing data received via each at least one channel means,
• task state means for controlling the task means, and
• error code generating means for indicating whether the task means has successfully obtained and processed the data;
• wherein the instantiating means instantiates a data processing pipeline before the invoking means invokes the data processing pipeline.

A method of creating and operating a data processing pipeline of linked data processing tasks in a single application processing environment that simulates a data processing pipeline of a multiprocessing environment, the data processing pipeline receiving data from a data source, processing the received data, and providing processed data to the host application, the method comprising the steps of:

• running a host application on a single application processor;
• creating a data processing pipeline of linked data processing tasks;
• and
• operating the data processing pipeline to provide processed data to the host application;
• wherein the step of creating the data processing pipeline comprises the steps of:
• instantiating a first data processing task for receiving data from a data source, and providing processed data to one of a downstream task in the pipeline and the host application,
• determining if the data that will be provided by the first task requires additional processing before it can be used by the host application, and
• instantiating at least one additional data processing task for further processing the processed data provided by the first task when the processed data provided by the first task requires additional processing before it can be used by the host application, each at least one additional task being linked to at least one of an upstream task of the pipeline, a downstream task in the pipeline and the host application, the host application being linked to the last instantiated task,
• wherein the first data processing task and the at least one additional task are stored in a memory and each comprise:
• state defining means for defining the state of the task,
• at least one data processing channel,
• means for accessing a data processing function stored in a memory, and
• link means for linking the task to at least one of an upstream task in the pipeline, a downstream task in the pipeline and the host application;
• and
• wherein the step of operating the data processing pipeline comprises the steps of:
• requesting data from the last instantiated task by the host application, each task in the pipeline in turn requesting data from a next upstream task until the data request is received by the first task,
• receiving data from a data source in the first task,
• the first task providing data to one of a next downstream task in the pipeline and the host application,
• processing received data in at least one additional task, each at least one additional task providing processed data to one of a next downstream task in the pipeline and the host application when the at least one additional task has been instantiated, and
• receiving processed data at the host application from the last instantiated task;
• wherein each of the tasks of the pipeline control the single application processor to accomplish their data processing so that the data processing pipeline simulates a data processing pipeline of a multiprocessing environment.