Method and system for data packet queue recovery

A processor-based method comprising:

• receiving, from a server, a data stream including normal data packets (N-packets) at a client device;
• queuing the N-packets in a data processing queue for processing at the client device;
• estimating data packet processing latency of the N-packets;
• when the data packet processing latency corresponds to a data processing latency spike, sending an alarm signal from the client device to the server;
• and
• dropping one or more remaining packets of the N-packets in the data processing queue in response to receiving an independent network packet (I-packet) from the server;
• wherein the I-packet is independently processed at the client device asynchronous to any previously received network packets.

A processor-based server system for providing resource-aware dynamic bandwidth control comprising:

• a non-transitory storage medium storing a server network module, the server network module operable when executed by a processor;
• wherein, the server network module is operable to:
• transmit a specific data stream across a network to a client network node according to a given output bandwidth, the specific data stream including normal packets (N-packets) which are processed sequentially;
• monitor for an alarm signal from the client network node indicating a processing spike of the specific data stream;
• dynamically adjust the output bandwidth in response to receiving the alarm signal;
• and
• in response to receiving the alarm signal, transmit an independent packet (I-packet) to the client network node, wherein the I-packet is a network packet processed independently of other packets at the client network node.

A client device comprising:

• a network engine stored on a non-transitory storage medium, the network engine operable when executed by a processor;
• wherein, the network engine is operable to:
• receive, from a server, a data stream including normal data packets (N-packets);
• queue the N-packets in a data processing queue for processing;
• estimate a data packet processing latency of the N-packets;
• when the data packet processing latency corresponds to a data processing latency spike, send an alarm signal to the server;
• and
• drop a remaining portion of the N-packets in the data processing queue in response to receiving an independent network packet (I-packet) from the server;
• wherein the I-packet is independently processed asynchronous to previously received network packets.