Granted Patent B2

US 12,341,693 · App. 17/686,581 · Granted Jun 24, 2025

Inventor: Zhe Wang (Dongguan, CN)

Assignee: Shenzhen Yinwang Intelligent Technologies Co., Ltd.

H04L45/74H04L47/2433H04L47/25H04L2212/00

Abstract

Claims (69)

1. A data transmission control apparatus, comprising a communications interface and a processor, wherein the processor performs steps comprising:

determine a feedback trigger condition, meta information, and a data flow identifier of a data flow, wherein the data flow communicates with one or more sensors;

obtain a packet header of a to-be-transmitted data packet;

determine, based on the data flow identifier and the obtained packet header, a first data packet corresponding to an egress port matching a data flow from the to-be-transmitted data packet;

obtain, based on the meta information, a meta information value corresponding to the first data packet; and

when determining that the feedback trigger condition is met, encapsulate the meta information value corresponding to the first data packet and a packet header of the first data packet into a second data packet, and send the second data packet to a second node through the communications interface, wherein the second data packet is used to enable the second node to reduce a transmission rate of at least one data flow in data flows corresponding to the first data packet, or send indication information to a third node through the communications interface, wherein the indication information is used to indicate the third node to reduce a transmission rate of at least one data flow in data flows corresponding to the first data packet;

wherein the meta information comprises at least one of a node identifier, an ingress port identifier, an egress port identifier, a queue identifier, a forwarding latency of a data packet, a maximum tolerable latency of a single packet, a data flow identifier corresponding to the data packet, or a data type corresponding to the data packet, and the data type comprises control plane data, management plane data, and data plane data; and

wherein the feedback trigger condition comprises any one or more of the following:

a forwarding latency of the first data packet is greater than the maximum tolerable latency of the single packet;

a quantity of received first data packets is greater than a preset quantity;

a queue depth is greater than a preset queue depth, wherein the queue depth is a ratio of a buffer occupied by all data packets in a queue to a total buffer for the queue; and

utilization of egress bandwidth for the queue is greater than reset bandwidth utilization.

2. The data transmission control apparatus according to claim 1 , wherein the processor further performs steps comprising:

add the meta information value corresponding to the first data packet before the packet header of the first data packet; and

add a new packet header before the meta information value corresponding to the first data packet, to obtain the second data packet, wherein a destination address in the new packet header is an address of the second node.

3. The data transmission control apparatus according to claim 1 , wherein the processor further performs steps comprising:

modify a priority of the second data packet to be greater than a priority threshold.

4. The data transmission control apparatus according to claim 1 , wherein the meta information further comprises the queue depth and/or the utilization of the egress bandwidth for the queue; and

the processor further performs steps comprising:

determine, based on the meta information value corresponding to the first data packet, that the feedback trigger condition is met.

5. The data transmission control apparatus according to claim 1 , wherein the to-be-transmitted data packet are from the third node and/or the second node.

6. The data transmission control apparatus according to claim 1 , wherein the communications interface further performs steps comprising:

receive the feedback trigger condition, the meta information, and the data flow identifier that are configured by the second node.

7. A data transmission control apparatus, comprising a processor and a communications interface, wherein:

the communications interface is configured to:

receive M second data packets from a first node, wherein M is an integer greater than or equal to 1, the second data packet is sent by the first node to a second node when the first node determines that a feedback trigger condition is met, the second data packet carries a packet header of a first data packet and a meta information value corresponding to the first data packet, and the first data packet is determined by the first node from a to-be-transmitted data packet based on a data flow identifier of a data flow, wherein the data flow communicates with one or more sensors; and

the processor is configured to:

determine a target data flow based on the M second data packets and a rate reduction condition, wherein the target data flow is at least one of the one or more data flows corresponding to the M second data packets, wherein M is an integer greater than or equal to 1;

the communications interface is further configured to:

reduce a transmission rate of the target data flow in a rate reduction manner; or

send indication information to a third node through the communications interface, wherein the indication information is used to indicate the third node to reduce the transmission rate of the target data flow in the rate reduction manner;

the communications interface is further configured to:

send, to the first node, the feedback trigger condition, meta information, and the data flow identifier that are configured; and

the meta information further comprises a queue depth and a queue occupancy depth that is of a data flow and that corresponds to the first data packet; and

the rate reduction condition comprises any of a first condition, a second condition, and a third condition, wherein:

the first condition is that in a sampling period, an average value of forwarding latencies in meta information values respectively corresponding to k first data packets belonging to a same data flow is greater than a first preset value, wherein k is an integer less than or equal to M, wherein k is an integer less than or equal to M;

the second condition is that in the sampling period, an average value of queue occupancy depths that are of data flows and that are in the meta information values respectively corresponding to the k first data packets belonging to the same data flow is greater than a second preset value; and

the third condition is that in the sampling period, an average value of queue depths in the meta information values respectively corresponding to the k first data packets belonging to the same data flow is greater than a third preset value.

