A data processing method is performed by a receiving device. The method includes: receiving, through at least two network channels, data elements transmitted by a transmitting device, the data elements comprising delivery serial numbers; obtaining subsequent data elements of the received n.sup.th data element on the basis of the delivery serial numbers; and determining, when the subsequent data elements comprise a target data element, that a delivery result of the n.sup.th data element is discarded, a state of the target data element being a complete state, the target data element having a same data type as the data type of the n.sup.th data element, the target data element being an independent data element, the data type being determined on the basis of an effect of the data element, and a dependence degree of the independent data element on other data elements during post-processing being less than a specified degree.

A data processing method is performed by a receiving device. The method includes: receiving, through at least two network channels, data elements transmitted by a transmitting device, the data elements comprising delivery serial numbers; obtaining subsequent data elements of the received n.sup.th data element on the basis of the delivery serial numbers; and determining, when the subsequent data elements comprise a target data element, that a delivery result of the n.sup.th data element is discarded, a state of the target data element being a complete state, the target data element having a same data type as the data type of the n.sup.th data element, the target data element being an independent data element, the data type being determined on the basis of an effect of the data element, and a dependence degree of the independent data element on other data elements during post-processing being less than a specified degree.

Disclosed is a user plane function (UPF) packet processing control apparatus including: a processor, and a memory storing instructions, wherein the processor is configured to execute the instructions to analyze a state in which UPF packets are processed by a plurality of packet processing pipelines, determine a size of a packet vector for each of the plurality of packet processing pipelines based on a result of the analyzing, and allocate a number of processing cores to each of the plurality of packet processing pipelines based on the result of the analyzing.

Disclosed is a user plane function (UPF) packet processing control apparatus including: a processor, and a memory storing instructions, wherein the processor is configured to execute the instructions to analyze a state in which UPF packets are processed by a plurality of packet processing pipelines, determine a size of a packet vector for each of the plurality of packet processing pipelines based on a result of the analyzing, and allocate a number of processing cores to each of the plurality of packet processing pipelines based on the result of the analyzing.

A system and method for automatically scaling consumer servers in a data processing system. To build an automatic scaling system, the present disclosure allows consumers to obtain additional information, e.g., the number of events that await to be read from an aggregator when receiving an event from the aggregator. This additionally obtained number provides a direct gauge for the data processing system to determine when the consumers are over-provisioned, i.e., when the number of events left to be read is close to zero, as well as when the consumers are under-provisioned, e.g., when the number of events left to be read continues to increase. As a result, the consumers can be automatically scaled to handle the dynamic data processing demand while providing optimal resource allocation.

A system and method for automatically scaling consumer servers in a data processing system. To build an automatic scaling system, the present disclosure allows consumers to obtain additional information, e.g., the number of events that await to be read from an aggregator when receiving an event from the aggregator. This additionally obtained number provides a direct gauge for the data processing system to determine when the consumers are over-provisioned, i.e., when the number of events left to be read is close to zero, as well as when the consumers are under-provisioned, e.g., when the number of events left to be read continues to increase. As a result, the consumers can be automatically scaled to handle the dynamic data processing demand while providing optimal resource allocation.

A network congestion notification method and network node are provided in a network system. The network node receives a remote direct memory access (RDMA) packet, where the RDMA packet carries a source queue pair number corresponding to a transmit end and a destination queue pair number corresponding to a receive end. The network node generates a congestion notification packet when detecting network congestion, where a destination queue pair number of the congestion notification packet is the source queue pair number. Then the network node sends the congestion notification packet to the transmit end so that the transmit end may decrease a sending rate of a data flow to which the first data packet belongs.

A device includes one or more processors configured to, during a call, receive a sequence of audio frames from a first device. The one or more processors are configured to, in response to determining that no audio frame of the sequence has been received for a threshold duration since a last received audio frame of the sequence, initiate transmission of a frame loss indication to the first device. The one or more processors are also configured to, responsive to the frame loss indication, receive a set of audio frames of the sequence and an indication of a second playback speed from the first device. The one or more processors are configured to initiate playback, via a speaker, of the set of audio frames based on the second playback speed. The second playback speed is greater than a first playback speed of a first set of audio frames of the sequence.

Example packet control methods and apparatus are described. One example method includes detecting, by a network node, a packet in a packet flow causing a congestion from an upstream node. The network node reduces a scheduling priority of the packet in the packet flow and generates a congestion isolation message, where the congestion isolation message includes description information of the packet flow. The congestion isolation message is sent to the upstream node to instruct the upstream node to reduce the scheduling priority of the packet in the packet flow.

The present technology is directed to a system and method for using cloud based processing to co-locate one or more tunnel end points, associated with mobile user generated traffic traversing a Core network, with the serving machine located on application provider network. The describe system/method involves early stage identification of traffic flow (i.e., at the Packet Data network Gateway device using Application Detection and Control function) and dynamically instantiating an end point for the aforementioned traffic flow at the server where the application request is being served. The traffic is then directly tunneled to the endpoint thus avoiding decapsulated mobile traffic from traversing across provider network.