Systems, methods and computer readable medium for management of data buffers using functional paradigm

A computer-readable medium comprising a plurality of instructions, which when executed by a processor unit and memory, manage processing of data entries in a data buffer, computer-readable medium comprising instructions for:

• storing a plurality of data entries in a data buffer;
• storing a representation of a two-directional matrix, and annotating the two-directional matrix to mark the data arrivals as a plurality of entries in the two-directional matrix such that the entries are arranged in a row direction of the two-directional matrix, based on a time of receipt of the data arrivals, and in a column direction of the two-directional matrix to uniquely identify the data entries;
• annotating the representation of the two-directional matrix the data entries to define a valid processing period for the data entries;
• processing the data entries in the data buffer, using the processor unit and the memory, by removing the data entries from the data buffer, marked for processing in the two-dimensional matrix during the valid processing period, by annotating the matrix, labeled as ACS, to define the number of available entries as a cumulative sum along the columns, A-X:
• ACS=cumsum(A-X), where ‘cumsum’ is the cumulative column-sum;
• and
• processing, using the processor unit and the memory, to determine the entries removed from the data buffer as defined by the row-sum of X.

A data processing system for managing processing of data entries in a data buffer, comprising:

• a data buffer for storing a plurality of data entries;
• a processor unit, comprising at least one processor, and memory to:
• store a representation of a two-directional matrix, and to annotate the two-directional matrix to mark the data arrivals as a plurality of entries in the two-directional matrix such that the entries are arranged in a row direction of the two-directional matrix, based on a time of receipt of the data arrivals, and in a column direction of the two-directional matrix to uniquely identify the data entries;
• annotate the representation of the two-directional matrix the data entries to define a valid processing period for the data entries;
• process the data entries in the data buffer by removing the data entries from the data buffer, marked for processing in the two-dimensional matrix during the valid processing period, to annotate the matrix, labeled as ACS, to define the number of available entries as a cumulative sum along the columns, A-X:
• ACS=cumsum(A-X), where ‘cumsum’ is the cumulative column-sum;
• and
• process to determine the entries removed from the data buffer as defined by the row-sum of X.