8. The data transmission control apparatus according to claim 7 , wherein the meta information comprises at least one of a node identifier, an ingress port identifier, an egress port identifier, a queue identifier, a forwarding latency of a data packet, a maximum tolerable latency of a single packet, a data flow identifier corresponding to the data packet, or a data type corresponding to the data packet, and the data type comprises control plane data, management plane data, and data plane data.

9. The data transmission control apparatus according to claim 7 , wherein the M second data packets correspond to one data flow; and

the processor is further configured to:

after determining that an average value of forwarding latencies in meta information values that correspond to first data packets and that are respectively carried in k second data packets in the M second data packets is greater than the first preset value, determine the data flow corresponding to the M second data packets as the target data flow; or

after determining that an average value of queue occupancy depths that are of data flows and that are in meta information values that correspond to first data packets and that are respectively carried in k second data packets in the M second data packets is greater than the second preset value, determine the data flow corresponding to the M second data packets as the target data flow; or

after determining that an average value of queue depths in meta information values that correspond to first data packets and that are respectively carried in k second data packets in the M second data packets is greater than the third preset value, determine the data flow corresponding to the M second data packets as the target data flow.

10. The data transmission control apparatus according to claim 7 , wherein k is an integer less than M, the M second data packets correspond to a plurality of data flows, and each data flow comprises k second data packets; and

the processor is further configured to:

determine an average value of forwarding latencies in meta information values that correspond to first data packets and that are respectively carried in the k second data packets in each data flow, and determining a data flow in which the average value of the forwarding latencies is greater than the first preset value and whose priority is the lowest as the target data flow; or

determine an average value of queue occupancy depths that are of data flows and that are in meta information values that correspond to first data packets and that are respectively carried in the k second data packets in each data flow, and determining a data flow in which the average value of the queue occupancy depths of the data flows is greater than the second preset value and whose priority is the lowest as the target data flow; or

determine an average value of queue depths in meta information values that correspond to first data packets and that are respectively carried in the k second data packets in each data flow, and determining a data flow in which the average value of the queue depths is greater than the third preset value and whose priority is the lowest as the target data flow.

11. The data transmission control apparatus according to claim 7 , wherein the rate reduction manner comprises any of the following:

after the target data flow is determined based on the first condition, reducing the transmission rate of the target data flow by a first percentage;

after the target data flow is determined based on the second condition, reducing the transmission rate of the target data flow by a second percentage; or

after the target data flow is determined based on the third condition, reducing the transmission rate of the target data flow by a third percentage.

12. A non-transitory computer-readable storage medium, comprising a program, wherein when being executed by a processor, the processor is configured to:

determining a feedback trigger condition, meta information, and a data flow identifier of a data flow, wherein the data flow communicates with one or more sensors;

obtaining a packet header of a to-be-transmitted data packet;

determining, based on the data flow identifier and the obtained packet header, a first data packet corresponding to an egress port same as the data flow from the to-be-transmitted data packet;

obtaining, based on the meta information, a meta information value corresponding to the first data packet; and

when determining that the feedback trigger condition is met, encapsulating the meta information value corresponding to the first data packet and a packet header of the first data packet into a second data packet, and sending the second data packet to a second node through the communications interface, wherein the second data packet is used to enable the second node to reduce a transmission rate of at least one data flow in data flows corresponding to the first data packet, or sending indication information to a third node through the communications interface, wherein the indication information is used to indicate the third node to reduce a transmission rate of at least one data flow in data flows corresponding to the first data packet;

wherein the meta information comprises at least one of a node identifier, an ingress port identifier, an egress port identifier, a queue identifier, a forwarding latency of a data packet, a maximum tolerable latency of a single packet, a data flow identifier corresponding to the data packet, and a data type corresponding to the data packet, and the data type comprises control plane data, management plane data, and data plane data; and

wherein the feedback trigger condition comprises any one or more of:

a forwarding latency of the first data packet is greater than the maximum tolerable latency of the single packet;

a quantity of received first data packets is greater than a preset quantity;

a queue depth is greater than a preset queue depth, wherein the queue depth is a ratio of a buffer occupied by all data packets in a queue to a total buffer for the queue; and

utilization of egress bandwidth for the queue is greater than preset bandwidth utilization.

13. The non-transitory computer-readable storage medium according to claim 12 , wherein when the program is executed by the processor, the following steps are further performed:

adding the meta information value corresponding to the first data packet before the packet header of the first data packet; and adding a new packet header before the meta information value corresponding to the first data packet, to obtain the second data packet, wherein a destination address in the new packet header is an address of the second node.

14. The non-transitory computer-readable storage medium according to claim 12 , wherein when the program is executed by the processor, the following steps are further performed:

modifying a priority of the second data packet to be greater than a priority threshold.

Assignments (3)

Priority Claims (1)

Continuity (2)

References Cited (39)