CN104717191A - Message processing method and device - Google Patents

Abstract

Embodiments of the present invention provide a message processing method and device. The message processing method of the present invention includes: determining whether the message to be sent is a delay-sensitive message or a time-delay-insensitive message; sending the message to a receiving device, so that the receiving device is sensitive to the delay message Perform interrupt processing and poll processing for delay-insensitive packets. The embodiment of the present invention satisfies the requirement on time delay in the message processing process, and controls the overhead of the CPU.

Description

Message processing method and device

technical field

Embodiments of the present invention relate to communication technologies, and in particular to a message processing method and device.

Background technique

The network system is to use communication equipment and lines to interconnect multiple nodes. Through the interconnection of nodes, the communication between nodes is realized, so as to realize the sharing of information, software and equipment resources between nodes, and collaborative work. In the process of communication between nodes, the sender transmits the message to be sent to the receiver through the network protocol and network equipment, and the receiver receives the message from the other party through the network device and network protocol, which involves the sending of the message and Receive processing.

In the existing communication process, there are two main methods for processing messages at the receiving end: 1. Interrupt processing: after receiving each message, an interrupt is triggered to process the received message; 2. Polling processing: timing Query whether there is a message arriving, and if so, process the received message.

For the first solution, the number of interrupts is too many, resulting in excessive CPU overhead; in the second solution, if the polling interval is large, it will inevitably lead to a large message delay; if the polling interval is too small, the polling interval will be large. The query thread may idle, and the overhead of thread switching is relatively large.

Contents of the invention

Embodiments of the present invention provide a message processing method and device to overcome the excessive CPU overhead caused by too many interrupts in message interrupt processing, and the polling thread idling due to too small polling intervals in polling processing. The problem of excessive switching overhead.

A first aspect of the present invention provides a message processing method, including:

Determine whether the message to be sent is a delay sensitive message or a delay insensitive message;

Sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message.

In a first possible implementation manner of the first aspect, before sending the message to the receiving device, the method further includes:

If the message to be sent is a delay-sensitive message, carrying a delay-sensitive identifier in the message;

The sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message, includes:

Sending the message to the receiving device, so that if the receiving device obtains the delay-sensitive identifier from the message, then interrupt processing of the message; if the delay-sensitive identifier is not obtained, then The message is polled.

With reference to the implementation manner of the first aspect, in a second possible implementation manner of the first aspect, the sending the message to the receiving device, so that the receiving device performs interrupt processing on the delay-sensitive message, and the Delay-insensitive packets are polled, including:

If the message is a delay-sensitive message, sending the message to the receiving device, and triggering an interruption of the receiving device to perform interrupt processing on the message.

With reference to the second possible implementation manner of the first aspect, in a third possible implementation manner of the first aspect, triggering an interruption of the receiving device to perform interruption processing on the message includes:

Sending an event message to the receiving device, where the event message is used to trigger the receiving device to interrupt processing of the message.

With reference to any one of the possible implementations from the first aspect to the third aspect of the first aspect, in the fourth possible implementation of the first aspect, the determining whether the message to be sent is a delay-sensitive message or a time-sensitive Before delaying insensitive packets, it also includes:

receiving the message to be sent and a delay-sensitive notification sent by an upper-layer application, where the delay-sensitive notification is used to indicate whether the message to be sent is delay-sensitive;

The determining whether the message to be sent is a delay sensitive message or a delay insensitive message includes:

According to the delay-sensitive notification, determine whether the packet to be sent is a delay-sensitive packet or a delay-insensitive packet.

A second aspect of the present invention provides a message processing method, including:

Receive the message sent by the sending device;

determining whether the packet is a delay-sensitive packet or a delay-insensitive packet;

If the message is a delay-sensitive message, interrupt processing is performed on the message;

If the message is a delay-insensitive message, polling is performed on the message.

In a first possible implementation manner of the second aspect, the determining whether the packet is a delay-sensitive packet or a delay-insensitive packet includes:

If the packet carries a delay-sensitive identifier, determining that the packet is a delay-sensitive packet;

