CN116017701A - Data processing method, network device, and computer-readable storage medium - Google Patents

Abstract

The invention discloses a data processing method, a network device and a computer-readable storage medium. Wherein, the data processing method includes receiving time-triggered data flow information; transmitting time-triggered data flow in the first time slot; receiving event-triggered data flow information; transmitting event-triggered data flow in the second time slot; wherein, the first time slot and the second time slot Two slots are different slots in the same transmission cycle. According to the solutions of the embodiments of the present invention, it is possible to reduce transmission conflicts between time-sensitive event-triggered data streams and time-triggered data streams, and realize common transmission of event-triggered data streams and time-triggered data streams.

Description

Data processing method, network device, and computer-readable storage medium

technical field

The present invention relates to the technical field of data processing, in particular to a data processing method, network equipment and computer-readable storage medium.

Background technique

In the context of rapid industrial development, more and more industrial application scenarios have put forward new requirements for the delay of information carried by the network. First of all, the deterministic transmission delay requirements are put forward. For example, the end-to-end transmission delay of data in the advanced driving assistance system should be less than 250 microseconds, and it should not exceed 10 microseconds in terms of power and chassis control. In the transmission of switch control information in the power system, in addition to the requirements for information transmission time delay, there are also requirements for the variation range of time delay. In order to meet the sensitive requirements for service bearer delay in some application scenarios, the IEEE TSN working group has developed an open and general standard protocol - TSN technology (Time-Sensitive Networks, time-sensitive network).

However, in the current TSN technology, due to the existence of event messages, such as operator commands, alarms, and status changes, etc., event-triggered data streams will appear in real-time application network systems. Due to the dynamic and unpredictable nature of the event-triggered data flow, when the event-triggered data flow also requires low latency, the event-triggered data flow will have the same priority as the time-triggered data flow. In this case, the event-triggered data flow The stream will occupy the transmission slots reserved for time-triggered data streams, making the transmission delay of time-triggered data streams increase or even become unschedulable.

Contents of the invention

The following is an overview of the topics described in detail in this article. This summary is not intended to limit the scope of the claims.

Embodiments of the present invention provide a data processing method, network equipment, and computer-readable storage medium, which can reduce conflicts between time-sensitive event-triggered data streams and time-triggered data streams in transmission, and realize event-triggered data streams and time-triggered data streams. Triggers the co-transmission of data streams.

In a first aspect, an embodiment of the present invention provides a data processing method, including:

Receive time-triggered data streams;

transmitting the time-triggered data stream in a first time slot;

Receive events to trigger data flow;

The event-triggered data stream is transmitted in a second time slot; wherein the first time slot and the second time slot are different time slots in the same transmission cycle.

In the second aspect, the embodiment of the present invention also provides a network device, including at least one control processor and a memory for communicating with the at least one control processor; the memory stores information that can be controlled by the at least one control processor. Instructions executed by a processor, the instructions are executed by the at least one control processor, so that the at least one control processor can execute the data processing method as described in the first aspect above.

In a third aspect, an embodiment of the present invention further provides a computer-readable storage medium, the computer-readable storage medium stores computer-executable instructions, and the computer-executable instructions are used to make a computer execute the data processing method described in the first aspect.

The embodiment of the present invention includes: receiving a time-triggered data stream, transmitting a time-triggered data stream in the first time slot; receiving an event-triggered data stream, and transmitting an event-triggered data stream in a second time slot; wherein, the first time slot and the second time slot Slots are different time slots in the same transmission cycle. According to the solution of the embodiment of the present invention, the time-triggered data flow is received, the time-triggered data flow is transmitted in the first time slot, the event-triggered data flow is received, and the event-triggered data flow is transmitted in the second time slot, wherein the first time slot and the second time slot The two time slots are different time slots in the same transmission period, therefore, the time-triggered data flow and the event-triggered data flow will not be transmitted in the same time slot of the same transmission period, that is to say, the solution of the embodiment of the present invention can reduce the time Sensitive event-triggered data streams and time-triggered data streams conflict in transmission, and the common transmission of event-triggered data streams and time-triggered data streams is realized.

Additional features and advantages of the invention will be set forth in the description which follows, and in part will be apparent from the description, or may be learned by practice of the invention. The objectives and other advantages of the invention may be realized and attained by the structure particularly pointed out in the written description and claims hereof as well as the appended drawings.

Description of drawings

The accompanying drawings are used to provide a further understanding of the technical solution of the present invention, and constitute a part of the description, and are used together with the embodiments of the present invention to explain the technical solution of the present invention, and do not constitute a limitation to the technical solution of the present invention.

Fig. 1 is a flowchart of a data processing method provided by an embodiment of the present invention;

Fig. 2 is the flowchart of the concrete method of step S120 in Fig. 1;

Fig. 3 is the flowchart of the specific method of step S140 in Fig. 1;

FIG. 4 is a flowchart of a data processing method provided by an embodiment of the present invention;

Fig. 5 is the flowchart of the concrete method of step S170 in Fig. 4;

Fig. 6 is the flowchart of the specific method of step S170 in Fig. 4;

FIG. 7 is a flowchart of a specific method of step S1722 in FIG. 6;

FIG. 8 is a flowchart of a data processing method provided by an embodiment of the present invention;

FIG. 9 is a flowchart of a specific method of step S810 in FIG. 8;

FIG. 10 is a flowchart of a specific method of step S810 in FIG. 8;

FIG. 11 is a schematic diagram of data stream transmission in the related art;

FIG. 12 is a schematic diagram of data stream transmission in the time shaping mechanism of TSN technology;

Fig. 13 is a transmission schematic diagram of a transmission queue provided by another embodiment of the present invention;

Fig. 14 is a transmission schematic diagram of a transmission queue provided by another embodiment of the present invention;

Fig. 15 is a schematic diagram of a transmission cycle of an event-triggered data stream provided by another embodiment of the present invention;

Fig. 16 is a schematic diagram of data stream transmission provided by another embodiment of the present invention.

Detailed ways

