Transaction processing method and system

Patent metadata

Field	Value
Publication number	US-9348841-B2
Application number	US-201514733705-A
Country	US
Kind code	B2
Filing date	Jun 8, 2015
Priority date	Oct 29, 2013
Publication date	May 24, 2016
Grant date	May 24, 2016

Abstract

The present invention provides a transaction processing method, which is applied to a node presenting a coordinator, where the coordinator is communicatively connected to nodes presenting participants. The method includes: sending, by the coordinator, a query message to each participant; drawing, by the coordinator, a conclusion according to response messages, executing, by the coordinator, the conclusion, and sending the conclusion to the participants, where the conclusion can be determined by a transaction ID, a object ID and a change information.

First claim

What is claimed is:

1. A transaction processing method, performed by an object-based storage device (OSD) in an OSD system that includes a first OSD acting as a coordinator and other OSDs acting as participants, the method comprising: electing a second OSD from the other OSDs as a new coordinator when the first OSD is faulty, wherein a coordinator determines whether to commit or revoke a transaction, a transaction is writing, deleting, or modifying an object, an object is distributed data stored in other OSDs, and a participant executes a determined transaction; sending, by the second OSD, a query message to the remaining OSDs acting as participants, wherein the query message carries: a transaction ID of the transaction in the second OSD, an object ID in the second OSD, and a version ID of the object in the second OSD, wherein the object obtains a new version ID when content of the object updated; receiving, by the second OSD, a response message for the query message from the remaining OSDs acting as participants, wherein the response message designates whether the transaction ID, object ID and the version received exist locally in the remaining OSDs; executing the transaction and releasing a resource occupied by the transaction after executing, by the second OSD, when the second OSD determines based on the response message from any one of the remaining OSDs acting as participants that the transaction ID does not exist, the object ID exists, and the version ID exists; and instructing, by the second OSD, all the remaining OSDs acting as participants to execute the transaction and release the resource occupied by the transaction after executing.

2. The method according to claim 1 , wherein, before the electing, the method further comprises: sending, by the first OSD, the transaction ID, the object ID and the second OSD to the other OSDs.

3. The method according to claim 1 , wherein, before the electing, the method further comprises: sending, by the first OSD, an operation request to the other OSDs, wherein the operation request carries the object ID, an operation type, and the version ID; and sending, by the first OSD, a prepare command to the other OSDs, wherein the prepare command carries the transaction ID, the object ID, and the version ID; and allocating, by the other OSDs, the resource for the transaction.

4. An object-based storage device (OSD) system, the OSD system comprising: a plurality of OSDs, each of which comprises a processor; a first OSD acting as a coordinator; other OSDs acting as participants, wherein a coordinator determines whether to commit or revoke a transaction, a transaction is writing, deleting, or modifying an object, an object is distributed data stored in the other OSDs, and a participant executes a determined transaction; wherein a second OSD from the other OSDs is elected as a new coordinator when the first OSD is faulty; wherein the second OSD is configured to send a query message to the remaining OSDs acting as participants, wherein the query message carries: a transaction ID of the transaction in the second OSD, an object ID in the second OSD, and a version ID of the object in the second OSD, wherein the object obtains a new version ID when content of the object updated; wherein the remaining OSDs acting as participants are configured to: receive the query message and determine whether the transaction ID, the object ID and the version received exist locally, and send, to the second OSD, a response message regarding the query message; and wherein both the second OSD and the remaining OSDs acting as participants are further configured to execute the transaction, and release a resource occupied by the transaction after executing, if the response message from any of the remaining OSD designates that the transaction ID does not exist, the object ID exists, and the version ID exists.

5. The system according to claim 4 , wherein: the second OSD and the remaining OSDs acting as participants are further configured to execute the transaction, and release a resource occupied by the transaction after executing, if the response message from all remaining OSDs are that the transaction ID exists; and the second OSD and the remaining OSDs acting as participants are further configured to execute the transaction, and release a resource occupied by the transaction after executing, if the response message from any remaining OSD is that both the transaction ID and the object ID do not exist.

6. A transaction processing method, performed by an object-based storage device (OSD) system that includes a first OSD acting as a coordinator and other OSDs acting as participants, the method comprising: electing a second OSD from the other OSDs as a new coordinator when the first OSD is faulty, wherein a coordinator determines whether to commit or revoke a transaction, a transaction is writing, deleting, or modifying an object, an object is distributed data stored in other OSDs, and a participant executes a determined transaction; sending, by the second OSD, a query message to the remaining OSDs acting as participants, wherein the query message carries: a transaction ID of the transaction in the second OSD and an object ID in the second OSD; receiving, by the remaining OSDs acting as participants, the query message and determining whether the transaction ID and the object ID exist locally; receiving, by the second OSD, a response message for the query message from the remaining OSDs acting as participants, wherein the response message indicates whether the transaction ID and the object ID received exist locally in the remaining OSDs and further indicates a version ID locally; and performing one of: executing the transaction and releasing a resource occupied by the transaction after executing, by the second OSD, when the second OSD determines based on the response message from any one of the remaining OSDs acting as participants that the transaction ID does not exist, the object ID exists, and the version ID exists in the second OSD; and instructing, by the second OSD, all the remaining OSDs acting as participants to execute the transaction and release the resource occupied by the transaction after executing; or revoking the transaction and releasing a resource occupied by the transaction after revoking, by the second OSD, when the second OSD determines based on the response message from any one of the remaining OSDs acting as participants that the transaction ID does not exist, the object ID exists, and the version ID does not exist in the second OSD; and instructing, by the second OSD, all the remaining OSDs acting as participants to revoke the transaction and release the resource occupied by the transaction after revoking.

7. The method according to claim 6 , wherein, before the electing, the method further comprises: sending, by the first OSD, the transaction ID, the object ID and the second OSD to the other OSDs.

8. The method according to claim 6 , wherein, before the electing, the method further comprises: sending, by the first OSD, an operation request to the other OSDs, wherein the operation request carries the object ID, an operation type, and the version ID; and sending, by the first OSD, a prepare command to the other OSDs, wherein the prepare command carries the transaction ID, the object ID and the version ID; and allocating, by the other OSDs, the resource for the transaction.

9. An object-based storage device (OSD) system, the OSD system comprising: a plurality of OSDs, each of which comprises a processor; a first OSD acting as a coordinator; other OSDs acting as participants, wherein a coordinator determines whether to commit or revoke a transaction, a transaction is writing, deleting, or modifying an object, an object is distributed data stored in the ot

Assignees

• Huawei Tech Co Ltd

Inventors

• Fang Xin

Classifications

• G06F16/2365 Primary

  Ensuring data consistency and integrity · CPC title

• G06F16/2379 Primary

  Updates performed during online database operations; commit processing · CPC title

• G06F16/1865

  Transactional file systems · CPC title

• G06F16/00

  Information retrieval; Database structures therefor; File system structures therefor · CPC title

• G06F9/542

  Event management; Broadcasting; Multicasting; Notifications · CPC title