If the packet does not carry a delay-sensitive identifier, it is determined that the packet is a delay-insensitive packet.

In combination with the implementation manner of the second aspect, in a second possible implementation manner of the second aspect, the determining whether the packet is a delay-sensitive packet or a delay-insensitive packet includes:

If the interrupt corresponding to the message is triggered by the sending device after receiving the message, it is determined that the message is a delay-sensitive message.

With reference to the second possible implementation of the second aspect, in a third possible implementation of the second aspect, the interrupt corresponding to the message triggered by the sending device includes:

receiving an event message sent by the sending device after sending the message, where the event message is used to trigger the receiving device to interrupt processing of the message.

A third aspect of the present invention provides a message processing device, including:

A determining module, configured to determine whether the message to be sent is a delay-sensitive message or a delay-insensitive message;

The sending module is configured to send the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message.

In the first possible implementation manner of the third aspect, it also includes:

A carrying module, configured to carry a delay-sensitive identifier in the message if the message to be sent is a delay-sensitive message before the sending module sends the message to the receiving device;

The sending module is specifically used for:

Sending the message to the receiving device, so that if the receiving device obtains the delay-sensitive identifier from the message, then interrupt processing of the message; if the delay-sensitive identifier is not obtained, then The message is polled.

In combination with the implementation of the third aspect, in a second possible implementation of the third aspect, the sending module is specifically configured to:

If the message is a delay-sensitive message, sending the message to the receiving device, and triggering an interruption of the receiving device to perform interrupt processing on the message.

With reference to the second possible implementation of the third aspect, in a third possible implementation of the third aspect, the sending module is specifically configured to:

Sending an event message to the receiving device, where the event message is used to trigger the receiving device to interrupt processing of the message.

Combining the third aspect to any third possible implementation manner of the third aspect, in the fourth possible implementation manner of the third aspect, it also includes:

The receiving module is used to receive the message to be sent and the delay sensitive notification sent by the upper layer application before the determining module determines whether the message to be sent is a delay-sensitive message or a delay-insensitive message, the The delay sensitive notification is used to indicate whether the message to be sent is sensitive to delay;

The determination module is specifically used for:

According to the delay-sensitive notification, determine whether the packet to be sent is a delay-sensitive packet or a delay-insensitive packet.

A fourth aspect of the present invention provides a message processing device, including:

The receiving module is used to receive the message sent by the sending device;

A determining module, configured to determine whether the packet is a delay-sensitive packet or a delay-insensitive packet;

A processing module, configured to perform interrupt processing on the message if the message is a delay-sensitive message, and perform polling processing on the message if the message is a delay-insensitive message .

In a first possible implementation manner of the fourth aspect, the determining module is specifically configured to:

If the packet carries a delay-sensitive identifier, determining that the packet is a delay-sensitive packet;

If the packet does not carry a delay-sensitive identifier, it is determined that the packet is a delay-insensitive packet.

With reference to the first possible implementation of the fourth aspect, in a second possible implementation of the fourth aspect, the determining module is specifically configured to:

If the interrupt corresponding to the message is triggered by the sending device after receiving the message, it is determined that the message is a delay-sensitive message.

With reference to the second possible implementation of the fourth aspect, in a third possible implementation of the fourth aspect, the determining module is specifically configured to:

receiving an event message sent by the sending device after sending the message.

The message processing method and device of the embodiment of the present invention determine the message to be sent as a delay-sensitive message and a delay-insensitive message so that the receiving device can interrupt the delay-sensitive message, and the delay is not affected. Sensitive packets are polled. The message processing method corresponds to the sensitivity of the message to delay, which solves the problem of excessive CPU overhead caused by interrupt processing messages in message processing and polling thread idling or high overhead caused by polling messages. . The CPU overhead is controlled while meeting the delay requirement.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description These are some embodiments of the present invention. For those skilled in the art, other drawings can also be obtained according to these drawings without any creative effort.

FIG. 1 is a flowchart of Embodiment 1 of the message processing method of the present invention;

FIG. 2 is a flow chart of Embodiment 2 of the message processing method of the present invention;