In order to make the object, technical solution and advantages of the present invention clearer, the present invention will be further described in detail below in conjunction with the accompanying drawings and embodiments. It should be understood that the specific embodiments described here are only used to explain the present invention, not to limit the present invention.

It should be noted that although a logical order is shown in the flowchart, in some cases, the steps shown or described may be performed in a different order than in the flowchart. The terms "first", "second" and the like in the specification and claims and the above drawings are used to distinguish similar objects, and not necessarily used to describe a specific sequence or sequence.

An embodiment of the present invention provides a data processing method, network equipment, and a computer scale storage medium, receiving a time-triggered data stream, transmitting a time-triggered data stream in the first time slot, receiving an event-triggered data stream, and transmitting an event-triggered data stream in the second time slot Data flow, wherein the first time slot and the second time slot are different time slots in the same transmission period, therefore, the time-triggered data flow and the event-triggered data flow will not be transmitted in the same time slot of the same transmission period, that is In other words, the solutions of the embodiments of the present invention can reduce the conflicts between transmission of time-sensitive event-triggered data streams and time-triggered data streams, and realize common transmission of event-triggered data streams and time-triggered data streams.

The embodiments of the present invention will be further described below in conjunction with the accompanying drawings.

As shown in FIG. 1 , FIG. 1 is a flowchart of a data processing method provided by an embodiment of the present invention. The data processing method may include but not limited to step S110 , step S120 , step S130 and step S140 .

Step S110: Receive a time-triggered data stream.

In this step, the time-triggered data flow refers to a time-sensitive data flow. The time-triggered data flow may be a periodically transmitted data flow, and the time-triggered data flow has a transmission cycle.

In an optional implementation manner, in a network application scenario using the TSN technology, when a certain service needs to be transmitted within a certain time, the service has a maximum delay requirement. For example, avionics full-duplex switched Ethernet must complete the end-to-end transmission of key data within a few milliseconds and has strict requirements on its delay jitter, and the transmission delay of many industrial control applications must be guaranteed within a few milliseconds. In addition, the end-to-end transmission delay of data in the advanced driver assistance system should be less than 250 microseconds, and it should not exceed 10 microseconds in terms of power and chassis control. The data flow generated by this service belongs to the time-triggered data flow.

It should be noted that receiving the time-triggered data stream can be received by using an array to save the time-triggered data stream, or directly storing the time-triggered data stream in any form of linked list in related technologies, which is not specifically limited in this embodiment. It then waits for subsequent transmissions of time-triggered data streams.

Step S120: Trigger data flow at the transmission time of the first time slot.

In this step, since the time-triggered data stream is received in step S110, the time-triggered data stream may be transmitted in the first time slot. The first time slot may be any time slot in the transmission cycle, the first time slot may be a single time slot in the transmission cycle, or any number of time slots, and when there are multiple first time slots, the first The interval between the time slots may be any interval, as long as it can meet the delay requirement of the time-triggered data stream, which is not specifically limited in this embodiment. In addition, the number of first time slots may be preset according to the number of time-triggered data streams.

It should be noted that the time-triggered data flow is transmitted in the first time slot. Referring to FIG. 11 , the time-triggered data flow can be transmitted from the client through the Ethernet device and finally reach the target client; The time-triggered data stream is stored in a transmission queue, which can be a first-in-first-out transmission queue set anywhere in the system in the related art, and then transmits the time-triggered data through any data stream transmission method in the related art For example, by periodically opening the gate in the first time slot to open the transmission queue to transmit the time-triggered data flow, or directly opening the transmission queue in the first time slot to periodically transmit the time-triggered data flow wait.

Step S130: Receive event-triggered data stream.

In this step, the event-triggered data flow may be in the real-time application network system, due to the existence of event messages, such as the data flow that occurs due to operator commands, accident alarms or state changes, etc., the event-triggered data flow may occur sporadically Data flow or sudden periodic data flow, event-triggered data flow is dynamic and unpredictable.

It should be noted that receiving the event-triggered data stream can be done by using an array to store the event-triggered data stream, or by directly storing the event-triggered data stream in any form of linked list in related technologies, as long as it can receive event-triggered data The function of the stream is sufficient, and is not specifically limited in this embodiment, and it waits for subsequent transmission of event-triggered data streams.

Step S140: Triggering a data stream on a second time slot transmission event, wherein the first time slot and the second time slot are different time slots in the same transmission period.

In this step, since the event-triggered data stream is received in step S130, the event-triggered data stream can be transmitted in the second time slot, and the second time slot can be any time slot in the transmission cycle, and the second time slot can be a transmission A single time slot in a cycle can also be any number of time slots. When there are multiple second time slots, the interval between the second time slots can be any interval, and the number of second time slots can be triggered according to time The number of data streams is preset.

It should be noted that the event-triggered data stream is transmitted in the second time slot. Referring to FIG. The three Ethernet devices 1130 and the fourth Ethernet device 1140 transmit, and finally reach the second client; it is also possible to store the event-triggered data stream in the queue, and then transmit the event-triggered data through any data stream transmission method in the related art For example, by periodically opening the gate in the second time slot to transmit the event-triggered data stream, or opening the queue in the second time slot to periodically transmit the event-triggered data stream, etc. Since the first time slot and the second time slot are in different time slots of the same transmission cycle, the time-triggered data flow and the event-triggered data flow are transmitted in different time slots, and there is no influence on each other, which can reduce time-sensitive When the event-triggered data flow and the time-triggered data flow conflict in transmission, the common transmission of the event-triggered data flow and the time-triggered data flow is realized.

In an optional implementation, in the TSN technology, only the gate of one queue is allowed to be opened in the same time slice. When two or more gate switches with different priorities are opened at the same time, only the data flow of the high-priority queue It can be output, but the data flow of the low priority queue cannot be output. When there are periodic time-triggered data streams and event-triggered data streams such as operation commands and system alarms in the system, if the event-triggered data stream is also time-sensitive, the transmission priority of the event-triggered data stream queue is higher than or equal to time The transmission priority of the trigger data flow queue will cause the time-triggered data flow to be unschedulable or unable to complete the transmission within the maximum allowable extended time range, and the transmission priority of the event-triggered data flow queue is too low to cause the event-triggered data flow to be unschedulable or impossible Complete the transfer within the maximum allowed extended time frame.

