Methods and apparatus for multiplexing data flows via a single data structure

A method for enabling data retrieval via a commonly shared data structure, the method comprising:

• receiving data via a plurality of data pipes;
• writing one or more first data to the commonly shared data structure, the one or more first data associated with one or more corresponding portions of the received data, the commonly shared data structure comprising a first data configuration corresponding to the plurality of data pipes;
• writing one or more second data to each of a plurality of second data structures, the one or more second data indicating completed receipt of corresponding one or more portions of the received data, each of the plurality of second data structures corresponding to respective ones of the plurality of data pipes;
• and
• enabling retrieval by a processor apparatus of at least a portion of the received data via the first data configuration based at least on the one or more second data.

A computerized apparatus configured to enable data retrieval via a commonly shared data structure, the computerized apparatus comprising:

• a first processor apparatus configured for data communication with a second processor apparatus;
• a plurality of data pipes associated with the first processor apparatus;
• and
• logic configured to, when operated, cause the first processor apparatus to:
• receive a plurality of data flows via respective ones of the plurality of data pipes;
• coordinate transfer of the plurality of data flows into the commonly shared data structure, the coordination comprising an assignment of transfer data structures to the commonly shared data structure;
• and
• signal respective completions of the assignment of the transfer data structures via at least provision of completion data structures to a plurality of completion data arrays, the plurality of completion data arrays corresponding to respective ones of the plurality of data pipes associated with the first processor apparatus;
• and
• wherein the completion data structures are configured to signal to the second processor apparatus that at least a portion of the coordinated plurality of data flows is retrievable.

A system for ensuring data transfer via an inter-processor communication (IPC) link, the system comprising:

• a first processor apparatus associated with a plurality of first data pipes;
• a second processor apparatus configured for data communication with the first processor via a shared memory apparatus, the shared memory apparatus comprising a commonly accessible data structure and a plurality of second data structures;
• and
• a non-transitory computer-readable apparatus comprising a storage medium, the storage medium comprising a plurality of instructions configured to, when executed, cause the second processor apparatus to:
• receive data via a plurality of second data pipes associated with the second processor apparatus, the received data comprising a plurality of sets of data records received via respective ones of the plurality of second data pipes;
• write, to the commonly accessible data structure, the plurality of sets of data records;
• write, to the plurality of second data structures, a plurality of data structures corresponding to the plurality of sets of data records;
• and
• cause the first processor apparatus to, based on the plurality of second data structures, (i) retrieve the plurality of sets of data records, and (ii) assign respective data flows to the plurality of first data pipes, each of the respective data flows corresponding to respective ones of the plurality of second data pipes.