FIG. 3 is a schematic structural diagram of Embodiment 1 of the message processing device of the present invention;

FIG. 4 is a schematic structural diagram of Embodiment 2 of the message processing device of the present invention;

FIG. 5 is a schematic structural diagram of Embodiment 3 of a message processing device according to the present invention.

Detailed ways

In order to make the purpose, technical solutions and advantages of the embodiments of the present invention clearer, the technical solutions in the embodiments of the present invention will be clearly and completely described below in conjunction with the drawings in the embodiments of the present invention. Obviously, the described embodiments It is a part of embodiments of the present invention, but not all embodiments. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of the present invention.

Fig. 1 is a flowchart of Embodiment 1 of the message processing method of the present invention. As shown in Fig. 1, the method of this embodiment may include:

Step 101, determine whether the message to be sent is a delay sensitive message or a delay insensitive message;

Specifically, distinguishing the packets to be sent into delay-sensitive packets and delay-insensitive packets depends on specific application scenarios and systems. For different systems and application scenarios, the criteria for judging sensitivity to delay are different. For example, in a storage device, the delay of operations such as configuration management can be regarded as delay-insensitive within tens to hundreds of milliseconds; therefore, the packets whose delay is within the range are determined as delay-insensitive In other end-to-end operating systems such as I/O, the delay requirement is generally a few milliseconds, or even lower than 1 millisecond. Therefore, the message with a delay within this range is determined to be delay-sensitive message.

Step 102: Send the message to the receiving device, so that the receiving device performs interrupt processing on the delay-sensitive message and polls the delay-insensitive message.

Optionally, if the message to be sent is a delay-sensitive message, carrying a delay-sensitive identifier in the message;

The sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message, includes:

Sending the message to the receiving device, so that if the receiving device obtains the delay-sensitive identifier from the message, then interrupt processing of the message; if the delay-sensitive identifier is not obtained, then The message is polled.

Specifically, the messages to be sent are divided into delay-sensitive messages and delay-insensitive messages, and only delay-sensitive messages are carried in the delay-sensitive messages, so that the receiving device receives the message It is determined that the message is a delay-sensitive message and interrupt processing is performed on the message, and the message for which the delay-sensitive identification is not obtained is processed by polling. The time-delay-sensitive identifier may be a special field added only at the header of the message, or a special field only added at the end of the message, or a special field may be added at the beginning and the end of the message at the same time. It should be noted that this embodiment does not limit the specific implementation manner of the delay-sensitive identifier carried in the delay-sensitive message in the message to be sent.

Optionally, the sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message, includes:

If the message is a delay-sensitive message, sending the message to the receiving device, and triggering an interruption of the receiving device to perform interrupt processing on the message.

Further, the triggering the receiving device to interrupt to perform interrupt processing on the message includes:

An event message is appended after the delay-sensitive message, and the event message is used to trigger the receiving device to interrupt processing of the message.

Specifically, for distinguishing the packets to be sent into delay-sensitive packets and delay-insensitive packets, no processing is done on the packets themselves, but the delay-sensitive packets among them are used as additional event packets In such a way that when receiving the delay-sensitive message, the processor of the receiving device directly triggers an interrupt by an event message attached to the message to interrupt processing of the message. The additional event message is a Message Signaled Interrupt mechanism (English: Message Signaled Interrupt, MSI for short) adopted. It should be noted that this embodiment does not limit the specific implementation of directly triggering an interrupt. It is also possible to trigger and interrupt the receiving device through other network protocols or chip direct triggering.

Further, before determining whether the message to be sent is a delay-sensitive message or a delay-insensitive message, it also includes:

receiving the message to be sent and a delay-sensitive notification sent by an upper-layer application, where the delay-sensitive notification is used to indicate whether the message to be sent is delay-sensitive;

The determining whether the message to be sent is a delay sensitive message or a delay insensitive message includes:

According to the delay-sensitive notification, determine whether the packet to be sent is a delay-sensitive packet or a delay-insensitive packet.