It should be noted that the time-triggered data stream is received, and the time-triggered data stream refers to a time-sensitive time-triggered data stream. The time-triggered data stream is transmitted in the first time slot, and the first time slot refers to any time in the transmission cycle. The first time slot may be one time slot or multiple time slots. Receive event-triggered data streams. Event-triggered data streams refer to system burst data streams, such as operation commands, system alarms, etc. Event-triggered data streams are dynamic and unpredictable. The data flow is triggered by the transmission event in the second time slot, where the second time slot refers to any time slot in the transmission cycle, and the second time slot may be one time slot or multiple time slots. Wherein, the first time slot and the second time slot are different time slots in the same transmission period, and the time-triggered data flow and the event-triggered data flow will not be transmitted in the same time slot of the same transmission period, which can avoid the time-triggered data flow and The collision of event-triggered data streams in transmission realizes the common transmission of event-triggered data streams and time-triggered data streams.

In this embodiment, by adopting the data processing method including the above steps S110 to S140, the time-triggered data stream is received, and the time-triggered data stream is transmitted in the first time slot; the event-triggered data stream is received, and the event is transmitted in the second time slot Triggered data flow; wherein, the first time slot and the second time slot are different time slots in the same transmission period, therefore, the time-triggered data flow and the event-triggered data flow will not be transmitted in the same time slot of the same transmission period. The embodiment can reduce the transmission conflict between the time-sensitive event-triggered data flow and the time-triggered data flow, and realize the common transmission of the event-triggered data flow and the time-triggered data flow.

It is worth noting that under the time-aware shaping mechanism of TSN technology, the time-aware shaping mechanism requires strict time synchronization. The data streams sent by the system terminal equipment are all periodic, and the dependence on synchronization and periodicity leads to network Unpredictable data flows are not allowed in the system. If unexpected flows other than traffic scheduling occur during system operation, such as operation commands, system alarms and other events triggering data flows, these bursts will inevitably affect the original The scheduling of the flow may even cause the system to crash. In this embodiment, since the time-triggered data flow and the event-triggered data flow are set to be transmitted in different time slots of the same transmission cycle, the time-sensitive event-triggered data flow can be reduced. Conflicts with time-triggered data streams in transmission, the purpose of co-transmitting time-triggered data streams and event-triggered data streams.

In an embodiment, as shown in FIG. 2 , step S120 is further described, and step S120 may include but not limited to step S121 and step S122 .

Step S121: Buffer the time-triggered data flow in the first transmission queue.

In this step, the number of the first transmission queue may be one or more, and the first transmission queue may be a first-in-first-out transmission queue in the related art. After receiving the time-triggered data flow, the time-triggered data flow is cached in the first transmission queue, and the transmission is performed after the queue is opened.

It should be noted that the setting of the first transmission queue can be any setting method in related technologies. For example, in an optional implementation, the first transmission queue is set through an array and an array subscript, or through a linked list, such as The first transmission queue is set in a singly-linked list or a double-linked list, as long as it can trigger a data flow at a buffer time, which is not specifically limited in this embodiment.

Step S122: Open the first transmission queue in the first time slot according to the preset queue switch information, so that the time-triggered data flow is transmitted in the first time slot.

In this step, since the time-triggered data flow has been buffered in the first transmission queue in step S121, the first transmission queue can be controlled to be opened to transmit the time-triggered data flow.

It should be noted that, according to the preset queue switch information, the first transmission queue is opened in the first time slot. The preset queue switch information may be based on the number of time-triggered data streams and delay requirements after the time-triggered data streams are acquired. and the transmission path set etc. to perform scheduling calculations to obtain the queue switch information of the first transmission queue. Referring to FIG. 16, the transmission path can be the path that the data flow actually passes according to the time trigger, such as the transmission from device 1 to device 5 in FIG. 16, Device 1, Device 2, Device 6, and Device 5 respectively pass through Device 2 and Device 6, which are the transmission paths of the time-triggered data flow.

It should be noted that the first transmission queue is enabled according to the queue switch information, and the first transmission queues for caching the time-triggered data flow are all enabled in the first time slot.

In addition, in an optional implementation manner, the queue switch information can be cached in a cache list, the first transmission queue can be set with gate control, and the gate control of the first transmission queue can be opened according to the queue switch information, then the second transmission queue can be opened. A transmit queue such that the time-triggered data flow is transmitted in the first time slot.

In this embodiment, by adopting the above steps S121 to S122, after the time-triggered data stream is acquired, the time-triggered data stream is cached in the first transmission queue, and the first transmission queue is opened in the first time slot according to the preset queue switch information. The transmission queue enables the time-triggered data flow to be transmitted in the first time slot, so that the purpose of transmitting the time-triggered data flow in the first time slot can be achieved.

In an embodiment, as shown in FIG. 3 , step S140 is further described, and step S140 may include but not limited to step S141 and step S142 .

Step S141: Buffer the event-triggered data stream in the second transmission queue.

In this step, the number of the second transmission queue may be one or more, and the second transmission queue may be a transmission queue set in any form in the related art. After receiving the event-triggered data flow, buffer the event-triggered data flow in the second transmission queue, and wait for the queue to be opened before transmitting.

It should be noted that the setting of the second transmission queue can be any setting method in the related art. For example, in an optional implementation, the second transmission queue is set in the form of an array, or through a linked list, such as a singly linked list or The second transmission queue is set in a double-linked list, etc., as long as the second transmission queue can play a role in buffering event-triggered data streams, which is not specifically limited in this embodiment.

Step S142: Open the second transmission queue in the second time slot according to the queue switch information, so that the event-triggered data flow is transmitted in the second time slot.

In this step, since the event-triggered data flow has been buffered in the second transmission queue in step S141, the second transmission queue can be controlled to be opened to transmit the event-triggered data flow.

It should be noted that, according to the queue switch information, the second transmission queue is opened in the second time slot. The queue switch information can be obtained after the event-triggered data flow is obtained, and the scheduling calculation is performed according to the number of event-triggered data flows and delay requirements, and the second transmission queue is obtained. Second, the queue switch information of the transmission queue.

