Data transmission method and system for transmitting data between processes using shared memory block indexes

Patent metadata

Field	Value
Publication number	US-10423542-B2
Application number	US-201615281261-A
Country	US
Kind code	B2
Filing date	Sep 30, 2016
Priority date	Jun 24, 2016
Publication date	Sep 24, 2019
Grant date	Sep 24, 2019

Abstract

A method and a system for transmitting data are disclosed. A method embodiment comprises: acquiring a most recent shared memory block index of a shared memory segment by a data receiver, the shared memory segment being used by a data transmitter and the data receiver to transmit data; deciding whether the most recent shared memory block index is consistent with a shared memory block index corresponding to data recently read by the data receiver; and determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index, where the determining includes reading the data in the shared memory block corresponding to the most recent shared memory block index when the decision indicates that the most recent shared memory block index is inconsistent with the shared memory block index corresponding to the data recently read by the data receiver.

First claim

What is claimed is:

1. A data transmission method, the method comprising:
acquiring a most recent shared memory block index of a shared memory segment by a data receiver, the shared memory segment being used by a data transmitter and the data receiver to transmit data, the most recent shared memory block index being used for indicating an address of a shared memory block in a shared memory segment where data recently written by the data transmitter is located;
deciding whether the most recent shared memory block index is consistent with a shared memory block index corresponding to data recently read by the data receiver; and
determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index,
wherein the determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index comprises:
ignoring the data in the shared memory block corresponding to the most recent shared memory block index if the decision indicates that the most recent shared memory block index is consistent with the shared memory block index corresponding to the data recently read by the data receiver; and
reading the data in the shared memory block corresponding to the most recent shared memory block index when the decision indicates that the most recent shared memory block index is inconsistent with the shared memory block index corresponding to the data recently read by the data receiver,
wherein the shared memory segment comprises a general flag variable and a general flag lock variable, the general flag variable being used for storing the most recent shared memory block index; and
the acquiring the most recent shared memory block index of the shared memory segment by the data receiver comprising:
acquiring the general flag lock variable by the data receiver; and
reading the general flag variable so as to acquire the most recent shared memory block index of the share memory segment.

2. The method according to claim 1 , wherein the data transmitter is a data transmitting process, and the data receiver is a data receiving process.

3. The method according to claim 2 , the method further comprising:
acquiring the general flag lock variable by the data transmitting process;
determining an index of a shared memory block for storing data to be written in the shared memory segment;
writing the data to be written into the shared memory block corresponding to the index;
acquiring the general flag lock variable when the data to be written is successfully written into the shared memory block corresponding to the index; and
updating a value of the general flag variable with the index of the shared memory block.

4. A data transmission system, comprising:
at least one processor; and
a memory storing instructions, which when executed by the at least one processor, cause the at least one processor to perform operations, the operations comprising:
acquiring a most recent shared memory block index of a shared memory segment by a data receiver, the shared memory segment being used by a data transmitter and the data receiver to transmit data, the most recent shared memory block index being used for indicating an address of a shared memory block in a shared memory segment where data recently written by the data transmitter is located;
deciding whether the most recent shared memory block index is consistent with a shared memory block index corresponding to data recently read by the data receiver; and
determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index,
wherein the determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index comprises:
ignoring the data in the shared memory block corresponding to the most recent shared memory block index if the decision indicates that the most recent shared memory block index is consistent with the shared memory block index corresponding to the data recently read by the data receiver; and
reading the data in the shared memory block corresponding to the most recent shared memory block index when the decision indicates that the most recent shared memory block index is inconsistent with the shared memory block index corresponding to the data recently read by the data receiver,
wherein the shared memory segment comprises a general flag variable and a general flag lock variable, the general flag variable being used for storing the most recent shared memory block index; and
the acquiring the most recent shared memory block index of the shared memory segment by the data receiver comprising:
acquiring the general flag lock variable by the data receiver; and
reading the general flag variable so as to acquire the most recent shared memory block index of the share memory segment.

5. The data transmission system according to claim 4 , wherein the data transmitter is a data transmitting process, and the data receiver is a data receiving process.

6. The data transmission system according to claim 4 , wherein the operations further comprise:
acquiring the general flag lock variable;
determining an index of a shared memory block for storing data to be written in the shared memory segment;
writing the data to be written into the shared memory block corresponding to the index;
acquiring the general flag lock variable when the data to be written is successfully written into the shared memory block corresponding to the index; and
updating a value of the general flag variable with the index of the shared memory block.

7. A non-transitory storage medium storing one or more programs, the one or more programs when executed by an apparatus, causing the apparatus to perform a data transmission method, comprising:
acquiring a most recent shared memory block index of a shared memory segment by a data receiver, the shared memory segment being used by a data transmitter and the data receiver to transmit data, the most recent shared memory block index being used for indicating an address of a shared memory block in a shared memory segment where data recently written by the data transmitter is located;
deciding whether the most recent shared memory block index is consistent with a shared memory block index corresponding to data recently read by the data receiver; and
determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index,
wherein the determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index comprises:
ignoring the data in the shared memory block corresponding to the most recent shared memory block index if the decision indicates that the most recent shared memory block index is consistent with the shared memory block index corresponding to the data recently read by the data receiver; and
reading the data in the shared memory block corresponding to the most recent shared memory block index when the decision indicates that the most recent shared memory block index is inconsistent with the shared memory block index corresponding to the data recently read by the data receiver,
wherein the shared memory segment comprises a general flag variable and a general flag lock variable, the general flag variable being used for storing the most recent shared memory block index; and
the acquiring the most recent shared memory block index of the shared memory segment by the data receiver comprising:
acquiring the general flag lock variable by the data receiver; and
r

Assignees

• Beijing Baidu Netcom Sci & Tec

Inventors

• Xia Liming
• Feng Jingchao
• Wang Quan
• Qu Ning
• Chen Zhuo

Classifications

• H04L2012/5681

  Buffer or queue management · CPC title

• G06F3/0647

  Migration mechanisms · CPC title

• G06F3/0659

  Command handling arrangements, e.g. command buffers, queues, command scheduling · CPC title

• G06F3/0613

  in relation to throughput · CPC title

• G06F3/0683

  Plurality of storage devices · CPC title