Specifically, whether the message to be sent is delay-sensitive in the embodiment of the present invention is notified by the upper-layer application when sending the delay-sensitive notification. Determine whether the message to be sent is a delay-sensitive message according to the delay-sensitive notification.

In this embodiment, by distinguishing the messages to be sent into delay-sensitive messages and delay-insensitive messages, the receiving device interrupts the delay-sensitive messages and polls the delay-insensitive messages . It solves the problem of excessive CPU overhead caused by interrupt processing messages in message processing and the problem of idle running or high overhead of polling threads for message processing. The CPU overhead is controlled while meeting the delay requirement.

Fig. 2 is a flow chart of Embodiment 2 of the message processing method of the present invention. As shown in Fig. 2, the method of this embodiment may include:

Step 201, receiving the message sent by the sending device;

Step 202, determining whether the packet is a delay-sensitive packet or a delay-insensitive packet;

Step 203, if the message is a delay-sensitive message, perform interrupt processing on the message;

Step 204, if the packet is a delay-insensitive packet, perform polling processing on the packet.

Optionally, the determining whether the packet is a delay-sensitive packet or a delay-insensitive packet includes:

If the packet carries a delay-sensitive identifier, determining that the packet is a delay-sensitive packet;

If the packet does not carry a delay-sensitive identifier, it is determined that the packet is a delay-insensitive packet.

Specifically, if the receiving device obtains the delay-sensitive identifier from the received message, it determines that the message is a delay-sensitive message, and for a message that does not obtain a delay-sensitive identifier, it determines that it is not delay-sensitive message. The delay-sensitive packets are interrupted, and the delay-insensitive packets wait for polling. Specifically, the receiving device receives the message sent by the sending device, and distinguishes the received message into a delay-sensitive message and a delay-insensitive message. Wherein, interrupt processing is performed for time-delay-sensitive packets; and polling processing is performed for time-delay-insensitive packets. The receiving device obtains the delay-sensitive identifier carried by the message from the received message, and if the receiving device obtains the delay-sensitive identifier, then determines that the message is a delay-sensitive message, and if the receiving device supports priority queues, Then add the message to the high priority queue, the more sensitive the message is to the delay, the higher the corresponding priority, and the receiving device directly triggers the interrupt and prioritizes the message; if the receiving device is receiving If no delay-sensitive identifier is obtained in the message, it is determined that the message is a delay-insensitive message, and polling is performed on the message. Delay-sensitive packets added to the high-priority queue are processed in the order of priority, and delay-insensitive packets waiting for polling processing are processed in the normal queue corresponding to the order in which the packets are received.

Optionally, the determining whether the packet is a delay-sensitive packet or a delay-insensitive packet includes:

If the interrupt corresponding to the message is triggered by the sending device after receiving the message, it is determined that the message is a delay-sensitive message.

Further, the interrupt corresponding to the message triggered by the sending device includes:

receiving an event message sent by the sending device after sending the message.

Specifically, if the receiving device receives an event message after receiving the message sent by the sending device, and the message directly triggers an interrupt of the receiving device for interrupt processing, then the message is determined to be a delay-sensitive message. Among the messages received by the receiving device, the messages that are not directly interrupted by the event message are determined as delay-insensitive messages and wait for polling processing.

It should be noted that in the embodiment of the present invention, when the receiving device processes the received message, both the interrupt processing and the polling processing need to disable the interrupt first, so as to prevent the interrupt from being triggered again and stop the processing. Correspondingly, the interrupt is turned on after the processing is finished.

In this embodiment, the receiving device distinguishes the received messages into delay-sensitive messages and delay-insensitive messages, performs interrupt processing on delay-sensitive messages, and performs polling processing on delay-insensitive messages. The message processing method corresponds to the sensitivity of the message to delay, which solves the problem of excessive CPU overhead caused by interrupt processing messages in message processing and polling thread idling or high overhead caused by polling messages. . The CPU overhead is controlled while meeting the delay requirement.

FIG. 3 is a schematic structural diagram of Embodiment 1 of the message processing device of the present invention. As shown in FIG. 3, the device of this embodiment may include:

Determining module 101, configured to determine whether the message to be sent is a delay sensitive message or a delay insensitive message;

The sending module 102 is configured to send the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message.

Further, the sending module is specifically used for:

If the message is a delay-sensitive message, sending the message to the receiving device, and triggering an interruption of the receiving device to perform interrupt processing on the message.

Further, the sending module is specifically used for:

An event message sent to the receiving device, where the event message is used to trigger the receiving device to interrupt processing of the message according to the identification information.

The device of this embodiment can be used to implement the technical solution of the method embodiment shown in FIG. 1 , and its implementation principle and technical effect are similar, and will not be repeated here.

Fig. 4 is a schematic structural diagram of Embodiment 2 of the message processing device of the present invention. As shown in Fig. 4, the device of this embodiment may further include:

The carrying module 103 is configured to carry a delay-sensitive identifier in the message if the message to be sent is a delay-sensitive message before the sending module sends the message to the receiving device;

The receiving module 105 is used to receive the message to be sent and the delay-sensitive notification sent by the upper layer application before the determining module determines whether the message to be sent is a delay-sensitive message or a delay-insensitive message, The delay-sensitive notification is used to indicate whether the message to be sent is delay-sensitive.

The device of this embodiment can be used to implement the technical solution of the method embodiment shown in FIG. 1 , and its implementation principle and technical effect are similar, and will not be repeated here.

Fig. 5 is a schematic structural diagram of Embodiment 3 of the message processing device of the present invention. As shown in Fig. 5, the device of this embodiment may include:

The receiving module 201 is configured to receive the message sent by the sending device;

A determining module 202, configured to determine whether the message is a delay-sensitive message or a time-delay-insensitive message;

The processing module 203 is configured to perform interrupt processing on the message if the message is a delay-sensitive message, and poll the message if the message is a delay-insensitive message deal with.

Optionally, the determining module is specifically configured to:

If the packet carries a delay-sensitive identifier, determining that the packet is a delay-sensitive packet;

If the packet does not carry a delay-sensitive identifier, it is determined that the packet is a delay-insensitive packet.

Optionally, the determining module is specifically configured to:

If the interrupt corresponding to the message is triggered by the sending device after receiving the message, it is determined that the message is a delay-sensitive message.

Further, the determining module is specifically used for:

receiving an event message sent by the sending device after sending the message.

The device of this embodiment can be used to implement the technical solution of the method embodiment shown in FIG. 2 , and its implementation principle and technical effect are similar, and will not be repeated here.

Those of ordinary skill in the art can understand that all or part of the steps for implementing the above method embodiments can be completed by program instructions and related hardware. The aforementioned program can be stored in a computer-readable storage medium. When the program is executed, it executes the steps of the above-mentioned method embodiments; and the aforementioned storage medium includes: ROM, RAM, magnetic disk or optical disk and other various media that can store program codes.

Finally, it should be noted that: the above embodiments are only used to illustrate the technical solutions of the present invention, rather than limiting them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: It is still possible to modify the technical solutions described in the foregoing embodiments, or perform equivalent replacements for some or all of the technical features; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the technical solutions of the various embodiments of the present invention. scope.

Claims (18)