It should be noted that the second transmission queue is opened according to the queue switch information, and the second transmission queue is opened in the second time slot. At the same time, the queue switch information is also used to control the opening of the first transmission queue in the first time slot. The queue switch The information may be list information formed according to the opening and closing information of the transmission queue, the first transmission queue is opened in the first time slot, and the second transmission queue is opened in the second time slot.

In addition, in an optional implementation manner, the queue switch information may be cached in a cache queue, and the second transmission queue may be provided with gate control. If the gate control of the second transmission queue is enabled according to the queue switch information, the second transmission queue may be enabled. A second transmission queue is used to enable the event-triggered data flow to be transmitted in the second time slot.

In this embodiment, by adopting the above steps S141 to S142, after the event-triggered data stream is acquired, the event-triggered data stream is first buffered in the second transmission queue, and then the second transmission is started in the second time slot according to the queue switch information The queue enables the event-triggered data flow to be transmitted in the second time slot, so that the purpose of transmitting the event-triggered data flow in the second time slot can be achieved.

It is worth noting that the first transmission queue and the second transmission queue are two types of transmission queues of different types, and both the first transmission queue and the second transmission queue may be any number of transmission queues, which is not specifically described in this embodiment. Restricted, since the first transmission queue is used for buffering time-triggered data flow, and the second transmission queue is used for buffering event-triggered data flow, according to the queue switch information, the first transmission queue is opened in the first time slot, and the second transmission queue is opened in the second time slot. The time slot is opened, the first time slot and the second time slot are different time slots in the same transmission cycle, that is to say, this embodiment achieves the joint transmission of time-triggered data flow and event-triggered data flow, and the time-triggered data flow and event The purpose of triggering data streams to transmit without conflicting.

In an embodiment, as shown in FIG. 4 , the data processing method may further include but not limited to step S150 , step S160 and step S170 .

Step S150: Receive a common data stream.

In this step, the ordinary data flow may be an ordinary data flow generated by a service that does not have strict requirements on time delay. In an optional implementation manner, referring to FIG. 12 , in the time shaping mechanism of the TSN technology, a There are 8 transmission queues with different transmission priorities in front of the port. According to the requirements for transmission delay, customer services can be divided into 8 categories at most, namely type 0 to type 7. Different types of services generate different types of data streams , the data flows generated by different levels of customer services enter the queues with corresponding transmission priorities. T1 to T4 refer to the gates corresponding to the transmission queues of type 1 to type 4. The gates are controlled according to the transmission cycle Tcycle through the gate list information Switch, when the gate control is turned on, the data stream in the transmission queue can pass through the gate control after the transmission selection algorithm, and then the final data stream to be transmitted is determined by the scheduling algorithm. In an optional implementation manner, both the time-triggered data flow and the event-triggered data flow are time-sensitive data flows with strict delay requirements. The two transmission queues may both be transmission queues with the highest priority, and the common data flow may be a transmission queue with any transmission priority except the highest transmission priority, which is not specifically limited in this embodiment.

Step S160: Buffer the common data flow in the third transmission queue, the transmission priority of the third transmission queue is lower than the transmission priority of the first transmission queue.

In this step, the third transmission queue is a transmission queue of a different type from the first transmission queue and the second transmission queue, and the time-triggered data flow, event-triggered data flow and common data flow are stored in different transmission queues separately. In an optional implementation, when the third transmission queue and the first transmission queue are opened at the same time, since the transmission priority of the third transmission queue is lower than that of the first transmission queue, the system will always give priority to the transmission of the first transmission queue. For the queue, this embodiment can prevent the transmission of ordinary data streams from adversely affecting the transmission of time-triggered data streams.

It should be noted that the first transmission queue, the second transmission queue, and the third transmission queue are all set with transmission priorities, which are mainly used to limit the simultaneous opening of two different transmission queues to avoid different transmission priorities. When two transmission queues are opened at the same time, the transmission queue with low transmission priority blocks the transmission queue with high transmission priority.

Step S170: Determine whether to transmit normal data flow according to the queue switch information.

In this step, since the ordinary data flow is obtained in step S150, the ordinary data flow is buffered in the third transmission queue in step S160, so whether to transmit the ordinary data flow is determined according to the queue switch information.

It should be noted that the queue switch information includes the switch information of the first transmission queue and the switch information of the second transmission queue, and it is determined whether to transmit ordinary data streams according to the queue switch information. The switch information determines whether to open the third transmission queue for buffering ordinary data streams, and it is necessary to determine whether other high-priority transmission queues are opened in the same time slot. This embodiment can avoid blocking other high-priority data for the transmission of ordinary data streams The transmission of streams further realizes the common transmission of time-triggered data streams, event-triggered data streams, and common data streams.

In this embodiment, by adopting the data processing method including the above-mentioned steps S140 to S170, the ordinary data flow is received, and then the ordinary data flow is cached in the third transmission queue, and the transmission priority of the third transmission queue is lower than that triggered by the cache time The transmission priority of the first transmission queue of the data flow, and then determine whether to transmit the normal data flow according to the queue switch information. Therefore, this embodiment can realize the common transmission of the time-triggered data stream, the event-triggered data stream and the common data stream under the condition of realizing the common transmission of the time-triggered data stream and the event-triggered data stream.

In an embodiment, as shown in FIG. 5 , step S170 is further described, and step S170 may include but not limited to step S1711 , step S1712 , step S1713 and step S1714 .

Step S1711: When the first transmission queue and the third transmission queue are enabled simultaneously according to the queue switch information, it is determined not to transmit the normal data flow.

In this step, when the first transmission queue and the third transmission queue are simultaneously enabled according to the queue switch information, since the transmission priority of the third transmission queue is lower than that of the first transmission queue, it is determined not to transmit the normal data flow, When the time-triggered data flow exists in the third transmission queue, the time-triggered data flow is transmitted.

It should be noted that since the third transmission queue is started in the first time slot, and the second transmission queue is started in the second time slot, the first time slot and the second time slot are different time slots in the same transmission cycle, therefore, when the first time slot The first transmission queue and the third transmission queue are opened at the same time, and the second transmission queue is not opened.

