Data processing method and apparatus, server, and controller

Patent metadata

Field	Value
Publication number	US-10708378-B2
Application number	US-201715845748-A
Country	US
Kind code	B2
Filing date	Dec 18, 2017
Priority date	Sep 29, 2015
Publication date	Jul 7, 2020
Grant date	Jul 7, 2020

Abstract

A data processing method and apparatus, a server, and a controller, where the method includes receiving, by a server, a data processing request, where the data processing request includes a request sequence number, and the request sequence number marks the data processing request, generating at least one input/output (I/O) request according to the data processing request, adding the request sequence number to each of the at least one I/O request, merging the I/O requests having the request sequence number, and generating an aggregation instruction when a quantity of I/O requests having the request sequence number is greater than a preset threshold, and sending the aggregation instruction to a controller of a storage system. Hence, a time taken to perform monitoring and management using a transaction mechanism can be reduced, thereby simplifying the transaction mechanism.

First claim

What is claimed is:

1. A data processing method implemented by a server in communication with a data processing system, the method comprising:
receiving a data processing request comprising a request sequence number, wherein the request sequence number marks the data processing request;
generating a plurality of input/output (I/O) requests according to the data processing request;
attaching the request sequence number to each I/O request in the plurality of I/O requests;
merging the I/O requests to generate an aggregation instruction when a quantity of the I/O requests is greater than a preset threshold, wherein the preset threshold is a positive integer greater than 1;
sending, via a storage area network (SAN) through which the server and the data processing system are communicatively connected, the aggregation instruction to a controller in the data processing system, wherein the aggregation instruction comprises an operation field of each I/O request and an identifier of a storage device whose data is to accessed according to the data processing request;
receiving, from the controller, a reminder message indicating an error in parsing the aggregation instruction when a quantity of operation fields is not equal to the quantity of I/O requests; and
resending the aggregation instruction to the controller in response to the reminder message.

2. The data processing method of claim 1 , wherein the aggregation instruction further comprises a value indicating the quantity of I/O requests merged into the aggregation instruction.

3. A server in a data processing system comprising a plurality of storage devices, the server comprising:
a communications interface; and
a processor coupled to the communications interface and configured to:
receive a data processing request through the communications interface, wherein the data processing request comprises a request sequence number, and wherein the request sequence number marks the data processing request;
generate a plurality of input/output (I/O) requests according to the data processing request, wherein each I/O request includes a request to access data in a same storage device selected from the plurality of storage devices;
attach the request sequence number to each of the I/O requests;
merge the I/O requests to generate an aggregation instruction when a quantity of the I/O requests is greater than a preset threshold, wherein the preset threshold is a positive integer greater than 1;
send the aggregation instruction to a controller in the data processing system using the communications interface, wherein the communication interface comprises a storage area network (SAN) interface communicatively connecting the server to the controller via an SAN, wherein the SAN interface is configured to send the aggregation instruction from the server to the controller via the SAN, and wherein the aggregation instruction comprises an operation field of each I/O request and an identifier of the same storage device;
receive, from the controller, a reminder message indicating an error in parsing the aggregation instruction when a quantity of operation fields is not equal to the quantity of I/O requests; and
resend the aggregation instruction to the controller in response to the reminder message.

4. The server of claim 3 , wherein the aggregation instruction further comprises a value indicating the quantity of I/O requests merged into the aggregation instruction.

5. The data processing method of claim 1 , wherein the I/O requests are related to a same storage device identified by the identifier in the aggregation instruction.

6. The data processing method of claim 1 , wherein the I/O requests are related to different storage devices.

7. The data processing method of claim 1 , further comprising generating the preset threshold.

8. The server of claim 3 , wherein the I/O requests are related to a same storage device.

9. The server of claim 3 , wherein the I/O requests are related to different storage devices.

10. The server of claim 3 , wherein the processor is further configured to generate the preset threshold.

11. A non-transitory computer readable medium comprising instructions executable by a processor of a server such that when executed, cause the server to implement a data processing method, the method comprising:
receiving a data processing request comprising a request sequence number, wherein the request sequence number marks the data processing request;
generating a plurality of input/output (I/O) requests according to the data processing request;
attaching the request sequence number to each I/O request in the plurality of I/O requests;
merging the I/O requests to generate an aggregation instruction when a quantity of the I/O requests is greater than a preset threshold, wherein the preset threshold is a positive integer greater than 1;
sending, via a storage area network (SAN) through which the server and a data processing system are communicatively connected, the aggregation instruction to a controller in the data processing system, wherein the aggregation instruction comprises an operation field of each I/O request and an identifier of a storage device whose data is to accessed according to the data processing request;
receiving, from the controller, a reminder message indicating an error in parsing the aggregation instruction when a quantity of operation fields is not equal to the quantity of I/O requests; and
resending the aggregation instruction to the controller in response to the reminder message.

Assignees

• Huawei Tech Co Ltd

Inventors

• Li Langbo

Classifications

• G06F3/061 Primary

  Improving I/O performance · CPC title

• H04L67/566

  Grouping or aggregating service requests, e.g. for unified processing · CPC title

• H04L67/565

  Conversion or adaptation of application format or content (adding application control or application functional data H04L67/561) · CPC title

• G06F3/0656

  Data buffering arrangements · CPC title

• G06F3/0659

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