1. A message processing method, characterized in that, comprising: Determine whether the message to be sent is a delay sensitive message or a delay insensitive message; Sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message. 2. The method according to claim 1, wherein before sending the message to the receiving device, further comprising: If the message to be sent is a delay-sensitive message, carrying a delay-sensitive identifier in the message; The sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message, includes: Sending the message to the receiving device, so that if the receiving device obtains the delay-sensitive identifier from the message, then interrupt processing of the message; if the delay-sensitive identifier is not obtained, then The message is polled. 3. The method according to claim 1, wherein the sending the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and processes the delay-insensitive message Polling processing, including: If the message is a delay-sensitive message, sending the message to the receiving device, and triggering an interrupt of the receiving device to perform interrupt processing on the message. 4. The method according to claim 3, wherein the triggering the interrupt of the receiving device to perform interrupt processing on the message comprises: Sending an event message to the receiving device, where the event message is used to trigger the receiving device to interrupt processing of the message. 5. The method according to any one of claims 1 to 4, wherein before determining whether the message to be sent is a delay-sensitive message or a delay-insensitive message, it further includes: receiving the message to be sent and a delay-sensitive notification sent by an upper-layer application, where the delay-sensitive notification is used to indicate whether the message to be sent is delay-sensitive; The determining whether the message to be sent is a delay sensitive message or a delay insensitive message includes: According to the delay-sensitive notification, determine whether the packet to be sent is a delay-sensitive packet or a delay-insensitive packet. 6. A message processing method, characterized in that, comprising: Receive the message sent by the sending device; determining whether the packet is a delay-sensitive packet or a delay-insensitive packet; If the message is a delay-sensitive message, interrupt processing is performed on the message; If the message is a delay-insensitive message, polling is performed on the message. 7. The method according to claim 6, wherein the determining whether the message is a delay-sensitive message or a delay-insensitive message comprises: If the packet carries a delay-sensitive identifier, determining that the packet is a delay-sensitive packet; If the packet does not carry a delay-sensitive identifier, it is determined that the packet is a delay-insensitive packet. 8. The method according to claim 6, wherein the determining whether the message is a delay-sensitive message or a delay-insensitive message comprises: If the interrupt corresponding to the message is triggered by the sending device after receiving the message, it is determined that the message is a delay-sensitive message. 9. The method according to claim 8, wherein the interrupt corresponding to the message triggered by the sending device comprises: receiving an event message sent by the sending device after sending the message, where the event message is used to trigger the receiving device to interrupt processing of the message. 10. A device for message processing, comprising: A determining module, configured to determine whether the message to be sent is a delay-sensitive message or a delay-insensitive message; The sending module is configured to send the message to the receiving device, so that the receiving device interrupts the delay-sensitive message and polls the delay-insensitive message. 11. The device according to claim 10, further comprising: A carrying module, configured to carry a delay-sensitive identifier in the message if the message to be sent is a delay-sensitive message before the sending module sends the message to the receiving device; The sending module is specifically used for: Sending the message to the receiving device, so that if the receiving device obtains the delay-sensitive identifier from the message, then interrupt processing of the message, and if the delay-sensitive identifier is not obtained, then The message is polled. 12. The device according to claim 10, wherein the sending module is specifically used for: If the message is a delay-sensitive message, sending the message to the receiving device, and triggering an interruption of the receiving device to perform interrupt processing on the message. 13. The device according to claim 12, wherein the sending module is specifically used for: Sending an event message to the receiving device, where the event message is used to trigger the receiving device to interrupt processing of the message. 14. The device according to any one of claims 10-13, further comprising: The receiving module is used to receive the message to be sent and the delay sensitive notification sent by the upper layer application before the determining module determines whether the message to be sent is a delay-sensitive message or a delay-insensitive message, the The delay sensitive notification is used to indicate whether the message to be sent is sensitive to delay; The determination module is specifically used for: According to the delay-sensitive notification, determine whether the packet to be sent is a delay-sensitive packet or a delay-insensitive packet. 15. A message processing device, comprising: The receiving module is used to receive the message sent by the sending device; A determining module, configured to determine whether the packet is a delay-sensitive packet or a delay-insensitive packet; A processing module, configured to perform interrupt processing on the message if the message is a delay-sensitive message, and perform polling processing on the message if the message is a delay-insensitive message . 16. The device according to claim 15, wherein the determining module is specifically configured to: If the packet carries a delay-sensitive identifier, determining that the packet is a delay-sensitive packet; If the packet does not carry a delay-sensitive identifier, it is determined that the packet is a delay-insensitive packet. 17. The device according to claim 16, wherein the determining module is specifically configured to: If the interrupt corresponding to the message is triggered by the sending device after receiving the message, it is determined that the message is a delay-sensitive message. 18. The device according to claim 17, wherein the determining module is specifically configured to: receiving an event message sent by the sending device after sending the message.