Step S1712: When the first transmission queue is enabled but the third transmission queue is not enabled according to the queue switch information, it is determined not to transmit the normal data flow.

In this step, when the first transmission queue is enabled but the third transmission queue is not enabled according to the queue switch information, since the third transmission queue is not enabled, it is determined not to transmit the normal data flow, and when the third transmission queue exists time to trigger the data flow, the transmission Time-triggered data flow.

It should be noted that the buffer time triggers the first transmission queue of the data flow to be opened, and the buffer event triggers the second transmission queue of the data flow to be closed, because the third transmission queue is opened in the first time slot, and the second transmission queue is in the second time slot On, the first time slot and the second time slot are different time slots of the same transmission cycle.

Step S1713: When the first transmission queue and the second transmission queue are not enabled according to the queue switch information, but the third transmission queue is enabled, determine to transmit the normal data flow, and perform transmission processing on the normal data flow.

In this step, when the first transmission queue and the second transmission queue are not enabled according to the queue switch information, but the third transmission queue is enabled, and only the third transmission queue is enabled in the current time slot, there is no need to determine the transmission priority, and determine the transmission of ordinary data stream, and perform transmission processing on ordinary data streams.

It should be noted that, in an optional implementation manner, the first transmission queue is started at the first time slot, and the second transmission queue is started at the second time slot, and the current time slot is neither the first time slot nor the second time slot. slot, the first transmission queue and the second transmission queue are not opened, but the third transmission queue is opened, that is to say, the ordinary data flow can also be a periodic transmission flow, which is neither the first time slot nor the second time slot in the transmission cycle Transmission is performed in the time slots of the two time slots, so that time-triggered data streams, event-triggered data streams, and common data streams reduce conflicts during transmission and realize common transmission.

Step S1714: When the second transmission queue and the third transmission queue are enabled simultaneously according to the queue switch information, and the event-triggered data flow is buffered in the second transmission queue, it is determined not to transmit the normal data flow.

In this step, when the second transmission queue and the third transmission queue are simultaneously enabled according to the queue switch information, and the event-triggered data flow is buffered in the second transmission queue, since the event-triggered data flow of the second transmission queue is a time-sensitive data flow, The transmission priority of the second transmission queue buffered with the event-triggered data stream is higher than that of the third transmission queue buffered with the normal data stream, therefore, it is determined not to transmit the normal data stream.

It should be noted that, in an optional implementation manner, the event-triggered data stream is buffered in the second transmission queue, which may be when the second transmission queue is started, and since the second transmission queue has a first-in-first-out structure, it may be The second transmission queue is provided with a processor, which detects the first linked list position or array position of the queue exit of the second transmission queue to determine whether the second transmission queue has an event-triggered data flow cached.

In this embodiment, by adopting the above steps S1711 to S1714, it is determined whether to transmit ordinary data streams according to the queue switch information, that is, the third transmission queue is opened or closed according to the queue switch information, when the third transmission queue with ordinary data streams buffered is closed Then it is determined not to transmit the normal data stream, and when only the third transmission queue is enabled, it is determined to transmit the normal data stream; when the third transmission queue is enabled, if the first transmission queue is enabled, then it is determined not to transmit the normal data stream; if the second transmission queue is enabled , and there is an event-triggered data flow in the second transmission queue, it is determined not to transmit the normal data flow, so that the purpose of determining whether to transmit the normal data flow according to the queue switch information can be achieved.

In an embodiment, as shown in FIG. 6 , step S172 is further described, and step S172 may include but not limited to step S1721 and step S1722 .

Step S1721: When the second transmission queue and the third transmission queue are simultaneously enabled according to the queue switch information, and the second transmission queue does not buffer event-triggered data streams, determine to transmit normal data streams.

In this step, when the second transmission queue and the third transmission queue are simultaneously enabled according to the queue switch information, and the second transmission queue does not have a cache event triggering data flow, it means that there is no event to be transmitted in the second time slot when the second transmission queue is currently enabled Trigger the data flow to confirm the transmission of ordinary data flow. Since the event-triggered data flow is generally a burst data flow, the event-triggered data flow is transmitted in the second time slot. When there is no event-triggered data flow to be transmitted, the normal data flow is transmitted in the second time slot. This transmission method achieves The purpose of improving link bandwidth utilization.

It should be noted that the data stream is triggered by a transmission event in the second time slot, so when the second transmission queue is enabled, the current time slot is the second time slot.

Step S1722: Perform transmission processing on the ordinary data stream.

In this step, since it is determined in step S1721 that the normal data flow is to be transmitted, and the second transmission queue and the third transmission queue are enabled at the same time, it is necessary to perform transmission processing on the normal data flow. Since the transmission priority of the second transmission queue is higher than that of the third transmission queue that caches ordinary data streams, it is necessary to perform corresponding processing on the second transmission queue, for example: lower the transmission priority of the second transmission queue, or close the second transmission queue etc., so that the normal data flow in the third transmission queue can be transmitted.

In an optional implementation manner, refer to FIG. 13 , which is a schematic transmission diagram of a transmission queue. When the second transmission queue and the third transmission queue are opened at the same time, if the state information is that there is no event-triggered data flow in the second transmission queue, the gate control is closed according to the state information, and the second transmission queue is not opened, so that the third transmission queue ordinary data streams can be transmitted.

In this embodiment, by adopting the above steps S1721 to S1722, the second transmission queue and the third transmission queue are simultaneously opened according to the queue switch information, and if there is no event-triggered data stream to be transmitted in the second transmission queue, it is determined to transmit the second transmission queue. The common data streams in the three transmission queues are transmitted, and the common data streams are transmitted and processed, so as to achieve the purpose of improving the bandwidth utilization rate of the link in the second time slot.

In an embodiment, as shown in FIG. 7 , step S1722 is further described, and this step S1722 may include but not limited to step S17221 and step S17222 .

Step S17221: Lower the transmission priority of the second transmission queue, so that the transmission priority of the second transmission queue is lower than the transmission priority of the third transmission queue.

In this step, reduce the transmission priority of the second transmission queue, for example, can be based on Burst Limiting Shaper (BLS) proposed in IEEE802.1Q and based on credit shaping (Credit-based Shaper, CBS), set The credit value of the second transmission queue, the minimum credit value is zero, the credit value is increased by multiplying the data waiting time in the transmission queue by the idle slope parameter, and the credit value is decreased by multiplying the transmission time by the sending slope. The credit value is used to control the transmission priority. In an optional implementation manner, a large value may be selected as the slope parameter so as to rapidly reduce the transmission priority of the second transmission queue. When there is no event triggering data flow in the second transmission queue, its credit value decreases, and the transmission priority decreases. At this time, the data in the third transmission queue that is also in the gate open state can be transmitted, that is, when the transmission is confirmed For ordinary data flow, there is no event-triggered data flow in the second transmission queue, so that the transmission priority of the second transmission queue is lower than the transmission priority of the third transmission queue.

It should be noted that reducing the transmission priority of the second transmission queue can also directly reduce the transmission priority of the second transmission queue to the lowest, so that the transmission priority of the second transmission queue is lower than the transmission priority of the third transmission queue class.

In an optional implementation manner, refer to FIG. 14 , which is a schematic transmission diagram of a transmission queue. Set the dynamic priority before the gating of the second transmission queue. When the second transmission queue and the third transmission queue are opened at the same time, and there is no event-triggered data flow in the second transmission queue, the priority of the second transmission queue is lowered. If the transmission priority of the second transmission queue is lowered to be lower than the transmission priority of the third transmission queue, normal data flow is transmitted.

Step S17222: Transmit ordinary data flow through the second time slot.

In this step, since the transmission priority of the second transmission queue is lowered to be lower than that of the third transmission queue in step S17221, and the second transmission queue for buffering the event-triggered data flow is only opened in the second time slot , the first transmission queue is not enabled in the second time slot, so the third transmission queue can transmit in the second time slot, and transmit ordinary data streams through the second time slot, so as to improve the bandwidth utilization rate of the link.

In this embodiment, by adopting the above steps S17221 to S17222, when performing transmission processing on ordinary data streams, the transmission priority of the second transmission queue is lowered first, so that the transmission priority of the second transmission queue is lower than that of the third transmission queue. transmission priority, and then transmit the ordinary data flow through the second time slot, so as to achieve the purpose of performing transmission processing on the ordinary data flow.

It is worth noting that in TSN technology, the time-triggered data stream is a periodic stream. When the time slot for transmitting ordinary data streams is the first time slot, all open transmission queues of the current time slot are detected, and high transmission queues are selected according to the transmission priority. prioritized data streams for transmission. However, in this embodiment, in the same transmission cycle, the first time slot transmits time-triggered data flow, and the second time slot transmits event-triggered data flow. The first time slot and the second time slot are not the same time slot. When the transmission The time slot of the ordinary data flow is the second time slot. It not only detects all the open transmission queues of the current time slot, but also detects whether there is an event-triggered data flow in the second transmission queue. flow, if it does not exist, reduce the priority of the second transmission queue, or close the second transmission queue, so that the third transmission queue that buffers the ordinary data flow can transmit, so the utilization rate of the second time slot is increased to achieve The purpose of improving link bandwidth utilization.

In an embodiment, as shown in FIG. 8 , before the data flow is triggered by the transmission event of the second time slot, the data processing method may further include but not limited to step S810 and step S820 .

Step S810: Set the transmission period of the event-triggered data stream.

In this step, set the transmission period of the event-triggered data flow. The event-triggered data flow can be a periodic flow that appears suddenly. The transmission period of the event-triggered data flow can be consistent with the transmission period of the time-triggered data flow. The event-triggered data flow The setting of the size of the transmission period needs to ensure that the periodically reserved resources can ensure that the transmission of the data flow is completed within the maximum tolerable delay when the event triggers.

It should be noted that the periodic resource reservation can be the reservation of time slots within the transmission period, or the terminal through which the event-triggered data stream is transmitted, determined according to the transmission path of the event-triggered data stream, as shown in Figure 16 The transmission from the first device to the fifth device passes through the second device and the sixth device respectively, and the first device, the second device, the sixth device and the fifth form a transmission path of an event-triggered data stream. The time slot for transmitting the event-triggered data stream is reserved for the event-triggered data stream to the port of the terminal, preventing the port from being occupied by other data streams to block the transmission of the event-triggered data stream.

Step S820: Determine the second time slots in the transmission cycle, where the distribution of the second time slots in each transmission cycle is the same.

In this step, since the transmission period of the event-triggered data flow is set in step S810, the second time slot is determined in the transmission period. When an event-triggered data flow occurs in any time slot, it is guaranteed that the event-triggered data flow occurring in any time slot The data stream can be transmitted in the second time slot, and the time interval between any time slot and the second time slot cannot be greater than the tolerable maximum delay of the event-triggered data stream. Wherein, the distribution of the second time slot in each transmission period is the same, ensuring that sending an event-triggered data stream at any time can meet the transmission time requirement. In an optional implementation, referring to FIG. 15 , in the TSN technology, the transmission period T of the event-triggered data stream is set, and within one transmission period T, 10 transmission time slots are divided, and each time slot corresponds to a transmission The duration of the gate of the queue to allow the data flow in the corresponding transmission queue to be transmitted. The event-triggered data flow is arranged to be output on time slot 2 and time slot 5, and the gate of the second transmission queue for buffering the event-triggered data flow is opened in the time segment of time slot 2 and time slot 5, allowing the event-triggered data flow to proceed transmission. The distribution of the second time slot in each transmission cycle is the same, that is to say, time slot 2 and time slot 5 are reserved and allocated to event-triggered data streams in all transmission cycles, ensuring that all event-triggered data streams The distribution of the second time slots in all transmission periods is the same, no matter in which time slot the event-triggered data stream is received, the event-triggered data stream can meet the transmission delay requirement when it arrives at the second time slot for transmission.

It should be noted that the second transmission queue of the data flow triggered by the buffering event is only opened in the second time slot.

In this embodiment, by adopting the above steps S810 to S820, the transmission period of the event-triggered data stream is set first, and then the second time slot is determined in the transmission period, wherein the distribution of the second time slot in each transmission period is uniform Similarly, in order to achieve the purpose that the time-sensitive event-triggered data flow can be transmitted within the maximum tolerable delay.

In an embodiment, as shown in FIG. 9 , step S810 is further described, and step S810 may include but not limited to step S8111 and step S8112 .

Step S8111: Obtain the tolerable delay values of all types of event-triggered data streams.

In this step, the tolerable delay values of all types of event-triggered data streams are obtained. Event-triggered data streams include sudden sporadic streams or periodic streams, such as system alarms, message reminders, etc. Different types of event-triggered data streams The tolerable delay values of can be different. The tolerable delay value may be the maximum tolerable delay value, or any delay value within the tolerable delay range, which is not limited in this embodiment.

Step S8112: Trigger the transmission period of the data flow according to the one setting event with the largest value among all tolerable delay values.

In this step, since the tolerable delay values of all types of event-triggered data streams have been obtained in step S8111, the transmission period of the event-triggered data stream can be set according to the largest value among all tolerable delay values. The setting of the transmission cycle size of the event-triggered data stream needs to ensure that the periodically reserved resources can ensure that the event-triggered data stream is transmitted within the maximum tolerable delay.

It should be noted that since the event-triggered data stream may also be a time-sensitive data stream, the event-triggered data stream also needs to be transmitted within a tolerable maximum delay. The size of the event-triggered data stream transmission period can be set according to the maximum tolerable delay of all types of event-triggered data streams. If the transmission cycle T is less than the tolerable maximum time delay Dmax, the transmission cycle T can be set to half of the maximum time delay, that is, T=1/2Dmax. Wherein, the shorter the transmission period, the higher the tolerance of the network to event-triggered data flow.

In this embodiment, by adopting the above steps S810 to S820, the tolerable delay values of all types of event-triggered data streams are obtained first, and then the value of the event-triggered data stream is set according to the largest value among all tolerable delay values. Transmission period, in order to achieve the purpose of setting the transmission period of the event-triggered data flow.

In an embodiment, as shown in FIG. 10 , step S810 is further described, and step S810 may include but not limited to step S8121 and step S8122 .

Step S8121: Determine the quantity ratio of time-triggered data streams and event-triggered data streams.

In this step, the size of the transmission period can also be modified and set according to the proportion of the number of data streams that may exist in the network. First receive the time-triggered data flow and the event-triggered data flow, and then determine the quantity ratio of the time-triggered data flow and the event-triggered data flow. Obtain the quantity ratio according to the quantity, or traverse the cached or saved data streams to obtain the number of time-triggered data streams and the number of event-triggered data streams, and then determine the proportion of time-triggered data streams and event-triggered data streams.

In addition, in an optional implementation manner, determining the ratio of time-triggered data streams and event-triggered data streams may also be set by the user according to a preset ratio of data streams, and the preset ratio of data streams Refers to the ratio of the number of time-triggered data streams and event-triggered data streams determined by the user according to the application scenario.

Step S8122: Set the transmission period of the event-triggered data stream according to the quantity ratio.

In this step, since the quantity ratio of the time-triggered data flow and the event-triggered data flow is determined in step S8121, the transmission period of the event-triggered data flow can be set according to the quantity ratio. Time-triggered data streams and event-triggered data streams are both time-sensitive. Therefore, while ensuring the joint transmission of time-triggered data streams and event-triggered data streams, it is also necessary to ensure that the transmission of data streams does not exceed the corresponding maximum tolerable delay. In an optional implementation, the time-triggered data flow and the event-triggered data flow are buffered in different transmission queues, queued for transmission according to the first-in-first-out rule, and the transmission cycle of the event-triggered data flow is set according to the quantity ratio to ensure The reserved second time slots will not occupy too many first time slots of the time-triggered data flow, so as to avoid too many time-triggered data flows exceeding the delay requirement.

It should be noted that the transmission cycle is set according to the proportion of the number of data streams, and then the number of reserved time slots is set according to the transmission cycle. This method can improve the bandwidth utilization of the link and avoid the transmission of data streams from exceeding the delay. the purpose of the request.

In this embodiment, by adopting the above steps S8121 to S8122, first determine the quantity ratio of the time-triggered data flow and the event-triggered data flow, and then set the transmission cycle of the event-triggered data flow according to the quantity ratio, and the transmission cycle of the event-triggered data flow The smaller the value, the higher the tolerance of the network to the event-triggered data flow. This embodiment can reasonably set the transmission cycle according to the ratio of the number of time-triggered data flows and event-triggered data flows, and realizes the time-triggered data flow and event-triggered data flow. common transmission, and also achieve the purpose of reasonably setting the transmission period of the event-triggered data stream.

In addition, an embodiment of the present invention also provides a network device, the network device includes: at least one processor and a memory for communicating with the at least one processor; the memory stores instructions that can be executed by the at least one processor , the instruction is executed by at least one processor.

The processor and memory can be connected by a bus or other means.

As a non-transitory computer-readable storage medium, memory can be used to store non-transitory software programs and non-transitory computer-executable programs. In addition, the memory may include high-speed random access memory, and may also include non-transitory memory, such as at least one magnetic disk storage device, flash memory device, or other non-transitory solid-state storage devices. In some embodiments, the memory optionally includes memory located remotely from the processor, and these remote memories may be connected to the processor via a network. Examples of the aforementioned networks include, but are not limited to, the Internet, intranets, local area networks, mobile communication networks, and combinations thereof.

The non-transitory software programs and instructions required to realize the data processing method of the above-mentioned embodiment are stored in the memory, and when executed by the processor, the data processing method in the above-mentioned embodiment is executed, for example, the above-described execution in FIG. 1 Method steps S110 to S140, method steps S121 to S122 in FIG. 2, method steps S141 to S142 in FIG. 3, method steps S150 to S170 in FIG. 4, method steps S1711 to S1714 in FIG. Method steps S1721 to S1722, method steps S17221 to S17222 in FIG. 7 , method steps S810 to S820 in FIG. 8 , method steps S8111 to S8112 in FIG. 9 , method steps S8121 to S8122 in FIG. 10 .

In addition, an embodiment of the present invention also provides a computer-readable storage medium, the computer-readable storage medium stores computer-executable instructions, and the computer-executable instructions are executed by a processor or a controller, for example, by the above-mentioned Execution by a processor of the network device in the embodiment can cause the processor to execute the data processing method in the above embodiment, for example, execute the method steps S110 to S140 in FIG. 1 and the method step S121 in FIG. 2 described above Method steps S141 to S142 in Fig. 3, method steps S150 to S170 in Fig. 4, method steps S1711 to S1714 in Fig. 5, method steps S1721 to S1722 in Fig. 6, method steps S17221 in Fig. 7 to S122, Fig. 3 to S17222, method steps S810 to S820 in FIG. 8 , method steps S8111 to S8112 in FIG. 9 , method steps S8121 to S8122 in FIG. 10 .

Those skilled in the art can understand that all or some of the steps and systems in the methods disclosed above can be implemented as software, firmware, hardware and an appropriate combination thereof. Some or all of the physical components may be implemented as software executed by a processor, such as a central processing unit, digital signal processor, or microprocessor, or as hardware, or as an integrated circuit, such as an application-specific integrated circuit . Such software may be distributed on computer readable media, which may include computer storage media (or non-transitory media) and communication media (or transitory media). As known to those of ordinary skill in the art, the term computer storage media includes both volatile and nonvolatile media implemented in any method or technology for storage of information, such as computer readable instructions, data structures, program modules, or other data. permanent, removable and non-removable media. Computer storage media includes, but is not limited to, RAM, ROM, EEPROM, flash memory or other memory technology, CD-ROM, digital versatile disk (DVD) or other optical disk storage, magnetic cartridges, tape, magnetic disk storage or other magnetic storage devices, or can Any other medium used to store desired information and which can be accessed by a computer. In addition, as is well known to those of ordinary skill in the art, communication media typically embodies computer readable instructions, data structures, program modules, or other data in a modulated data signal such as a carrier wave or other transport mechanism, and may include any information delivery media .

The above is a specific description of the preferred implementation of the present invention, but the present invention is not limited to the above-mentioned implementation, and those skilled in the art can also make various equivalent deformations or replacements without violating the spirit of the present invention. Equivalent modifications or replacements are all within the scope defined by the claims of the present invention.

Claims (12)

1. A data processing method, comprising:

receiving a time-triggered data stream;

transmitting the time-triggered data stream in a first time slot;

receiving an event-triggered data stream;

the event triggered data stream is transmitted in a second time slot, wherein the first time slot and the second time slot are different time slots in the same transmission period.

2. The data processing method according to claim 1, wherein the transmitting the time-triggered data stream in the first slot comprises:

caching the time-triggered data stream in a first transmission queue;

and starting the first transmission queue in a first time slot according to preset queue switch information, so that the time triggering data stream is transmitted in the first time slot.

3. The data processing method according to claim 2, wherein said transmitting said event-triggered data stream in the second time slot comprises:

Buffering the event-triggered data stream in a second transmission queue;

and opening the second transmission queue in a second time slot according to the queue switch information, so that the event-triggered data stream is transmitted in the second time slot, wherein the second transmission queue has the same transmission priority as the first transmission queue, and the second transmission queue is not opened at the same time as the first transmission queue.

4. A data processing method according to claim 3, characterized in that the data processing method further comprises:

receiving a normal data stream;

the common data stream is cached in a third transmission queue, and the transmission priority of the third transmission queue is lower than that of the first transmission queue;

and determining whether to transmit the common data stream according to the queue switch information.

5. The data processing method of claim 4, wherein said determining whether to transmit the normal data stream based on the queue switch information comprises:

when the first transmission queue and the third transmission queue are simultaneously started according to the queue switching information, determining that the common data stream is not transmitted;

or,

When the first transmission queue is started but the third transmission queue is not started according to the queue switch information, determining that the common data stream is not transmitted;

or,

when the first transmission queue and the second transmission queue are not started according to the queue switch information, but the third transmission queue is started, determining to transmit the common data stream, and performing transmission processing on the common data stream;

or,

and when the second transmission queue and the third transmission queue are simultaneously started according to the queue switch information, and the event trigger data stream is cached in the second transmission queue, determining that the common data stream is not transmitted.

6. The data processing method of claim 4, wherein said determining whether to transmit the normal data stream based on the queue switch information comprises:

and when the second transmission queue and the third transmission queue are simultaneously started according to the queue switch information and the event trigger data stream is not cached by the second transmission queue, determining to transmit the common data stream and performing transmission processing on the common data stream.

7. The data processing method according to claim 6, wherein said performing transmission processing on said normal data stream includes:

Reducing the transmission priority of the second transmission queue so that the transmission priority of the second transmission queue is smaller than the transmission priority of the third transmission queue;

and transmitting the common data stream through the second time slot.

8. The data processing method of claim 1, wherein the data processing method further comprises, prior to the transmission of the event triggered data stream in the second time slot:

setting a transmission period of the event-triggered data stream;

and determining the second time slot in the transmission period, wherein the distribution of the second time slot in each transmission period is the same.

9. The data processing method according to claim 8, wherein the setting the transmission period of the event-triggered data stream includes:

obtaining the tolerable delay values of all kinds of event trigger data streams;

and setting the transmission period of the event-triggered data stream according to the one with the largest value in all the tolerable delay values.

10. The data processing method according to claim 8, wherein the setting the transmission period of the event-triggered data stream includes:

determining a quantity ratio of the time triggered data stream and the event triggered data stream;

And setting the transmission period of the event-triggered data stream according to the quantity proportion.

11. A network device comprising at least one processor and a memory for communication connection with the at least one processor; the memory stores instructions executable by the at least one processor to enable the at least one processor to perform the data processing method of any one of claims 1 to 10.

12. A computer-readable storage medium storing computer-executable instructions for causing a computer to perform the data processing method according to any one of claims 1 to 10.

Images